| /foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/ |
| H A D | trans_tcp_direct_message.c | 244 static void SendFailToFlushDevice(SessionConn *conn) in SendFailToFlushDevice() argument
281 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in TransTdcPostBytes() local
307 GetChannelInfoFromConn(ChannelInfo *info, SessionConn *conn, int32_t channelId) GetChannelInfoFromConn() argument
386 SessionConn conn; NotifyChannelOpened() local
439 SessionConn conn; NotifyChannelBind() local
465 NotifyChannelOpenFailedBySessionConn(const SessionConn *conn, int32_t errCode) NotifyChannelOpenFailedBySessionConn() argument
516 SessionConn conn; NotifyChannelOpenFailed() local
526 TransTdcPostFastData(SessionConn *conn) TransTdcPostFastData() argument
622 SessionConn conn; OpenDataBusReply() local
727 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); GetSessionConnFromDataBusRequest() local
746 NotifyFastDataRecv(SessionConn *conn, int32_t channelId) NotifyFastDataRecv() argument
815 ReportTransEventExtra( TransEventExtra *extra, int32_t channelId, SessionConn *conn, NodeInfo *nodeInfo, char *peerUuid) ReportTransEventExtra() argument
908 HandleDataBusReply( SessionConn *conn, int32_t channelId, TransEventExtra *extra, uint32_t flags, uint64_t seq) HandleDataBusReply() argument
934 SessionConn *conn = GetSessionConnFromDataBusRequest(channelId, request); OpenDataBusRequest() local
[all...] |
| H A D | trans_tcp_direct_p2p.c | 548 SessionConn *conn = NULL; in OnAuthConnOpened() local
590 SessionConn *conn = NULL; OnAuthConnOpenFailed() local
818 SessionConn *conn = NULL; AddHmlTrigger() local
867 SessionConn *conn = NULL; OnVerifyP2pReply() local
988 OpenNewAuthConn(const AppInfo *appInfo, SessionConn *conn, int32_t newChannelId, ConnectType type) OpenNewAuthConn() argument
1025 TransProxyGetAuthIdByUuid(SessionConn *conn) TransProxyGetAuthIdByUuid() argument
1042 StartVerifyP2pInfo(const AppInfo *appInfo, SessionConn *conn, ConnectType type) StartVerifyP2pInfo() argument
1093 CopyAppInfoFastTransData(SessionConn *conn, const AppInfo *appInfo) CopyAppInfoFastTransData() argument
1118 BuildSessionConn(const AppInfo *appInfo, SessionConn **conn) BuildSessionConn() argument
1143 StartTransP2pDirectListener(ConnectType type, SessionConn *conn, const AppInfo *appInfo) StartTransP2pDirectListener() argument
1163 SessionConn *conn = NULL; OpenP2pDirectChannel() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | auto_launch.cpp | 1092 IKvDBConnection *conn = KvDBManager::GetDatabaseConnection(*properties, errCode, false); OpenKvConnection() local
1107 auto conn = RelationalStoreInstance::GetDatabaseConnection(*properties, errCode, false); OpenRelationalConnection() local
1290 RelationalStoreConnection *conn = static_cast<RelationalStoreConnection *>(autoLaunchItem.conn); RegisterRelationalObserver() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_multi_ver_p2p_sync_test.cpp | 88 auto conn = KvDBManager::GetDatabaseConnection(prop, errCode); in GetConnection() local
96 int GetDataFromConnection(IKvDBConnection *conn, const Key &key, Value &value) in GetDataFromConnection() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | kv_store_nb_delegate_impl.cpp | 68 KvStoreNbDelegateImpl::KvStoreNbDelegateImpl(IKvDBConnection *conn, const std::string &storeId) in KvStoreNbDelegateImpl() argument
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/ |
| H A D | l2cap_core.c | 28 static uint8_t L2capGetNewIdentifier(L2capConnection *conn) in L2capGetNewIdentifier() argument
60 L2capConnection *conn = NULL; in L2capResponseTimeout() local
107 L2capSendEchoReq(L2capConnection *conn, const uint8_t *data, uint16_t dataLen) L2capSendEchoReq() argument
122 L2capSendEchoRsp(L2capConnection *conn, uint8_t ident, const uint8_t *data, uint16_t dataLen) L2capSendEchoRsp() argument
135 L2capSendConnectionReq(L2capConnection *conn, L2capChannel *chan) L2capSendConnectionReq() argument
157 L2capSendConnectionRsp(L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t result, uint16_t status) L2capSendConnectionRsp() argument
181 L2capSendConfigurationReq(L2capConnection *conn, const L2capChannel *chan) L2capSendConfigurationReq() argument
277 L2capSendConfigurationRsp( const L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t result, const L2capConfigInfo *cfg) L2capSendConfigurationRsp() argument
326 L2capSendDisconnectionReq(L2capConnection *conn, L2capChannel *chan) L2capSendDisconnectionReq() argument
348 L2capSendDisconnectionRsp(const L2capConnection *conn, const L2capChannel *chan, uint8_t ident) L2capSendDisconnectionRsp() argument
366 L2capSendInformationReq(L2capConnection *conn, uint16_t type) L2capSendInformationReq() argument
385 L2capSendInformationRsp(const L2capConnection *conn, uint8_t ident, uint16_t infoType) L2capSendInformationRsp() argument
507 L2capSendSFrame(const L2capConnection *conn, L2capChannel *chan, uint8_t pBit, uint8_t fBit, uint8_t sBit) L2capSendSFrame() argument
586 L2capErfcTxOneFrame(L2capConnection *conn, L2capChannel *chan, uint8_t txSeq) L2capErfcTxOneFrame() argument
665 L2capConnection *conn = NULL; L2capErfcMonitorTimeout() local
714 L2capConnection *conn = NULL; L2capErfcRetransmissionTimeout() local
762 L2capErfcDoTx(L2capConnection *conn, L2capChannel *chan, uint16_t txWindow, const ListNode *node) L2capErfcDoTx() argument
809 L2capErfcTx(L2capConnection *conn, L2capChannel *chan) L2capErfcTx() argument
849 L2capStreamTx(const L2capConnection *conn, L2capChannel *chan) L2capStreamTx() argument
938 L2capSendIFrame(L2capConnection *conn, L2capChannel *chan, Packet *pkt) L2capSendIFrame() argument
1004 L2capErfcProcessSFrame(L2capConnection *conn, L2capChannel *chan, uint8_t ctrl[2]) L2capErfcProcessSFrame() argument
1090 L2capErfcProcessIFrame(L2capConnection *conn, L2capChannel *chan, const Packet *pkt, uint8_t ctrl[2]) L2capErfcProcessIFrame() argument
1264 L2capConfigurationRspReject(const L2capConnection *conn, uint8_t ident, uint16_t rcid) L2capConfigurationRspReject() argument
1283 L2capConfigurationRspUnknownOptions( const L2capConnection *conn, uint8_t ident, uint16_t rcid, L2capOptions *unknown) L2capConfigurationRspUnknownOptions() argument
1308 L2capConfigurationRspContinuation(const L2capConnection *conn, uint8_t ident, uint16_t rcid) L2capConfigurationRspContinuation() argument
1338 L2capProcessConfigurationReqWithContinue( L2capConnection *conn, L2capChannel *chan, L2capSignalHeader *signal, const uint8_t *data, uint16_t optLength) L2capProcessConfigurationReqWithContinue() argument
1370 L2capProcessConfigurationReqContinueOption( L2capConnection *conn, L2capChannel *chan, L2capSignalHeader *signal, const uint8_t *data, uint16_t optLength) L2capProcessConfigurationReqContinueOption() argument
1392 L2capProcessConfigurationReqParse( L2capConnection *conn, L2capChannel *chan, L2capSignalHeader *signal, const uint8_t *data, uint16_t optLength) L2capProcessConfigurationReqParse() argument
1443 L2capConnection *conn = NULL; L2capProcessConfigurationReq() local
1487 L2capConfigurationReqContinuation(L2capConnection *conn, const L2capChannel *chan) L2capConfigurationReqContinuation() argument
1510 L2capConnection *conn = NULL; L2capProcessConfigurationRsp() local
1574 L2capConnection *conn = NULL; L2capProcessConnectionReq() local
1634 L2capConnection *conn = NULL; L2capProcessConnectionRsp() local
1698 L2capConnection *conn = NULL; L2capProcessDisconnectionReq() local
1745 L2capConnection *conn = NULL; L2capProcessDisconnectionRsp() local
1785 L2capConnection *conn = NULL; L2capProcessInformationReq() local
1799 L2capIncomingConnection(const L2capConnection *conn, const L2capChannel *chan) L2capIncomingConnection() argument
1824 L2capConnection *conn = NULL; L2capProcessInformationRsp() local
1878 L2capConnection *conn = NULL; L2capProcessEchoReq() local
1897 L2capConnection *conn = NULL; L2capProcessEchoRsp() local
1915 L2capConnection *conn = NULL; L2capProcessCommandReject() local
2066 L2capProcessErfcData(L2capConnection *conn, L2capChannel *chan, Packet *pkt) L2capProcessErfcData() argument
2103 L2capConnection *conn = NULL; L2capProcessData() local
2206 L2capConnection *conn = NULL; L2capConnectComplete() local
2243 L2capAclDisconnected(L2capConnection *conn, uint8_t status, uint8_t reason) L2capAclDisconnected() argument
2283 L2capConnection *conn = NULL; L2capDisconnectComplete() local
[all...] |
| H A D | l2cap_le.c | 140 L2capLeConnection *conn = NULL; in L2capLeGetConnection2() local
156 static L2capLeChannel *L2capLeGetChannel(L2capLeConnection *conn, int16_t lcid) in L2capLeGetChannel() argument
174 static void L2capLeGetChannel2(uint16_t lcid, L2capLeConnection **conn, L2capLeChannel **chan) in L2capLeGetChannel2() argument
193 static void L2capLeGetChannel3(uint16_t aclHandle, uint16_t lcid, L2capLeConnection **conn, L2capLeChanne argument
204 L2capLeGetChannel4(L2capLeConnection *conn, int16_t ident) L2capLeGetChannel4() argument
228 L2capLeConnection *conn = NULL; L2capLeGetNewLcid() local
252 L2capLeNewChannel(L2capLeConnection *conn, uint16_t lpsm, uint16_t rpsm) L2capLeNewChannel() argument
302 L2capLeDeleteChannel(L2capLeConnection *conn, L2capLeChannel *chan, uint16_t removeAcl) L2capLeDeleteChannel() argument
320 L2capLeConnection *conn = NULL; L2capLeNewConnection() local
338 L2capLeDeleteConnection(L2capLeConnection *conn) L2capLeDeleteConnection() argument
393 L2capLeConnection *conn = NULL; L2capLeResponseTimeout() local
447 L2capSendCreditBasedConnectionReq(L2capLeConnection *conn, L2capLeChannel *chan) L2capSendCreditBasedConnectionReq() argument
470 L2capSendCreditBasedConnectionRsp( L2capLeConnection *conn, L2capLeChannel *chan, uint8_t ident, uint16_t result) L2capSendCreditBasedConnectionRsp() argument
491 L2capLeSendDisconnectionReq(L2capLeConnection *conn, const L2capLeChannel *chan) L2capLeSendDisconnectionReq() argument
510 L2capLeSendDisconnectionRsp(const L2capLeConnection *conn, const L2capLeChannel *chan, uint8_t ident) L2capLeSendDisconnectionRsp() argument
527 L2capLeSendFlowControlCredit(L2capLeConnection *conn, const L2capLeChannel *chan, uint16_t credit) L2capLeSendFlowControlCredit() argument
544 L2capLeTxWithCredit(const L2capLeConnection *conn, L2capLeChannel *chan) L2capLeTxWithCredit() argument
642 L2capLeConnection *conn = NULL; L2capLeProcessConnectionParameterUpdateReq() local
675 L2capLeConnection *conn = NULL; L2capLeProcessConnectionParameterUpdateRsp() local
698 L2capLeConnection *conn = NULL; L2capLeProcessCreditBasedConnectionReq() local
759 L2capLeConnection *conn = NULL; L2capLeProcessCreditBasedConnectionRsp() local
818 L2capLeConnection *conn = NULL; L2capLeProcessDisconnectionReq() local
864 L2capLeConnection *conn = NULL; L2capLeProcessDisconnectionRsp() local
904 L2capLeConnection *conn = NULL; L2capLeProcessFlowControlCredit() local
1004 L2capLeConnection *conn = NULL; L2capLeProcessFixChannelData() local
1044 L2capLeConnection *conn = NULL; L2capLeProcessLeData() local
1111 L2capLeCleanAllChannels(L2capLeConnection *conn, uint8_t status) L2capLeCleanAllChannels() argument
1142 L2capLeAclDisconnectProcess(L2capLeConnection *conn, uint8_t status, uint8_t reason) L2capLeAclDisconnectProcess() argument
1166 L2capLeAclConnectProcess(L2capLeConnection *conn) L2capLeAclConnectProcess() argument
1187 L2capLeConnection *conn = NULL; L2capLeConnectComplete() local
1233 L2capLeConnection *conn = NULL; L2capLeDisconnectComplete() local
1257 L2capLeConnection *conn = NULL; L2CAP_LeCreditBasedConnectionReq() local
1315 L2capLeConnection *conn = NULL; L2CAP_LeCreditBasedConnectionRsp() local
1362 L2capLeConnection *conn = NULL; L2CAP_LeDisconnectionReq() local
1384 L2capLeConnection *conn = NULL; L2CAP_LeDisconnectionRsp() local
1406 L2capLeConnection *conn = NULL; L2CAP_LeSendData() local
1498 L2capLeConnection *conn = NULL; L2CAP_LeDeregisterService() local
1627 L2capLeConnection *conn = NULL; L2CAP_LeSendFixChannelData() local
1698 L2capLeConnection *conn = NULL; L2CAP_LeConnectionParameterUpdateReq() local
1754 L2capLeConnection *conn = NULL; L2CAP_LeConnectionParameterUpdateRsp() local
1803 L2capLeConnection *conn = NULL; L2CAP_LeFinalize() local
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/ |
| H A D | socket_app.c | 947 static void SockCopyAddr(struct sockaddr *addr, socklen_t *addrLen, struct FtNetconn *conn) in SockCopyAddr() argument
973 struct FtNetconn *conn = FILLP_NULL_PTR; in SockPopConn() local
1043 struct FtNetconn *conn = FILLP_NULL_PTR; in SockAccept() local
1297 struct FtNetconn *conn = FILLP_NULL_PTR; SockGetRtt() local
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| H A D | fillp_conn.c | 210 static void FillpDecodeRtt(struct FtNetconn *conn, FILLP_CONST FILLP_UCHAR *buf, FILLP_INT bufLen) in FillpDecodeRtt() argument
229 static void FillpDecodePktSize(struct FtNetconn *conn, FILLP_CONST FILLP_UCHAR *buf, FILLP_INT bufLen) in FillpDecodePktSize() argument
248 static void FillpDecodeCharacters(struct FtNetconn *conn, FILLP_CONST FILLP_UCHAR *buf, FILLP_INT bufLen) in FillpDecodeCharacters() argument
267 FillpDecodeFcAlg(struct FtNetconn *conn, FILLP_CONST FILLP_UCHAR *buf, FILLP_INT bufLen) FillpDecodeFcAlg() argument
288 FillpDecodeExtPara(FILLP_CONST FILLP_UCHAR *buf, FILLP_INT bufLen, struct FtNetconn *conn) FillpDecodeExtPara() argument
376 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpDecodeConnReqAckClientPara() local
548 FillpInitNewconnBySock(struct FtNetconn *conn, FILLP_CONST struct FtSocket *sock) FillpInitNewconnBySock() argument
559 FillpInitNewConnByConfirm(struct FillpPcb *pcb, struct FtNetconn *newConn, FILLP_CONST struct FillpPktConnConfirm *confirm, FILLP_CONST struct FtNetconn *conn, FILLP_CONST struct NetBuf *p) FillpInitNewConnByConfirm() argument
631 FillpProcessConnConfirm(struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p, FILLP_CONST struct FillpPktConnConfirm *confirm, FILLP_CONST struct FtNetconn *conn, struct SpungeInstance *inst) FillpProcessConnConfirm() argument
750 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpConnConfirmInput() local
811 FillpHandleConnConfirmAckInput(struct FtSocket *sock, struct FtNetconn *conn, struct FillpPcb *pcb, FILLP_CONST struct NetBuf *p) FillpHandleConnConfirmAckInput() argument
893 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpConnConnectionEstFailure() local
984 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpCheckConfirmAckPar() local
1047 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpConnConfirmAckInput() local
1088 ConnectingHandleFinInput(struct FillpPcb *pcb, struct FtSocket *sock, struct FtNetconn *conn, FILLP_CONST struct NetBuf *p, FILLP_CONST struct FillpFinFlags *flags) ConnectingHandleFinInput() argument
1115 FillpStateClosingHandleFinInput(struct FillpPcb *pcb, struct FtNetconn *conn, FILLP_BOOL isAck, FILLP_BOOL isWr, FILLP_BOOL *pcbFreed) FillpStateClosingHandleFinInput() argument
1138 ConnectedHandleFinInput(struct FtSocket *sock, struct FtNetconn *conn, FILLP_BOOL isWr) ConnectedHandleFinInput() argument
1208 FillpHandleFinRst(struct FtNetconn *conn, struct FtSocket *sock) FillpHandleFinRst() argument
1224 struct FtNetconn *conn = FILLP_NULL_PTR; FillpHandleFin() local
1303 struct FtNetconn *conn = FILLP_NULL_PTR; FillpFinInput() local
1379 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpSendConnReq() local
1497 struct FtNetconn *conn = FILLP_NULL_PTR; FillpSendConnReqAck() local
1651 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpSendConnConfirm() local
1701 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpSendConnConfirmAck() local
1787 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpSendFinInnerImpl() local
1861 struct FtNetconn *conn = FILLP_GET_CONN(pcb); FillpSendFin() local
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
| H A D | spunge_core.c | 125 struct FtNetconn *conn = (struct FtNetconn *)pcb->conn; in SpungeDoSendCycle() local
1111 struct FtNetconn *conn = FILLP_NULL_PTR; in FillpCalculateFairness() local
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/ohos/ |
| H A D | rs_render_service_client.cpp | 165 sptr<IVSyncConnection> conn = renderService->CreateVSyncConnection(name, token, id, windowNodeId); in CreateVSyncReceiver() local
|
| H A D | rs_render_service_connection_proxy.cpp | 308 sptr<IVSyncConnection> conn = iface_cast<IVSyncConnection>(rObj); in CreateVSyncConnection() local
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service/core/transaction/ |
| H A D | rs_render_service_connection_stub.cpp | 1069 sptr<IVSyncConnection> conn = CreateVSyncConnection(name, token, id, windowNodeID); in OnRemoteRequest() local
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_store_impl.cpp | 311 auto conn = connectionPool_->AcquireConnection(false); in SetDistributedTables() local
1489 auto conn = connectionPool_->AcquireConnection(false); in InnerBackup() local
1498 auto conn = connectionPool_->AcquireConnection(false); in InnerBackup() local
1540 auto conn = connectionPool_->AcquireConnection(assumeReadOnly); BeginExecuteSql() local
1586 SetDefaultEncryptAlgo(const ConnectionPool::SharedConn &conn, const RdbStoreConfig &config) SetDefaultEncryptAlgo() argument
2254 auto conn = connectionPool_->AcquireConnection(read); GetStatement() local
2316 auto conn = connectionPool_->AcquireConnection(false); ExchangeSlaverToMaster() local
[all...] |
| H A D | sqlite_connection.cpp | 430 CreateStatement( const std::string &sql, std::shared_ptr<Connection> conn) CreateStatement() argument
[all...] |
| /foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/ |
| H A D | rs_main_thread.cpp | 560 sptr<VSyncConnection> conn = new VSyncConnection(rsVSyncDistributor_, "rs", token->AsObject()); in Init() local
|