Home
last modified time | relevance | path

Searched refs:fifo (Results 1 - 25 of 51) sorted by relevance

123

/third_party/mesa3d/src/util/
H A Du_fifo.h42 struct util_fifo *fifo; in u_fifo_create() local
43 fifo = MALLOC(sizeof(*fifo) + size * sizeof(void*)); in u_fifo_create()
45 fifo->head = 0; in u_fifo_create()
46 fifo->tail = 0; in u_fifo_create()
47 fifo->num = 0; in u_fifo_create()
48 fifo->size = size; in u_fifo_create()
50 return fifo; in u_fifo_create()
54 u_fifo_add(struct util_fifo *fifo, void *ptr) in u_fifo_add() argument
56 void **array = (void**)&fifo[ in u_fifo_add()
71 u_fifo_pop(struct util_fifo *fifo, void **ptr) u_fifo_pop() argument
89 u_fifo_destroy(struct util_fifo *fifo) u_fifo_destroy() argument
[all...]
/third_party/ffmpeg/libavformat/
H A Dfifo.c126 FifoContext *fifo = avf->priv_data; in fifo_thread_write_header() local
127 AVFormatContext *avf2 = fifo->avf; in fifo_thread_write_header()
131 ret = av_dict_copy(&format_options, fifo->format_options, 0); in fifo_thread_write_header()
165 FifoContext *fifo = avf->priv_data; in fifo_thread_flush_output() local
166 AVFormatContext *avf2 = fifo->avf; in fifo_thread_flush_output()
183 FifoContext *fifo = avf->priv_data; in fifo_thread_write_packet() local
184 AVFormatContext *avf2 = fifo->avf; in fifo_thread_write_packet()
189 if (fifo->timeshift && pkt->dts != AV_NOPTS_VALUE) in fifo_thread_write_packet()
190 atomic_fetch_sub_explicit(&fifo->queue_duration, next_duration(avf, pkt, &ctx->last_received_dts), memory_order_relaxed); in fifo_thread_write_packet()
226 FifoContext *fifo in fifo_thread_write_trailer() local
266 is_recoverable(const FifoContext *fifo, int err_no) is_recoverable() argument
297 FifoContext *fifo = avf->priv_data; fifo_thread_process_recovery_failure() local
328 FifoContext *fifo = avf->priv_data; fifo_thread_attempt_recovery() local
399 FifoContext *fifo = avf->priv_data; fifo_thread_recover() local
425 FifoContext *fifo = avf->priv_data; fifo_consumer_thread() local
486 FifoContext *fifo = avf->priv_data; fifo_mux_init() local
522 FifoContext *fifo = avf->priv_data; fifo_init() local
561 FifoContext * fifo = avf->priv_data; fifo_write_header() local
576 FifoContext *fifo = avf->priv_data; fifo_write_packet() local
620 FifoContext *fifo= avf->priv_data; fifo_write_trailer() local
659 FifoContext *fifo = avf->priv_data; fifo_deinit() local
[all...]
H A Dudp.c34 #include "libavutil/fifo.h"
101 AVFifo *fifo; member
521 if (av_fifo_can_write(s->fifo) < len + 4) { in circular_buffer_task_rx()
535 av_fifo_write(s->fifo, s->tmp, len + 4); in circular_buffer_task_rx()
569 len = av_fifo_can_read(s->fifo); in circular_buffer_task_tx()
575 len = av_fifo_can_read(s->fifo); in circular_buffer_task_tx()
578 av_fifo_read(s->fifo, tmp, 4); in circular_buffer_task_tx()
584 av_fifo_read(s->fifo, s->tmp, len); in circular_buffer_task_tx()
932 s->fifo = av_fifo_alloc2(s->circular_buffer_size, 1, 0); in udp_open()
933 if (!s->fifo) { in udp_open()
[all...]
H A Dasync.c33 #include "libavutil/fifo.h"
50 AVFifo *fifo; member
86 ring->fifo = av_fifo_alloc2(capacity + read_back_capacity, 1, 0); in ring_init()
87 if (!ring->fifo) in ring_init()
96 av_fifo_freep2(&ring->fifo); in ring_destroy()
101 av_fifo_reset2(ring->fifo); in ring_reset()
107 return av_fifo_can_read(ring->fifo) - ring->read_pos; in ring_size()
112 return av_fifo_can_write(ring->fifo); in ring_space()
121 ret = av_fifo_peek(ring->fifo, dest, buf_size, ring->read_pos); in ring_read()
125 av_fifo_drain2(ring->fifo, rin in ring_read()
[all...]
/third_party/ffmpeg/libavutil/tests/
H A Dfifo.c22 #include "libavutil/fifo.h"
72 AVFifo *fifo = av_fifo_alloc2(13, sizeof(int), 0); in main() local
76 for (i = 0; av_fifo_can_write(fifo); i++) in main()
77 av_fifo_write(fifo, &i, 1); in main()
80 n = av_fifo_can_read(fifo); in main()
82 av_fifo_peek(fifo, &j, 1, i); in main()
89 n = av_fifo_can_read(fifo); in main()
90 p = malloc(n * av_fifo_elem_size(fifo)); in main()
96 (void) av_fifo_peek(fifo, p, n, 0); in main()
105 for (i = 0; av_fifo_can_read(fifo); in main()
[all...]
/third_party/ffmpeg/tests/fate/
H A Dfifo-muxer.mak1 fate-fifo-muxer-h264: CMD = ffmpeg -i $(TARGET_SAMPLES)/mkv/1242-small.mkv -frames:v 11\
3 -fflags +bitexact -f fifo -fifo_format framecrc -
4 fate-fifo-muxer-h264: REF = $(SRC_PATH)/tests/ref/fate/mkv-1242
5 FATE_SAMPLES_FIFO_MUXER-$(call ALLYES, FIFO_MUXER, MATROSKA_DEMUXER, H264_DECODER) += fate-fifo-muxer-h264
7 fate-fifo-muxer-wav: CMD = ffmpeg -i $(TARGET_SAMPLES)/audio-reference/chorusnoise_2ch_44kHz_s16.wav\
9 -fflags +bitexact -f fifo -fifo_format wav md5:
10 fate-fifo-muxer-wav: CMP = oneline
11 fate-fifo-muxer-wav: REF = 4dda5dcc7ecdc2218b0739a152ada802
12 FATE_SAMPLES_FIFO_MUXER-$(call ALLYES, FIFO_MUXER, WAV_DEMUXER) += fate-fifo-muxer-wav
14 fate-fifo
[all...]
/third_party/libwebsockets/plugins/
H A Dprotocol_lws_raw_test.c31 * "fifo-path": "/tmp/lws-test-raw"
88 int fifo; member
126 if (!strcmp(pvo->name, "fifo-path")) in callback_raw_test()
132 lwsl_warn("%s: Missing pvo \"fifo-path\", " in callback_raw_test()
143 vhd->fifo = lws_open(vhd->fifo_path, O_NONBLOCK | O_RDONLY); in callback_raw_test()
144 if (vhd->fifo == -1) { in callback_raw_test()
145 lwsl_err("opening fifo failed\n"); in callback_raw_test()
150 u.filefd = vhd->fifo; in callback_raw_test()
155 lwsl_err("Failed to adopt fifo descriptor\n"); in callback_raw_test()
156 close(vhd->fifo); in callback_raw_test()
[all...]
/third_party/ltp/testcases/kernel/syscalls/read/
H A Dread03.c10 * a pipe (fifo, opened in O_NONBLOCK mode) without writing to it.
17 static char fifo[100]; variable
32 sprintf(fifo, "fifo.%d", getpid()); in setup()
34 SAFE_MKNOD(fifo, S_IFIFO | 0777, 0); in setup()
35 SAFE_STAT(fifo, &buf); in setup()
38 tst_brk(TBROK, "Mode does not indicate fifo file"); in setup()
40 rfd = SAFE_OPEN(fifo, O_RDONLY | O_NONBLOCK); in setup()
41 wfd = SAFE_OPEN(fifo, O_WRONLY | O_NONBLOCK); in setup()
48 SAFE_UNLINK(fifo); in cleanup()
[all...]
/third_party/ltp/testcases/kernel/syscalls/write/
H A Dwrite04.c10 * Verify that write(2) fails with errno EAGAIN when attempt to write to fifo
23 static char fifo[100]; variable
40 sprintf(fifo, "%s.%d", fifo, getpid()); in setup()
42 SAFE_MKNOD(fifo, S_IFIFO | 0777, 0); in setup()
44 rfd = SAFE_OPEN(fifo, O_RDONLY | O_NONBLOCK); in setup()
45 wfd = SAFE_OPEN(fifo, O_WRONLY | O_NONBLOCK); in setup()
/third_party/ffmpeg/doc/examples/
H A Dtranscode_aac.c326 * @param[out] fifo Sample buffer
330 static int init_fifo(AVAudioFifo **fifo, AVCodecContext *output_codec_context) in init_fifo() argument
333 if (!(*fifo = av_audio_fifo_alloc(output_codec_context->sample_fmt, in init_fifo()
508 * @param fifo Buffer to add the samples to
514 static int add_samples_to_fifo(AVAudioFifo *fifo, in add_samples_to_fifo() argument
522 if ((error = av_audio_fifo_realloc(fifo, av_audio_fifo_size(fifo) + frame_size)) < 0) { in add_samples_to_fifo()
528 if (av_audio_fifo_write(fifo, (void **)converted_input_samples, in add_samples_to_fifo()
539 * @param fifo Buffer used for temporary storage
552 static int read_decode_convert_and_store(AVAudioFifo *fifo, in read_decode_convert_and_store() argument
737 load_encode_and_write(AVAudioFifo *fifo, AVFormatContext *output_format_context, AVCodecContext *output_codec_context) load_encode_and_write() argument
793 AVAudioFifo *fifo = NULL; main() local
[all...]
/third_party/ffmpeg/libavutil/
H A Dthreadmessage.c22 #include "fifo.h"
29 AVFifo *fifo; member
69 if (!(rmq->fifo = av_fifo_alloc2(nelem, elsize, 0))) { in av_thread_message_queue_alloc()
98 av_fifo_freep2(&(*mq)->fifo); in av_thread_message_queue_free()
112 ret = av_fifo_can_read(mq->fifo); in av_thread_message_queue_nb_elems()
126 while (!mq->err_send && !av_fifo_can_write(mq->fifo)) { in av_thread_message_queue_send_locked()
133 av_fifo_write(mq->fifo, msg, 1); in av_thread_message_queue_send_locked()
143 while (!mq->err_recv && !av_fifo_can_read(mq->fifo)) { in av_thread_message_queue_recv_locked()
148 if (!av_fifo_can_read(mq->fifo)) in av_thread_message_queue_recv_locked()
150 av_fifo_read(mq->fifo, ms in av_thread_message_queue_recv_locked()
[all...]
/third_party/ffmpeg/libavfilter/
H A Daf_axcorrelate.c39 AVAudioFifo *fifo[2]; member
215 ret = av_audio_fifo_write(s->fifo[i], (void **)frame->extended_data, in activate()
223 available = FFMIN(av_audio_fifo_size(s->fifo[0]), av_audio_fifo_size(s->fifo[1])); in activate()
242 ret = av_audio_fifo_peek(s->fifo[0], (void **)s->cache[0]->extended_data, available); in activate()
246 ret = av_audio_fifo_peek(s->fifo[1], (void **)s->cache[1]->extended_data, available); in activate()
259 av_audio_fifo_drain(s->fifo[0], out_samples); in activate()
260 av_audio_fifo_drain(s->fifo[1], out_samples); in activate()
271 (av_audio_fifo_size(s->fifo[0]) <= 0 || in activate()
272 av_audio_fifo_size(s->fifo[ in activate()
[all...]
H A Daf_agate.c62 AVAudioFifo *fifo[2]; member
263 av_audio_fifo_write(s->fifo[0], (void **)in[0]->extended_data, in activate()
270 av_audio_fifo_write(s->fifo[1], (void **)in[1]->extended_data, in activate()
277 nb_samples = FFMIN(av_audio_fifo_size(s->fifo[0]), av_audio_fifo_size(s->fifo[1])); in activate()
290 av_audio_fifo_read(s->fifo[i], (void **)in[i]->data, nb_samples); in activate()
312 if (!av_audio_fifo_size(s->fifo[0])) in activate()
314 if (!av_audio_fifo_size(s->fifo[1])) in activate()
349 s->fifo[0] = av_audio_fifo_alloc(ctx->inputs[0]->format, ctx->inputs[0]->ch_layout.nb_channels, 1024); in scconfig_output()
350 s->fifo[ in scconfig_output()
[all...]
H A Daf_sidechaincompress.c67 AVAudioFifo *fifo[2]; member
244 av_audio_fifo_write(s->fifo[0], (void **)in[0]->extended_data, in activate()
251 av_audio_fifo_write(s->fifo[1], (void **)in[1]->extended_data, in activate()
258 nb_samples = FFMIN(av_audio_fifo_size(s->fifo[0]), av_audio_fifo_size(s->fifo[1])); in activate()
271 av_audio_fifo_read(s->fifo[i], (void **)in[i]->data, nb_samples); in activate()
293 if (!av_audio_fifo_size(s->fifo[0])) in activate()
295 if (!av_audio_fifo_size(s->fifo[1])) in activate()
330 s->fifo[0] = av_audio_fifo_alloc(ctx->inputs[0]->format, ctx->inputs[0]->ch_layout.nb_channels, 1024); in config_output()
331 s->fifo[ in config_output()
[all...]
H A Davf_showspatial.c52 AVAudioFifo *fifo; member
82 av_audio_fifo_free(s->fifo); in uninit()
192 av_audio_fifo_free(s->fifo); in config_output()
193 s->fifo = av_audio_fifo_alloc(inlink->format, inlink->ch_layout.nb_channels, s->win_size); in config_output()
194 if (!s->fifo) in config_output()
269 if (av_audio_fifo_size(s->fifo) < s->win_size) { in spatial_activate()
279 av_audio_fifo_write(s->fifo, (void **)frame->extended_data, frame->nb_samples); in spatial_activate()
284 if (av_audio_fifo_size(s->fifo) >= s->win_size) { in spatial_activate()
291 ret = av_audio_fifo_peek(s->fifo, (void **)fin->extended_data, in spatial_activate()
292 FFMIN(s->win_size, av_audio_fifo_size(s->fifo))); in spatial_activate()
[all...]
H A Dvf_feedback.c24 #include "libavutil/fifo.h"
44 AVFifo *fifo; member
133 if (s->feed && av_fifo_can_read(s->fifo)) { in activate()
137 av_fifo_read(s->fifo, &dst, 1); in activate()
197 ret = av_fifo_write(s->fifo, &in, 1); in activate()
256 s->fifo = av_fifo_alloc2(8, sizeof(AVFrame *), AV_FIFO_FLAG_AUTO_GROW); in init()
257 if (!s->fifo) in init()
266 if (s->fifo) { in uninit()
267 size_t size = av_fifo_can_read(s->fifo); in uninit()
272 av_fifo_read(s->fifo, in uninit()
[all...]
H A Davfilter.c174 ff_framequeue_init(&link->fifo, &src->graph->internal->frame_queues); in avfilter_link()
184 ff_framequeue_free(&(*link)->fifo); in avfilter_link_free()
408 if (ff_framequeue_queued_frames(&link->fifo)) { in ff_request_frame()
1034 ret = ff_framequeue_add(&link->fifo, frame); in ff_filter_frame()
1049 return ff_framequeue_queued_frames(&link->fifo) && in samples_ready()
1050 (ff_framequeue_queued_samples(&link->fifo) >= min || in samples_ready()
1064 frame0 = frame = ff_framequeue_peek(&link->fifo, 0); in take_samples()
1065 if (!link->fifo.samples_skipped && frame->nb_samples >= min && frame->nb_samples <= max) { in take_samples()
1066 *rframe = ff_framequeue_take(&link->fifo); in take_samples()
1079 if (nb_frames == ff_framequeue_queued_frames(&link->fifo)) in take_samples()
[all...]
/third_party/ltp/testcases/kernel/controllers/cpuset/cpuset_load_balance_test/
H A Dcpuset_load_balance_test.sh62 local fifo=
89 read fifo < ./myfifo
90 if [ $fifo -ne 0 ]; then
117 read fifo < ./myfifo
118 if [ $fifo -ne 0 ]; then
215 read fifo < ./myfifo
216 if [ $fifo -ne 0 ]; then
244 read fifo < ./myfifo
245 if [ $fifo -ne 0 ]; then
/third_party/mesa3d/src/freedreno/afuc/
H A Demu.h71 uint32_t fifo[0x100]; member
77 if (q->count >= ARRAY_SIZE(q->fifo)) in emu_queue_push()
82 q->head %= ARRAY_SIZE(q->fifo); in emu_queue_push()
84 q->fifo[q->head] = val; in emu_queue_push()
97 q->tail %= ARRAY_SIZE(q->fifo); in emu_queue_pop()
99 *val = q->fifo[q->tail]; in emu_queue_pop()
/third_party/mesa3d/src/gallium/drivers/nouveau/nv30/
H A Dnv30_transfer.c406 struct nv04_fifo *fifo = push->channel->data; in nv30_transfer_rect_sifm() local
440 PUSH_RELOC(push, dst->bo, 0, NOUVEAU_BO_OR, fifo->vram, fifo->gart); in nv30_transfer_rect_sifm()
441 PUSH_RELOC(push, dst->bo, 0, NOUVEAU_BO_OR, fifo->vram, fifo->gart); in nv30_transfer_rect_sifm()
451 PUSH_RELOC(push, dst->bo, 0, NOUVEAU_BO_OR, fifo->vram, fifo->gart); in nv30_transfer_rect_sifm()
461 PUSH_RELOC(push, src->bo, 0, NOUVEAU_BO_OR, fifo->vram, fifo->gart); in nv30_transfer_rect_sifm()
503 struct nv04_fifo *fifo in nv30_transfer_rect_m2mf() local
692 struct nv04_fifo *fifo = nv->screen->channel->data; nv30_transfer_copy_data() local
[all...]
H A Dnv30_screen.c588 struct nv04_fifo *fifo; in nv30_screen_create() local
676 fifo = screen->base.channel->data; in nv30_screen_create()
733 ret = nouveau_bo_wrap(screen->base.device, fifo->notify, &screen->notify); in nv30_screen_create()
748 PUSH_DATA (push, fifo->vram); /* TEXTURE0 */ in nv30_screen_create()
749 PUSH_DATA (push, fifo->gart); /* TEXTURE1 */ in nv30_screen_create()
750 PUSH_DATA (push, fifo->vram); /* COLOR1 */ in nv30_screen_create()
752 PUSH_DATA (push, fifo->vram); /* COLOR0 */ in nv30_screen_create()
753 PUSH_DATA (push, fifo->vram); /* ZETA */ in nv30_screen_create()
754 PUSH_DATA (push, fifo->vram); /* VTXBUF0 */ in nv30_screen_create()
755 PUSH_DATA (push, fifo in nv30_screen_create()
[all...]
/third_party/FreeBSD/sys/dev/usb/input/
H A Duhid.c389 uhid_start_read(struct usb_fifo *fifo) in uhid_start_read() argument
391 struct uhid_softc *sc = usb_fifo_softc(fifo); in uhid_start_read()
401 uhid_stop_read(struct usb_fifo *fifo) in uhid_stop_read() argument
403 struct uhid_softc *sc = usb_fifo_softc(fifo); in uhid_stop_read()
410 uhid_start_write(struct usb_fifo *fifo) in uhid_start_write() argument
412 struct uhid_softc *sc = usb_fifo_softc(fifo); in uhid_start_write()
423 uhid_stop_write(struct usb_fifo *fifo) in uhid_stop_write() argument
425 struct uhid_softc *sc = usb_fifo_softc(fifo); in uhid_stop_write()
511 uhid_open(struct usb_fifo *fifo, int fflags) in uhid_open() argument
513 struct uhid_softc *sc = usb_fifo_softc(fifo); in uhid_open()
541 uhid_close(struct usb_fifo *fifo, int fflags) uhid_close() argument
549 uhid_ioctl(struct usb_fifo *fifo, u_long cmd, void *addr, int fflags) uhid_ioctl() argument
684 uhid_ioctl_post(struct usb_fifo *fifo, u_long cmd, void *addr, int fflags) uhid_ioctl_post() argument
[all...]
/third_party/FreeBSD/sys/dev/usb/
H A Dusbdi.h97 typedef int (usb_fifo_open_t)(struct usb_fifo *fifo, int fflags);
98 typedef void (usb_fifo_close_t)(struct usb_fifo *fifo, int fflags);
99 typedef int (usb_fifo_ioctl_t)(struct usb_fifo *fifo, u_long cmd, void *addr, int fflags);
100 typedef void (usb_fifo_cmd_t)(struct usb_fifo *fifo);
101 typedef void (usb_fifo_filter_t)(struct usb_fifo *fifo, struct usb_mbuf *m);
643 uint32_t usb_fifo_put_bytes_max(struct usb_fifo *fifo);
644 void usb_fifo_put_data(struct usb_fifo *fifo, struct usb_page_cache *pc,
646 void usb_fifo_put_data_linear(struct usb_fifo *fifo, void *ptr,
649 void usb_fifo_put_data_error(struct usb_fifo *fifo);
650 uint8_t usb_fifo_get_data(struct usb_fifo *fifo, struc
[all...]
H A Dusb_dev.h144 int usb_fifo_wait(struct usb_fifo *fifo);
145 void usb_fifo_signal(struct usb_fifo *fifo);
146 uint8_t usb_fifo_opened(struct usb_fifo *fifo);
/third_party/curl/docs/examples/
H A Dephiperfifo.c38 When running, the program creates the named pipe "hiper.fifo"
40 Whenever there is input into the fifo, the program reads the input as a list
46 % echo http://www.yahoo.com > hiper.fifo
49 % cat my-url-list > hiper.fifo
51 The fifo buffer is handled almost instantly, so you can even add more URL's
86 int fifofd; /* fifo filedescriptor */
393 /* This gets called whenever data is received from the fifo */
413 static const char *fifo = "hiper.fifo"; variable
420 fprintf(MSG_OUT, "Creating named pipe \"%s\"\n", fifo); in init_fifo()
[all...]

Completed in 17 milliseconds

123