Home
last modified time | relevance | path

Searched refs:pipe (Results 1 – 20 of 20) sorted by relevance

/components/drivers/ipc/
A Dpipe.c62 rt_pipe_t *pipe; in pipe_fops_open() local
65 if (!pipe) in pipe_fops_open()
83 pipe->fifo = rt_ringbuffer_create(pipe->bufsz); in pipe_fops_open()
94 rc = rt_condvar_timedwait(&pipe->waitfor_parter, &pipe->lock, in pipe_fops_open()
124 rt_pipe_t *pipe; in pipe_fops_close() local
127 if (!pipe) in pipe_fops_close()
188 rt_pipe_t *pipe; in pipe_fops_ioctl() local
229 rt_pipe_t *pipe; in pipe_fops_read() local
288 rt_pipe_t *pipe; in pipe_fops_write() local
441 pipe->fifo = rt_ringbuffer_create(pipe->bufsz); in rt_pipe_open()
[all …]
A DSConscript9 SrcRemove(src, 'pipe.c')
A DKconfig7 int "The number of unamed pipe"
/components/drivers/audio/
A Ddev_audio_pipe.c57 struct rt_audio_pipe *pipe; in rt_audio_pipe_read() local
61 RT_ASSERT(pipe != RT_NULL); in rt_audio_pipe_read()
116 pipe->parent.rx_indicate(&pipe->parent, in _rt_audio_pipe_resume_reader()
157 struct rt_audio_pipe *pipe; in rt_audio_pipe_write() local
161 RT_ASSERT(pipe != RT_NULL); in rt_audio_pipe_write()
272 RT_ASSERT(pipe); in rt_audio_pipe_init()
282 pipe->flag = flag; in rt_audio_pipe_init()
334 if (pipe == RT_NULL) in rt_audio_pipe_create()
341 rt_free(pipe); in rt_audio_pipe_create()
357 if (pipe == RT_NULL) in rt_audio_pipe_destroy()
[all …]
A Ddev_audio_pipe.h72 rt_err_t rt_audio_pipe_init(struct rt_audio_pipe *pipe,
77 rt_err_t rt_audio_pipe_detach(struct rt_audio_pipe *pipe);
80 void rt_audio_pipe_destroy(struct rt_audio_pipe *pipe);
A DKconfig15 int "Record pipe size"
A Ddev_audio.c232 rt_device_open(RT_DEVICE(&audio->record->pipe), RT_DEVICE_OFLAG_RDONLY); in _audio_record_start()
263 rt_device_close(RT_DEVICE(&audio->record->pipe)); in _audio_record_stop()
344 rt_audio_pipe_init(&record->pipe, "record", in _audio_dev_init()
473 return rt_device_read(RT_DEVICE(&audio->record->pipe), pos, buffer, size); in _audio_dev_read()
777 rt_device_write(RT_DEVICE(&audio->record->pipe), 0, pbuf, len); in rt_audio_rx_done()
/components/drivers/usb/cherryusb/port/rp2040/
A Dusb_hc_rp2040.c72 if (pipe->urb) { in rp2040_pipe_free()
74 pipe->urb = NULL; in rp2040_pipe_free()
76 pipe->inuse = false; in rp2040_pipe_free()
104 struct rp2040_pipe *pipe; in rp2040_init_endpoint() local
145 struct rp2040_pipe *pipe; in usb_buf_ctrl_fill() local
151 urb = pipe->urb; in usb_buf_ctrl_fill()
198 urb = pipe->urb; in usb_start_transfer()
531 pipe->chidx = chidx; in usbh_submit_urb()
532 pipe->urb = urb; in usbh_submit_urb()
534 urb->hcpriv = pipe; in usbh_submit_urb()
[all …]
/components/drivers/include/drivers/
A Dusb_host.h76 rt_list_t pipe; member
218 RT_ASSERT(pipe != RT_NULL); in rt_usb_instance_add_pipe()
219 rt_list_insert_before(&inst->pipe, &pipe->list); in rt_usb_instance_add_pipe()
225 for(l = inst->pipe.next;l != &inst->pipe;l = l->next) in rt_usb_instance_find_pipe()
237 if(*pipe == RT_NULL) in rt_usb_hcd_alloc_pipe()
242 (*pipe)->inst = inst; in rt_usb_hcd_alloc_pipe()
244 return hcd->ops->open_pipe(*pipe); in rt_usb_hcd_alloc_pipe()
248 pipe->callback = callback; in rt_usb_pipe_add_callback()
253 RT_ASSERT(pipe != RT_NULL); in rt_usb_hcd_free_pipe()
254 hcd->ops->close_pipe(pipe); in rt_usb_hcd_free_pipe()
[all …]
A Dserial_bypass.h55 struct rt_ringbuffer* pipe; member
A Ddev_audio.h252 struct rt_audio_pipe pipe; member
/components/drivers/usb/cherryusb/port/musb/
A Dusb_hc_musb.c511 if (pipe->urb) { in musb_pipe_free()
513 pipe->urb = NULL; in musb_pipe_free()
516 pipe->inuse = false; in musb_pipe_free()
710 struct musb_pipe *pipe; in usbh_submit_urb() local
743 pipe->chidx = chidx; in usbh_submit_urb()
744 pipe->urb = urb; in usbh_submit_urb()
746 urb->hcpriv = pipe; in usbh_submit_urb()
796 struct musb_pipe *pipe; in usbh_kill_urb() local
839 struct musb_pipe *pipe; in musb_urb_waitup() local
842 pipe->urb = NULL; in musb_urb_waitup()
[all …]
/components/legacy/usb/usbhost/core/
A Dusbhost_core.c47 rt_list_init(&dev[i].pipe); in rt_usbh_alloc_instance()
98 upipe_t pipe; in rt_usbh_attatch_instance() local
209 if(rt_usb_hcd_alloc_pipe(device->hcd, &pipe, device, ep_desc) != RT_EOK) in rt_usbh_attatch_instance()
214 rt_usb_instance_add_pipe(device,pipe); in rt_usbh_attatch_instance()
293 while(device->pipe.next!= &device->pipe) in rt_usbh_detach_instance()
295 l = device->pipe.next; in rt_usbh_detach_instance()
565 int rt_usb_hcd_pipe_xfer(uhcd_t hcd, upipe_t pipe, void* buffer, int nbytes, int timeout) in rt_usb_hcd_pipe_xfer() argument
574 send_size = (remain_size > pipe->ep.wMaxPacketSize) ? pipe->ep.wMaxPacketSize : remain_size; in rt_usb_hcd_pipe_xfer()
575 if(hcd->ops->pipe_xfer(pipe, USBH_PID_DATA, pbuffer, send_size, timeout) == send_size) in rt_usb_hcd_pipe_xfer()
A Dhub.c468 upipe_t pipe; in rt_usbh_hub_irq() local
474 pipe = (upipe_t)context; in rt_usbh_hub_irq()
475 hub = (uhub_t)pipe->user_data; in rt_usbh_hub_irq()
477 if(pipe->status != UPIPE_STATUS_OK) in rt_usbh_hub_irq()
488 RT_ASSERT(pipe->inst->hcd != RT_NULL); in rt_usbh_hub_irq()
490 rt_usb_hcd_pipe_xfer(hub->self->hcd, pipe, hub->buffer, pipe->ep.wMaxPacketSize, timeout); in rt_usbh_hub_irq()
/components/legacy/usb/usbhost/class/
A Dhid.c244 upipe_t pipe; in rt_usbh_hid_callback() local
251 pipe = (upipe_t)context; in rt_usbh_hid_callback()
252 hid = (struct uhid*)((struct uhintf*)pipe->inst)->user_data; in rt_usbh_hid_callback()
258 RT_ASSERT(((struct uhintf*)pipe->inst)->device->hcd != RT_NULL); in rt_usbh_hid_callback()
260 rt_usb_hcd_pipe_xfer(((struct uhintf*)pipe->inst)->device->hcd, pipe, in rt_usbh_hid_callback()
261 hid->buffer, pipe->ep.wMaxPacketSize, timeout); in rt_usbh_hid_callback()
A Dmass.c34 static rt_err_t _pipe_check(struct uhintf* intf, upipe_t pipe) in _pipe_check() argument
42 if(intf == RT_NULL || pipe == RT_NULL) in _pipe_check()
55 if(pipe->status == UPIPE_STATUS_OK) return RT_EOK; in _pipe_check()
57 if(pipe->status == UPIPE_STATUS_ERROR) in _pipe_check()
62 if(pipe->status == UPIPE_STATUS_STALL) in _pipe_check()
65 ret = rt_usbh_clear_feature(device, pipe->ep.bEndpointAddress, in _pipe_check()
104 upipe_t pipe; in rt_usb_bulk_only_xfer() local
131 pipe = (cmd->dflags == CBWFLAGS_DIR_IN) ? stor->pipe_in : in rt_usb_bulk_only_xfer()
133 size = rt_usb_hcd_pipe_xfer(pipe->inst->hcd, pipe, (void*)buffer, in rt_usb_bulk_only_xfer()
/components/libc/posix/ipc/
A DKconfig4 bool "Enable pipe and FIFO"
12 int "Set pipe buffer size"
/components/drivers/serial/
A Dbypass.c45 serial->bypass->pipe = rt_ringbuffer_create(serial->config.rx_bufsz); in rt_serial_bypass_init()
47 serial->bypass->pipe = rt_ringbuffer_create(serial->config.bufsz); in rt_serial_bypass_init()
125 rt_ringbuffer_putchar(serial->bypass->pipe, ch); in rt_bypass_putchar()
133 flags = rt_ringbuffer_getchar(serial->bypass->pipe, ch); in rt_bypass_getchar()
/components/libc/compilers/common/include/sys/
A Dunistd.h47 int pipe(int fildes[2]);
/components/lwp/
A Dlwp_syscall.c7967 ret = pipe(kfd); in sys_pipe()

Completed in 61 milliseconds