19b2bb4f2STakashi Sakamoto /* 29b2bb4f2STakashi Sakamoto * motu-stream.c - a part of driver for MOTU FireWire series 39b2bb4f2STakashi Sakamoto * 49b2bb4f2STakashi Sakamoto * Copyright (c) 2015-2017 Takashi Sakamoto <o-takashi@sakamocchi.jp> 59b2bb4f2STakashi Sakamoto * 69b2bb4f2STakashi Sakamoto * Licensed under the terms of the GNU General Public License, version 2. 79b2bb4f2STakashi Sakamoto */ 89b2bb4f2STakashi Sakamoto 99b2bb4f2STakashi Sakamoto #include "motu.h" 109b2bb4f2STakashi Sakamoto 119b2bb4f2STakashi Sakamoto #define CALLBACK_TIMEOUT 200 129b2bb4f2STakashi Sakamoto 139b2bb4f2STakashi Sakamoto #define ISOC_COMM_CONTROL_OFFSET 0x0b00 149b2bb4f2STakashi Sakamoto #define ISOC_COMM_CONTROL_MASK 0xffff0000 159b2bb4f2STakashi Sakamoto #define CHANGE_RX_ISOC_COMM_STATE 0x80000000 169b2bb4f2STakashi Sakamoto #define RX_ISOC_COMM_IS_ACTIVATED 0x40000000 179b2bb4f2STakashi Sakamoto #define RX_ISOC_COMM_CHANNEL_MASK 0x3f000000 189b2bb4f2STakashi Sakamoto #define RX_ISOC_COMM_CHANNEL_SHIFT 24 199b2bb4f2STakashi Sakamoto #define CHANGE_TX_ISOC_COMM_STATE 0x00800000 209b2bb4f2STakashi Sakamoto #define TX_ISOC_COMM_IS_ACTIVATED 0x00400000 219b2bb4f2STakashi Sakamoto #define TX_ISOC_COMM_CHANNEL_MASK 0x003f0000 229b2bb4f2STakashi Sakamoto #define TX_ISOC_COMM_CHANNEL_SHIFT 16 239b2bb4f2STakashi Sakamoto 249b2bb4f2STakashi Sakamoto #define PACKET_FORMAT_OFFSET 0x0b10 259b2bb4f2STakashi Sakamoto #define TX_PACKET_EXCLUDE_DIFFERED_DATA_CHUNKS 0x00000080 269b2bb4f2STakashi Sakamoto #define RX_PACKET_EXCLUDE_DIFFERED_DATA_CHUNKS 0x00000040 279b2bb4f2STakashi Sakamoto #define TX_PACKET_TRANSMISSION_SPEED_MASK 0x0000000f 289b2bb4f2STakashi Sakamoto 299b2bb4f2STakashi Sakamoto static int start_both_streams(struct snd_motu *motu, unsigned int rate) 309b2bb4f2STakashi Sakamoto { 319b2bb4f2STakashi Sakamoto __be32 reg; 329b2bb4f2STakashi Sakamoto u32 data; 339b2bb4f2STakashi Sakamoto int err; 349b2bb4f2STakashi Sakamoto 359b2bb4f2STakashi Sakamoto /* Set packet formation to our packet streaming engine. */ 369b2bb4f2STakashi Sakamoto err = amdtp_motu_set_parameters(&motu->rx_stream, rate, 379b2bb4f2STakashi Sakamoto &motu->rx_packet_formats); 389b2bb4f2STakashi Sakamoto if (err < 0) 399b2bb4f2STakashi Sakamoto return err; 409b2bb4f2STakashi Sakamoto 419b2bb4f2STakashi Sakamoto err = amdtp_motu_set_parameters(&motu->tx_stream, rate, 429b2bb4f2STakashi Sakamoto &motu->tx_packet_formats); 439b2bb4f2STakashi Sakamoto if (err < 0) 449b2bb4f2STakashi Sakamoto return err; 459b2bb4f2STakashi Sakamoto 469b2bb4f2STakashi Sakamoto 479b2bb4f2STakashi Sakamoto /* Get isochronous resources on the bus. */ 489b2bb4f2STakashi Sakamoto err = fw_iso_resources_allocate(&motu->rx_resources, 499b2bb4f2STakashi Sakamoto amdtp_stream_get_max_payload(&motu->rx_stream), 509b2bb4f2STakashi Sakamoto fw_parent_device(motu->unit)->max_speed); 519b2bb4f2STakashi Sakamoto if (err < 0) 529b2bb4f2STakashi Sakamoto return err; 539b2bb4f2STakashi Sakamoto 549b2bb4f2STakashi Sakamoto err = fw_iso_resources_allocate(&motu->tx_resources, 559b2bb4f2STakashi Sakamoto amdtp_stream_get_max_payload(&motu->tx_stream), 569b2bb4f2STakashi Sakamoto fw_parent_device(motu->unit)->max_speed); 579b2bb4f2STakashi Sakamoto if (err < 0) 589b2bb4f2STakashi Sakamoto return err; 599b2bb4f2STakashi Sakamoto 609b2bb4f2STakashi Sakamoto /* Configure the unit to start isochronous communication. */ 619b2bb4f2STakashi Sakamoto err = snd_motu_transaction_read(motu, ISOC_COMM_CONTROL_OFFSET, ®, 629b2bb4f2STakashi Sakamoto sizeof(reg)); 639b2bb4f2STakashi Sakamoto if (err < 0) 649b2bb4f2STakashi Sakamoto return err; 659b2bb4f2STakashi Sakamoto data = be32_to_cpu(reg) & ~ISOC_COMM_CONTROL_MASK; 669b2bb4f2STakashi Sakamoto 679b2bb4f2STakashi Sakamoto data |= CHANGE_RX_ISOC_COMM_STATE | RX_ISOC_COMM_IS_ACTIVATED | 689b2bb4f2STakashi Sakamoto (motu->rx_resources.channel << RX_ISOC_COMM_CHANNEL_SHIFT) | 699b2bb4f2STakashi Sakamoto CHANGE_TX_ISOC_COMM_STATE | TX_ISOC_COMM_IS_ACTIVATED | 709b2bb4f2STakashi Sakamoto (motu->tx_resources.channel << TX_ISOC_COMM_CHANNEL_SHIFT); 719b2bb4f2STakashi Sakamoto 729b2bb4f2STakashi Sakamoto reg = cpu_to_be32(data); 739b2bb4f2STakashi Sakamoto return snd_motu_transaction_write(motu, ISOC_COMM_CONTROL_OFFSET, ®, 749b2bb4f2STakashi Sakamoto sizeof(reg)); 759b2bb4f2STakashi Sakamoto } 769b2bb4f2STakashi Sakamoto 779b2bb4f2STakashi Sakamoto static void stop_both_streams(struct snd_motu *motu) 789b2bb4f2STakashi Sakamoto { 799b2bb4f2STakashi Sakamoto __be32 reg; 809b2bb4f2STakashi Sakamoto u32 data; 819b2bb4f2STakashi Sakamoto int err; 829b2bb4f2STakashi Sakamoto 839b2bb4f2STakashi Sakamoto err = motu->spec->protocol->switch_fetching_mode(motu, false); 849b2bb4f2STakashi Sakamoto if (err < 0) 859b2bb4f2STakashi Sakamoto return; 869b2bb4f2STakashi Sakamoto 879b2bb4f2STakashi Sakamoto err = snd_motu_transaction_read(motu, ISOC_COMM_CONTROL_OFFSET, ®, 889b2bb4f2STakashi Sakamoto sizeof(reg)); 899b2bb4f2STakashi Sakamoto if (err < 0) 909b2bb4f2STakashi Sakamoto return; 919b2bb4f2STakashi Sakamoto data = be32_to_cpu(reg); 929b2bb4f2STakashi Sakamoto 939b2bb4f2STakashi Sakamoto data &= ~(RX_ISOC_COMM_IS_ACTIVATED | TX_ISOC_COMM_IS_ACTIVATED); 949b2bb4f2STakashi Sakamoto data |= CHANGE_RX_ISOC_COMM_STATE | CHANGE_TX_ISOC_COMM_STATE; 959b2bb4f2STakashi Sakamoto 969b2bb4f2STakashi Sakamoto reg = cpu_to_be32(data); 979b2bb4f2STakashi Sakamoto snd_motu_transaction_write(motu, ISOC_COMM_CONTROL_OFFSET, ®, 989b2bb4f2STakashi Sakamoto sizeof(reg)); 999b2bb4f2STakashi Sakamoto 1009b2bb4f2STakashi Sakamoto fw_iso_resources_free(&motu->tx_resources); 1019b2bb4f2STakashi Sakamoto fw_iso_resources_free(&motu->rx_resources); 1029b2bb4f2STakashi Sakamoto } 1039b2bb4f2STakashi Sakamoto 1049b2bb4f2STakashi Sakamoto static int start_isoc_ctx(struct snd_motu *motu, struct amdtp_stream *stream) 1059b2bb4f2STakashi Sakamoto { 1069b2bb4f2STakashi Sakamoto struct fw_iso_resources *resources; 1079b2bb4f2STakashi Sakamoto int err; 1089b2bb4f2STakashi Sakamoto 1099b2bb4f2STakashi Sakamoto if (stream == &motu->rx_stream) 1109b2bb4f2STakashi Sakamoto resources = &motu->rx_resources; 1119b2bb4f2STakashi Sakamoto else 1129b2bb4f2STakashi Sakamoto resources = &motu->tx_resources; 1139b2bb4f2STakashi Sakamoto 1149b2bb4f2STakashi Sakamoto err = amdtp_stream_start(stream, resources->channel, 1159b2bb4f2STakashi Sakamoto fw_parent_device(motu->unit)->max_speed); 1169b2bb4f2STakashi Sakamoto if (err < 0) 1179b2bb4f2STakashi Sakamoto return err; 1189b2bb4f2STakashi Sakamoto 1199b2bb4f2STakashi Sakamoto if (!amdtp_stream_wait_callback(stream, CALLBACK_TIMEOUT)) { 1209b2bb4f2STakashi Sakamoto amdtp_stream_stop(stream); 1219b2bb4f2STakashi Sakamoto fw_iso_resources_free(resources); 1229b2bb4f2STakashi Sakamoto return -ETIMEDOUT; 1239b2bb4f2STakashi Sakamoto } 1249b2bb4f2STakashi Sakamoto 1259b2bb4f2STakashi Sakamoto return 0; 1269b2bb4f2STakashi Sakamoto } 1279b2bb4f2STakashi Sakamoto 1289b2bb4f2STakashi Sakamoto static void stop_isoc_ctx(struct snd_motu *motu, struct amdtp_stream *stream) 1299b2bb4f2STakashi Sakamoto { 1309b2bb4f2STakashi Sakamoto struct fw_iso_resources *resources; 1319b2bb4f2STakashi Sakamoto 1329b2bb4f2STakashi Sakamoto if (stream == &motu->rx_stream) 1339b2bb4f2STakashi Sakamoto resources = &motu->rx_resources; 1349b2bb4f2STakashi Sakamoto else 1359b2bb4f2STakashi Sakamoto resources = &motu->tx_resources; 1369b2bb4f2STakashi Sakamoto 1379b2bb4f2STakashi Sakamoto amdtp_stream_stop(stream); 1389b2bb4f2STakashi Sakamoto fw_iso_resources_free(resources); 1399b2bb4f2STakashi Sakamoto } 1409b2bb4f2STakashi Sakamoto 1419b2bb4f2STakashi Sakamoto static int ensure_packet_formats(struct snd_motu *motu) 1429b2bb4f2STakashi Sakamoto { 1439b2bb4f2STakashi Sakamoto __be32 reg; 1449b2bb4f2STakashi Sakamoto u32 data; 1459b2bb4f2STakashi Sakamoto int err; 1469b2bb4f2STakashi Sakamoto 1479b2bb4f2STakashi Sakamoto err = snd_motu_transaction_read(motu, PACKET_FORMAT_OFFSET, ®, 1489b2bb4f2STakashi Sakamoto sizeof(reg)); 1499b2bb4f2STakashi Sakamoto if (err < 0) 1509b2bb4f2STakashi Sakamoto return err; 1519b2bb4f2STakashi Sakamoto data = be32_to_cpu(reg); 1529b2bb4f2STakashi Sakamoto 1539b2bb4f2STakashi Sakamoto data &= ~(TX_PACKET_EXCLUDE_DIFFERED_DATA_CHUNKS | 1549b2bb4f2STakashi Sakamoto RX_PACKET_EXCLUDE_DIFFERED_DATA_CHUNKS| 1559b2bb4f2STakashi Sakamoto TX_PACKET_TRANSMISSION_SPEED_MASK); 1569b2bb4f2STakashi Sakamoto if (motu->tx_packet_formats.differed_part_pcm_chunks[0] == 0) 1579b2bb4f2STakashi Sakamoto data |= TX_PACKET_EXCLUDE_DIFFERED_DATA_CHUNKS; 1589b2bb4f2STakashi Sakamoto if (motu->rx_packet_formats.differed_part_pcm_chunks[0] == 0) 1599b2bb4f2STakashi Sakamoto data |= RX_PACKET_EXCLUDE_DIFFERED_DATA_CHUNKS; 1609b2bb4f2STakashi Sakamoto data |= fw_parent_device(motu->unit)->max_speed; 1619b2bb4f2STakashi Sakamoto 1629b2bb4f2STakashi Sakamoto reg = cpu_to_be32(data); 1639b2bb4f2STakashi Sakamoto return snd_motu_transaction_write(motu, PACKET_FORMAT_OFFSET, ®, 1649b2bb4f2STakashi Sakamoto sizeof(reg)); 1659b2bb4f2STakashi Sakamoto } 1669b2bb4f2STakashi Sakamoto 1679b2bb4f2STakashi Sakamoto int snd_motu_stream_start_duplex(struct snd_motu *motu, unsigned int rate) 1689b2bb4f2STakashi Sakamoto { 1699b2bb4f2STakashi Sakamoto const struct snd_motu_protocol *protocol = motu->spec->protocol; 1709b2bb4f2STakashi Sakamoto unsigned int curr_rate; 1719b2bb4f2STakashi Sakamoto int err = 0; 1729b2bb4f2STakashi Sakamoto 1739b2bb4f2STakashi Sakamoto if (motu->capture_substreams == 0 && motu->playback_substreams == 0) 1749b2bb4f2STakashi Sakamoto return 0; 1759b2bb4f2STakashi Sakamoto 1769b2bb4f2STakashi Sakamoto /* Some packet queueing errors. */ 1779b2bb4f2STakashi Sakamoto if (amdtp_streaming_error(&motu->rx_stream) || 1789b2bb4f2STakashi Sakamoto amdtp_streaming_error(&motu->tx_stream)) { 1799b2bb4f2STakashi Sakamoto amdtp_stream_stop(&motu->rx_stream); 1809b2bb4f2STakashi Sakamoto amdtp_stream_stop(&motu->tx_stream); 1819b2bb4f2STakashi Sakamoto stop_both_streams(motu); 1829b2bb4f2STakashi Sakamoto } 1839b2bb4f2STakashi Sakamoto 1849b2bb4f2STakashi Sakamoto err = protocol->cache_packet_formats(motu); 1859b2bb4f2STakashi Sakamoto if (err < 0) 1869b2bb4f2STakashi Sakamoto return err; 1879b2bb4f2STakashi Sakamoto 1889b2bb4f2STakashi Sakamoto /* Stop stream if rate is different. */ 1899b2bb4f2STakashi Sakamoto err = protocol->get_clock_rate(motu, &curr_rate); 1909b2bb4f2STakashi Sakamoto if (err < 0) { 1919b2bb4f2STakashi Sakamoto dev_err(&motu->unit->device, 1929b2bb4f2STakashi Sakamoto "fail to get sampling rate: %d\n", err); 1939b2bb4f2STakashi Sakamoto return err; 1949b2bb4f2STakashi Sakamoto } 1959b2bb4f2STakashi Sakamoto if (rate == 0) 1969b2bb4f2STakashi Sakamoto rate = curr_rate; 1979b2bb4f2STakashi Sakamoto if (rate != curr_rate) { 1989b2bb4f2STakashi Sakamoto amdtp_stream_stop(&motu->rx_stream); 1999b2bb4f2STakashi Sakamoto amdtp_stream_stop(&motu->tx_stream); 2009b2bb4f2STakashi Sakamoto stop_both_streams(motu); 2019b2bb4f2STakashi Sakamoto } 2029b2bb4f2STakashi Sakamoto 2039b2bb4f2STakashi Sakamoto if (!amdtp_stream_running(&motu->rx_stream)) { 2049b2bb4f2STakashi Sakamoto err = protocol->set_clock_rate(motu, rate); 2059b2bb4f2STakashi Sakamoto if (err < 0) { 2069b2bb4f2STakashi Sakamoto dev_err(&motu->unit->device, 2079b2bb4f2STakashi Sakamoto "fail to set sampling rate: %d\n", err); 2089b2bb4f2STakashi Sakamoto return err; 2099b2bb4f2STakashi Sakamoto } 2109b2bb4f2STakashi Sakamoto 2119b2bb4f2STakashi Sakamoto err = ensure_packet_formats(motu); 2129b2bb4f2STakashi Sakamoto if (err < 0) 2139b2bb4f2STakashi Sakamoto return err; 2149b2bb4f2STakashi Sakamoto 2159b2bb4f2STakashi Sakamoto err = start_both_streams(motu, rate); 2169b2bb4f2STakashi Sakamoto if (err < 0) { 2179b2bb4f2STakashi Sakamoto dev_err(&motu->unit->device, 2189b2bb4f2STakashi Sakamoto "fail to start isochronous comm: %d\n", err); 2199b2bb4f2STakashi Sakamoto stop_both_streams(motu); 2209b2bb4f2STakashi Sakamoto return err; 2219b2bb4f2STakashi Sakamoto } 2229b2bb4f2STakashi Sakamoto 2239b2bb4f2STakashi Sakamoto err = start_isoc_ctx(motu, &motu->rx_stream); 2249b2bb4f2STakashi Sakamoto if (err < 0) { 2259b2bb4f2STakashi Sakamoto dev_err(&motu->unit->device, 2269b2bb4f2STakashi Sakamoto "fail to start IT context: %d\n", err); 2279b2bb4f2STakashi Sakamoto stop_both_streams(motu); 2289b2bb4f2STakashi Sakamoto return err; 2299b2bb4f2STakashi Sakamoto } 2309b2bb4f2STakashi Sakamoto 2319b2bb4f2STakashi Sakamoto err = protocol->switch_fetching_mode(motu, true); 2329b2bb4f2STakashi Sakamoto if (err < 0) { 2339b2bb4f2STakashi Sakamoto dev_err(&motu->unit->device, 2349b2bb4f2STakashi Sakamoto "fail to enable frame fetching: %d\n", err); 2359b2bb4f2STakashi Sakamoto stop_both_streams(motu); 2369b2bb4f2STakashi Sakamoto return err; 2379b2bb4f2STakashi Sakamoto } 2389b2bb4f2STakashi Sakamoto } 2399b2bb4f2STakashi Sakamoto 2409b2bb4f2STakashi Sakamoto if (!amdtp_stream_running(&motu->tx_stream) && 2419b2bb4f2STakashi Sakamoto motu->capture_substreams > 0) { 2429b2bb4f2STakashi Sakamoto err = start_isoc_ctx(motu, &motu->tx_stream); 2439b2bb4f2STakashi Sakamoto if (err < 0) { 2449b2bb4f2STakashi Sakamoto dev_err(&motu->unit->device, 2459b2bb4f2STakashi Sakamoto "fail to start IR context: %d", err); 2469b2bb4f2STakashi Sakamoto amdtp_stream_stop(&motu->rx_stream); 2479b2bb4f2STakashi Sakamoto stop_both_streams(motu); 2489b2bb4f2STakashi Sakamoto return err; 2499b2bb4f2STakashi Sakamoto } 2509b2bb4f2STakashi Sakamoto } 2519b2bb4f2STakashi Sakamoto 2529b2bb4f2STakashi Sakamoto return 0; 2539b2bb4f2STakashi Sakamoto } 2549b2bb4f2STakashi Sakamoto 2559b2bb4f2STakashi Sakamoto void snd_motu_stream_stop_duplex(struct snd_motu *motu) 2569b2bb4f2STakashi Sakamoto { 2579b2bb4f2STakashi Sakamoto if (motu->capture_substreams == 0) { 2589b2bb4f2STakashi Sakamoto if (amdtp_stream_running(&motu->tx_stream)) 2599b2bb4f2STakashi Sakamoto stop_isoc_ctx(motu, &motu->tx_stream); 2609b2bb4f2STakashi Sakamoto 2619b2bb4f2STakashi Sakamoto if (motu->playback_substreams == 0) { 2629b2bb4f2STakashi Sakamoto if (amdtp_stream_running(&motu->rx_stream)) 2639b2bb4f2STakashi Sakamoto stop_isoc_ctx(motu, &motu->rx_stream); 2649b2bb4f2STakashi Sakamoto stop_both_streams(motu); 2659b2bb4f2STakashi Sakamoto } 2669b2bb4f2STakashi Sakamoto } 2679b2bb4f2STakashi Sakamoto } 2689b2bb4f2STakashi Sakamoto 2699b2bb4f2STakashi Sakamoto static int init_stream(struct snd_motu *motu, enum amdtp_stream_direction dir) 2709b2bb4f2STakashi Sakamoto { 2719b2bb4f2STakashi Sakamoto int err; 2729b2bb4f2STakashi Sakamoto struct amdtp_stream *stream; 2739b2bb4f2STakashi Sakamoto struct fw_iso_resources *resources; 2749b2bb4f2STakashi Sakamoto 2759b2bb4f2STakashi Sakamoto if (dir == AMDTP_IN_STREAM) { 2769b2bb4f2STakashi Sakamoto stream = &motu->tx_stream; 2779b2bb4f2STakashi Sakamoto resources = &motu->tx_resources; 2789b2bb4f2STakashi Sakamoto } else { 2799b2bb4f2STakashi Sakamoto stream = &motu->rx_stream; 2809b2bb4f2STakashi Sakamoto resources = &motu->rx_resources; 2819b2bb4f2STakashi Sakamoto } 2829b2bb4f2STakashi Sakamoto 2839b2bb4f2STakashi Sakamoto err = fw_iso_resources_init(resources, motu->unit); 2849b2bb4f2STakashi Sakamoto if (err < 0) 2859b2bb4f2STakashi Sakamoto return err; 2869b2bb4f2STakashi Sakamoto 2879b2bb4f2STakashi Sakamoto err = amdtp_motu_init(stream, motu->unit, dir, motu->spec->protocol); 2889b2bb4f2STakashi Sakamoto if (err < 0) { 2899b2bb4f2STakashi Sakamoto amdtp_stream_destroy(stream); 2909b2bb4f2STakashi Sakamoto fw_iso_resources_destroy(resources); 2919b2bb4f2STakashi Sakamoto } 2929b2bb4f2STakashi Sakamoto 2939b2bb4f2STakashi Sakamoto return err; 2949b2bb4f2STakashi Sakamoto } 2959b2bb4f2STakashi Sakamoto 2969b2bb4f2STakashi Sakamoto static void destroy_stream(struct snd_motu *motu, 2979b2bb4f2STakashi Sakamoto enum amdtp_stream_direction dir) 2989b2bb4f2STakashi Sakamoto { 2999b2bb4f2STakashi Sakamoto struct amdtp_stream *stream; 3009b2bb4f2STakashi Sakamoto struct fw_iso_resources *resources; 3019b2bb4f2STakashi Sakamoto 3029b2bb4f2STakashi Sakamoto if (dir == AMDTP_IN_STREAM) { 3039b2bb4f2STakashi Sakamoto stream = &motu->tx_stream; 3049b2bb4f2STakashi Sakamoto resources = &motu->tx_resources; 3059b2bb4f2STakashi Sakamoto } else { 3069b2bb4f2STakashi Sakamoto stream = &motu->rx_stream; 3079b2bb4f2STakashi Sakamoto resources = &motu->rx_resources; 3089b2bb4f2STakashi Sakamoto } 3099b2bb4f2STakashi Sakamoto 3109b2bb4f2STakashi Sakamoto amdtp_stream_destroy(stream); 3119b2bb4f2STakashi Sakamoto fw_iso_resources_free(resources); 3129b2bb4f2STakashi Sakamoto } 3139b2bb4f2STakashi Sakamoto 3149b2bb4f2STakashi Sakamoto int snd_motu_stream_init_duplex(struct snd_motu *motu) 3159b2bb4f2STakashi Sakamoto { 3169b2bb4f2STakashi Sakamoto int err; 3179b2bb4f2STakashi Sakamoto 3189b2bb4f2STakashi Sakamoto err = init_stream(motu, AMDTP_IN_STREAM); 3199b2bb4f2STakashi Sakamoto if (err < 0) 3209b2bb4f2STakashi Sakamoto return err; 3219b2bb4f2STakashi Sakamoto 3229b2bb4f2STakashi Sakamoto err = init_stream(motu, AMDTP_OUT_STREAM); 3239b2bb4f2STakashi Sakamoto if (err < 0) 3249b2bb4f2STakashi Sakamoto destroy_stream(motu, AMDTP_IN_STREAM); 3259b2bb4f2STakashi Sakamoto 3269b2bb4f2STakashi Sakamoto return err; 3279b2bb4f2STakashi Sakamoto } 3289b2bb4f2STakashi Sakamoto 3299b2bb4f2STakashi Sakamoto /* 3309b2bb4f2STakashi Sakamoto * This function should be called before starting streams or after stopping 3319b2bb4f2STakashi Sakamoto * streams. 3329b2bb4f2STakashi Sakamoto */ 3339b2bb4f2STakashi Sakamoto void snd_motu_stream_destroy_duplex(struct snd_motu *motu) 3349b2bb4f2STakashi Sakamoto { 3359b2bb4f2STakashi Sakamoto destroy_stream(motu, AMDTP_IN_STREAM); 3369b2bb4f2STakashi Sakamoto destroy_stream(motu, AMDTP_OUT_STREAM); 3379b2bb4f2STakashi Sakamoto 3389b2bb4f2STakashi Sakamoto motu->playback_substreams = 0; 3399b2bb4f2STakashi Sakamoto motu->capture_substreams = 0; 3409b2bb4f2STakashi Sakamoto } 341