/haiku/src/system/libroot/posix/unistd/ |
H A D | pipe.c | 14 pipe(int streams[2]) function
|
/haiku/src/add-ons/kernel/bus_managers/usb/ |
H A D | usb.cpp | 29 debug_run_transfer(Pipe *pipe, uint8 *data, size_t dataLength, argument 36 BusManager *bus = pipe->GetBusManager(); 55 transfer = new(transferBuffer) Transfer(pipe); 91 Pipe *pipe = (Pipe *)get_debug_variable("_usbPipe", 0); local 92 if (pipe == NULL) 100 return debug_run_transfer(pipe, data, length, requestData, 108 Pipe *pipe = (Pipe *)get_debug_variable("_usbPipe", 0); local 109 if (pipe == NULL) 117 requestData.Index = pipe->EndpointAddress() 118 | (pipe 425 queue_interrupt(usb_pipe pipe, void *data, size_t dataLength, usb_callback_func callback, void *callbackCookie) argument 440 queue_bulk(usb_pipe pipe, void *data, size_t dataLength, usb_callback_func callback, void *callbackCookie) argument 455 queue_bulk_v(usb_pipe pipe, iovec *vector, size_t vectorCount, usb_callback_func callback, void *callbackCookie) argument 470 queue_bulk_v_physical(usb_pipe pipe, physical_entry *vector, size_t vectorCount, usb_callback_func callback, void *callbackCookie) argument 485 queue_isochronous(usb_pipe pipe, void *data, size_t dataLength, usb_iso_packet_descriptor *packetDesc, uint32 packetCount, uint32 *startingFrameNumber, uint32 flags, usb_callback_func callback, void *callbackCookie) argument 505 set_pipe_policy(usb_pipe pipe, uint8 maxQueuedPackets, uint16 maxBufferDurationMS, uint16 sampleSize) argument 520 cancel_queued_transfers(usb_pipe pipe) argument 800 queue_interrupt_v2(const void *pipe, void *data, size_t dataLength, usb_callback_func callback, void *callbackCookie) argument 809 queue_bulk_v2(const void *pipe, void *data, size_t dataLength, usb_callback_func callback, void *callbackCookie) argument 818 queue_isochronous_v2(const void *pipe, void *data, size_t dataLength, rlea *rleArray, uint16 bufferDurationMS, usb_callback_func callback, void *callbackCookie) argument 831 set_pipe_policy_v2(const void *pipe, uint8 maxQueuedPackets, uint16 maxBufferDurationMS, uint16 sampleSize) argument 840 cancel_queued_transfers_v2(const void *pipe) argument [all...] |
H A D | BusManager.cpp | 132 TRACE_ERROR("error getting the default pipe for speed %d\n", speed); 167 // Create a temporary pipe with the new address 168 ControlPipe pipe(fRootObject); 169 pipe.InitCommon(deviceAddress, 0, speed, Pipe::Default, 8, 0, hubAddress, 180 pipe.SendRequest( 307 BusManager::CancelQueuedTransfers(Pipe *pipe, bool force) argument 315 BusManager::NotifyPipeChange(Pipe *pipe, usb_change change) argument 334 TRACE_ERROR("failed to allocate default pipe for speed %d\n", speed);
|
H A D | Device.cpp | 38 TRACE_ERROR("could not allocate default pipe\n"); 332 // Cancel transfers on the default pipe and put its USBID to prevent 534 Pipe* pipe = NULL; local 566 pipe = new(std::nothrow) ControlPipe(this); 571 pipe = new(std::nothrow) IsochronousPipe(this); 575 pipe = new(std::nothrow) BulkPipe(this); 579 pipe = new(std::nothrow) InterruptPipe(this); 583 if (pipe == NULL) { 584 TRACE_ERROR("failed to allocate pipe\n"); 589 pipe 647 Pipe* pipe = (Pipe*)GetStack()->GetObject(endpoint->handle); local [all...] |
/haiku/src/system/kernel/debug/ |
H A D | debug_commands.cpp | 61 static int invoke_pipe_segment(debugger_command_pipe* pipe, int32 index, 71 PipeDebugOutputFilter(debugger_command_pipe* pipe, int32 segment, argument 74 fPipe(pipe), 182 invoke_pipe_segment(debugger_command_pipe* pipe, int32 index, char* argument) argument 186 index == pipe->segment_count - 1 191 debugger_command_pipe_segment& segment = pipe->segments[index]; 209 pipe->broken = true; 211 // Abort the previous pipe segment execution. The complete pipe is 346 /*! Aborts the currently executed debugger command (in fact the complete pipe), 361 invoke_debugger_command_pipe(debugger_command_pipe* pipe) argument [all...] |
H A D | debug_commands.h | 55 int invoke_debugger_command_pipe(debugger_command_pipe* pipe);
|
/haiku/src/tests/system/libroot/posix/ |
H A D | posix_spawn_pipe_test.c | 19 panic(pipe(out), "pipe stdout"); 20 panic(pipe(err), "pipe stderr");
|
/haiku/headers/os/drivers/ |
H A D | USB2.h | 48 usb_pipe *handle; /* of this endpoint/pipe */ 167 status_t (*queue_interrupt)(const usb_pipe *pipe, 172 status_t (*queue_bulk)(const usb_pipe *pipe, 177 status_t (*queue_isochronous)(const usb_pipe *pipe, 192 status_t (*set_pipe_policy)(const usb_pipe *pipe, 197 /* Cancel all pending async requests in a pipe */ 198 status_t (*cancel_queued_transfers)(const usb_pipe *pipe);
|
H A D | USB3.h | 49 usb_pipe handle; /* of this endpoint/pipe */ 170 status_t (*queue_interrupt)(usb_pipe pipe, 175 status_t (*queue_bulk)(usb_pipe pipe, 180 status_t (*queue_bulk_v)(usb_pipe pipe, 185 status_t (*queue_bulk_v_physical)(usb_pipe pipe, 190 status_t (*queue_isochronous)(usb_pipe pipe, 206 status_t (*set_pipe_policy)(usb_pipe pipe, 211 /* Cancel all pending async requests in a pipe */ 212 status_t (*cancel_queued_transfers)(usb_pipe pipe); 214 /* Cancel all pending async requests in a device control pipe */ [all...] |
/haiku/src/add-ons/kernel/busses/usb/ |
H A D | ehci.h | 64 ehci_qh *queueHead, Pipe *pipe); 71 virtual status_t CancelQueuedTransfers(Pipe *pipe, bool force); 72 status_t CancelQueuedIsochronousTransfers(Pipe *pipe, bool force); 74 virtual status_t NotifyPipeChange(Pipe *pipe, 132 Pipe *pipe); 137 Pipe *pipe); 160 status_t CreateDescriptorChain(Pipe *pipe,
|
H A D | uhci.cpp | 830 Pipe *pipe = transfer->TransferPipe(); local 831 if (pipe->DeviceAddress() == fRootHubAddress) 834 TRACE("submit transfer called for device %d\n", pipe->DeviceAddress()); 835 if (pipe->Type() & USB_OBJECT_CONTROL_PIPE) 840 if (pipe->Type() & USB_OBJECT_ISO_PIPE) 844 if (pipe->Type() & USB_OBJECT_ISO_PIPE) 856 if (pipe->Type() & USB_OBJECT_INTERRUPT_PIPE) 861 bool directionIn = (pipe->Direction() == Pipe::In); 985 UHCI::CancelQueuedTransfers(Pipe *pipe, bool force) argument 987 if (pipe 1049 CancelQueuedIsochronousTransfers(Pipe *pipe, bool force) argument 1080 Pipe *pipe = transfer->TransferPipe(); local 1256 Pipe *pipe = transfer->TransferPipe(); local 2084 Pipe *pipe = transfer->TransferPipe(); local 2145 CreateDescriptor(Pipe *pipe, uint8 direction, size_t bufferSize) argument 2198 CreateDescriptorChain(Pipe *pipe, uhci_td **_firstDescriptor, uhci_td **_lastDescriptor, uint8 direction, size_t bufferSize) argument [all...] |
H A D | ehci.cpp | 909 Pipe *pipe = transfer->TransferPipe(); 910 status_t result = InitQueueHead(transferData.queue_head, pipe); 916 if ((pipe->Type() & USB_OBJECT_CONTROL_PIPE) != 0) { 929 if ((pipe->Type() & USB_OBJECT_INTERRUPT_PIPE) != 0) 930 LinkPeriodicDebugQueueHead(transferData.queue_head, pipe); 954 EHCI::LinkPeriodicDebugQueueHead(ehci_qh *queueHead, Pipe *pipe) argument 956 if (pipe->Speed() == USB_SPEED_HIGHSPEED) 1092 Pipe *pipe = transfer->TransferPipe(); 1093 if ((pipe->Type() & USB_OBJECT_ISO_PIPE) != 0) 1106 result = InitQueueHead(queueHead, pipe); 1160 Pipe *pipe = transfer->TransferPipe(); local 1346 NotifyPipeChange(Pipe *pipe, usb_change change) argument 1740 CancelQueuedTransfers(Pipe *pipe, bool force) argument 1805 CancelQueuedIsochronousTransfers(Pipe *pipe, bool force) argument 2283 InitQueueHead(ehci_qh *queueHead, Pipe *pipe) argument 2352 LinkInterruptQueueHead(ehci_qh *queueHead, Pipe *pipe) argument 2435 Pipe *pipe = transfer->TransferPipe(); local 2506 Pipe *pipe = transfer->TransferPipe(); local 2596 CreateDescriptorChain(Pipe *pipe, ehci_qtd **_firstDescriptor, ehci_qtd **_lastDescriptor, ehci_qtd *strayDescriptor, size_t bufferSize, uint8 pid) argument [all...] |
H A D | uhci.h | 107 virtual status_t CancelQueuedTransfers(Pipe *pipe, bool force); 108 status_t CancelQueuedIsochronousTransfers(Pipe *pipe, bool force); 171 uhci_td * CreateDescriptor(Pipe *pipe, 174 status_t CreateDescriptorChain(Pipe *pipe,
|
H A D | ohci.h | 43 virtual status_t CancelQueuedTransfers(Pipe *pipe, 46 virtual status_t NotifyPipeChange(Pipe *pipe, 108 status_t _InsertEndpointForPipe(Pipe *pipe); 109 status_t _RemoveEndpointForPipe(Pipe *pipe);
|
H A D | ohci.cpp | 674 TRACE_ERROR("tried to submit transfer for unknown pipe type %" B_PRIu32 "\n", 681 OHCI::CancelQueuedTransfers(Pipe *pipe, bool force) argument 694 if (current->transfer && current->transfer->TransferPipe() == pipe) { 708 if (pipe->Type() & USB_OBJECT_ISO_PIPE) { 755 while (fProcessingPipe == pipe) 765 OHCI::NotifyPipeChange(Pipe *pipe, usb_change change) argument 767 TRACE("pipe change %d for pipe %p\n", change, pipe); 768 if (pipe 1544 Pipe *pipe = transfer->TransferPipe(); local 1614 Pipe *pipe = transfer->TransferPipe(); local 1832 _InsertEndpointForPipe(Pipe *pipe) argument 1948 _RemoveEndpointForPipe(Pipe *pipe) argument 2150 Pipe *pipe = transfer->TransferPipe(); local [all...] |
H A D | xhci.h | 104 virtual status_t CancelQueuedTransfers(Pipe *pipe, bool force); 110 virtual status_t NotifyPipeChange(Pipe *pipe, 147 status_t _InsertEndpointForPipe(Pipe *pipe); 148 status_t _RemoveEndpointForPipe(Pipe *pipe);
|
/haiku/src/add-ons/print/drivers/postscript/ |
H A D | FilterIO.cpp | 107 // Create new pipe FDs as stdin, stdout, stderr 108 pipe(filedes); dup2(filedes[0], 0); close(filedes[0]); 110 pipe(filedes); dup2(filedes[1], 1); close(filedes[1]); 112 pipe(filedes); dup2(filedes[1], 2); close(filedes[1]);
|
/haiku/src/add-ons/kernel/busses/scsi/usb/ |
H A D | proto_common.c | 57 usb_pipe pipe = (dir == eDirIn) ? udi->pipe_in : udi->pipe_out; local 59 status = (*udi->usb_m->queue_bulk_v)(pipe, sg_data, sg_count, bulk_callback, udi); 65 status_t st=(*udi->usb_m->clear_feature)(pipe, USB_FEATURE_ENDPOINT_HALT); 70 (*udi->usb_m->cancel_queued_transfers)(pipe);
|
/haiku/src/tests/kits/app/common/ |
H A D | PipedAppRunner.cpp | 151 FILE *pipe = fPipe; local 153 while (!feof(pipe)) { 154 size_t bytes = fread(buffer, 1, sizeof(buffer), pipe);
|
/haiku/headers/private/graphics/intel_extreme/ |
H A D | intel_extreme.h | 497 bool HasPipe(pipe_index pipe) argument 499 if (pipe == INTEL_PIPE_ANY) 502 return (bitmask & (1 << pipe)) != 0; 505 void SetPipe(pipe_index pipe) argument 507 if (pipe == INTEL_PIPE_ANY) { 512 bitmask |= (1 << pipe); 515 void ClearPipe(pipe_index pipe) argument 517 if (pipe == INTEL_PIPE_ANY) 520 bitmask &= ~(1 << pipe); 746 // the introduction of pipe [all...] |
/haiku/src/add-ons/kernel/drivers/graphics/intel_extreme/ |
H A D | intel_extreme.cpp | 88 gen8_enable_interrupts(intel_info& info, pipe_index pipe, bool enable) argument 90 ASSERT(pipe != INTEL_PIPE_ANY); 91 ASSERT(info.device_type.Generation() >= 12 || pipe != INTEL_PIPE_D); 93 const uint32 regMask = PCH_INTERRUPT_PIPE_MASK_BDW(pipe); 94 const uint32 regEnabled = PCH_INTERRUPT_PIPE_ENABLED_BDW(pipe); 95 const uint32 regIdentity = PCH_INTERRUPT_PIPE_IDENTITY_BDW(pipe); 134 dprintf("gen8_handle_interrupts unhandled interrupt on pipe A\n"); 145 dprintf("gen8_handle_interrupts unhandled interrupt on pipe B\n"); 156 dprintf("gen8_handle_interrupts unhandled interrupt on pipe C\n"); 207 * the given pipe 217 intel_get_interrupt_mask(intel_info& info, pipe_index pipe, bool enable) argument 303 g35_clear_interrupt_status(intel_info& info, pipe_index pipe) argument 324 intel_clear_pipe_interrupt(intel_info& info, pipe_index pipe) argument [all...] |
/haiku/src/add-ons/kernel/drivers/audio/echo/ |
H A D | echo.cpp | 170 if (stream->pipe >= 0) { 171 close_params.wPipeIndex = stream->pipe; 186 status = stream->card->pEG->OpenAudio(&open_params, &stream->pipe); 194 status = stream->card->pEG->VerifyAudioOpen(stream->pipe); 214 status = stream->card->pEG->QueryAudioFormat(stream->pipe, &format_params); 221 status = stream->card->pEG->SetAudioFormat(stream->pipe, &format_params); 261 CDaffyDuck *duck = stream->card->pEG->GetDaffyDuck(stream->pipe); 276 if (stream->card->pEG->GetAudioPositionPtr(stream->pipe, stream->position)!=ECHOSTATUS_OK) { 323 status = stream->card->pEG->Start(stream->pipe); 325 PRINT(("echo_stream_start : Could not start the pipe [all...] |
/haiku/src/tests/system/benchmarks/ |
H A D | ctxbench.c | 100 if (pipe(fd0) != 0) 101 errx(1, "Unable to create pipe"); 102 if (pipe(fd1) != 0) 103 errx(1, "Unable to create pipe");
|
/haiku/src/apps/remotedesktop/ |
H A D | RemoteDesktop.cpp | 145 if (pipe(&pipes[0]) != 0 || pipe(&pipes[2]) != 0) {
|
/haiku/src/kits/shared/ |
H A D | CommandPipe.cpp | 118 pipe(stdOutAndErr); 151 pipe(stdOut); 152 pipe(stdErr);
|