Searched refs:conn (Results 1 - 25 of 34) sorted by relevance

12

/haiku/src/add-ons/kernel/bluetooth/btCoreData/
H A DConnectionInterface.cpp20 void PurgeChannels(HciConnection* conn);
25 mutex_init(&fLock, "conn outgoing");
42 HciConnection* conn = ConnectionByHandle(handle, hid); local
43 if (conn != NULL)
46 conn = new (std::nothrow) HciConnection;
47 if (conn == NULL)
50 // memset(conn, 0, sizeof(HciConnection));
52 conn->currentRxPacket = NULL;
53 conn->currentRxExpectedLength = 0;
56 bdaddrUtils::Copy(conn
75 HciConnection* conn; local
104 HciConnection* conn; local
132 HciConnection* conn; local
151 HciConnection* conn; local
170 HciConnection* conn; local
192 SetAclBuffer(HciConnection* conn, net_buffer* nbuf) argument
199 SetAclExpectedSize(HciConnection* conn, size_t size) argument
206 AclPutting(HciConnection* conn, size_t size) argument
213 AclComplete(HciConnection* conn) argument
220 AclOverFlowed(HciConnection* conn) argument
231 PurgeChannels(HciConnection* conn) argument
[all...]
H A DChannelInterface.h13 L2capChannel* AddChannel(HciConnection* conn, uint16 psm);
14 void RemoveChannel(HciConnection* conn, uint16 scid);
16 L2capChannel* ChannelBySourceID(HciConnection* conn, uint16 scid);
17 uint16 ChannelAllocateCid(HciConnection* conn);
18 uint16 ChannelAllocateIdent(HciConnection* conn);
H A DChannelInterface.cpp17 ChannelBySourceID(HciConnection *conn, uint16 scid) argument
21 DoublyLinkedList<L2capChannel>::Iterator iterator = conn->ChannelList.GetIterator();
34 ChannelAllocateCid(HciConnection* conn) argument
36 uint16 cid = conn->lastCid;
41 if (ChannelBySourceID(conn, cid) == NULL) {
42 conn->lastCid = cid;
46 } while (cid != conn->lastCid);
53 ChannelAllocateIdent(HciConnection* conn) argument
55 uint8 ident = conn->lastIdent + 1;
60 while (ident != conn
77 AddChannel(HciConnection* conn, uint16 psm) argument
116 RemoveChannel(HciConnection* conn, uint16 scid) argument
[all...]
H A DFrameInterface.cpp14 SignalByIdent(HciConnection* conn, uint8 ident) argument
18 mutex_lock(&conn->fLockExpected);
20 = conn->ExpectedResponses.GetIterator();
26 mutex_unlock(&frame->conn->fLockExpected);
31 mutex_unlock(&conn->fLockExpected);
58 SpawmFrame(HciConnection* conn, L2capChannel* channel, net_buffer* buffer, argument
66 frame->conn = conn;
72 mutex_lock(&conn->fLock);
74 conn
83 SpawmSignal(HciConnection* conn, L2capChannel* channel, net_buffer* buffer, uint8 ident, uint8 code) argument
[all...]
H A DConnectionInterface.h29 void SetAclBuffer(HciConnection* conn, net_buffer* nbuf);
30 void SetAclExpectedSize(HciConnection* conn, size_t size);
31 void AclPutting(HciConnection* conn, size_t size);
32 bool AclComplete(HciConnection* conn);
33 bool AclOverFlowed(HciConnection* conn);
H A DFrameInterface.h11 SignalByIdent(HciConnection* conn, uint8 ident);
20 SpawmFrame(HciConnection* conn, L2capChannel* channel, net_buffer* buffer, frame_type frame);
23 SpawmSignal(HciConnection* conn, L2capChannel* channel, net_buffer* buffer, uint8 ident, uint8 code);
H A DBTCoreData.cpp42 HciConnection* conn; local
49 conn = iterator.Next();
52 "outqueue=%" B_PRId32 " expected=%" B_PRId32 "\n", conn->Hid,
53 bdaddrUtils::ToString(conn->destination).String(), conn->handle,
54 conn->type, conn->OutGoingFrames.Count(),
55 conn->ExpectedResponses.Count());
61 = conn->ChannelList.GetIterator();
72 = conn
111 HciConnection* conn = AddConnection(data->handle, BT_ACL, local
[all...]
/haiku/src/add-ons/kernel/network/protocols/l2cap/
H A Dl2cap_lower.h8 status_t l2cap_receive(HciConnection* conn, net_buffer* buffer);
13 void SchedConnectionPurgeThread(HciConnection* conn);
H A Dl2cap_signal.h9 status_t l2cap_process_signal_cmd(HciConnection* conn, net_buffer* buffer);
16 send_l2cap_reject(HciConnection *conn, uint8 ident, uint16 reason, uint16 mtu, uint16 scid, uint16 dcid);
18 send_l2cap_con_rej(HciConnection *conn, uint8 ident, uint16 scid, uint16 dcid, uint16 result);
20 send_l2cap_cfg_rsp(HciConnection *conn, uint8 ident, uint16 scid, uint16 result, net_buffer *opt);
H A Dl2cap_upper.h15 status_t l2cap_con_rsp_ind(HciConnection* conn, L2capChannel* channel);
23 status_t l2cap_co_receive(HciConnection* conn, net_buffer* buffer, uint16 dcid);
24 status_t l2cap_cl_receive(HciConnection* conn, net_buffer* buffer, uint16 psm);
H A Dl2cap_upper.cpp42 L2capFrame* cmd = btCoreData->SpawnSignal(channel->conn, channel, buf,
53 SchedConnectionPurgeThread(channel->conn);
59 l2cap_con_rsp_ind(HciConnection* conn, L2capChannel* channel) argument
102 channel->ident = btCoreData->ChannelAllocateIdent(conn);
110 L2capFrame* command = btCoreData->SpawnSignal(conn, channel, buffer,
128 SchedConnectionPurgeThread(channel->conn);
157 L2capFrame* cmd = btCoreData->SpawnSignal(channel->conn, channel, buf,
166 SchedConnectionPurgeThread(channel->conn);
184 channel->ident = btCoreData->ChannelAllocateIdent(channel->conn);
186 L2capFrame* cmd = btCoreData->SpawnSignal(channel->conn, channe
282 l2cap_co_receive(HciConnection* conn, net_buffer* buffer, uint16 dcid) argument
305 l2cap_cl_receive(HciConnection* conn, net_buffer* buffer, uint16 psm) argument
[all...]
H A Dl2cap_signal.cpp56 l2cap_process_con_req(HciConnection* conn, uint8 ident, net_buffer* buffer);
59 l2cap_process_con_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer);
62 l2cap_process_cfg_req(HciConnection* conn, uint8 ident, net_buffer* buffer);
65 l2cap_process_cfg_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer);
68 l2cap_process_discon_req(HciConnection* conn, uint8 ident, net_buffer* buffer);
71 l2cap_process_discon_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer);
74 l2cap_process_echo_req(HciConnection* conn, uint8 ident, net_buffer* buffer);
77 l2cap_process_echo_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer);
80 l2cap_process_info_req(HciConnection* conn, uint8 ident, net_buffer* buffer);
83 l2cap_process_info_rsp(HciConnection* conn, uint
98 l2cap_process_signal_cmd(HciConnection* conn, net_buffer* buffer) argument
217 l2cap_process_con_req(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
266 l2cap_process_con_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
438 l2cap_process_cfg_req(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
570 l2cap_process_cfg_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
709 l2cap_process_discon_req(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
785 l2cap_process_discon_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
845 l2cap_process_echo_req(HciConnection *conn, uint8 ident, net_buffer *buffer) argument
865 l2cap_process_echo_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
895 l2cap_process_info_req(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
939 l2cap_process_info_rsp(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
1004 l2cap_process_cmd_rej(HciConnection* conn, uint8 ident, net_buffer* buffer) argument
1077 send_l2cap_reject(HciConnection* conn, uint8 ident, uint16 reason, uint16 mtu, uint16 scid, uint16 dcid) argument
1095 send_l2cap_con_rej(HciConnection* conn, uint8 ident, uint16 scid, uint16 dcid, uint16 result) argument
1113 send_l2cap_cfg_rsp(HciConnection* conn, uint8 ident, uint16 scid, uint16 result, net_buffer* opt) argument
[all...]
H A Dl2cap_lower.cpp38 l2cap_receive(HciConnection* conn, net_buffer* buffer) argument
87 error = l2cap_process_signal_cmd(conn, buffer);
96 error = l2cap_co_receive(conn, buffer, dcid);
108 #pragma mark - thread conn sched -
143 purge_connection(HciConnection* conn) argument
149 mutex_lock(&conn->fLock);
151 frame = conn->OutGoingFrames.RemoveHead();
153 mutex_unlock(&conn->fLock);
181 frame->buffer->type = conn->handle;
182 btDevices->PostACL(conn
203 HciConnection* conn = NULL; local
277 SchedConnectionPurgeThread(HciConnection* conn) argument
[all...]
H A Dl2cap.cpp271 HciConnection* conn = (HciConnection*)buffer; local
273 conn->currentRxPacket->size);
275 l2cap_receive(conn, conn->currentRxPacket);
/haiku/src/add-ons/kernel/bluetooth/hci/
H A Dacl.cpp31 status_t PostToUpper(HciConnection* conn, net_buffer* buf);
71 HciConnection* conn = btCoreData->ConnectionByHandle(con_handle, hid); local
72 if (conn == NULL) {
75 conn = btCoreData->AddConnection(con_handle, BT_ACL, BDADDR_NULL, hid);
79 if (conn->status!= HCI_CONN_OPEN) {
89 if (conn->currentRxPacket != NULL) {
91 " want %d \n", __func__, conn->currentRxPacket->size, length );
92 gBufferModule->free(conn->currentRxPacket);
93 conn->currentRxPacket = NULL;
94 conn
170 PostToUpper(HciConnection* conn, net_buffer* buf) argument
[all...]
/haiku/src/kits/media/experimental/
H A DMediaClientNode.cpp43 BMediaClientNode::SendBuffer(BBuffer* buffer, BMediaConnection* conn) argument
45 return BBufferProducer::SendBuffer(buffer, conn->_Source(), conn->_Destination());
151 BMediaInput* conn = fOwner->_FindInput(dest); local
152 if (conn == NULL)
155 return conn->AcceptFormat(format);
172 BMediaInput* conn = fOwner->InputAt(*cookie); local
173 if (conn != NULL) {
174 *input = conn->fConnection._BuildMediaInput();
207 BMediaInput* conn local
224 BMediaInput* conn = fOwner->_FindInput(dest); local
252 BMediaInput* conn = fOwner->_FindInput(dest); local
309 BMediaOutput* conn = fOwner->_FindOutput(source); local
349 BMediaOutput* conn = fOwner->OutputAt(*cookie); local
374 BMediaOutput* conn = fOwner->_FindOutput(source); local
403 BMediaOutput* conn = fOwner->_FindOutput(source); local
435 BMediaOutput* conn = fOwner->_FindOutput(source); local
473 BMediaOutput* conn = fOwner->_FindOutput(source); local
499 BMediaOutput* conn = fOwner->_FindOutput(source); local
614 BMediaInput* conn = fOwner->_FindInput(dest); local
[all...]
H A DMediaClient.cpp23 ConnReleaser(BMediaConnection* conn) argument
25 fConn(conn) {}
555 BMediaClient::_DisconnectConnection(BMediaConnection* conn) argument
559 if (conn->Client() != this)
562 const media_connection& handle = conn->Connection();
578 BMediaClient::_ReleaseConnection(BMediaConnection* conn) argument
580 if (conn->Client() != this)
583 if (conn->Connection().IsInput()) {
584 InputReleaser obj(dynamic_cast<BMediaInput*>(conn));
588 OutputReleaser obj(dynamic_cast<BMediaOutput*>(conn));
[all...]
/haiku/headers/private/bluetooth/
H A DbtCoreData.h91 HciConnection* conn; member in struct:L2capChannel
119 HciConnection* conn; member in struct:L2capFrame
151 void (*SetAclBuffer)(struct HciConnection* conn,
153 void (*SetAclExpectedSize)(struct HciConnection* conn,
155 void (*AclPutting)(struct HciConnection* conn,
157 bool (*AclComplete)(struct HciConnection* conn);
158 bool (*AclOverFlowed)(struct HciConnection* conn);
164 struct L2capChannel* (*AddChannel)(struct HciConnection* conn,
166 void (*RemoveChannel)(struct HciConnection* conn,
168 struct L2capChannel* (*ChannelBySourceID)(struct HciConnection* conn,
[all...]
/haiku/src/tests/kits/net/service/
H A Dproxy.py53 conn = self._connections.get(target.netloc, None)
54 if conn is None:
55 conn = http.client.HTTPConnection(target.netloc)
84 conn.request(self.command, target_path, request_body, client_headers)
85 response = conn.getresponse()
104 conn.close()
109 self._connections[target.netloc] = conn
/haiku/src/add-ons/print/transports/ipp/
H A DIppSetupDlg.cpp117 IppURLConnection conn(BUrl(url->Text()));
118 conn.setIppRequest(request);
119 conn.setRequestProperty("Connection", "close");
121 HTTP_RESPONSECODE response_code = conn.getResponseCode();
123 const char *content_type = conn.getContentType();
126 const IppContent *ipp_response = conn.getIppResponse();
138 error_msg = conn.getResponseMessage();
H A DIppTransport.cpp101 IppURLConnection conn(url);
102 conn.setIppRequest(request);
103 conn.setRequestProperty("Connection", "close");
107 HTTP_RESPONSECODE response_code = conn.getResponseCode();
109 const char *content_type = conn.getContentType();
111 const IppContent *ipp_response = conn.getIppResponse();
122 error_msg = conn.getResponseMessage();
/haiku/src/tests/kits/net/netservices2/
H A Dproxy.py53 conn = self._connections.get(target.netloc, None)
54 if conn is None:
55 conn = http.client.HTTPConnection(target.netloc)
84 conn.request(self.command, target_path, request_body, client_headers)
85 response = conn.getresponse()
104 conn.close()
109 self._connections[target.netloc] = conn
/haiku/src/add-ons/kernel/drivers/disk/virtual/nbd/
H A Dnbd-server.py85 def __init__(self, conn):
86 conn = buffsock(conn)
88 header = conn.recv(struct.calcsize(template))
93 self.data = conn.recv(self.len)
124 print "got conn on", addr
/haiku/src/add-ons/kernel/file_systems/nfs4/
H A DConnection.cpp589 Connection* conn = CreateObject(address);
590 if (conn == NULL)
594 if (conn->fWaitCancel < B_OK) {
595 result = conn->fWaitCancel;
596 delete conn;
600 result = conn->Connect();
602 delete conn;
606 *_connection = conn;
619 Connection* conn = CreateObject(address);
620 if (conn
[all...]
/haiku/headers/private/media/experimental/
H A DMediaClient.h157 status_t _DisconnectConnection(BMediaConnection* conn);
158 status_t _ReleaseConnection(BMediaConnection* conn);

Completed in 255 milliseconds

12