Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 25 of 165) sorted by relevance

1234567

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dnet.c50 sock->netconn = conn; in NetconnSetSock()
51 conn->sock = (void *)sock; in NetconnSetSock()
124 conn->pcb = SpungePcbNew(conn, inst); in FillpNetconnAlloc()
127 DympFree(conn); in FillpNetconnAlloc()
131 conn->pcb->conn = conn; in FillpNetconnAlloc()
141 conn->flagsReverse = 0; in FillpNetconnAlloc()
144 conn->iovCount = 0; in FillpNetconnAlloc()
146 return conn; in FillpNetconnAlloc()
171 DympFree(conn); in FillpNetconnDestroy()
238 conn->lastErr = err; in FillpNetconnSetSafeErr()
[all …]
H A Dpcb.c104 if (conn->iovCount == 0) { in SpungePcbSendmsgInner()
110 mh.msg_iov = conn->sendIov; in SpungePcbSendmsgInner()
113 if (conn->iovCount == 1) { in SpungePcbSendmsgInner()
134 … ret = spcb->fpcb.sendFunc(conn, conn->sendIov[i].iov_base, conn->sendIov[i].iov_len, spcb); in SpungePcbSendmsgInner()
149 conn->iovCount = 0; in SpungePcbSendmsgInner()
165 conn = (struct FtNetconn *)spcb->conn; in SpungePcbSendmsg()
185 conn->sendIov[conn->iovCount].iov_len = (size_t)(FILLP_UINT)size; in SpungePcbSendmsg()
186 conn->sendIov[conn->iovCount].iov_base = (void *)buf; in SpungePcbSendmsg()
187 conn->iovCount++; in SpungePcbSendmsg()
214 pcb->conn = argConn; in SpungePcbNew()
[all …]
H A Dspunge_stack.c115 FillpNetconnDestroy(conn); in SpungeFreeAcceptBox()
344 if ((conn == FILLP_NULL_PTR) || (conn->pcb == FILLP_NULL_PTR)) { in SpungeConnCheckUnsendBoxEmpty()
383 SpungeConnClosed(conn); in SpungeDestroyNoWait()
403 pcb = &conn->pcb->fpcb; in SpungeCheckDisconn()
405 connState = NETCONN_GET_STATE(conn); in SpungeCheckDisconn()
423 sendPcb = &conn->pcb->fpcb.send; in SpungeCheckDisconn()
434 conn->sendBufRunOut = FILLP_TRUE; in SpungeCheckDisconn()
463 if (NetconnIsConnectTimeout(conn)) { in SpungeSendConnectMsg()
534 if (conn->sock == FILLP_NULL_PTR) { in SpungeConnClosed()
539 if (conn->pcb == FILLP_NULL_PTR) { in SpungeConnClosed()
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/
H A Dtrans_tcp_direct_listener.c94 conn->channelId, conn->appInfo.fd); in StartVerifySession()
97 …SetSessionKeyByChanId(conn->channelId, conn->appInfo.sessionKey, sizeof(conn->appInfo.sessionKey)); in StartVerifySession()
105 conn->channelId, conn->appInfo.fd); in StartVerifySession()
117 conn->channelId, conn->appInfo.fd); in StartVerifySession()
127 if (conn->isMeta) { in StartVerifySession()
135 conn->channelId, conn->appInfo.fd, ret); in StartVerifySession()
166 conn->timeout = 0; in CreateSessionConnNode()
290 …(void)memset_s(conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.se… in TransProcDataRes()
303 int32_t ret = TransTdcSrvRecvData(conn->listenMod, conn->channelId, conn->authHandle.type); in ProcessSocketInEvent()
310 TransProcDataRes(conn->listenMod, ret, conn->channelId, fd); in ProcessSocketInEvent()
[all …]
H A Dtrans_tcp_direct_message.c287 …(void)memset_s(conn->appInfo.sessionKey, sizeof(conn->appInfo.sessionKey), 0, sizeof(conn->appInfo… in TransTdcPostBytes()
392 …(void)memset_s(conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.se… in NotifyChannelOpened()
401 …(void)memset_s(conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.se… in NotifyChannelOpened()
417 …(void)memset_s(conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.se… in NotifyChannelOpened()
426 …(void)memset_s(conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.se… in NotifyChannelOpened()
439 …(void)memset_s(&conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.s… in NotifyChannelBind()
503 conn->appInfo.myData.pkgName, conn->appInfo.myData.pid, conn->channelId, errCode); in NotifyChannelOpenFailedBySessionConn()
518 …(void)memset_s(conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.se… in NotifyChannelOpenFailed()
643 …(void)memset_s(conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.se… in OpenDataBusReply()
647 …(void)memset_s(conn.appInfo.sessionKey, sizeof(conn.appInfo.sessionKey), 0, sizeof(conn.appInfo.se… in OpenDataBusReply()
[all …]
H A Dtrans_tcp_direct_sessionconn.c146 if (conn == NULL) { in CreateNewSessinConn()
152 SoftBusFree(conn); in CreateNewSessinConn()
157 conn->timeout = 0; in CreateNewSessinConn()
158 conn->req = -1; in CreateNewSessinConn()
161 conn->listenMod = module; in CreateNewSessinConn()
162 return conn; in CreateNewSessinConn()
208 SessionConn *conn = NULL; in SetAppInfoById() local
226 SessionConn *conn = NULL; in GetAppInfoById() local
244 SessionConn *conn = NULL; in SetAuthHandleByChanId() local
333 if (conn == NULL) { in TransTdcAddSessionConn()
[all …]
H A Dtrans_tcp_direct_p2p.c424 if (conn == NULL) { in OnAuthConnOpened()
439 reqNum = conn->req; in OnAuthConnOpened()
465 if (conn == NULL) { in OnAuthConnOpenFailed()
746 if (conn == NULL) { in OnVerifyP2pReply()
761 …fd = ConnectTcpDirectPeer(conn->appInfo.peerData.addr, conn->appInfo.peerData.port, conn->appInfo.… in OnVerifyP2pReply()
767 conn->appInfo.fd = fd; in OnVerifyP2pReply()
987 if (*conn == NULL) { in BuildSessionConn()
995 *conn = NULL; in BuildSessionConn()
1002 *conn = NULL; in BuildSessionConn()
1040 SoftBusFree(conn); in OpenP2pDirectChannel()
[all …]
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/
H A Dl2cap_inst.c66 L2capConnection *conn = NULL; in L2capGetConnection() local
73 return conn; in L2capGetConnection()
85 L2capConnection *conn = NULL; in L2capGetConnection2() local
92 return conn; in L2capGetConnection2()
115 return conn; in L2capGetConnection3()
124 return conn; in L2capGetConnection3()
167 if ((*conn) == NULL) { in L2capGetChannel3()
391 if (conn == NULL) { in L2capNewConnection()
403 conn->discTimer = NULL; in L2capNewConnection()
406 return conn; in L2capNewConnection()
[all …]
H A Dl2cap_le.c147 return conn; in L2capLeGetConnection2()
323 if (conn == NULL) { in L2capLeNewConnection()
330 conn->role = role; in L2capLeNewConnection()
335 return conn; in L2capLeNewConnection()
366 L2capFree(conn); in L2capLeDeleteConnection()
646 if (conn == NULL) { in L2capLeProcessConnectionParameterUpdateReq()
679 if (conn == NULL) { in L2capLeProcessConnectionParameterUpdateRsp()
707 if (conn == NULL) { in L2capLeProcessCreditBasedConnectionReq()
769 if (conn == NULL) { in L2capLeProcessCreditBasedConnectionRsp()
825 if (conn == NULL) { in L2capLeProcessDisconnectionReq()
[all …]
H A Dl2cap_core.c673 if (conn == NULL) { in L2capErfcMonitorTimeout()
723 if (conn == NULL) { in L2capErfcRetransmissionTimeout()
1450 if (conn == NULL) { in L2capProcessConfigurationReq()
1519 if (conn == NULL) { in L2capProcessConfigurationRsp()
1581 if (conn == NULL) { in L2capProcessConnectionReq()
1643 if (conn == NULL) { in L2capProcessConnectionRsp()
1705 if (conn == NULL) { in L2capProcessDisconnectionReq()
1752 if (conn == NULL) { in L2capProcessDisconnectionRsp()
1789 if (conn == NULL) { in L2capProcessInformationReq()
1829 if (conn == NULL) { in L2capProcessInformationRsp()
[all …]
H A Dl2cap.c31 L2capConnection *conn = NULL; in L2CAP_ConnectReq() local
50 conn = L2capGetConnection2(addr); in L2CAP_ConnectReq()
51 if (conn == NULL) { in L2CAP_ConnectReq()
83 L2capConnection *conn = NULL; in L2CAP_ConnectRsp() local
118 L2capConnection *conn = NULL; in L2CAP_ConfigReq() local
183 L2capConnection *conn = NULL; in L2CAP_ConfigRsp() local
239 L2capConnection *conn = NULL; in L2CAP_DisconnectionReq() local
263 L2capConnection *conn = NULL; in L2CAP_DisconnectionRsp() local
288 L2capConnection *conn = NULL; in L2CAP_LocalBusy() local
432 if (conn == NULL) { in L2CAP_EchoReq()
[all …]
H A Dl2cap_core.h70 int L2capSendEchoReq(L2capConnection *conn, const uint8_t *data, uint16_t dataLen);
71 int L2capSendEchoRsp(L2capConnection *conn, uint8_t ident, const uint8_t *data, uint16_t dataLen);
72 int L2capSendConnectionReq(L2capConnection *conn, L2capChannel *chan);
74 int L2capSendConfigurationReq(L2capConnection *conn, const L2capChannel *chan);
76 …const L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t result, const L2capConfig…
77 int L2capSendDisconnectionReq(L2capConnection *conn, L2capChannel *chan);
78 int L2capSendDisconnectionRsp(const L2capConnection *conn, const L2capChannel *chan, uint8_t ident);
79 int L2capSendInformationReq(L2capConnection *conn, uint16_t type);
80 int L2capSendInformationRsp(const L2capConnection *conn, uint8_t ident, uint16_t infoType);
82 int L2capSendSFrame(const L2capConnection *conn, L2capChannel *chan, uint8_t pBit, uint8_t fBit, ui…
[all …]
/ohos5.0/foundation/filemanagement/user_file_service/test/fuzztest/fileaccessextconnection_fuzzer/
H A Dfileaccessextconnection_fuzzer.cpp38 conn->OnAbilityDisconnectDone(element, 0); in OnAbilityDisconnectDoneFuzzTest()
44 conn->IsExtAbilityConnected(); in IsExtAbilityConnectedFuzzTest()
50 conn->GetFileExtProxy(); in GetFileExtProxyFuzzTest()
64 conn->DisconnectFileExtAbility(); in DisconnectFileExtAbility()
75 if (conn == nullptr) { in LLVMFuzzerTestOneInput()
79 OHOS::OnAbilityConnectDoneFuzzTest(conn); in LLVMFuzzerTestOneInput()
80 OHOS::OnAbilityDisconnectDoneFuzzTest(conn); in LLVMFuzzerTestOneInput()
81 OHOS::IsExtAbilityConnectedFuzzTest(conn); in LLVMFuzzerTestOneInput()
82 OHOS::GetFileExtProxyFuzzTest(conn); in LLVMFuzzerTestOneInput()
83 OHOS::ConnectFileExtAbility(conn); in LLVMFuzzerTestOneInput()
[all …]
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/test/unittest/
H A Dvsync_distributor_test.cpp72 ASSERT_EQ(VSyncDistributorTest::vsyncDistributor->AddConnection(conn), VSYNC_ERROR_OK);
111 VSyncDistributorTest::vsyncDistributor->AddConnection(conn);
150 VSyncDistributorTest::vsyncDistributor->AddConnection(conn);
164 VSyncDistributorTest::vsyncDistributor->AddConnection(conn);
203 VSyncDistributorTest::vsyncDistributor->AddConnection(conn);
217 VSyncDistributorTest::vsyncDistributor->AddConnection(conn);
249 VSyncDistributorTest::vsyncDistributor->AddConnection(conn);
305 auto res = VSyncDistributorTest::vsyncDistributor->SetUiDvsyncSwitch(true, conn);
320 auto res = VSyncDistributorTest::vsyncDistributor->SetUiDvsyncSwitch(false, conn);
350 auto res = VSyncDistributorTest::vsyncDistributor->SetUiDvsyncSwitch(true, conn);
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/
H A Dtrans_tcp_direct_message_static_test.cpp91 conn->channelId = 1; in TestSetSessionConn()
93 conn->timeout = 0; in TestSetSessionConn()
96 conn->requestId = 1; in TestSetSessionConn()
101 return conn; in TestSetSessionConn()
158 SoftBusFree(conn);
159 conn = nullptr;
194 SoftBusFree(conn);
195 conn = nullptr;
512 SoftBusFree(conn);
666 SoftBusFree(conn);
[all …]
H A Dtrans_core_tcp_direct_test.cpp91 if (conn == nullptr) { in TestSetSessionConn()
97 conn->channelId = 1; in TestSetSessionConn()
99 conn->timeout = 0; in TestSetSessionConn()
102 conn->requestId = 0; in TestSetSessionConn()
106 return conn; in TestSetSessionConn()
543 conn->timeout = 0;
546 conn->requestId = 0;
566 SoftBusFree(conn);
588 conn->channelId = 3;
590 conn->timeout = 0;
[all …]
H A Dtrans_tcp_direct_p2p_test.cpp89 conn->channelId = 1; in TestSetSessionConn()
91 conn->timeout = 0; in TestSetSessionConn()
92 conn->req = 1; in TestSetSessionConn()
94 conn->requestId = 1; in TestSetSessionConn()
100 return conn; in TestSetSessionConn()
464 SoftBusFree(conn);
465 conn = nullptr;
499 SoftBusFree(conn);
500 conn = nullptr;
575 SoftBusFree(conn);
[all …]
H A Dtrans_tcp_direct_message_append_test.cpp112 if (conn == nullptr) { in TestSetSessionConn()
115 conn->serverSide = true; in TestSetSessionConn()
116 conn->appInfo.fd = TEST_FD; in TestSetSessionConn()
128 conn->timeout = 0; in TestSetSessionConn()
129 conn->req = INVALID_VALUE; in TestSetSessionConn()
132 conn->requestId = 0; in TestSetSessionConn()
136 conn->appInfo.linkType = 1; in TestSetSessionConn()
145 return conn; in TestSetSessionConn()
627 conn->serverSide = false;
669 ReleaseSessionConn(conn);
[all …]
/ohos5.0/base/powermgr/battery_manager/charger/src/dev/
H A Ddrm_driver.cpp106 if (conn.encoder_id != 0) { in GetCrtc()
142 if (conn == nullptr) { in GetFirstConnector()
145 if (conn->count_modes > 0 && conn->connection == DRM_MODE_CONNECTED) { in GetFirstConnector()
146 return conn; in GetFirstConnector()
158 if (conn == nullptr) { in GetConnectorByType()
161 …if (conn->connector_type == type && conn->count_modes > 0 && conn->connection == DRM_MODE_CONNECTE… in GetConnectorByType()
162 return conn; in GetConnectorByType()
181 if (conn != nullptr) { in GetConnector()
186 if (conn == nullptr) { in GetConnector()
190 if (conn == nullptr) { in GetConnector()
[all …]
/ohos5.0/base/update/updater/services/ui/driver/
H A Ddrm_driver.cpp103 if (conn.encoder_id != 0) { in GetCrtc()
139 if (conn == nullptr) { in GetFirstConnector()
144 return conn; in GetFirstConnector()
146 drmModeFreeConnector(conn); in GetFirstConnector()
156 if (conn == nullptr) { in GetConnectorByType()
162 return conn; in GetConnectorByType()
182 if (conn != nullptr) { in GetConnector()
187 if (conn == nullptr) { in GetConnector()
191 if (conn == nullptr) { in GetConnector()
205 return conn; in GetConnector()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dhttp1.rs38 mut conn: Http1Conn<S>, in request()
55 &mut conn, in request()
94 conn: &mut Http1Conn<S>, in encode_various_body()
138 conn: &mut Http1Conn<S>, in encode_request_part()
172 conn: Http1Conn<S>, in decode_response()
185 conn.shutdown() in decode_response()
204 conn.shutdown() in decode_response()
212 conn.shutdown(); in decode_response()
224 conn: &mut Http1Conn<S>, in encode_body()
254 conn: &mut Http1Conn<S>, in read_body_result()
[all …]
/ohos5.0/foundation/ability/ability_lite/frameworks/abilitymgr_lite/src/
H A Dability_service_manager.cpp49 int AbilityServiceManager::ConnectAbility(const Want &want, const IAbilityConnection &conn, in ConnectAbility() argument
52 if (conn.OnAbilityDisconnectDone == nullptr || conn.OnAbilityConnectDone == nullptr) { in ConnectAbility()
57 StoreArgs *storeArgs = AddStoreArgs(conn, storeArg); in ConnectAbility()
81 StoreArgs *storeArgs = RemoveStoreArgs(&conn, nullptr); in DisconnectAbility()
95 if (GetStoreArgs(conn) != nullptr) { in AddStoreArgs()
104 storeArgs->conn = &conn; in AddStoreArgs()
112 StoreArgs *AbilityServiceManager::GetStoreArgs(const IAbilityConnection &conn) const in GetStoreArgs()
115 if (storeArgs->conn == &conn) { in GetStoreArgs()
126 storeArgs = GetStoreArgs(*conn); in RemoveStoreArgs()
137 if (storeArgs == nullptr || storeArgs->conn == nullptr || in ConnectAbilityCallBack()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
H A Dnet.h93 void FillpNetconnSetSafeErr(struct FtNetconn *conn, FILLP_INT err);
95 void FillpNetconnSetState(struct FtNetconn *conn, FILLP_UINT8 state);
103 void NetconnSetPktSize(struct FtNetconn *conn, FILLP_UINT32 pktSize);
104 void NetconnSetOpersiteRate(struct FtNetconn *conn, FILLP_UINT32 rate);
105 void NetconnSetSlowStart(struct FtNetconn *conn, FILLP_BOOL slowStart);
106 void NetconnSetPackInterval(struct FtNetconn *conn, FILLP_UINT32 interval);
107 void NetconnSetLocalPort(struct FtNetconn *conn, FILLP_INT port);
108 void NetconnSetAddrType(struct FtNetconn *conn, FILLP_UINT16 addrType);
112 FILLP_BOOL NetconnIsConnectTimeout(struct FtNetconn *conn);
114 void NetconnSetSock(struct FtSocket *sock, struct FtNetconn *conn);
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_conn.c387 conn->peerFcAlgs = 0; in FillpDecodeConnReqAckClientPara()
388 conn->peerCharacters = 0; in FillpDecodeConnReqAckClientPara()
1122 if (isWr || conn->peerWrSet || (isAck && conn->shutdownRdSet && conn->shutdownWrSet)) { in FillpStateClosingHandleFinInput()
1134 SpungeConnClosed(conn); in FillpStateClosingHandleFinInput()
1212 conn->peerRdSet = conn->peerWrSet = FILLP_TRUE; in FillpHandleFinRst()
1219 SpungeConnClosed(conn); in FillpHandleFinRst()
1229 conn = FILLP_GET_CONN(pcb); in FillpHandleFin()
1403 ret = pcb->sendFunc(conn, (char *)&req, sizeof(struct FillpPktConnReq), conn->pcb); in FillpSendConnReq()
1675 ret = pcb->sendFunc(conn, (FILLP_CHAR *)g_rawMsg, encMsgLen, conn->pcb); in FillpSendConnConfirm()
1866 if (conn->shutdownWrSet && conn->sendBufRunOut) { in FillpSendFin()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_adapter_standard.cpp174 auto expireTime = conn->GetExpireTime() > now ? conn->GetExpireTime() : now; in GetExpireTime()
192 conn = connect; in SendData()
198 conn = connect; in SendData()
201 if (conn == nullptr) { in SendData()
213 GetExpireTime(conn); in SendData()
224 if (conn != nullptr) { in OpenConnect()
244 conn = connect; in StartCloseSessionTask()
248 if (conn == nullptr) { in StartCloseSessionTask()
252 auto expireTime = conn->GetExpireTime() > now ? conn->GetExpireTime() : now; in StartCloseSessionTask()
284 if (conn.empty()) { in GetCloseSessionTask()
[all …]

1234567