Searched refs:pipe (Results 1 - 25 of 58) sorted by relevance

123

/haiku/src/system/libroot/posix/unistd/
H A Dpipe.c14 pipe(int streams[2]) function
/haiku/src/add-ons/kernel/bus_managers/usb/
H A Dusb.cpp29 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 DBusManager.cpp132 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 DDevice.cpp38 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 Ddebug_commands.cpp61 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 Ddebug_commands.h55 int invoke_debugger_command_pipe(debugger_command_pipe* pipe);
/haiku/src/tests/system/libroot/posix/
H A Dposix_spawn_pipe_test.c19 panic(pipe(out), "pipe stdout");
20 panic(pipe(err), "pipe stderr");
/haiku/headers/os/drivers/
H A DUSB2.h48 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 DUSB3.h49 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 Dehci.h64 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 Duhci.cpp830 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 Dehci.cpp909 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 Duhci.h107 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 Dohci.h43 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 Dohci.cpp674 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 Dxhci.h104 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 DFilterIO.cpp107 // 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 Dproto_common.c57 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 DPipedAppRunner.cpp151 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 Dintel_extreme.h497 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 Dintel_extreme.cpp88 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 Decho.cpp170 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 Dctxbench.c100 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 DRemoteDesktop.cpp145 if (pipe(&pipes[0]) != 0 || pipe(&pipes[2]) != 0) {
/haiku/src/kits/shared/
H A DCommandPipe.cpp118 pipe(stdOutAndErr);
151 pipe(stdOut);
152 pipe(stdErr);

Completed in 207 milliseconds

123