sound/firewire/dice/dice-stream.c

   1 /*
   2  * dice_stream.c - a part of driver for DICE based devices
   3  *
   4  * Copyright (c) Clemens Ladisch <clemens@ladisch.de>
   5  * Copyright (c) 2014 Takashi Sakamoto <o-takashi@sakamocchi.jp>
   6  *
   7  * Licensed under the terms of the GNU General Public License, version 2.
   8  */
   9
  10 #include "dice.h"
  11
  12 #define CALLBACK_TIMEOUT        200
  13 #define NOTIFICATION_TIMEOUT_MS (2 * MSEC_PER_SEC)
  14
  15 struct reg_params {
  16         unsigned int count;
  17         unsigned int size;
  18 };
  19
  20 const unsigned int snd_dice_rates[SND_DICE_RATES_COUNT] = {
  21         /* mode 0 */
  22         [0] =  32000,
  23         [1] =  44100,
  24         [2] =  48000,
  25         /* mode 1 */
  26         [3] =  88200,
  27         [4] =  96000,
  28         /* mode 2 */
  29         [5] = 176400,
  30         [6] = 192000,
  31 };
  32
  33 /*
  34  * This operation has an effect to synchronize GLOBAL_STATUS/GLOBAL_SAMPLE_RATE
  35  * to GLOBAL_STATUS. Especially, just after powering on, these are different.
  36  */
  37 static int ensure_phase_lock(struct snd_dice *dice)
  38 {
  39         __be32 reg, nominal;
  40         int err;
  41
  42         err = snd_dice_transaction_read_global(dice, GLOBAL_CLOCK_SELECT,
  43                                                &reg, sizeof(reg));
  44         if (err < 0)
  45                 return err;
  46
  47         if (completion_done(&dice->clock_accepted))
  48                 reinit_completion(&dice->clock_accepted);
  49
  50         err = snd_dice_transaction_write_global(dice, GLOBAL_CLOCK_SELECT,
  51                                                 &reg, sizeof(reg));
  52         if (err < 0)
  53                 return err;
  54
  55         if (wait_for_completion_timeout(&dice->clock_accepted,
  56                         msecs_to_jiffies(NOTIFICATION_TIMEOUT_MS)) == 0) {
  57                 /*
  58                  * Old versions of Dice firmware transfer no notification when
  59                  * the same clock status as current one is set. In this case,
  60                  * just check current clock status.
  61                  */
  62                 err = snd_dice_transaction_read_global(dice, GLOBAL_STATUS,
  63                                                 &nominal, sizeof(nominal));
  64                 if (err < 0)
  65                         return err;
  66                 if (!(be32_to_cpu(nominal) & STATUS_SOURCE_LOCKED))
  67                         return -ETIMEDOUT;
  68         }
  69
  70         return 0;
  71 }
  72
  73 static int get_register_params(struct snd_dice *dice,
  74                                struct reg_params *tx_params,
  75                                struct reg_params *rx_params)
  76 {
  77         __be32 reg[2];
  78         int err;
  79
  80         err = snd_dice_transaction_read_tx(dice, TX_NUMBER, reg, sizeof(reg));
  81         if (err < 0)
  82                 return err;
  83         tx_params->count =
  84                         min_t(unsigned int, be32_to_cpu(reg[0]), MAX_STREAMS);
  85         tx_params->size = be32_to_cpu(reg[1]) * 4;
  86
  87         err = snd_dice_transaction_read_rx(dice, RX_NUMBER, reg, sizeof(reg));
  88         if (err < 0)
  89                 return err;
  90         rx_params->count =
  91                         min_t(unsigned int, be32_to_cpu(reg[0]), MAX_STREAMS);
  92         rx_params->size = be32_to_cpu(reg[1]) * 4;
  93
  94         return 0;
  95 }
  96
  97 static void release_resources(struct snd_dice *dice)
  98 {
  99         unsigned int i;
 100
 101         for (i = 0; i < MAX_STREAMS; i++) {
 102                 if (amdtp_stream_running(&dice->tx_stream[i])) {
 103                         amdtp_stream_pcm_abort(&dice->tx_stream[i]);
 104                         amdtp_stream_stop(&dice->tx_stream[i]);
 105                 }
 106                 if (amdtp_stream_running(&dice->rx_stream[i])) {
 107                         amdtp_stream_pcm_abort(&dice->rx_stream[i]);
 108                         amdtp_stream_stop(&dice->rx_stream[i]);
 109                 }
 110
 111                 fw_iso_resources_free(&dice->tx_resources[i]);
 112                 fw_iso_resources_free(&dice->rx_resources[i]);
 113         }
 114 }
 115
 116 static void stop_streams(struct snd_dice *dice, enum amdtp_stream_direction dir,
 117                          struct reg_params *params)
 118 {
 119         __be32 reg;
 120         unsigned int i;
 121
 122         for (i = 0; i < params->count; i++) {
 123                 reg = cpu_to_be32((u32)-1);
 124                 if (dir == AMDTP_IN_STREAM) {
 125                         snd_dice_transaction_write_tx(dice,
 126                                         params->size * i + TX_ISOCHRONOUS,
 127                                         &reg, sizeof(reg));
 128                 } else {
 129                         snd_dice_transaction_write_rx(dice,
 130                                         params->size * i + RX_ISOCHRONOUS,
 131                                         &reg, sizeof(reg));
 132                 }
 133         }
 134 }
 135
 136 static int keep_resources(struct snd_dice *dice,
 137                           enum amdtp_stream_direction dir, unsigned int index,
 138                           unsigned int rate, unsigned int pcm_chs,
 139                           unsigned int midi_ports)
 140 {
 141         struct amdtp_stream *stream;
 142         struct fw_iso_resources *resources;
 143         bool double_pcm_frames;
 144         unsigned int i;
 145         int err;
 146
 147         if (dir == AMDTP_IN_STREAM) {
 148                 stream = &dice->tx_stream[index];
 149                 resources = &dice->tx_resources[index];
 150         } else {
 151                 stream = &dice->rx_stream[index];
 152                 resources = &dice->rx_resources[index];
 153         }
 154
 155         /*
 156          * At 176.4/192.0 kHz, Dice has a quirk to transfer two PCM frames in
 157          * one data block of AMDTP packet. Thus sampling transfer frequency is
 158          * a half of PCM sampling frequency, i.e. PCM frames at 192.0 kHz are
 159          * transferred on AMDTP packets at 96 kHz. Two successive samples of a
 160          * channel are stored consecutively in the packet. This quirk is called
 161          * as 'Dual Wire'.
 162          * For this quirk, blocking mode is required and PCM buffer size should
 163          * be aligned to SYT_INTERVAL.
 164          */
 165         double_pcm_frames = rate > 96000;
 166         if (double_pcm_frames) {
 167                 rate /= 2;
 168                 pcm_chs *= 2;
 169         }
 170
 171         err = amdtp_am824_set_parameters(stream, rate, pcm_chs, midi_ports,
 172                                          double_pcm_frames);
 173         if (err < 0)
 174                 return err;
 175
 176         if (double_pcm_frames) {
 177                 pcm_chs /= 2;
 178
 179                 for (i = 0; i < pcm_chs; i++) {
 180                         amdtp_am824_set_pcm_position(stream, i, i * 2);
 181                         amdtp_am824_set_pcm_position(stream, i + pcm_chs,
 182                                                      i * 2 + 1);
 183                 }
 184         }
 185
 186         return fw_iso_resources_allocate(resources,
 187                                 amdtp_stream_get_max_payload(stream),
 188                                 fw_parent_device(dice->unit)->max_speed);
 189 }
 190
 191 static int start_streams(struct snd_dice *dice, enum amdtp_stream_direction dir,
 192                          unsigned int rate, struct reg_params *params)
 193 {
 194         __be32 reg[2];
 195         unsigned int i, pcm_chs, midi_ports;
 196         struct amdtp_stream *streams;
 197         struct fw_iso_resources *resources;
 198         int err = 0;
 199
 200         if (dir == AMDTP_IN_STREAM) {
 201                 streams = dice->tx_stream;
 202                 resources = dice->tx_resources;
 203         } else {
 204                 streams = dice->rx_stream;
 205                 resources = dice->rx_resources;
 206         }
 207
 208         for (i = 0; i < params->count; i++) {
 209                 if (dir == AMDTP_IN_STREAM) {
 210                         err = snd_dice_transaction_read_tx(dice,
 211                                         params->size * i + TX_NUMBER_AUDIO,
 212                                         reg, sizeof(reg));
 213                 } else {
 214                         err = snd_dice_transaction_read_rx(dice,
 215                                         params->size * i + RX_NUMBER_AUDIO,
 216                                         reg, sizeof(reg));
 217                 }
 218                 if (err < 0)
 219                         return err;
 220                 pcm_chs = be32_to_cpu(reg[0]);
 221                 midi_ports = be32_to_cpu(reg[1]);
 222
 223                 err = keep_resources(dice, dir, i, rate, pcm_chs, midi_ports);
 224                 if (err < 0)
 225                         return err;
 226
 227                 reg[0] = cpu_to_be32(resources[i].channel);
 228                 if (dir == AMDTP_IN_STREAM) {
 229                         err = snd_dice_transaction_write_tx(dice,
 230                                         params->size * i + TX_ISOCHRONOUS,
 231                                         reg, sizeof(reg[0]));
 232                 } else {
 233                         err = snd_dice_transaction_write_rx(dice,
 234                                         params->size * i + RX_ISOCHRONOUS,
 235                                         reg, sizeof(reg[0]));
 236                 }
 237                 if (err < 0)
 238                         return err;
 239
 240                 err = amdtp_stream_start(&streams[i], resources[i].channel,
 241                                 fw_parent_device(dice->unit)->max_speed);
 242                 if (err < 0)
 243                         return err;
 244         }
 245
 246         return err;
 247 }
 248
 249 /*
 250  * MEMO: After this function, there're two states of streams:
 251  *  - None streams are running.
 252  *  - All streams are running.
 253  */
 254 int snd_dice_stream_start_duplex(struct snd_dice *dice, unsigned int rate)
 255 {
 256         unsigned int curr_rate;
 257         unsigned int i;
 258         struct reg_params tx_params, rx_params;
 259         bool need_to_start;
 260         int err;
 261
 262         if (dice->substreams_counter == 0)
 263                 return -EIO;
 264
 265         err = get_register_params(dice, &tx_params, &rx_params);
 266         if (err < 0)
 267                 return err;
 268
 269         err = snd_dice_transaction_get_rate(dice, &curr_rate);
 270         if (err < 0) {
 271                 dev_err(&dice->unit->device,
 272                         "fail to get sampling rate\n");
 273                 return err;
 274         }
 275         if (rate == 0)
 276                 rate = curr_rate;
 277         if (rate != curr_rate)
 278                 return -EINVAL;
 279
 280         /* Judge to need to restart streams. */
 281         for (i = 0; i < MAX_STREAMS; i++) {
 282                 if (i < tx_params.count) {
 283                         if (amdtp_streaming_error(&dice->tx_stream[i]) ||
 284                             !amdtp_stream_running(&dice->tx_stream[i]))
 285                                 break;
 286                 }
 287                 if (i < rx_params.count) {
 288                         if (amdtp_streaming_error(&dice->rx_stream[i]) ||
 289                             !amdtp_stream_running(&dice->rx_stream[i]))
 290                                 break;
 291                 }
 292         }
 293         need_to_start = (i < MAX_STREAMS);
 294
 295         if (need_to_start) {
 296                 /* Stop transmission. */
 297                 snd_dice_transaction_clear_enable(dice);
 298                 stop_streams(dice, AMDTP_IN_STREAM, &tx_params);
 299                 stop_streams(dice, AMDTP_OUT_STREAM, &rx_params);
 300                 release_resources(dice);
 301
 302                 err = ensure_phase_lock(dice);
 303                 if (err < 0) {
 304                         dev_err(&dice->unit->device,
 305                                 "fail to ensure phase lock\n");
 306                         return err;
 307                 }
 308
 309                 /* Start both streams. */
 310                 err = start_streams(dice, AMDTP_IN_STREAM, rate, &tx_params);
 311                 if (err < 0)
 312                         goto error;
 313                 err = start_streams(dice, AMDTP_OUT_STREAM, rate, &rx_params);
 314                 if (err < 0)
 315                         goto error;
 316
 317                 err = snd_dice_transaction_set_enable(dice);
 318                 if (err < 0) {
 319                         dev_err(&dice->unit->device,
 320                                 "fail to enable interface\n");
 321                         goto error;
 322                 }
 323
 324                 for (i = 0; i < MAX_STREAMS; i++) {
 325                         if ((i < tx_params.count &&
 326                             !amdtp_stream_wait_callback(&dice->tx_stream[i],
 327                                                         CALLBACK_TIMEOUT)) ||
 328                             (i < rx_params.count &&
 329                              !amdtp_stream_wait_callback(&dice->rx_stream[i],
 330                                                          CALLBACK_TIMEOUT))) {
 331                                 err = -ETIMEDOUT;
 332                                 goto error;
 333                         }
 334                 }
 335         }
 336
 337         return err;
 338 error:
 339         snd_dice_transaction_clear_enable(dice);
 340         stop_streams(dice, AMDTP_IN_STREAM, &tx_params);
 341         stop_streams(dice, AMDTP_OUT_STREAM, &rx_params);
 342         release_resources(dice);
 343         return err;
 344 }
 345
 346 /*
 347  * MEMO: After this function, there're two states of streams:
 348  *  - None streams are running.
 349  *  - All streams are running.
 350  */
 351 void snd_dice_stream_stop_duplex(struct snd_dice *dice)
 352 {
 353         struct reg_params tx_params, rx_params;
 354
 355         if (dice->substreams_counter > 0)
 356                 return;
 357
 358         snd_dice_transaction_clear_enable(dice);
 359
 360         if (get_register_params(dice, &tx_params, &rx_params) == 0) {
 361                 stop_streams(dice, AMDTP_IN_STREAM, &tx_params);
 362                 stop_streams(dice, AMDTP_OUT_STREAM, &rx_params);
 363         }
 364
 365         release_resources(dice);
 366 }
 367
 368 static int init_stream(struct snd_dice *dice, enum amdtp_stream_direction dir,
 369                        unsigned int index)
 370 {
 371         struct amdtp_stream *stream;
 372         struct fw_iso_resources *resources;
 373         int err;
 374
 375         if (dir == AMDTP_IN_STREAM) {
 376                 stream = &dice->tx_stream[index];
 377                 resources = &dice->tx_resources[index];
 378         } else {
 379                 stream = &dice->rx_stream[index];
 380                 resources = &dice->rx_resources[index];
 381         }
 382
 383         err = fw_iso_resources_init(resources, dice->unit);
 384         if (err < 0)
 385                 goto end;
 386         resources->channels_mask = 0x00000000ffffffffuLL;
 387
 388         err = amdtp_am824_init(stream, dice->unit, dir, CIP_BLOCKING);
 389         if (err < 0) {
 390                 amdtp_stream_destroy(stream);
 391                 fw_iso_resources_destroy(resources);
 392         }
 393 end:
 394         return err;
 395 }
 396
 397 /*
 398  * This function should be called before starting streams or after stopping
 399  * streams.
 400  */
 401 static void destroy_stream(struct snd_dice *dice,
 402                            enum amdtp_stream_direction dir,
 403                            unsigned int index)
 404 {
 405         struct amdtp_stream *stream;
 406         struct fw_iso_resources *resources;
 407
 408         if (dir == AMDTP_IN_STREAM) {
 409                 stream = &dice->tx_stream[index];
 410                 resources = &dice->tx_resources[index];
 411         } else {
 412                 stream = &dice->rx_stream[index];
 413                 resources = &dice->rx_resources[index];
 414         }
 415
 416         amdtp_stream_destroy(stream);
 417         fw_iso_resources_destroy(resources);
 418 }
 419
 420 int snd_dice_stream_init_duplex(struct snd_dice *dice)
 421 {
 422         int i, err;
 423
 424         for (i = 0; i < MAX_STREAMS; i++) {
 425                 err = init_stream(dice, AMDTP_IN_STREAM, i);
 426                 if (err < 0) {
 427                         for (; i >= 0; i--)
 428                                 destroy_stream(dice, AMDTP_OUT_STREAM, i);
 429                         goto end;
 430                 }
 431         }
 432
 433         for (i = 0; i < MAX_STREAMS; i++) {
 434                 err = init_stream(dice, AMDTP_OUT_STREAM, i);
 435                 if (err < 0) {
 436                         for (; i >= 0; i--)
 437                                 destroy_stream(dice, AMDTP_OUT_STREAM, i);
 438                         for (i = 0; i < MAX_STREAMS; i++)
 439                                 destroy_stream(dice, AMDTP_IN_STREAM, i);
 440                         break;
 441                 }
 442         }
 443 end:
 444         return err;
 445 }
 446
 447 void snd_dice_stream_destroy_duplex(struct snd_dice *dice)
 448 {
 449         struct reg_params tx_params, rx_params;
 450
 451         snd_dice_transaction_clear_enable(dice);
 452
 453         if (get_register_params(dice, &tx_params, &rx_params) == 0) {
 454                 stop_streams(dice, AMDTP_IN_STREAM, &tx_params);
 455                 stop_streams(dice, AMDTP_OUT_STREAM, &rx_params);
 456         }
 457
 458         release_resources(dice);
 459
 460         dice->substreams_counter = 0;
 461 }
 462
 463 void snd_dice_stream_update_duplex(struct snd_dice *dice)
 464 {
 465         struct reg_params tx_params, rx_params;
 466
 467         /*
 468          * On a bus reset, the DICE firmware disables streaming and then goes
 469          * off contemplating its own navel for hundreds of milliseconds before
 470          * it can react to any of our attempts to reenable streaming.  This
 471          * means that we lose synchronization anyway, so we force our streams
 472          * to stop so that the application can restart them in an orderly
 473          * manner.
 474          */
 475         dice->global_enabled = false;
 476
 477         if (get_register_params(dice, &tx_params, &rx_params) == 0) {
 478                 stop_streams(dice, AMDTP_IN_STREAM, &tx_params);
 479                 stop_streams(dice, AMDTP_OUT_STREAM, &rx_params);
 480         }
 481 }
 482
 483 static void dice_lock_changed(struct snd_dice *dice)
 484 {
 485         dice->dev_lock_changed = true;
 486         wake_up(&dice->hwdep_wait);
 487 }
 488
 489 int snd_dice_stream_lock_try(struct snd_dice *dice)
 490 {
 491         int err;
 492
 493         spin_lock_irq(&dice->lock);
 494
 495         if (dice->dev_lock_count < 0) {
 496                 err = -EBUSY;
 497                 goto out;
 498         }
 499
 500         if (dice->dev_lock_count++ == 0)
 501                 dice_lock_changed(dice);
 502         err = 0;
 503 out:
 504         spin_unlock_irq(&dice->lock);
 505         return err;
 506 }
 507
 508 void snd_dice_stream_lock_release(struct snd_dice *dice)
 509 {
 510         spin_lock_irq(&dice->lock);
 511
 512         if (WARN_ON(dice->dev_lock_count <= 0))
 513                 goto out;
 514
 515         if (--dice->dev_lock_count == 0)
 516                 dice_lock_changed(dice);
 517 out:
 518         spin_unlock_irq(&dice->lock);
 519 }