cregit-Linux how code gets into the kernel

Release 4.8 sound/firewire/digi00x/digi00x-stream.c

/*
 * digi00x-stream.c - a part of driver for Digidesign Digi 002/003 family
 *
 * Copyright (c) 2014-2015 Takashi Sakamoto
 *
 * Licensed under the terms of the GNU General Public License, version 2.
 */

#include "digi00x.h"


#define CALLBACK_TIMEOUT 500


const unsigned int snd_dg00x_stream_rates[SND_DG00X_RATE_COUNT] = {
	[SND_DG00X_RATE_44100] = 44100,
	[SND_DG00X_RATE_48000] = 48000,
	[SND_DG00X_RATE_88200] = 88200,
	[SND_DG00X_RATE_96000] = 96000,
};

/* Multi Bit Linear Audio data channels for each sampling transfer frequency. */
const unsigned int

snd_dg00x_stream_pcm_channels[SND_DG00X_RATE_COUNT] = {
	/* Analog/ADAT/SPDIF */
	[SND_DG00X_RATE_44100] = (8 + 8 + 2),
	[SND_DG00X_RATE_48000] = (8 + 8 + 2),
	/* Analog/SPDIF */
	[SND_DG00X_RATE_88200] = (8 + 2),
	[SND_DG00X_RATE_96000] = (8 + 2),
};


int snd_dg00x_stream_get_local_rate(struct snd_dg00x *dg00x, unsigned int *rate) { u32 data; __be32 reg; int err; err = snd_fw_transaction(dg00x->unit, TCODE_READ_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_LOCAL_RATE, &reg, sizeof(reg), 0); if (err < 0) return err; data = be32_to_cpu(reg) & 0x0f; if (data < ARRAY_SIZE(snd_dg00x_stream_rates)) *rate = snd_dg00x_stream_rates[data]; else err = -EIO; return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto93100.00%1100.00%
Total93100.00%1100.00%


int snd_dg00x_stream_set_local_rate(struct snd_dg00x *dg00x, unsigned int rate) { __be32 reg; unsigned int i; for (i = 0; i < ARRAY_SIZE(snd_dg00x_stream_rates); i++) { if (rate == snd_dg00x_stream_rates[i]) break; } if (i == ARRAY_SIZE(snd_dg00x_stream_rates)) return -EINVAL; reg = cpu_to_be32(i); return snd_fw_transaction(dg00x->unit, TCODE_WRITE_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_LOCAL_RATE, &reg, sizeof(reg), 0); }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto93100.00%1100.00%
Total93100.00%1100.00%


int snd_dg00x_stream_get_clock(struct snd_dg00x *dg00x, enum snd_dg00x_clock *clock) { __be32 reg; int err; err = snd_fw_transaction(dg00x->unit, TCODE_READ_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_CLOCK_SOURCE, &reg, sizeof(reg), 0); if (err < 0) return err; *clock = be32_to_cpu(reg) & 0x0f; if (*clock >= SND_DG00X_CLOCK_COUNT) err = -EIO; return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto80100.00%1100.00%
Total80100.00%1100.00%


int snd_dg00x_stream_check_external_clock(struct snd_dg00x *dg00x, bool *detect) { __be32 reg; int err; err = snd_fw_transaction(dg00x->unit, TCODE_READ_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_DETECT_EXTERNAL, &reg, sizeof(reg), 0); if (err >= 0) *detect = be32_to_cpu(reg) > 0; return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto64100.00%1100.00%
Total64100.00%1100.00%


int snd_dg00x_stream_get_external_rate(struct snd_dg00x *dg00x, unsigned int *rate) { u32 data; __be32 reg; int err; err = snd_fw_transaction(dg00x->unit, TCODE_READ_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_EXTERNAL_RATE, &reg, sizeof(reg), 0); if (err < 0) return err; data = be32_to_cpu(reg) & 0x0f; if (data < ARRAY_SIZE(snd_dg00x_stream_rates)) *rate = snd_dg00x_stream_rates[data]; /* This means desync. */ else err = -EBUSY; return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto94100.00%1100.00%
Total94100.00%1100.00%


static void finish_session(struct snd_dg00x *dg00x) { __be32 data = cpu_to_be32(0x00000003); snd_fw_transaction(dg00x->unit, TCODE_WRITE_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_STREAMING_SET, &data, sizeof(data), 0); }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto42100.00%1100.00%
Total42100.00%1100.00%


static int begin_session(struct snd_dg00x *dg00x) { __be32 data; u32 curr; int err; err = snd_fw_transaction(dg00x->unit, TCODE_READ_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_STREAMING_STATE, &data, sizeof(data), 0); if (err < 0) goto error; curr = be32_to_cpu(data); if (curr == 0) curr = 2; curr--; while (curr > 0) { data = cpu_to_be32(curr); err = snd_fw_transaction(dg00x->unit, TCODE_WRITE_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_STREAMING_SET, &data, sizeof(data), 0); if (err < 0) goto error; msleep(20); curr--; } return 0; error: finish_session(dg00x); return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto144100.00%1100.00%
Total144100.00%1100.00%


static void release_resources(struct snd_dg00x *dg00x) { __be32 data = 0; /* Unregister isochronous channels for both direction. */ snd_fw_transaction(dg00x->unit, TCODE_WRITE_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_ISOC_CHANNELS, &data, sizeof(data), 0); /* Release isochronous resources. */ fw_iso_resources_free(&dg00x->tx_resources); fw_iso_resources_free(&dg00x->rx_resources); }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto57100.00%1100.00%
Total57100.00%1100.00%


static int keep_resources(struct snd_dg00x *dg00x, unsigned int rate) { unsigned int i; __be32 data; int err; /* Check sampling rate. */ for (i = 0; i < SND_DG00X_RATE_COUNT; i++) { if (snd_dg00x_stream_rates[i] == rate) break; } if (i == SND_DG00X_RATE_COUNT) return -EINVAL; /* Keep resources for out-stream. */ err = amdtp_dot_set_parameters(&dg00x->rx_stream, rate, snd_dg00x_stream_pcm_channels[i]); if (err < 0) return err; err = fw_iso_resources_allocate(&dg00x->rx_resources, amdtp_stream_get_max_payload(&dg00x->rx_stream), fw_parent_device(dg00x->unit)->max_speed); if (err < 0) return err; /* Keep resources for in-stream. */ err = amdtp_dot_set_parameters(&dg00x->tx_stream, rate, snd_dg00x_stream_pcm_channels[i]); if (err < 0) return err; err = fw_iso_resources_allocate(&dg00x->tx_resources, amdtp_stream_get_max_payload(&dg00x->tx_stream), fw_parent_device(dg00x->unit)->max_speed); if (err < 0) goto error; /* Register isochronous channels for both direction. */ data = cpu_to_be32((dg00x->tx_resources.channel << 16) | dg00x->rx_resources.channel); err = snd_fw_transaction(dg00x->unit, TCODE_WRITE_QUADLET_REQUEST, DG00X_ADDR_BASE + DG00X_OFFSET_ISOC_CHANNELS, &data, sizeof(data), 0); if (err < 0) goto error; return 0; error: release_resources(dg00x); return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto256100.00%1100.00%
Total256100.00%1100.00%


int snd_dg00x_stream_init_duplex(struct snd_dg00x *dg00x) { int err; /* For out-stream. */ err = fw_iso_resources_init(&dg00x->rx_resources, dg00x->unit); if (err < 0) goto error; err = amdtp_dot_init(&dg00x->rx_stream, dg00x->unit, AMDTP_OUT_STREAM); if (err < 0) goto error; /* For in-stream. */ err = fw_iso_resources_init(&dg00x->tx_resources, dg00x->unit); if (err < 0) goto error; err = amdtp_dot_init(&dg00x->tx_stream, dg00x->unit, AMDTP_IN_STREAM); if (err < 0) goto error; return 0; error: snd_dg00x_stream_destroy_duplex(dg00x); return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto124100.00%1100.00%
Total124100.00%1100.00%

/* * This function should be called before starting streams or after stopping * streams. */
void snd_dg00x_stream_destroy_duplex(struct snd_dg00x *dg00x) { amdtp_stream_destroy(&dg00x->rx_stream); fw_iso_resources_destroy(&dg00x->rx_resources); amdtp_stream_destroy(&dg00x->tx_stream); fw_iso_resources_destroy(&dg00x->tx_resources); }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto42100.00%1100.00%
Total42100.00%1100.00%


int snd_dg00x_stream_start_duplex(struct snd_dg00x *dg00x, unsigned int rate) { unsigned int curr_rate; int err = 0; if (dg00x->substreams_counter == 0) goto end; /* Check current sampling rate. */ err = snd_dg00x_stream_get_local_rate(dg00x, &curr_rate); if (err < 0) goto error; if (rate == 0) rate = curr_rate; if (curr_rate != rate || amdtp_streaming_error(&dg00x->tx_stream) || amdtp_streaming_error(&dg00x->rx_stream)) { finish_session(dg00x); amdtp_stream_stop(&dg00x->tx_stream); amdtp_stream_stop(&dg00x->rx_stream); release_resources(dg00x); } /* * No packets are transmitted without receiving packets, reagardless of * which source of clock is used. */ if (!amdtp_stream_running(&dg00x->rx_stream)) { err = snd_dg00x_stream_set_local_rate(dg00x, rate); if (err < 0) goto error; err = keep_resources(dg00x, rate); if (err < 0) goto error; err = begin_session(dg00x); if (err < 0) goto error; err = amdtp_stream_start(&dg00x->rx_stream, dg00x->rx_resources.channel, fw_parent_device(dg00x->unit)->max_speed); if (err < 0) goto error; if (!amdtp_stream_wait_callback(&dg00x->rx_stream, CALLBACK_TIMEOUT)) { err = -ETIMEDOUT; goto error; } } /* * The value of SYT field in transmitted packets is always 0x0000. Thus, * duplex streams with timestamp synchronization cannot be built. */ if (!amdtp_stream_running(&dg00x->tx_stream)) { err = amdtp_stream_start(&dg00x->tx_stream, dg00x->tx_resources.channel, fw_parent_device(dg00x->unit)->max_speed); if (err < 0) goto error; if (!amdtp_stream_wait_callback(&dg00x->tx_stream, CALLBACK_TIMEOUT)) { err = -ETIMEDOUT; goto error; } } end: return err; error: finish_session(dg00x); amdtp_stream_stop(&dg00x->tx_stream); amdtp_stream_stop(&dg00x->rx_stream); release_resources(dg00x); return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto344100.00%2100.00%
Total344100.00%2100.00%


void snd_dg00x_stream_stop_duplex(struct snd_dg00x *dg00x) { if (dg00x->substreams_counter > 0) return; amdtp_stream_stop(&dg00x->tx_stream); amdtp_stream_stop(&dg00x->rx_stream); finish_session(dg00x); release_resources(dg00x); /* * Just after finishing the session, the device may lost transmitting * functionality for a short time. */ msleep(50); }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto51100.00%1100.00%
Total51100.00%1100.00%


void snd_dg00x_stream_update_duplex(struct snd_dg00x *dg00x) { fw_iso_resources_update(&dg00x->tx_resources); fw_iso_resources_update(&dg00x->rx_resources); amdtp_stream_update(&dg00x->tx_stream); amdtp_stream_update(&dg00x->rx_stream); }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto42100.00%1100.00%
Total42100.00%1100.00%


void snd_dg00x_stream_lock_changed(struct snd_dg00x *dg00x) { dg00x->dev_lock_changed = true; wake_up(&dg00x->hwdep_wait); }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto24100.00%1100.00%
Total24100.00%1100.00%


int snd_dg00x_stream_lock_try(struct snd_dg00x *dg00x) { int err; spin_lock_irq(&dg00x->lock); /* user land lock this */ if (dg00x->dev_lock_count < 0) { err = -EBUSY; goto end; } /* this is the first time */ if (dg00x->dev_lock_count++ == 0) snd_dg00x_stream_lock_changed(dg00x); err = 0; end: spin_unlock_irq(&dg00x->lock); return err; }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto72100.00%1100.00%
Total72100.00%1100.00%


void snd_dg00x_stream_lock_release(struct snd_dg00x *dg00x) { spin_lock_irq(&dg00x->lock); if (WARN_ON(dg00x->dev_lock_count <= 0)) goto end; if (--dg00x->dev_lock_count == 0) snd_dg00x_stream_lock_changed(dg00x); end: spin_unlock_irq(&dg00x->lock); }

Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto56100.00%1100.00%
Total56100.00%1100.00%


Overall Contributors

PersonTokensPropCommitsCommitProp
takashi sakamototakashi sakamoto1778100.00%3100.00%
Total1778100.00%3100.00%
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.