| /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/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 …]
|
| /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 …]
|
| H A D | decompressor_multi_percpu.c | 23 void *stream; member
30 struct squashfs_stream *stream; in squashfs_decompressor_create() local
39 stream = per_cpu_ptr(percpu, cpu); in squashfs_decompressor_create()
40 stream->stream = msblk->decompressor->init(msblk, comp_opts); in squashfs_decompressor_create()
41 if (IS_ERR(stream->stream)) { in squashfs_decompressor_create()
42 err = PTR_ERR(stream->stream); in squashfs_decompressor_create()
45 local_lock_init(&stream->lock); in squashfs_decompressor_create()
53 stream = per_cpu_ptr(percpu, cpu); in squashfs_decompressor_create()
54 if (!IS_ERR_OR_NULL(stream->stream)) in squashfs_decompressor_create()
55 msblk->decompressor->free(stream->stream); in squashfs_decompressor_create()
[all …]
|
| /linux/lib/kunit/ |
| H A D | string-stream.c | 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()
90 int string_stream_add(struct string_stream *stream, const char *fmt, ...) in string_stream_add() argument
96 result = string_stream_vadd(stream, fmt, args); in string_stream_add()
[all …]
|
| H A D | assert_test.c | 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()
72 kunit_assert_prologue(&location, KUNIT_ASSERTION, stream); in kunit_test_assert_prologue()
73 str = get_str_from_stream(test, stream); in kunit_test_assert_prologue()
[all …]
|
| H A D | assert.c | 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()
66 kunit_assert_print_msg(message, stream); in kunit_unary_assert_format()
[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()
51 sctp_sched_rr_sched(struct sctp_stream * stream,struct sctp_stream_out_ext * soute) sctp_sched_rr_sched() argument
65 sctp_sched_rr_set(struct sctp_stream * stream,__u16 sid,__u16 prio,gfp_t gfp) sctp_sched_rr_set() argument
71 sctp_sched_rr_get(struct sctp_stream * stream,__u16 sid,__u16 * value) sctp_sched_rr_get() argument
77 sctp_sched_rr_init(struct sctp_stream * stream) sctp_sched_rr_init() argument
85 sctp_sched_rr_init_sid(struct sctp_stream * stream,__u16 sid,gfp_t gfp) sctp_sched_rr_init_sid() argument
93 sctp_sched_rr_free_sid(struct sctp_stream * stream,__u16 sid) sctp_sched_rr_free_sid() argument
100 struct sctp_stream *stream; sctp_sched_rr_enqueue() local
112 struct sctp_stream *stream = &q->asoc->stream; sctp_sched_rr_dequeue() local
149 sctp_sched_rr_sched_all(struct sctp_stream * stream) sctp_sched_rr_sched_all() argument
166 sctp_sched_rr_unsched_all(struct sctp_stream * stream) sctp_sched_rr_unsched_all() argument
[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, si in sctp_stream_free_ext()
72 sctp_stream_outq_migrate(struct sctp_stream * stream,struct sctp_stream * new,__u16 outcnt) sctp_stream_outq_migrate() argument
96 sctp_stream_alloc_out(struct sctp_stream * stream,__u16 outcnt,gfp_t gfp) sctp_stream_alloc_out() argument
113 sctp_stream_alloc_in(struct sctp_stream * stream,__u16 incnt,gfp_t gfp) sctp_stream_alloc_in() argument
130 sctp_stream_init(struct sctp_stream * stream,__u16 outcnt,__u16 incnt,gfp_t gfp) sctp_stream_init() argument
164 sctp_stream_init_ext(struct sctp_stream * stream,__u16 sid) sctp_stream_init_ext() argument
183 sctp_stream_free(struct sctp_stream * stream) sctp_stream_free() argument
195 sctp_stream_clear(struct sctp_stream * stream) sctp_stream_clear() argument
208 sctp_stream_update(struct sctp_stream * stream,struct sctp_stream * new) sctp_stream_update() argument
241 sctp_stream_outq_is_empty(struct sctp_stream * stream,__u16 str_nums,__be16 * str_list) sctp_stream_outq_is_empty() argument
268 struct sctp_stream *stream = &asoc->stream; sctp_send_reset_streams() local
382 struct sctp_stream *stream = &asoc->stream; sctp_send_reset_assoc() local
427 struct sctp_stream *stream = &asoc->stream; sctp_send_add_streams() local
522 struct sctp_stream *stream = &asoc->stream; sctp_process_strreset_outreq() local
611 struct sctp_stream *stream = &asoc->stream; sctp_process_strreset_inreq() local
689 struct sctp_stream *stream = &asoc->stream; sctp_process_strreset_tsnreq() local
785 struct sctp_stream *stream = &asoc->stream; sctp_process_strreset_addstrm_out() local
855 struct sctp_stream *stream = &asoc->stream; sctp_process_strreset_addstrm_in() local
919 struct sctp_stream *stream = &asoc->stream; sctp_process_strreset_resp() local
[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 in sctp_sched_fc_init()
67 sctp_sched_fc_init_sid(struct sctp_stream * stream,__u16 sid,gfp_t gfp) sctp_sched_fc_init_sid() argument
79 sctp_sched_fc_free_sid(struct sctp_stream * stream,__u16 sid) sctp_sched_fc_free_sid() argument
83 sctp_sched_fc_sched(struct sctp_stream * stream,struct sctp_stream_out_ext * soute) sctp_sched_fc_sched() argument
101 struct sctp_stream *stream; sctp_sched_fc_enqueue() local
113 struct sctp_stream *stream = &q->asoc->stream; sctp_sched_fc_dequeue() local
135 struct sctp_stream *stream = &q->asoc->stream; sctp_sched_fc_dequeue_done() local
169 sctp_sched_fc_sched_all(struct sctp_stream * stream) sctp_sched_fc_sched_all() argument
183 sctp_sched_fc_unsched_all(struct sctp_stream * stream) sctp_sched_fc_unsched_all() argument
[all...] |
| H A D | stream_sched.c | 7 * These functions manipulate sctp stream queue/scheduling.
25 static int sctp_sched_fcfs_set(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_set() argument
31 static int sctp_sched_fcfs_get(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_get() argument
38 static int sctp_sched_fcfs_init(struct sctp_stream *stream) in sctp_sched_fcfs_init() argument
43 static int sctp_sched_fcfs_init_sid(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_init_sid() argument
49 static void sctp_sched_fcfs_free_sid(struct sctp_stream *stream, __u16 sid) in sctp_sched_fcfs_free_sid() argument
60 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_fcfs_dequeue() local
67 if (stream->out_curr) { in sctp_sched_fcfs_dequeue()
68 ch = list_entry(stream in sctp_sched_fcfs_dequeue()
86 sctp_sched_fcfs_sched_all(struct sctp_stream * stream) sctp_sched_fcfs_sched_all() argument
90 sctp_sched_fcfs_unsched_all(struct sctp_stream * stream) sctp_sched_fcfs_unsched_all() argument
131 sctp_sched_free_sched(struct sctp_stream * stream) sctp_sched_free_sched() argument
264 sctp_sched_init_sid(struct sctp_stream * stream,__u16 sid,gfp_t gfp) sctp_sched_init_sid() argument
273 sctp_sched_ops_from_stream(struct sctp_stream * stream) sctp_sched_ops_from_stream() argument
[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()
130 sctp_sched_prio_sched(struct sctp_stream * stream,struct sctp_stream_out_ext * soute) sctp_sched_prio_sched() argument
163 sctp_sched_prio_set(struct sctp_stream * stream,__u16 sid,__u16 prio,gfp_t gfp) sctp_sched_prio_set() argument
188 sctp_sched_prio_get(struct sctp_stream * stream,__u16 sid,__u16 * value) sctp_sched_prio_get() argument
195 sctp_sched_prio_init(struct sctp_stream * stream) sctp_sched_prio_init() argument
202 sctp_sched_prio_init_sid(struct sctp_stream * stream,__u16 sid,gfp_t gfp) sctp_sched_prio_init_sid() argument
209 sctp_sched_prio_free_sid(struct sctp_stream * stream,__u16 sid) sctp_sched_prio_free_sid() argument
218 struct sctp_stream *stream; sctp_sched_prio_enqueue() local
230 struct sctp_stream *stream = &q->asoc->stream; sctp_sched_prio_dequeue() local
276 sctp_sched_prio_sched_all(struct sctp_stream * stream) sctp_sched_prio_sched_all() argument
293 sctp_sched_prio_unsched_all(struct sctp_stream * stream) sctp_sched_prio_unsched_all() argument
[all...] |
| /linux/sound/soc/ |
| H A D | soc-pcm.c | 39 static int snd_soc_dpcm_can_fe_update(struct snd_soc_pcm_runtime *fe, int stream)
41 if (fe->dpcm[stream].runtime_update == SND_SOC_DPCM_UPDATE_FE)
49 struct snd_soc_pcm_runtime *be, int stream) in snd_soc_dpcm_can_be_update() argument
51 if ((fe->dpcm[stream].runtime_update == SND_SOC_DPCM_UPDATE_FE) || in snd_soc_dpcm_can_be_update()
52 ((fe->dpcm[stream].runtime_update == SND_SOC_DPCM_UPDATE_BE) && in snd_soc_dpcm_can_be_update()
53 be->dpcm[stream].runtime_update)) in snd_soc_dpcm_can_be_update()
60 int stream, in snd_soc_dpcm_check_state() argument
69 for_each_dpcm_fe(be, stream, dpcm) { in snd_soc_dpcm_check_state()
74 state = dpcm->fe->dpcm[stream].state; in snd_soc_dpcm_check_state()
89 * are not running, paused or suspended for the specified stream directio
92 snd_soc_dpcm_can_be_free_stop(struct snd_soc_pcm_runtime * fe,struct snd_soc_pcm_runtime * be,int stream) snd_soc_dpcm_can_be_free_stop() argument
108 snd_soc_dpcm_can_be_params(struct snd_soc_pcm_runtime * fe,struct snd_soc_pcm_runtime * be,int stream) snd_soc_dpcm_can_be_params() argument
125 snd_soc_dpcm_can_be_prepared(struct snd_soc_pcm_runtime * fe,struct snd_soc_pcm_runtime * be,int stream) snd_soc_dpcm_can_be_prepared() argument
177 dpcm_show_state(struct snd_soc_pcm_runtime * fe,int stream,char * buf,size_t size) dpcm_show_state() argument
238 int stream; dpcm_state_read_file() local
284 dpcm_create_debugfs_state(struct snd_soc_dpcm * dpcm,int stream) dpcm_create_debugfs_state() argument
306 dpcm_create_debugfs_state(struct snd_soc_dpcm * dpcm,int stream) dpcm_create_debugfs_state() argument
322 dpcm_set_fe_update_state(struct snd_soc_pcm_runtime * fe,int stream,enum snd_soc_dpcm_update state) dpcm_set_fe_update_state() argument
338 dpcm_set_be_update_state(struct snd_soc_pcm_runtime * be,int stream,enum snd_soc_dpcm_update state) dpcm_set_be_update_state() argument
357 snd_soc_runtime_action(struct snd_soc_pcm_runtime * rtd,int stream,int action) snd_soc_runtime_action() argument
545 int stream = substream->stream; soc_pcm_apply_msb() local
620 snd_soc_runtime_calc_hw(struct snd_soc_pcm_runtime * rtd,struct snd_pcm_hardware * hw,int stream) snd_soc_runtime_calc_hw() argument
1288 dpcm_be_connect(struct snd_soc_pcm_runtime * fe,struct snd_soc_pcm_runtime * be,int stream) dpcm_be_connect() argument
1337 dpcm_be_reparent(struct snd_soc_pcm_runtime * fe,struct snd_soc_pcm_runtime * be,int stream) dpcm_be_reparent() argument
1366 dpcm_be_disconnect(struct snd_soc_pcm_runtime * fe,int stream) dpcm_be_disconnect() argument
1406 dpcm_get_be(struct snd_soc_card * card,struct snd_soc_dapm_widget * widget,int stream) dpcm_get_be() argument
1456 int stream; dpcm_end_walk_at_be() local
1473 dpcm_path_get(struct snd_soc_pcm_runtime * fe,int stream,struct snd_soc_dapm_widget_list ** list) dpcm_path_get() argument
1502 dpcm_be_is_active(struct snd_soc_dpcm * dpcm,int stream,struct snd_soc_dapm_widget_list * list) dpcm_be_is_active() argument
1523 dpcm_prune_paths(struct snd_soc_pcm_runtime * fe,int stream,struct snd_soc_dapm_widget_list ** list_) dpcm_prune_paths() argument
1546 dpcm_add_paths(struct snd_soc_pcm_runtime * fe,int stream,struct snd_soc_dapm_widget_list ** list_) dpcm_add_paths() argument
1615 dpcm_clear_pending_state(struct snd_soc_pcm_runtime * fe,int stream) dpcm_clear_pending_state() argument
1623 dpcm_be_dai_stop(struct snd_soc_pcm_runtime * fe,int stream,int do_hw_free,struct snd_soc_dpcm * last) dpcm_be_dai_stop() argument
1667 dpcm_be_dai_startup(struct snd_soc_pcm_runtime * fe,int stream) dpcm_be_dai_startup() argument
1740 int stream = substream->stream; dpcm_runtime_setup_fe() local
1775 int stream = substream->stream; dpcm_runtime_setup_be_format() local
1811 int stream = substream->stream; dpcm_runtime_setup_be_chan() local
1859 int stream = substream->stream; dpcm_runtime_setup_be_rate() local
1891 dpcm_apply_symmetry(struct snd_pcm_substream * fe_substream,int stream) dpcm_apply_symmetry() argument
1941 int stream = fe_substream->stream, ret = 0; dpcm_fe_dai_startup() local
1978 int stream = substream->stream; dpcm_fe_dai_shutdown() local
2000 dpcm_be_dai_hw_free(struct snd_soc_pcm_runtime * fe,int stream) dpcm_be_dai_hw_free() argument
2044 int stream = substream->stream; dpcm_fe_dai_hw_free() local
2065 dpcm_be_dai_hw_params(struct snd_soc_pcm_runtime * fe,int stream) dpcm_be_dai_hw_params() argument
2147 int ret, stream = substream->stream; dpcm_fe_dai_hw_params() local
2176 dpcm_be_dai_trigger(struct snd_soc_pcm_runtime * fe,int stream,int cmd) dpcm_be_dai_trigger() argument
2381 int stream = substream->stream; dpcm_fe_dai_do_trigger() local
2445 int stream = substream->stream; dpcm_fe_dai_trigger() local
2459 dpcm_be_dai_prepare(struct snd_soc_pcm_runtime * fe,int stream) dpcm_be_dai_prepare() argument
2505 int stream = substream->stream, ret = 0; dpcm_fe_dai_prepare() local
2537 dpcm_run_update_shutdown(struct snd_soc_pcm_runtime * fe,int stream) dpcm_run_update_shutdown() argument
2556 dpcm_run_update_startup(struct snd_soc_pcm_runtime * fe,int stream) dpcm_run_update_startup() argument
2632 int stream; soc_dpcm_fe_runtime_update() local
2727 int stream = fe_substream->stream; dpcm_fe_dai_cleanup() local
2757 int stream = fe_substream->stream; dpcm_fe_dai_open() local
2992 snd_soc_dpcm_get_substream(struct snd_soc_pcm_runtime * be,int stream) snd_soc_dpcm_get_substream() argument
[all...] |
| /linux/kernel/bpf/ |
| H A D | stream.c | 60 static int bpf_stream_consume_capacity(struct bpf_stream *stream, int len) in bpf_stream_consume_capacity() argument
62 if (atomic_read(&stream->capacity) >= BPF_STREAM_MAX_CAPACITY) in bpf_stream_consume_capacity()
64 if (atomic_add_return(len, &stream->capacity) >= BPF_STREAM_MAX_CAPACITY) { in bpf_stream_consume_capacity()
65 atomic_sub(len, &stream->capacity); in bpf_stream_consume_capacity()
71 static void bpf_stream_release_capacity(struct bpf_stream *stream, struct bpf_stream_elem *elem) in bpf_stream_release_capacity() argument
75 atomic_sub(len, &stream->capacity); in bpf_stream_release_capacity()
78 static int bpf_stream_push_str(struct bpf_stream *stream, const char *str, int len) in bpf_stream_push_str() argument
80 int ret = bpf_stream_consume_capacity(stream, len); in bpf_stream_push_str()
82 return ret ?: __bpf_stream_push_str(&stream->log, str, len); in bpf_stream_push_str()
89 return &aux->stream[stream_id - 1]; in bpf_stream_get()
[all …]
|
| /linux/drivers/slimbus/ |
| H A D | stream.c | 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
148 struct slim_device *sdev = stream->dev; in slim_disconnect_port()
152 DEFINE_SLIM_LDEST_TXN(txn, mc, 5, stream->dev->laddr, &msg); in slim_disconnect_port()
161 static int slim_deactivate_remove_channel(struct slim_stream_runtime *stream, in slim_deactivate_remove_channel() argument
164 struct slim_device *sdev = stream->dev; in slim_deactivate_remove_channel()
168 DEFINE_SLIM_LDEST_TXN(txn, mc, 5, stream->dev->laddr, &msg); in slim_deactivate_remove_channel()
272 static int slim_define_channel_content(struct slim_stream_runtime *stream, in slim_define_channel_content() argument
[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/staging/media/atomisp/pci/ |
| H A D | ia_css_stream_public.h | 173 struct ia_css_stream **stream);
182 ia_css_stream_destroy(struct ia_css_stream *stream);
192 ia_css_stream_get_info(const struct ia_css_stream *stream,
207 ia_css_stream_start(struct ia_css_stream *stream);
217 ia_css_stream_stop(struct ia_css_stream *stream);
226 ia_css_stream_has_stopped(struct ia_css_stream *stream);
235 ia_css_stream_unload(struct ia_css_stream *stream);
244 ia_css_stream_get_format(const struct ia_css_stream *stream);
254 ia_css_stream_get_two_pixels_per_clock(const struct ia_css_stream *stream);
264 ia_css_stream_set_output_padded_width(struct ia_css_stream *stream,
[all …]
|
| /linux/drivers/media/platform/mediatek/jpeg/ |
| H A D | mtk_jpeg_dec_parse.c | 20 static int read_byte(struct mtk_jpeg_stream *stream) in read_byte() argument
22 if (stream->curr >= stream->size) in read_byte()
24 return stream->addr[stream->curr++]; in read_byte()
27 static int read_word_be(struct mtk_jpeg_stream *stream, u32 *word) in read_word_be() argument
32 byte = read_byte(stream); in read_word_be()
36 byte = read_byte(stream); in read_word_be()
44 static void read_skip(struct mtk_jpeg_stream *stream, long len) in read_skip() argument
49 read_byte(stream); in read_skip()
56 struct mtk_jpeg_stream stream; in mtk_jpeg_do_parse() local
58 stream.addr = src_addr_va; in mtk_jpeg_do_parse()
[all …]
|
| /linux/drivers/gpu/drm/amd/display/dc/link/ |
| H A D | link_dpms.c | 171 streams[i] = pipes[i]->stream; in link_set_all_streams_dpms_off_for_link()
174 stream_update.stream = streams[i]; in link_set_all_streams_dpms_off_for_link()
199 pipe->stream->link == link; in is_master_pipe_for_link()
219 pipe->stream->dpms_off == false) { in link_get_master_pipes_with_dpms_on()
232 pipe_ctx->stream->ctx->dc_bios->integrated_info; in get_ext_hdmi_settings()
333 cmd.speed = pipe_ctx->stream->ctx->dc->caps.i2c_speed_in_khz; in write_i2c()
341 if (dm_helpers_submit_i2c(pipe_ctx->stream->ctx, in write_i2c()
342 pipe_ctx->stream->link, &cmd)) in write_i2c()
361 DC_LOGGER_INIT(pipe_ctx->stream->ctx->logger); in write_i2c_retimer_setting()
395 pipe_ctx->stream->link->ddc, in write_i2c_retimer_setting()
[all …]
|
| /linux/fs/netfs/ |
| H A D | write_retry.c | 18 struct netfs_io_stream *stream) in netfs_retry_write_stream() argument
22 _enter("R=%x[%x:]", wreq->debug_id, stream->stream_nr); in netfs_retry_write_stream()
24 if (list_empty(&stream->subrequests)) in netfs_retry_write_stream()
27 if (stream->source == NETFS_UPLOAD_TO_SERVER && in netfs_retry_write_stream()
29 wreq->netfs_ops->retry_request(wreq, stream); in netfs_retry_write_stream()
31 if (unlikely(stream->failed)) in netfs_retry_write_stream()
35 if (!stream->prepare_write) { in netfs_retry_write_stream()
38 list_for_each_entry(subreq, &stream->subrequests, rreq_link) { in netfs_retry_write_stream()
47 netfs_reissue_write(stream, subreq, &source); in netfs_retry_write_stream()
53 next = stream->subrequests.next; in netfs_retry_write_stream()
[all …]
|
| /linux/sound/soc/sof/amd/ |
| H A D | acp-pcm.c | 24 struct acp_dsp_stream *stream = runtime->private_data; in acp_pcm_hw_params() local
30 stream->num_pages = PFN_UP(runtime->dma_bytes); in acp_pcm_hw_params()
31 stream->dmab = substream->runtime->dma_buffer_p; in acp_pcm_hw_params()
33 ret = acp_dsp_stream_config(sdev, stream); in acp_pcm_hw_params()
40 platform_params->phy_addr = stream->reg_offset; in acp_pcm_hw_params()
41 platform_params->stream_tag = stream->stream_tag; in acp_pcm_hw_params()
48 index = stream->stream_tag - 1; in acp_pcm_hw_params()
59 struct acp_dsp_stream *stream; in acp_pcm_open() local
61 stream = acp_dsp_stream_get(sdev, 0); in acp_pcm_open()
62 if (!stream) in acp_pcm_open()
[all …]
|