HelenOS sources
pipe 174 uspace/drv/block/usbmast/main.c epm_in->pipe.desc.endpoint_no, epm_in->pipe.desc.max_transfer_size);
pipe 176 uspace/drv/block/usbmast/main.c epm_out->pipe.desc.endpoint_no, epm_out->pipe.desc.max_transfer_size);
pipe 186 uspace/drv/block/usbmast/main.c mdev->bulk_in_pipe = &epm_in->pipe;
pipe 187 uspace/drv/block/usbmast/main.c mdev->bulk_out_pipe = &epm_out->pipe;
pipe 75 uspace/drv/bus/usb/usbdiag/device.c target = &epm->pipe;\
pipe 48 uspace/drv/bus/usb/usbdiag/tests.c static errno_t test_in(usb_pipe_t *pipe, const usbdiag_test_params_t *params, usbdiag_test_results_t *results)
pipe 50 uspace/drv/bus/usb/usbdiag/tests.c if (!pipe)
pipe 56 uspace/drv/bus/usb/usbdiag/tests.c size = pipe->desc.max_transfer_size;
pipe 63 uspace/drv/bus/usb/usbdiag/tests.c char *buffer = usb_pipe_alloc_buffer(pipe, size);
pipe 69 uspace/drv/bus/usb/usbdiag/tests.c usb_log_info("Performing %s IN test with duration %ld ms.", usb_str_transfer_type(pipe->desc.transfer_type), params->min_duration);
pipe 89 uspace/drv/bus/usb/usbdiag/tests.c if ((rc = usb_pipe_read_dma(pipe, buffer, buffer + size - remaining, remaining, &transferred))) {
pipe 90 uspace/drv/bus/usb/usbdiag/tests.c usb_log_error("Read of %s IN endpoint failed with error: %s", usb_str_transfer_type(pipe->desc.transfer_type), str_error(rc));
pipe 95 uspace/drv/bus/usb/usbdiag/tests.c usb_log_error("Read of %s IN endpoint returned more data than expected.", usb_str_transfer_type(pipe->desc.transfer_type));
pipe 114 uspace/drv/bus/usb/usbdiag/tests.c usb_str_transfer_type(pipe->desc.transfer_type), i * sizeof(test_data), beef_buffer[i], test_data);
pipe 129 uspace/drv/bus/usb/usbdiag/tests.c usb_log_info("Test on %s IN endpoint completed in %lu ms.", usb_str_transfer_type(pipe->desc.transfer_type), in_duration);
pipe 135 uspace/drv/bus/usb/usbdiag/tests.c usb_pipe_free_buffer(pipe, buffer);
pipe 140 uspace/drv/bus/usb/usbdiag/tests.c static errno_t test_out(usb_pipe_t *pipe, const usbdiag_test_params_t *params, usbdiag_test_results_t *results)
pipe 142 uspace/drv/bus/usb/usbdiag/tests.c if (!pipe)
pipe 148 uspace/drv/bus/usb/usbdiag/tests.c size = pipe->desc.max_transfer_size;
pipe 155 uspace/drv/bus/usb/usbdiag/tests.c char *buffer = usb_pipe_alloc_buffer(pipe, size);
pipe 167 uspace/drv/bus/usb/usbdiag/tests.c usb_log_info("Performing %s OUT test.", usb_str_transfer_type(pipe->desc.transfer_type));
pipe 183 uspace/drv/bus/usb/usbdiag/tests.c if ((rc = usb_pipe_write_dma(pipe, buffer, buffer, size))) {
pipe 184 uspace/drv/bus/usb/usbdiag/tests.c usb_log_error("Write to %s OUT endpoint failed with error: %s", usb_str_transfer_type(pipe->desc.transfer_type), str_error(rc));
pipe 194 uspace/drv/bus/usb/usbdiag/tests.c usb_log_info("Test on %s OUT endpoint completed in %ld ms.", usb_str_transfer_type(pipe->desc.transfer_type), in_duration);
pipe 200 uspace/drv/bus/usb/usbdiag/tests.c usb_pipe_free_buffer(pipe, buffer);
pipe 211 uspace/drv/bus/usb/usbdiag/tests.c usb_pipe_t *pipe;
pipe 215 uspace/drv/bus/usb/usbdiag/tests.c pipe = params->validate_data ? dev->data_intr_in : dev->burst_intr_in;
pipe 218 uspace/drv/bus/usb/usbdiag/tests.c pipe = params->validate_data ? dev->data_bulk_in : dev->burst_bulk_in;
pipe 221 uspace/drv/bus/usb/usbdiag/tests.c pipe = params->validate_data ? dev->data_isoch_in : dev->burst_isoch_in;
pipe 227 uspace/drv/bus/usb/usbdiag/tests.c return test_in(pipe, params, results);
pipe 236 uspace/drv/bus/usb/usbdiag/tests.c usb_pipe_t *pipe;
pipe 240 uspace/drv/bus/usb/usbdiag/tests.c pipe = params->validate_data ? dev->data_intr_out : dev->burst_intr_out;
pipe 243 uspace/drv/bus/usb/usbdiag/tests.c pipe = params->validate_data ? dev->data_bulk_out : dev->burst_bulk_out;
pipe 246 uspace/drv/bus/usb/usbdiag/tests.c pipe = params->validate_data ? dev->data_isoch_out : dev->burst_isoch_out;
pipe 252 uspace/drv/bus/usb/usbdiag/tests.c return test_out(pipe, params, results);
pipe 531 uspace/drv/hid/usbhid/usbhid.c polling->request_size = hid_dev->poll_pipe_mapping->pipe.desc.max_transfer_size;
pipe 82 uspace/drv/nic/ar9271/ath_usb.c target = &epm->pipe;\
pipe 154 uspace/lib/pcut/src/os/unix.c rc = pipe(link_stdout);
pipe 161 uspace/lib/pcut/src/os/unix.c rc = pipe(link_stderr);
pipe 168 uspace/lib/posix/include/posix/unistd.h extern int pipe(int fildes[2]);
pipe 84 uspace/lib/usbdev/include/usb/dev/pipes.h usb_pipe_t pipe;
pipe 271 uspace/lib/usbdev/src/devdrv.c rc = usb_pipe_register(&pipes[i].pipe, pipes[i].descriptor, pipes[i].companion_descriptor);
pipe 293 uspace/lib/usbdev/src/devdrv.c usb_pipe_unregister(&pipes[i].pipe);
pipe 351 uspace/lib/usbdev/src/devdrv.c const int rc = usb_pipe_unregister(&epm->pipe);
pipe 111 uspace/lib/usbdev/src/devpoll.c usb_pipe_t *pipe = &polling->ep_mapping->pipe;
pipe 123 uspace/lib/usbdev/src/devpoll.c polling->request_size, pipe->desc.max_transfer_size);
pipe 129 uspace/lib/usbdev/src/devpoll.c const errno_t rc = usb_pipe_read(pipe, polling->buffer,
pipe 154 uspace/lib/usbdev/src/devpoll.c usb_device_get_default_pipe(polling->device), pipe);
pipe 239 uspace/lib/usbdev/src/devpoll.c if (!polling->ep_mapping || (polling->ep_mapping->pipe.desc.transfer_type != USB_TRANSFER_INTERRUPT) ||
pipe 240 uspace/lib/usbdev/src/devpoll.c (polling->ep_mapping->pipe.desc.direction != USB_DIRECTION_IN))
pipe 52 uspace/lib/usbdev/src/pipes.c static void clear_self_endpoint_halt(usb_pipe_t *pipe)
pipe 54 uspace/lib/usbdev/src/pipes.c assert(pipe != NULL);
pipe 56 uspace/lib/usbdev/src/pipes.c if (!pipe->auto_reset_halt || (pipe->desc.endpoint_no != 0)) {
pipe 61 uspace/lib/usbdev/src/pipes.c pipe->auto_reset_halt = false;
pipe 62 uspace/lib/usbdev/src/pipes.c usb_pipe_clear_halt(pipe, pipe);
pipe 63 uspace/lib/usbdev/src/pipes.c pipe->auto_reset_halt = true;
pipe 68 uspace/lib/usbdev/src/pipes.c usb_pipe_t *pipe;
pipe 82 uspace/lib/usbdev/src/pipes.c if (!t->pipe)
pipe 94 uspace/lib/usbdev/src/pipes.c if (t->pipe->desc.direction != USB_DIRECTION_BOTH &&
pipe 95 uspace/lib/usbdev/src/pipes.c t->pipe->desc.direction != t->dir)
pipe 99 uspace/lib/usbdev/src/pipes.c if ((t->pipe->desc.transfer_type == USB_TRANSFER_CONTROL) != t->is_control)
pipe 102 uspace/lib/usbdev/src/pipes.c async_exch_t *exch = async_exchange_begin(t->pipe->bus_session);
pipe 107 uspace/lib/usbdev/src/pipes.c t->req.endpoint = t->pipe->desc.endpoint_no;
pipe 114 uspace/lib/usbdev/src/pipes.c clear_self_endpoint_halt(t->pipe);
pipe 128 uspace/lib/usbdev/src/pipes.c t->req.buffer.policy = t->pipe->desc.transfer_buffer_policy;
pipe 143 uspace/lib/usbdev/src/pipes.c void *dma_buf = usb_pipe_alloc_buffer(t->pipe, size);
pipe 154 uspace/lib/usbdev/src/pipes.c usb_pipe_free_buffer(t->pipe, dma_buf);
pipe 180 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_control_read(usb_pipe_t *pipe,
pipe 186 uspace/lib/usbdev/src/pipes.c .pipe = pipe,
pipe 214 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_control_write(usb_pipe_t *pipe,
pipe 218 uspace/lib/usbdev/src/pipes.c assert(pipe);
pipe 221 uspace/lib/usbdev/src/pipes.c .pipe = pipe,
pipe 239 uspace/lib/usbdev/src/pipes.c void *usb_pipe_alloc_buffer(usb_pipe_t *pipe, size_t size)
pipe 242 uspace/lib/usbdev/src/pipes.c if (dma_buffer_alloc_policy(&buf, size, pipe->desc.transfer_buffer_policy))
pipe 248 uspace/lib/usbdev/src/pipes.c void usb_pipe_free_buffer(usb_pipe_t *pipe, void *buffer)
pipe 263 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_read(usb_pipe_t *pipe,
pipe 266 uspace/lib/usbdev/src/pipes.c assert(pipe);
pipe 269 uspace/lib/usbdev/src/pipes.c .pipe = pipe,
pipe 289 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_write(usb_pipe_t *pipe, const void *buffer, size_t size)
pipe 291 uspace/lib/usbdev/src/pipes.c assert(pipe);
pipe 293 uspace/lib/usbdev/src/pipes.c .pipe = pipe,
pipe 310 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_read_dma(usb_pipe_t *pipe, void *base, void *ptr, size_t size,
pipe 313 uspace/lib/usbdev/src/pipes.c assert(pipe);
pipe 316 uspace/lib/usbdev/src/pipes.c .pipe = pipe,
pipe 340 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_write_dma(usb_pipe_t *pipe, void *base, void *ptr, size_t size)
pipe 342 uspace/lib/usbdev/src/pipes.c assert(pipe);
pipe 344 uspace/lib/usbdev/src/pipes.c .pipe = pipe,
pipe 359 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_initialize(usb_pipe_t *pipe, usb_dev_session_t *bus_session)
pipe 361 uspace/lib/usbdev/src/pipes.c assert(pipe);
pipe 363 uspace/lib/usbdev/src/pipes.c pipe->auto_reset_halt = false;
pipe 364 uspace/lib/usbdev/src/pipes.c pipe->bus_session = bus_session;
pipe 386 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_initialize_default_control(usb_pipe_t *pipe,
pipe 389 uspace/lib/usbdev/src/pipes.c const errno_t ret = usb_pipe_initialize(pipe, bus_session);
pipe 393 uspace/lib/usbdev/src/pipes.c pipe->desc = default_control_pipe;
pipe 394 uspace/lib/usbdev/src/pipes.c pipe->auto_reset_halt = true;
pipe 406 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_register(usb_pipe_t *pipe,
pipe 410 uspace/lib/usbdev/src/pipes.c assert(pipe);
pipe 411 uspace/lib/usbdev/src/pipes.c assert(pipe->bus_session);
pipe 414 uspace/lib/usbdev/src/pipes.c async_exch_t *exch = async_exchange_begin(pipe->bus_session);
pipe 436 uspace/lib/usbdev/src/pipes.c &pipe->desc, &descriptors);
pipe 446 uspace/lib/usbdev/src/pipes.c errno_t usb_pipe_unregister(usb_pipe_t *pipe)
pipe 448 uspace/lib/usbdev/src/pipes.c assert(pipe);
pipe 449 uspace/lib/usbdev/src/pipes.c assert(pipe->bus_session);
pipe 450 uspace/lib/usbdev/src/pipes.c async_exch_t *exch = async_exchange_begin(pipe->bus_session);
pipe 454 uspace/lib/usbdev/src/pipes.c const errno_t ret = usbhc_unregister_endpoint(exch, &pipe->desc);
pipe 205 uspace/lib/usbdev/src/pipesinit.c errno_t err = usb_pipe_initialize(&ep_mapping->pipe, bus_session);
pipe 71 uspace/lib/usbdev/src/request.c errno_t usb_control_request_set(usb_pipe_t *pipe,
pipe 76 uspace/lib/usbdev/src/request.c if (pipe == NULL) {
pipe 101 uspace/lib/usbdev/src/request.c return usb_pipe_control_write(pipe,
pipe 130 uspace/lib/usbdev/src/request.c errno_t usb_control_request_get(usb_pipe_t *pipe,
pipe 135 uspace/lib/usbdev/src/request.c if (pipe == NULL) {
pipe 161 uspace/lib/usbdev/src/request.c return usb_pipe_control_read(pipe, &setup_packet, sizeof(setup_packet),
pipe 173 uspace/lib/usbdev/src/request.c errno_t usb_request_get_status(usb_pipe_t *pipe,
pipe 187 uspace/lib/usbdev/src/request.c errno_t rc = usb_control_request_get(pipe, USB_REQUEST_TYPE_STANDARD,
pipe 211 uspace/lib/usbdev/src/request.c errno_t usb_request_clear_feature(usb_pipe_t *pipe,
pipe 221 uspace/lib/usbdev/src/request.c return usb_control_request_set(pipe,
pipe 235 uspace/lib/usbdev/src/request.c errno_t usb_request_set_feature(usb_pipe_t *pipe,
pipe 245 uspace/lib/usbdev/src/request.c return usb_control_request_set(pipe,
pipe 263 uspace/lib/usbdev/src/request.c errno_t usb_request_get_descriptor(usb_pipe_t *pipe,
pipe 282 uspace/lib/usbdev/src/request.c return usb_control_request_get(pipe,
pipe 301 uspace/lib/usbdev/src/request.c errno_t usb_request_get_descriptor_alloc(usb_pipe_t *pipe,
pipe 318 uspace/lib/usbdev/src/request.c rc = usb_request_get_descriptor(pipe, request_type, recipient,
pipe 341 uspace/lib/usbdev/src/request.c rc = usb_request_get_descriptor(pipe, request_type, recipient,
pipe 367 uspace/lib/usbdev/src/request.c errno_t usb_request_get_device_descriptor(usb_pipe_t *pipe,
pipe 376 uspace/lib/usbdev/src/request.c errno_t rc = usb_request_get_descriptor(pipe,
pipe 407 uspace/lib/usbdev/src/request.c errno_t usb_request_get_bare_configuration_descriptor(usb_pipe_t *pipe,
pipe 420 uspace/lib/usbdev/src/request.c const errno_t rc = usb_request_get_descriptor(pipe,
pipe 451 uspace/lib/usbdev/src/request.c errno_t usb_request_get_full_configuration_descriptor(usb_pipe_t *pipe,
pipe 458 uspace/lib/usbdev/src/request.c return usb_request_get_descriptor(pipe,
pipe 477 uspace/lib/usbdev/src/request.c usb_pipe_t *pipe, int index,
pipe 487 uspace/lib/usbdev/src/request.c rc = usb_request_get_bare_configuration_descriptor(pipe, index,
pipe 507 uspace/lib/usbdev/src/request.c rc = usb_request_get_full_configuration_descriptor(pipe, index,
pipe 542 uspace/lib/usbdev/src/request.c errno_t usb_request_set_descriptor(usb_pipe_t *pipe,
pipe 557 uspace/lib/usbdev/src/request.c return usb_control_request_set(pipe,
pipe 568 uspace/lib/usbdev/src/request.c errno_t usb_request_get_configuration(usb_pipe_t *pipe,
pipe 574 uspace/lib/usbdev/src/request.c const errno_t rc = usb_control_request_get(pipe,
pipe 598 uspace/lib/usbdev/src/request.c errno_t usb_request_set_configuration(usb_pipe_t *pipe,
pipe 604 uspace/lib/usbdev/src/request.c return usb_control_request_set(pipe,
pipe 617 uspace/lib/usbdev/src/request.c errno_t usb_request_get_interface(usb_pipe_t *pipe,
pipe 623 uspace/lib/usbdev/src/request.c const errno_t rc = usb_control_request_get(pipe,
pipe 650 uspace/lib/usbdev/src/request.c errno_t usb_request_set_interface(usb_pipe_t *pipe,
pipe 653 uspace/lib/usbdev/src/request.c return usb_control_request_set(pipe,
pipe 669 uspace/lib/usbdev/src/request.c errno_t usb_request_get_supported_languages(usb_pipe_t *pipe,
pipe 678 uspace/lib/usbdev/src/request.c const errno_t rc = usb_request_get_descriptor_alloc(pipe,
pipe 736 uspace/lib/usbdev/src/request.c errno_t usb_request_get_string(usb_pipe_t *pipe,
pipe 762 uspace/lib/usbdev/src/request.c rc = usb_request_get_descriptor_alloc(pipe,
pipe 826 uspace/lib/usbdev/src/request.c static errno_t usb_request_clear_endpoint_halt(usb_pipe_t *pipe, uint16_t ep_index)
pipe 828 uspace/lib/usbdev/src/request.c return usb_request_clear_feature(pipe,
pipe 858 uspace/lib/usbdev/src/request.c errno_t usb_request_get_endpoint_status(usb_pipe_t *ctrl_pipe, usb_pipe_t *pipe,
pipe 862 uspace/lib/usbdev/src/request.c uint16_t pipe_index = (uint16_t) pipe->desc.endpoint_no;
pipe 182 uspace/srv/audio/hound/audio_data.c void audio_pipe_init(audio_pipe_t *pipe)
pipe 184 uspace/srv/audio/hound/audio_data.c assert(pipe);
pipe 185 uspace/srv/audio/hound/audio_data.c list_initialize(&pipe->list);
pipe 186 uspace/srv/audio/hound/audio_data.c fibril_mutex_initialize(&pipe->guard);
pipe 187 uspace/srv/audio/hound/audio_data.c pipe->frames = 0;
pipe 188 uspace/srv/audio/hound/audio_data.c pipe->bytes = 0;
pipe 195 uspace/srv/audio/hound/audio_data.c void audio_pipe_fini(audio_pipe_t *pipe)
pipe 197 uspace/srv/audio/hound/audio_data.c assert(pipe);
pipe 198 uspace/srv/audio/hound/audio_data.c while (!list_empty(&pipe->list)) {
pipe 199 uspace/srv/audio/hound/audio_data.c audio_data_t *adata = audio_pipe_pop(pipe);
pipe 210 uspace/srv/audio/hound/audio_data.c errno_t audio_pipe_push(audio_pipe_t *pipe, audio_data_t *data)
pipe 212 uspace/srv/audio/hound/audio_data.c assert(pipe);
pipe 218 uspace/srv/audio/hound/audio_data.c fibril_mutex_lock(&pipe->guard);
pipe 219 uspace/srv/audio/hound/audio_data.c list_append(&alink->link, &pipe->list);
pipe 220 uspace/srv/audio/hound/audio_data.c pipe->bytes += audio_data_link_remain_size(alink);
pipe 221 uspace/srv/audio/hound/audio_data.c pipe->frames += audio_data_link_available_frames(alink);
pipe 222 uspace/srv/audio/hound/audio_data.c fibril_mutex_unlock(&pipe->guard);
pipe 231 uspace/srv/audio/hound/audio_data.c audio_data_t *audio_pipe_pop(audio_pipe_t *pipe)
pipe 233 uspace/srv/audio/hound/audio_data.c assert(pipe);
pipe 234 uspace/srv/audio/hound/audio_data.c fibril_mutex_lock(&pipe->guard);
pipe 236 uspace/srv/audio/hound/audio_data.c link_t *l = list_first(&pipe->list);
pipe 240 uspace/srv/audio/hound/audio_data.c pipe->bytes -= audio_data_link_remain_size(alink);
pipe 241 uspace/srv/audio/hound/audio_data.c pipe->frames -= audio_data_link_available_frames(alink);
pipe 246 uspace/srv/audio/hound/audio_data.c fibril_mutex_unlock(&pipe->guard);
pipe 258 uspace/srv/audio/hound/audio_data.c size_t audio_pipe_mix_data(audio_pipe_t *pipe, void *data,
pipe 261 uspace/srv/audio/hound/audio_data.c assert(pipe);
pipe 267 uspace/srv/audio/hound/audio_data.c fibril_mutex_lock(&pipe->guard);
pipe 268 uspace/srv/audio/hound/audio_data.c while (needed_frames > 0 && !list_empty(&pipe->list)) {
pipe 270 uspace/srv/audio/hound/audio_data.c link_t *l = list_first(&pipe->list);
pipe 294 uspace/srv/audio/hound/audio_data.c pipe->bytes -= src_copy_size;
pipe 295 uspace/srv/audio/hound/audio_data.c pipe->frames -= copy_frames;
pipe 303 uspace/srv/audio/hound/audio_data.c fibril_mutex_unlock(&pipe->guard);
pipe 74 uspace/srv/audio/hound/audio_data.h void audio_pipe_init(audio_pipe_t *pipe);
pipe 75 uspace/srv/audio/hound/audio_data.h void audio_pipe_fini(audio_pipe_t *pipe);
pipe 77 uspace/srv/audio/hound/audio_data.h errno_t audio_pipe_push(audio_pipe_t *pipe, audio_data_t *data);
pipe 78 uspace/srv/audio/hound/audio_data.h audio_data_t *audio_pipe_pop(audio_pipe_t *pipe);
pipe 80 uspace/srv/audio/hound/audio_data.h size_t audio_pipe_mix_data(audio_pipe_t *pipe, void *buffer, size_t size,
pipe 88 uspace/srv/audio/hound/audio_data.h static inline size_t audio_pipe_bytes(audio_pipe_t *pipe)
pipe 90 uspace/srv/audio/hound/audio_data.h assert(pipe);
pipe 91 uspace/srv/audio/hound/audio_data.h return pipe->bytes;
pipe 99 uspace/srv/audio/hound/audio_data.h static inline size_t audio_pipe_frames(audio_pipe_t *pipe)
pipe 101 uspace/srv/audio/hound/audio_data.h assert(pipe);
pipe 102 uspace/srv/audio/hound/audio_data.h return pipe->frames;
pipe 115 uspace/srv/audio/hound/audio_data.h static inline errno_t audio_pipe_push_data(audio_pipe_t *pipe,
pipe 120 uspace/srv/audio/hound/audio_data.h const errno_t ret = audio_pipe_push(pipe, adata);
HelenOS homepage, sources at GitHub