Searched refs:endpoint (Results 1 - 25 of 73) sorted by relevance

123

/haiku/src/add-ons/kernel/network/protocols/tcp/
H A DEndpointManager.cpp39 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 DEndpointManager.h45 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/l2cap/
H A DL2capEndpointManager.cpp32 L2capEndpointManager::Bind(L2capEndpoint* endpoint, const sockaddr_l2cap& address) argument
47 memcpy(*endpoint->LocalAddress(), &address, sizeof(struct sockaddr_l2cap));
48 fBoundEndpoints.Insert(endpoint);
49 gSocketModule->acquire_socket(endpoint->socket);
56 L2capEndpointManager::Unbind(L2capEndpoint* endpoint) argument
60 fBoundEndpoints.Remove(endpoint);
61 (*endpoint->LocalAddress())->sa_len = 0;
62 gSocketModule->release_socket(endpoint->socket);
78 L2capEndpointManager::BindToChannel(L2capEndpoint* endpoint) argument
91 endpoint
102 UnbindFromChannel(L2capEndpoint* endpoint) argument
129 L2capEndpoint* endpoint = iter.Next(); local
[all...]
H A DL2capEndpointManager.h18 status_t Bind(L2capEndpoint* endpoint, const sockaddr_l2cap& address);
19 status_t Unbind(L2capEndpoint* endpoint);
22 status_t BindToChannel(L2capEndpoint* endpoint);
23 status_t UnbindFromChannel(L2capEndpoint* endpoint);
H A Dl2cap_signal.cpp49 L2capEndpoint* endpoint = gL2capEndpointManager.ForPSM(psm); local
50 if (endpoint == NULL) {
57 endpoint->_HandleConnectionReq(conn, ident, psm, scid);
63 l2cap_handle_connection_rsp(L2capEndpoint* endpoint, uint8 ident, net_buffer* buffer) argument
78 endpoint->_HandleConnectionRsp(ident, response);
147 L2capEndpoint* endpoint = gL2capEndpointManager.ForChannel(dcid); local
148 if (endpoint == NULL) {
168 endpoint->_HandleConfigurationReq(ident, flags,
177 l2cap_handle_configuration_rsp(HciConnection* conn, L2capEndpoint* endpoint, argument
180 if (endpoint
221 L2capEndpoint* endpoint = gL2capEndpointManager.ForChannel(dcid); local
237 l2cap_handle_disconnection_rsp(L2capEndpoint* endpoint, uint8 ident, net_buffer* buffer) argument
264 l2cap_handle_echo_rsp(L2capEndpoint* endpoint, uint8 ident, net_buffer* buffer, uint16 length) argument
300 l2cap_handle_info_rsp(L2capEndpoint* endpoint, uint8 ident, net_buffer* buffer) argument
308 l2cap_handle_command_reject(L2capEndpoint* endpoint, uint8 ident, net_buffer* buffer) argument
465 L2capEndpoint* endpoint = NULL; local
[all...]
/haiku/src/add-ons/kernel/network/protocols/unix/
H A DUnixAddressManager.h24 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 DOption.cpp37 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 DProlific.cpp38 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 DKLSI.cpp28 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 DACM.cpp89 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 DSilicon.cpp33 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 DFTDI.cpp36 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 DWinChipHead.cpp31 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 DMidiServerApp.cpp173 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 DNetEndpoint.cpp88 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 DNetReceiver.h18 typedef status_t (*NewConnectionCallback)(void *cookie, BNetEndpoint &endpoint);
23 NetReceiver(BNetEndpoint *endpoint,
H A DNetSender.h19 NetSender(BNetEndpoint *endpoint,
H A DNetSender.cpp23 NetSender::NetSender(BNetEndpoint *endpoint, StreamingRingBuffer *source) argument
25 fEndpoint(endpoint),
/haiku/src/add-ons/kernel/network/protocols/udp/
H A Dudp.cpp39 // 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 Drtwn_usb_ep.c63 .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/apps/patchbay/
H A DEndpointInfo.cpp50 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 Dohci.cpp305 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 Dxhci.cpp865 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...]
/haiku/src/bin/listusb/
H A Dlistusb.cpp104 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 Dusb-io.h98 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,

Completed in 136 milliseconds

123