/haiku/src/add-ons/kernel/network/protocols/tcp/ |
H A D | EndpointManager.cpp | 39 Bind(TCPEndpoint* endpoint, ConstSocketAddress& address, bool ephemeral) argument 41 fEndpoint(endpoint), 48 Bind(TCPEndpoint* endpoint, SocketAddress& address, bool ephemeral) argument 50 fEndpoint(endpoint), 71 Connect(TCPEndpoint* endpoint) argument 73 fEndpoint(endpoint) 75 endpoint->LocalAddress().AsString(fLocal, sizeof(fLocal), true); 76 endpoint->PeerAddress().AsString(fPeer, sizeof(fPeer), true); 94 Unbind(TCPEndpoint* endpoint) argument 96 fEndpoint(endpoint) 259 SetConnection(TCPEndpoint* endpoint, const sockaddr* _local, const sockaddr* peer, const sockaddr* interfaceLocal) argument 305 SetPassive(TCPEndpoint* endpoint) argument 336 TCPEndpoint *endpoint = _LookupConnection(local, peer); local 380 Bind(TCPEndpoint* endpoint, const sockaddr* address) argument 396 BindChild(TCPEndpoint* endpoint, const sockaddr* address) argument 405 _BindToAddress(WriteLocker& locker, TCPEndpoint* endpoint, const sockaddr* _address) argument 466 _BindToEphemeral(TCPEndpoint* endpoint, const sockaddr* address) argument 510 _Bind(TCPEndpoint* endpoint, const sockaddr* address) argument 525 Unbind(TCPEndpoint* endpoint) argument 596 TCPEndpoint *endpoint = iterator.Next(); local [all...] |
H A D | EndpointManager.h | 45 size_t Hash(TCPEndpoint* endpoint) const; 47 TCPEndpoint* endpoint) const; 48 TCPEndpoint*& GetLink(TCPEndpoint* endpoint) const; 61 size_t Hash(TCPEndpoint* endpoint) const; 62 bool Compare(uint16 port, TCPEndpoint* endpoint) const; 65 TCPEndpoint*& GetLink(TCPEndpoint* endpoint) const; 78 status_t SetConnection(TCPEndpoint* endpoint, 81 status_t SetPassive(TCPEndpoint* endpoint); 83 status_t Bind(TCPEndpoint* endpoint, 85 status_t BindChild(TCPEndpoint* endpoint, [all...] |
/haiku/src/add-ons/kernel/network/protocols/unix/ |
H A D | UnixAddressManager.h | 24 size_t Hash(UnixEndpoint* endpoint) const 26 return HashKey(endpoint->Address()); 29 bool Compare(const KeyType& key, UnixEndpoint* endpoint) const 31 return key == endpoint->Address(); 34 UnixEndpoint*& GetLink(UnixEndpoint* endpoint) const 36 return endpoint->HashTableLink(); 73 void Add(UnixEndpoint* endpoint) argument 75 fBoundEndpoints.Insert(endpoint); 78 void Remove(UnixEndpoint* endpoint) argument 80 fBoundEndpoints.Remove(endpoint); [all...] |
/haiku/src/add-ons/kernel/drivers/ports/usb_serial/ |
H A D | Option.cpp | 37 usb_endpoint_info *endpoint = &interface->endpoint[i]; local 39 // Find our Interrupt endpoint 40 if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_INTERRUPT 41 && (endpoint->descr->endpoint_address 48 if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_BULK) { 49 if ((endpoint->descr->endpoint_address 59 TRACE("> OptionDevice::%s: endpoint %d, tx: %d, rx: %d, ir: %d\n", 69 usb_endpoint_info *irEndpoint = &interface->endpoint[irEndpointID]; 70 usb_endpoint_info *txEndpoint = &interface->endpoint[txEndpointI [all...] |
H A D | Prolific.cpp | 38 usb_endpoint_info *endpoint = &interface->endpoint[i]; local 39 if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_INTERRUPT) { 40 if (endpoint->descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN) { 41 SetControlPipe(endpoint->handle); 52 usb_endpoint_info *endpoint = &interface->endpoint[i]; local 53 if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_BULK) { 54 if (endpoint->descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN) 55 SetReadPipe(endpoint [all...] |
H A D | KLSI.cpp | 28 usb_endpoint_info *endpoint = &interface->endpoint[i]; local 29 if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_INTERRUPT) { 30 if (endpoint->descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN) { 31 SetControlPipe(endpoint->handle); 32 SetInterruptBufferSize(endpoint->descr->max_packet_size); 34 } else if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_BULK) { 35 if (endpoint->descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN) { 36 SetReadBufferSize(ROUNDUP(endpoint->descr->max_packet_size, 16)); 37 SetReadPipe(endpoint [all...] |
H A D | ACM.cpp | 89 SetControlPipe(interface->endpoint[0].handle); 90 SetInterruptBufferSize(interface->endpoint[0].descr->max_packet_size); 103 if (!(interface->endpoint[0].descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN)) { 104 SetWriteBufferSize(ROUNDUP(interface->endpoint[0].descr->max_packet_size, 16)); 105 SetWritePipe(interface->endpoint[0].handle); 107 SetReadBufferSize(ROUNDUP(interface->endpoint[0].descr->max_packet_size, 16)); 108 SetReadPipe(interface->endpoint[0].handle); 111 if (interface->endpoint[1].descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN) { 112 SetReadBufferSize(ROUNDUP(interface->endpoint[1].descr->max_packet_size, 16)); 113 SetReadPipe(interface->endpoint[ [all...] |
H A D | Silicon.cpp | 33 usb_endpoint_info *endpoint = &interface->endpoint[i]; local 34 if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_BULK) { 35 if (endpoint->descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN) { 36 SetReadPipe(endpoint->handle); 40 if (endpoint->descr->endpoint_address) { 41 SetControlPipe(endpoint->handle); 42 SetWritePipe(endpoint->handle);
|
H A D | FTDI.cpp | 36 usb_endpoint_info *endpoint = &interface->endpoint[i]; local 37 if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_BULK) { 38 if (endpoint->descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN) { 39 SetReadPipe(endpoint->handle); 43 if (endpoint->descr->endpoint_address) { 44 SetControlPipe(endpoint->handle); 45 SetWritePipe(endpoint->handle);
|
H A D | WinChipHead.cpp | 31 usb_endpoint_info *endpoint = &interface->endpoint[i]; local 32 if (endpoint->descr->attributes == USB_ENDPOINT_ATTR_BULK) { 33 if (endpoint->descr->endpoint_address & USB_ENDPOINT_ADDR_DIR_IN) { 34 SetReadPipe(endpoint->handle); 38 if (endpoint->descr->endpoint_address) { 39 SetControlPipe(endpoint->handle); 40 SetWritePipe(endpoint->handle);
|
/haiku/src/servers/midi/ |
H A D | MidiServerApp.cpp | 173 endpoint_t* endpoint = new endpoint_t; local 175 endpoint->app = _WhichApp(msg); 176 if (endpoint->app == NULL) { 181 if (msg->FindBool("midi:consumer", &endpoint->consumer) == B_OK 182 && msg->FindBool("midi:registered", &endpoint->registered) == B_OK 183 && msg->FindString("midi:name", &endpoint->name) == B_OK 184 && msg->FindMessage("midi:properties", &endpoint->properties) 186 if (endpoint->consumer) { 187 if (msg->FindInt32("midi:port", &endpoint->port) == B_OK 188 && msg->FindInt64("midi:latency", &endpoint 224 endpoint_t* endpoint = _WhichEndpoint(msg, app); local 245 endpoint_t* endpoint = _FindEndpoint(id); local 258 endpoint_t* endpoint = NULL; local 392 endpoint_t* endpoint = _EndpointAt(t); local 436 _AddEndpoint(BMessage* msg, endpoint_t* endpoint) argument 462 _RemoveEndpoint(app_t* app, endpoint_t* endpoint) argument 507 _MakeCreatedNotification(BMessage* msg, endpoint_t* endpoint) argument 585 endpoint_t* endpoint = _FindEndpoint(id); local 603 endpoint_t* endpoint = _EndpointAt(t); local 703 endpoint_t* endpoint = _EndpointAt(t); local 802 endpoint_t* endpoint = _EndpointAt(t); local [all...] |
/haiku/src/kits/network/libnetapi/ |
H A D | NetEndpoint.cpp | 88 BNetEndpoint::BNetEndpoint(const BNetEndpoint& endpoint) argument 90 fStatus(endpoint.fStatus), 91 fFamily(endpoint.fFamily), 92 fType(endpoint.fType), 93 fProtocol(endpoint.fProtocol), 95 fTimeout(endpoint.fTimeout), 96 fAddr(endpoint.fAddr), 97 fPeer(endpoint.fPeer) 100 if (endpoint.fSocket >= 0) { 101 fSocket = dup(endpoint 109 BNetEndpoint(const BNetEndpoint& endpoint, int socket, const struct sockaddr_in& localAddress, const struct sockaddr_in& peerAddress) argument 126 operator =(const BNetEndpoint& endpoint) argument 459 BNetEndpoint* endpoint = new (std::nothrow) BNetEndpoint(*this, socket, local [all...] |
/haiku/src/servers/app/drawing/interface/remote/ |
H A D | NetReceiver.h | 18 typedef status_t (*NewConnectionCallback)(void *cookie, BNetEndpoint &endpoint); 23 NetReceiver(BNetEndpoint *endpoint,
|
H A D | NetSender.h | 19 NetSender(BNetEndpoint *endpoint,
|
H A D | NetSender.cpp | 23 NetSender::NetSender(BNetEndpoint *endpoint, StreamingRingBuffer *source) argument 25 fEndpoint(endpoint),
|
/haiku/src/add-ons/kernel/network/protocols/udp/ |
H A D | udp.cpp | 39 // is dictated by the receive path as blind access to the endpoint 114 // endpoint hash (and it is bound and 138 size_t Hash(UdpEndpoint *endpoint) const 140 return _Mix(endpoint->LocalAddress().HashPair( 141 *endpoint->PeerAddress())); 151 bool Compare(const KeyType &key, UdpEndpoint *endpoint) const 153 return endpoint->LocalAddress().EqualTo(key.first, true) 154 && endpoint->PeerAddress().EqualTo(key.second, true); 157 UdpEndpoint *&GetLink(UdpEndpoint *endpoint) const 159 return endpoint 312 UdpEndpoint* endpoint = _FindActiveEndpoint(buffer->source, local 325 BindEndpoint(UdpEndpoint *endpoint, const sockaddr *address) argument 341 ConnectEndpoint(UdpEndpoint *endpoint, const sockaddr *address) argument 396 UnbindEndpoint(UdpEndpoint *endpoint) argument 424 _BindEndpoint(UdpEndpoint *endpoint, const sockaddr *address) argument 435 _Bind(UdpEndpoint *endpoint, const sockaddr *address) argument 472 _BindToEphemeral(UdpEndpoint *endpoint, const sockaddr *address) argument 491 _FinishBind(UdpEndpoint *endpoint, const sockaddr *address) argument 514 UdpEndpoint* endpoint = fActiveEndpoints.Lookup( local 589 UdpEndpoint* endpoint = _FindActiveEndpoint(localAddress, peerAddress, local 654 UdpEndpoint *endpoint = it.Next(); local 849 OpenEndpoint(UdpEndpoint *endpoint) argument 1135 UdpEndpoint *endpoint = new (std::nothrow) UdpEndpoint(socket); local [all...] |
/haiku/src/add-ons/kernel/drivers/network/wlan/realtekwifi/dev/rtwn/usb/ |
H A D | rtwn_usb_ep.c | 63 .endpoint = UE_ADDR_ANY, 73 .endpoint = UE_ADDR_ANY, 86 .endpoint = UE_ADDR_ANY, 99 .endpoint = UE_ADDR_ANY, 112 .endpoint = UE_ADDR_ANY, 182 "%s: endpoint: addr %u, direction %s\n", __func__, 204 rtwn_config[RTWN_BULK_TX_VO].endpoint = addr[0]; 208 rtwn_config[RTWN_BULK_TX_BE].endpoint = addr[2]; 209 rtwn_config[RTWN_BULK_TX_BK].endpoint = addr[2]; 210 rtwn_config[RTWN_BULK_TX_VI].endpoint [all...] |
/haiku/src/add-ons/kernel/network/protocols/l2cap/ |
H A D | l2cap_upper.cpp | 30 L2capEndpoint* endpoint = L2capEndpoint::ForPsm(channel->psm); local 32 if (endpoint == NULL) { // TODO: refuse connection no endpoint bound 33 ERROR("%s: No endpoint bound for psm %d\n", __func__, channel->psm); 37 // Pair Channel with endpoint 38 endpoint->BindNewEnpointToChannel(channel); 81 if (channel->endpoint->fConfigurationSet) { 139 return channel->endpoint->MarkEstablished(); 175 channel->endpoint->MarkEstablished(); 179 if (channel->endpoint 307 L2capEndpoint* endpoint = L2capEndpoint::ForPsm(psm); local [all...] |
H A D | L2capEndpoint.cpp | 305 // unassign any channel for the parent endpoint 396 L2capEndpoint* endpoint; local 403 endpoint = iterator.Next(); 404 if (((struct sockaddr_l2cap*)&endpoint->socket->address)->l2cap_psm == psm 405 && endpoint->fState == LISTEN) { 406 // TODO endpoint ocupied, lock it! define a channel for it 407 return endpoint; 426 L2capEndpoint* endpoint = (L2capEndpoint*)newSocket->first_protocol; local 428 endpoint->fChannel = channel; 429 endpoint [all...] |
/haiku/src/apps/patchbay/ |
H A D | EndpointInfo.cpp | 50 BMidiEndpoint* endpoint = roster->FindEndpoint(id); local 51 if (endpoint != NULL) { 52 printf("endpoint %" B_PRId32 " = %p\n", id, endpoint); 54 if (endpoint->GetProperties(&msg) == B_OK) { 57 endpoint->Release();
|
/haiku/src/add-ons/kernel/busses/usb/ |
H A D | ohci.cpp | 305 mutex_init(&fEndpointLock, "ohci endpoint lock"); 384 TRACE_ERROR("failed to allocate interrupt endpoint %" B_PRId32 "\n", 396 // fInterruptEndpoints[i] == interrupt endpoint for interval 2^i 420 // Now link the first endpoint to the isochronous endpoint 696 if (!(current->endpoint->flags & OHCI_ENDPOINT_SKIP)) { 697 current->endpoint->flags |= OHCI_ENDPOINT_SKIP; 699 // this endpoint, wait for it to finish 703 // Clear the endpoint 704 current->endpoint 1001 _AddPendingTransfer(Transfer *transfer, ohci_endpoint_descriptor *endpoint, ohci_general_td *firstDescriptor, ohci_general_td *dataDescriptor, ohci_general_td *lastDescriptor, bool directionIn) argument 1058 _AddPendingIsochronousTransfer(Transfer *transfer, ohci_endpoint_descriptor *endpoint, ohci_isochronous_td *firstDescriptor, ohci_isochronous_td *lastDescriptor, bool directionIn) argument 1143 ohci_endpoint_descriptor *endpoint = transfer->endpoint; local 1518 ohci_endpoint_descriptor *endpoint local 1572 ohci_endpoint_descriptor *endpoint local 1639 ohci_endpoint_descriptor *endpoint local 1663 _SwitchEndpointTail(ohci_endpoint_descriptor *endpoint, ohci_general_td *first, ohci_general_td *last) argument 1703 _SwitchIsochronousEndpointTail(ohci_endpoint_descriptor *endpoint, ohci_isochronous_td *first, ohci_isochronous_td *last) argument 1762 ohci_endpoint_descriptor *endpoint = transfer->endpoint; local 1786 ohci_endpoint_descriptor *endpoint; local 1818 _FreeEndpoint(ohci_endpoint_descriptor *endpoint) argument 1837 ohci_endpoint_descriptor *endpoint = _AllocateEndpoint(); local 1953 ohci_endpoint_descriptor *endpoint local 2648 _PrintEndpoint(ohci_endpoint_descriptor *endpoint) argument [all...] |
H A D | xhci.cpp | 865 xhci_endpoint *endpoint = (xhci_endpoint *)pipe->ControllerCookie(); local 866 if (endpoint == NULL) { 867 TRACE_ERROR("control pipe has no endpoint!\n"); 870 if (endpoint->device == NULL) { 871 panic("endpoint is not initialized!"); 932 status = _LinkDescriptorForPipe(descriptor, endpoint); 951 xhci_endpoint *endpoint = (xhci_endpoint *)pipe->ControllerCookie(); local 952 if (endpoint == NULL) { 953 TRACE_ERROR("pipe has no endpoint!\n"); 956 if (endpoint 1087 xhci_endpoint* endpoint = (xhci_endpoint*)pipe->ControllerCookie(); local 1202 xhci_endpoint *endpoint = (xhci_endpoint *)pipe->ControllerCookie(); local 1851 _GetEndpointState(xhci_endpoint* endpoint) argument 1898 xhci_endpoint* endpoint = &device->endpoints[id]; local 2000 _LinkDescriptorForPipe(xhci_td *descriptor, xhci_endpoint *endpoint) argument 2124 _UnlinkDescriptorForPipe(xhci_td *descriptor, xhci_endpoint *endpoint) argument 2548 Ring(uint8 slot, uint8 endpoint) argument 2634 xhci_endpoint *endpoint = &device->endpoints[endpointNumber - 1]; local 2938 ResetEndpoint(bool preserve, xhci_endpoint* endpoint) argument 2965 StopEndpoint(bool suspend, xhci_endpoint* endpoint) argument 2993 SetTRDequeue(uint64 dequeue, uint16 stream, uint8 endpoint, uint8 slot) argument [all...] |
H A D | ohci.h | 25 ohci_endpoint_descriptor * endpoint; member in struct:transfer_data 67 ohci_endpoint_descriptor *endpoint, 74 ohci_endpoint_descriptor *endpoint, 93 ohci_endpoint_descriptor *endpoint, 97 ohci_endpoint_descriptor *endpoint, 107 ohci_endpoint_descriptor *endpoint); 181 ohci_endpoint_descriptor *endpoint);
|
/haiku/src/bin/listusb/ |
H A D | listusb.cpp | 104 const BUSBEndpoint* endpoint = interface->EndpointAt(i); local 105 if (!endpoint) 110 ((endpoint->MaxPacketSize() >> 11) & 0x3) + 1, endpoint->MaxPacketSize() & 0x7ff); 112 endpoint->Interval()); 114 if (endpoint->IsControl()) 116 else if (endpoint->IsBulk()) 118 else if (endpoint->IsIsochronous()) 120 else if (endpoint->IsInterrupt()) 123 if (endpoint [all...] |
/haiku/headers/private/kernel/platform/efi/protocol/ |
H A D | usb-io.h | 98 uint8_t endpoint, void* data, 103 uint8_t endpoint, bool is_new_transfer, 110 uint8_t endpoint, void* data, 115 uint8_t endpoint, 120 uint8_t endpoint,
|