/linux/drivers/media/usb/dvb-usb-v2/ |
H A D | usb_urb.c | 16 int usb_urb_reconfig(struct usb_data_stream *stream, 21 struct usb_data_stream *stream = urb->context; in usb_urb_complete() local 26 dev_dbg_ratelimited(&stream->udev->dev, in usb_urb_complete() 42 dev_dbg_ratelimited(&stream->udev->dev, in usb_urb_complete() 53 dev_dbg(&stream->udev->dev, in usb_urb_complete() 58 stream->complete(stream, in usb_urb_complete() 68 stream->complete(stream, b, urb->actual_length); in usb_urb_complete() 71 dev_err(&stream->udev->dev, in usb_urb_complete() 79 int usb_urb_killv2(struct usb_data_stream *stream) in usb_urb_killv2() argument 82 for (i = 0; i < stream->urbs_submitted; i++) { in usb_urb_killv2() [all …]
|
/linux/drivers/media/usb/dvb-usb/ |
H A D | usb-urb.c | 17 struct usb_data_stream *stream = urb->context; in usb_urb_complete() local 48 … stream->complete(stream, b + urb->iso_frame_desc[i].offset, urb->iso_frame_desc[i].actual_length); in usb_urb_complete() 57 stream->complete(stream, b, urb->actual_length); in usb_urb_complete() 66 int usb_urb_kill(struct usb_data_stream *stream) in usb_urb_kill() argument 69 for (i = 0; i < stream->urbs_submitted; i++) { in usb_urb_kill() 73 usb_kill_urb(stream->urb_list[i]); in usb_urb_kill() 75 stream->urbs_submitted = 0; in usb_urb_kill() 79 int usb_urb_submit(struct usb_data_stream *stream) in usb_urb_submit() argument 82 for (i = 0; i < stream->urbs_initialized; i++) { in usb_urb_submit() 84 if ((ret = usb_submit_urb(stream->urb_list[i],GFP_ATOMIC))) { in usb_urb_submit() [all …]
|
/linux/sound/core/ |
H A D | compress_offload.c | 53 struct snd_compr_stream stream; member 59 static void snd_compr_task_free_all(struct snd_compr_stream *stream); 61 static inline void snd_compr_task_free_all(struct snd_compr_stream *stream) { } in snd_compr_task_free_all() argument 65 * a note on stream states used: 67 * SNDRV_PCM_STATE_OPEN: When stream has been opened. 68 * SNDRV_PCM_STATE_SETUP: When stream has been initialized. This is done by 71 * SNDRV_PCM_STATE_PREPARED: When a stream has been written to (for 72 * playback only). User after setting up stream writes the data buffer 73 * before starting the stream. 74 * SNDRV_PCM_STATE_RUNNING: When stream has been started and is [all …]
|
/linux/drivers/gpu/drm/amd/display/dc/core/ |
H A D | dc_stream.c | 48 void update_stream_signal(struct dc_stream_state *stream, struct dc_sink *sink) in update_stream_signal() argument 51 stream->signal = stream->link->connector_signal; in update_stream_signal() 53 stream->signal = sink->sink_signal; in update_stream_signal() 55 if (dc_is_dvi_signal(stream->signal)) { in update_stream_signal() 56 if (stream->ctx->dc->caps.dual_link_dvi && in update_stream_signal() 57 (stream->timing.pix_clk_100hz / 10) > TMDS_MAX_PIXEL_CLOCK && in update_stream_signal() 59 stream->signal = SIGNAL_TYPE_DVI_DUAL_LINK; in update_stream_signal() 61 stream->signal = SIGNAL_TYPE_DVI_SINGLE_LINK; in update_stream_signal() 65 bool dc_stream_construct(struct dc_stream_state *stream, in dc_stream_construct() argument 70 stream->sink = dc_sink_data; in dc_stream_construct() [all …]
|
H A D | dc_link_enc_cfg.c | 31 /* Check whether stream is supported by DIG link encoders. */ 32 static bool is_dig_link_enc_stream(struct dc_stream_state *stream) in is_dig_link_enc_stream() argument 39 if (stream) { in is_dig_link_enc_stream() 40 for (i = 0; i < stream->ctx->dc->res_pool->res_cap->num_dig_link_enc; i++) { in is_dig_link_enc_stream() 41 link_enc = stream->ctx->dc->res_pool->link_encoders[i]; in is_dig_link_enc_stream() 43 /* Need to check link signal type rather than stream signal type which may not in is_dig_link_enc_stream() 46 if (link_enc && ((uint32_t)stream->link->connector_signal & link_enc->output_signals)) { in is_dig_link_enc_stream() 47 if (dc_is_dp_signal(stream->signal)) { in is_dig_link_enc_stream() 51 stream->ctx->dc->link_srv->dp_decide_link_settings(stream, &link_settings); in is_dig_link_enc_stream() 79 /* Return stream using DIG link encoder resource. NULL if unused. */ [all …]
|
/linux/fs/squashfs/ |
H A D | decompressor_multi.c | 47 void *stream; member 53 struct squashfs_stream *stream) in put_decomp_stream() argument 55 mutex_lock(&stream->mutex); in put_decomp_stream() 56 list_add(&decomp_strm->list, &stream->strm_list); in put_decomp_stream() 57 mutex_unlock(&stream->mutex); in put_decomp_stream() 58 wake_up(&stream->wait); in put_decomp_stream() 64 struct squashfs_stream *stream; in squashfs_decompressor_create() local 68 stream = kzalloc(sizeof(*stream), GFP_KERNEL); in squashfs_decompressor_create() 69 if (!stream) in squashfs_decompressor_create() 72 stream->comp_opts = comp_opts; in squashfs_decompressor_create() [all …]
|
H A D | decompressor_single.c | 23 void *stream; member 30 struct squashfs_stream *stream; in squashfs_decompressor_create() local 33 stream = kmalloc(sizeof(*stream), GFP_KERNEL); in squashfs_decompressor_create() 34 if (stream == NULL) in squashfs_decompressor_create() 37 stream->stream = msblk->decompressor->init(msblk, comp_opts); in squashfs_decompressor_create() 38 if (IS_ERR(stream->stream)) { in squashfs_decompressor_create() 39 err = PTR_ERR(stream->stream); in squashfs_decompressor_create() 44 mutex_init(&stream->mutex); in squashfs_decompressor_create() 45 return stream; in squashfs_decompressor_create() 48 kfree(stream); in squashfs_decompressor_create() [all …]
|
H A D | xz_wrapper.c | 84 struct squashfs_xz *stream; in squashfs_xz_init() local 87 stream = kmalloc(sizeof(*stream), GFP_KERNEL); in squashfs_xz_init() 88 if (stream == NULL) { in squashfs_xz_init() 93 stream->state = xz_dec_init(XZ_PREALLOC, comp_opts->dict_size); in squashfs_xz_init() 94 if (stream->state == NULL) { in squashfs_xz_init() 95 kfree(stream); in squashfs_xz_init() 100 return stream; in squashfs_xz_init() 110 struct squashfs_xz *stream = strm; in squashfs_xz_free() local 112 if (stream) { in squashfs_xz_free() 113 xz_dec_end(stream->state); in squashfs_xz_free() [all …]
|
H A D | zlib_wrapper.c | 26 z_stream *stream = kmalloc(sizeof(z_stream), GFP_KERNEL); in zlib_init() local 27 if (stream == NULL) in zlib_init() 29 stream->workspace = vmalloc(zlib_inflate_workspacesize()); in zlib_init() 30 if (stream->workspace == NULL) in zlib_init() 33 return stream; in zlib_init() 37 kfree(stream); in zlib_init() 44 z_stream *stream = strm; in zlib_free() local 46 if (stream) in zlib_free() 47 vfree(stream->workspace); in zlib_free() 48 kfree(stream); in zlib_free() [all …]
|
/linux/lib/kunit/ |
H A D | string-stream.c | 3 * C++ stream style string builder used in KUnit for building messages. 14 #include "string-stream.h" 41 int string_stream_vadd(struct string_stream *stream, in string_stream_vadd() argument 61 if (stream->append_newlines) in string_stream_vadd() 67 frag_container = alloc_string_stream_fragment(buf_len, stream->gfp); in string_stream_vadd() 71 if (stream->append_newlines) { in string_stream_vadd() 82 spin_lock(&stream->lock); in string_stream_vadd() 83 stream->length += result_len; in string_stream_vadd() 84 list_add_tail(&frag_container->node, &stream->fragments); in string_stream_vadd() 85 spin_unlock(&stream->lock); in string_stream_vadd() [all …]
|
H A D | assert_test.c | 7 #include "string-stream.h" 40 /* this function is used to get a "char *" string from the string stream and defer its cleanup */ 41 static char *get_str_from_stream(struct kunit *test, struct string_stream *stream) in get_str_from_stream() argument 43 char *str = string_stream_get_string(stream); in get_str_from_stream() 53 struct string_stream *stream; in kunit_test_assert_prologue() local 60 stream = kunit_alloc_string_stream(test, GFP_KERNEL); in kunit_test_assert_prologue() 61 KUNIT_ASSERT_NOT_ERR_OR_NULL(test, stream); in kunit_test_assert_prologue() 64 kunit_assert_prologue(&location, KUNIT_EXPECTATION, stream); in kunit_test_assert_prologue() 65 str = get_str_from_stream(test, stream); in kunit_test_assert_prologue() 71 string_stream_clear(stream); in kunit_test_assert_prologue() [all …]
|
H A D | assert.c | 12 #include "string-stream.h" 16 struct string_stream *stream) in kunit_assert_prologue() argument 29 string_stream_add(stream, "%s FAILED at %s:%d\n", in kunit_assert_prologue() 36 struct string_stream *stream) in kunit_assert_print_msg() argument 39 string_stream_add(stream, "\n%pV", message); in kunit_assert_print_msg() 44 struct string_stream *stream) in kunit_fail_assert_format() argument 46 string_stream_add(stream, "%pV", message); in kunit_fail_assert_format() 52 struct string_stream *stream) in kunit_unary_assert_format() argument 59 string_stream_add(stream, in kunit_unary_assert_format() 63 string_stream_add(stream, in kunit_unary_assert_format() [all …]
|
/linux/drivers/staging/media/atomisp/pci/ |
H A D | ia_css_stream_public.h | 31 IA_CSS_INPUT_MODE_PRBS, /** data from pseudo-random bit stream */ 44 stream */ 59 enum atomisp_input_format format; /** Format of input stream. This data 74 enum atomisp_input_format format; /** Format of input stream. This data 80 /* Input stream description. This describes how input will flow into the 135 /* Stream info, this struct describes properties of a stream after it has been 143 /* @brief Load default stream configuration 144 * @param[in,out] stream_config The stream configuration. 147 * This function will reset the stream configuration to the default state: 160 /* @brief Creates a stream [all …]
|
/linux/net/sctp/ |
H A D | stream_sched_rr.c | 7 * These functions manipulate sctp stream queue/scheduling. 25 static void sctp_sched_rr_unsched_all(struct sctp_stream *stream); 27 static void sctp_sched_rr_next_stream(struct sctp_stream *stream) in sctp_sched_rr_next_stream() argument 31 pos = stream->rr_next->rr_list.next; in sctp_sched_rr_next_stream() 32 if (pos == &stream->rr_list) in sctp_sched_rr_next_stream() 34 stream->rr_next = list_entry(pos, struct sctp_stream_out_ext, rr_list); in sctp_sched_rr_next_stream() 37 static void sctp_sched_rr_unsched(struct sctp_stream *stream, in sctp_sched_rr_unsched() argument 40 if (stream->rr_next == soute) in sctp_sched_rr_unsched() 41 /* Try to move to the next stream */ in sctp_sched_rr_unsched() 42 sctp_sched_rr_next_stream(stream); in sctp_sched_rr_unsched() [all …]
|
H A D | stream.c | 10 * This file contains sctp stream maniuplation primitives and helpers. 25 static void sctp_stream_shrink_out(struct sctp_stream *stream, __u16 outcnt) in sctp_stream_shrink_out() argument 31 asoc = container_of(stream, struct sctp_association, stream); in sctp_stream_shrink_out() 55 static void sctp_stream_free_ext(struct sctp_stream *stream, __u16 sid) in sctp_stream_free_ext() argument 59 if (!SCTP_SO(stream, sid)->ext) in sctp_stream_free_ext() 62 sched = sctp_sched_ops_from_stream(stream); in sctp_stream_free_ext() 63 sched->free_sid(stream, sid); in sctp_stream_free_ext() 64 kfree(SCTP_SO(stream, sid)->ext); in sctp_stream_free_ext() 65 SCTP_SO(stream, sid)->ext = NULL; in sctp_stream_free_ext() 68 /* Migrates chunks from stream queues to new stream queues if needed, [all …]
|
H A D | stream_sched_fc.c | 7 * These functions manipulate sctp stream queue/scheduling. 25 static void sctp_sched_fc_unsched_all(struct sctp_stream *stream); 27 static int sctp_sched_wfq_set(struct sctp_stream *stream, __u16 sid, in sctp_sched_wfq_set() argument 30 struct sctp_stream_out_ext *soute = SCTP_SO(stream, sid)->ext; in sctp_sched_wfq_set() 39 static int sctp_sched_wfq_get(struct sctp_stream *stream, __u16 sid, in sctp_sched_wfq_get() argument 42 struct sctp_stream_out_ext *soute = SCTP_SO(stream, sid)->ext; in sctp_sched_wfq_get() 48 static int sctp_sched_fc_set(struct sctp_stream *stream, __u16 sid, in sctp_sched_fc_set() argument 54 static int sctp_sched_fc_get(struct sctp_stream *stream, __u16 sid, in sctp_sched_fc_get() argument 60 static int sctp_sched_fc_init(struct sctp_stream *stream) in sctp_sched_fc_init() argument 62 INIT_LIST_HEAD(&stream->fc_list); in sctp_sched_fc_init() [all …]
|
H A D | stream_sched_prio.c | 7 * These functions manipulate sctp stream queue/scheduling. 26 static void sctp_sched_prio_unsched_all(struct sctp_stream *stream); 41 struct sctp_stream *stream, int prio, gfp_t gfp) in sctp_sched_prio_new_head() argument 59 struct sctp_stream *stream, int prio, gfp_t gfp) in sctp_sched_prio_get_head() argument 67 list_for_each_entry(p, &stream->prio_list, prio_sched) { in sctp_sched_prio_get_head() 75 for (i = 0; i < stream->outcnt; i++) { in sctp_sched_prio_get_head() 76 if (!SCTP_SO(stream, i)->ext) in sctp_sched_prio_get_head() 79 p = SCTP_SO(stream, i)->ext->prio_head; in sctp_sched_prio_get_head() 90 return sctp_sched_prio_new_head(stream, prio, gfp); in sctp_sched_prio_get_head() 114 /* Try to move to the next stream */ in sctp_sched_prio_unsched() [all …]
|
/linux/drivers/gpu/drm/xe/ |
H A D | xe_oa.c | 137 static u32 xe_oa_circ_diff(struct xe_oa_stream *stream, u32 tail, u32 head) in xe_oa_circ_diff() argument 140 tail + stream->oa_buffer.circ_size - head; in xe_oa_circ_diff() 143 static u32 xe_oa_circ_incr(struct xe_oa_stream *stream, u32 ptr, u32 n) in xe_oa_circ_incr() argument 145 return ptr + n >= stream->oa_buffer.circ_size ? in xe_oa_circ_incr() 146 ptr + n - stream->oa_buffer.circ_size : ptr + n; in xe_oa_circ_incr() 192 static const struct xe_oa_regs *__oa_regs(struct xe_oa_stream *stream) in __oa_regs() argument 194 return &stream->hwe->oa_unit->regs; in __oa_regs() 197 static u32 xe_oa_hw_tail_read(struct xe_oa_stream *stream) in xe_oa_hw_tail_read() argument 199 return xe_mmio_read32(&stream->gt->mmio, __oa_regs(stream)->oa_tail_ptr) & in xe_oa_hw_tail_read() 206 static u64 oa_report_id(struct xe_oa_stream *stream, void *report) in oa_report_id() argument [all …]
|
/linux/drivers/slimbus/ |
H A D | stream.c | 55 * The Presence rate of a constant bitrate stream is mean flow rate of the 56 * stream expressed in occupied Segments of that Data Channel per second. 90 * slim_stream_allocate() - Allocate a new SLIMbus Stream 92 * @name: name of the stream 95 * a new SLIMbus stream and return a valid stream runtime pointer for client 96 * to use it in subsequent stream apis. state of stream is set to ALLOCATED 125 static int slim_connect_port_channel(struct slim_stream_runtime *stream, in slim_connect_port_channel() argument 128 struct slim_device *sdev = stream->dev; in slim_connect_port_channel() 132 DEFINE_SLIM_LDEST_TXN(txn, mc, 6, stream->dev->laddr, &msg); in slim_connect_port_channel() 145 static int slim_disconnect_port(struct slim_stream_runtime *stream, in slim_disconnect_port() argument [all …]
|
/linux/sound/soc/intel/atom/ |
H A D | sst-mfld-platform-compress.c | 23 /* compress stream operations */ 47 struct sst_runtime_stream *stream; in sst_platform_compr_open() local 49 stream = kzalloc(sizeof(*stream), GFP_KERNEL); in sst_platform_compr_open() 50 if (!stream) in sst_platform_compr_open() 53 spin_lock_init(&stream->status_lock); in sst_platform_compr_open() 61 stream->compr_ops = sst->compr_ops; in sst_platform_compr_open() 62 stream->id = 0; in sst_platform_compr_open() 67 sst_set_stream_status(stream, SST_PLATFORM_INIT); in sst_platform_compr_open() 68 runtime->private_data = stream; in sst_platform_compr_open() 71 kfree(stream); in sst_platform_compr_open() [all …]
|
/linux/sound/soc/sprd/ |
H A D | sprd-pcm-compress.c | 107 struct sprd_compr_stream *stream = runtime->private_data; in sprd_platform_compr_drain_notify() local 109 memset(stream->info_area, 0, sizeof(struct sprd_compr_playinfo)); in sprd_platform_compr_drain_notify() 118 struct sprd_compr_stream *stream = runtime->private_data; in sprd_platform_compr_dma_complete() local 119 struct sprd_compr_dma *dma = &stream->dma[1]; in sprd_platform_compr_dma_complete() 122 stream->copied_total += dma->trans_len; in sprd_platform_compr_dma_complete() 123 if (stream->copied_total > stream->received_total) in sprd_platform_compr_dma_complete() 124 stream->copied_total = stream->received_total; in sprd_platform_compr_dma_complete() 135 struct sprd_compr_stream *stream = runtime->private_data; in sprd_platform_compr_dma_config() local 140 struct sprd_compr_dma *dma = &stream->dma[channel]; in sprd_platform_compr_dma_config() 174 src_addr = stream->iram_buffer.addr; in sprd_platform_compr_dma_config() [all …]
|
/linux/sound/xen/ |
H A D | xen_snd_front_alsa.c | 212 static void stream_clear(struct xen_snd_front_pcm_stream_info *stream) in stream_clear() argument 214 stream->is_open = false; in stream_clear() 215 stream->be_cur_frame = 0; in stream_clear() 216 stream->out_frames = 0; in stream_clear() 217 atomic_set(&stream->hw_ptr, 0); in stream_clear() 218 xen_snd_front_evtchnl_pair_clear(stream->evt_pair); in stream_clear() 219 memset(&stream->shbuf, 0, sizeof(stream->shbuf)); in stream_clear() 220 stream->buffer = NULL; in stream_clear() 221 stream->buffer_sz = 0; in stream_clear() 222 stream->pages = NULL; in stream_clear() [all …]
|
/linux/drivers/gpu/drm/amd/display/dc/link/ |
H A D | link_dpms.c | 27 * This file owns the programming sequence of stream's dpms state associated 28 * with the link and link's enable/disable sequences as result of the stream's 31 * TODO - The reason link owns stream's dpms programming sequence is 34 * stream state programming sequence. This creates a gray area where the 35 * boundary between link and stream is not clearly defined. 164 stream_update.stream = pipes[i]->stream; in link_set_all_streams_dpms_off_for_link() 166 pipes[i]->stream, &stream_update, in link_set_all_streams_dpms_off_for_link() 189 pipe->stream->link == link; in is_master_pipe_for_link() 209 pipe->stream->dpms_off == false) { in link_get_master_pipes_with_dpms_on() 222 pipe_ctx->stream->ctx->dc_bios->integrated_info; in get_ext_hdmi_settings() [all …]
|
/linux/drivers/media/v4l2-core/ |
H A D | v4l2-jpeg.c | 41 #define SOS 0xffda /* start of stream */ 97 * interchange format JPEG stream or an abbreviated format table specification 98 * data stream. Specifies the huffman table used for encoding the luminance DC 110 * interchange format JPEG stream or an abbreviated format table specification 111 * data stream. Specifies the huffman table used for encoding the luminance AC 135 * stream or an abbreviated format table specification data stream. 148 * interchange format JPEG stream or an abbreviated format table specification 149 * data stream. Specifies the huffman table used for encoding the chrominance 172 * struct jpeg_stream - JPEG byte stream 173 * @curr: current position in stream [all …]
|
/linux/Documentation/driver-api/soundwire/ |
H A D | stream.rst | 2 Audio Stream in SoundWire 5 An audio stream is a logical or virtual connection created between 16 audio stream contains one or more channels of data. All channels within 17 stream must have same sample rate and same sample size. 19 Assume a stream with two channels (Left & Right) is opened using SoundWire 20 interface. Below are some ways a stream can be represented in SoundWire. 22 Stream Sample in memory (System memory, DSP memory or FIFOs) :: 28 Example 1: Stereo Stream with L and R channels is rendered from Master to 41 Example 2: Stereo Stream with L and R channels is captured from Slave to 55 Example 3: Stereo Stream with L and R channels is rendered by Master. Each [all …]
|