Home
last modified time | relevance | path

Searched refs:connection (Results 1 - 25 of 243) sorted by relevance

12345678910

/foundation/communication/dsoftbus/core/connection/ble/src/
H A Dsoftbus_conn_ble_connection.c110 ConnBleConnection *connection = (ConnBleConnection *)SoftBusCalloc(sizeof(ConnBleConnection)); in ConnBleCreateConnection() local
111 CONN_CHECK_AND_RETURN_RET_LOGW(connection != NULL, NULL, CONN_BLE, "calloc ble connection failed"); in ConnBleCreateConnection()
112 ListInit(&connection->node); in ConnBleCreateConnection()
114 connection->connectionId = 0; in ConnBleCreateConnection()
115 connection->protocol = protocol; in ConnBleCreateConnection()
116 connection->side = side; in ConnBleCreateConnection()
117 connection->fastestConnectEnable = fastestConnectEnable; in ConnBleCreateConnection()
118 if (strcpy_s(connection->addr, BT_MAC_LEN, addr) != EOK) { in ConnBleCreateConnection()
120 SoftBusFree(connection); in ConnBleCreateConnection()
156 ConnBleFreeConnection(ConnBleConnection *connection) ConnBleFreeConnection() argument
241 ConnBleConnect(ConnBleConnection *connection) ConnBleConnect() argument
274 ConnBleDisconnectNow(ConnBleConnection *connection, enum ConnBleDisconnectReason reason) ConnBleDisconnectNow() argument
337 NeedProccessOccupy(ConnBleConnection *connection, int32_t delta, uint16_t challengeCode, bool isActiveUpdateLocalRc, int32_t peerRc) NeedProccessOccupy() argument
367 ConnBleUpdateConnectionRc(ConnBleConnection *connection, uint16_t challengeCode, int32_t delta) ConnBleUpdateConnectionRc() argument
422 BleOnReferenceRequest(ConnBleConnection *connection, BleReferenceContext *referenceCount) BleOnReferenceRequest() argument
468 ConnBleOnReferenceRequest(ConnBleConnection *connection, const cJSON *json) ConnBleOnReferenceRequest() argument
493 ConnBleUpdateConnectionPriority(ConnBleConnection *connection, ConnectBlePriority priority) ConnBleUpdateConnectionPriority() argument
506 ConnBleSend(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen, int32_t module) ConnBleSend() argument
522 ConnBleRefreshIdleTimeout(ConnBleConnection *connection) ConnBleRefreshIdleTimeout() argument
530 ConnBleInnerComplementDeviceId(ConnBleConnection *connection) ConnBleInnerComplementDeviceId() argument
563 SendBasicInfo(ConnBleConnection *connection) SendBasicInfo() argument
659 ParsePeerBasicInfoInner(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen, BaseInfo *baseInfo) ParsePeerBasicInfoInner() argument
705 ParseBasicInfo(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen) ParseBasicInfo() argument
761 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleOnClientConnected() local
795 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleOnClientFailed() local
821 HandleBasicInfo(ConnBleConnection *connection, uint8_t *data, uint32_t dataLen, const BleUnifyInterface *interface) HandleBasicInfo() argument
863 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleOnDataReceived() local
948 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleOnServerAccepted() local
1000 ConnBleOccupy(ConnBleConnection *connection) ConnBleOccupy() argument
1047 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BasicInfoExchangeTimeoutHandler() local
1065 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); WaitNegotiationClosingTimeoutHandler() local
1086 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); ConnectionIdleDisconnectTimeoutHandler() local
1099 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleOnOccupyRelease() local
1115 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleRetryUpdateConnectionRc() local
[all...]
H A Dsoftbus_conn_ble_client.c50 static int32_t NotificatedConnHandler(int32_t underlayerHandle, ConnBleConnection *connection);
51 static int32_t NotificatedNetHandler(int32_t underlayerHandle, ConnBleConnection *connection);
54 static int32_t RetrySearchService(ConnBleConnection *connection, enum RetrySearchServiceReason reason);
79 ConnBleConnection *connection, enum ConnBleConnectionState expectedState, enum ConnBleConnectionState nextState) in UpdateBleConnectionStateInOrder()
81 int32_t status = SoftBusMutexLock(&connection->lock); in UpdateBleConnectionStateInOrder()
83 CONN_LOGE(CONN_BLE, "lock failed, connId=%{public}u, err=%{public}d", connection->connectionId, status); in UpdateBleConnectionStateInOrder()
87 if (connection->state != expectedState) { in UpdateBleConnectionStateInOrder()
89 connection->state, expectedState, nextState); in UpdateBleConnectionStateInOrder()
90 (void)SoftBusMutexUnlock(&connection->lock); in UpdateBleConnectionStateInOrder()
93 connection in UpdateBleConnectionStateInOrder()
78 UpdateBleConnectionStateInOrder( ConnBleConnection *connection, enum ConnBleConnectionState expectedState, enum ConnBleConnectionState nextState) UpdateBleConnectionStateInOrder() argument
98 SetConnectionHandleAndState(ConnBleConnection *connection, int32_t underlayerHandle) SetConnectionHandleAndState() argument
116 ConnGattClientConnect(ConnBleConnection *connection) ConnGattClientConnect() argument
172 ConnBleConnection *connection = ConnBleGetConnectionByHandle(underlayerHandle, CONN_SIDE_CLIENT, BLE_GATT); BleGattcConnStateCallback() local
214 ConnBleConnection *connection = ConnBleGetConnectionByHandle(ctx->underlayerHandle, CONN_SIDE_CLIENT, BLE_GATT); ConnectedMsgHandler() local
265 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); ClientWaitFastConnectTimeoutMsgHandler() local
283 RetrySearchService(ConnBleConnection *connection, enum RetrySearchServiceReason reason) RetrySearchService() argument
355 GattcGetServiceAndRegisterNotification(ConnBleConnection *connection, const CommonStatusContext *ctx) GattcGetServiceAndRegisterNotification() argument
404 ConnBleConnection *connection = ConnBleGetConnectionByHandle(ctx->underlayerHandle, CONN_SIDE_CLIENT, BLE_GATT); SearchedMsgHandler() local
455 SwitchNotifacatedHandler( enum ConnBleConnectionState state, const CommonStatusContext *ctx, ConnBleConnection *connection) SwitchNotifacatedHandler() argument
480 ConnBleConnection *connection = ConnBleGetConnectionByHandle(ctx->underlayerHandle, CONN_SIDE_CLIENT, BLE_GATT); NotificatedMsgHandler() local
515 NotificatedConnHandler(int32_t underlayerHandle, ConnBleConnection *connection) NotificatedConnHandler() argument
553 NotificatedNetHandler(int32_t underlayerHandle, ConnBleConnection *connection) NotificatedNetHandler() argument
603 ConnBleConnection *connection = ConnBleGetConnectionByHandle(underlayerHandle, CONN_SIDE_CLIENT, BLE_GATT); MtuSettedMsgHandler() local
643 ConnGattClientDisconnect(ConnBleConnection *connection, bool grace, bool refreshGatt) ConnGattClientDisconnect() argument
680 ConnBleConnection *connection = ConnBleGetConnectionByHandle(ctx->underlayerHandle, CONN_SIDE_CLIENT, BLE_GATT); DisconnectedMsgHandler() local
711 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); ClientWaitDiconnetTimeoutMsgHandler() local
732 ConnBleConnection *connection = ConnBleGetConnectionByHandle(underlayerHandle, CONN_SIDE_CLIENT, BLE_GATT); BleGattcNotificationReceiveCallback() local
779 ConnGattClientSend(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen, int32_t module) ConnGattClientSend() argument
812 ConnGattClientUpdatePriority(ConnBleConnection *connection, ConnectBlePriority priority) ConnGattClientUpdatePriority() argument
[all...]
H A Dsoftbus_conn_ble_manager.c116 typedef bool (*BleConnectionCompareFunc)(ConnBleConnection *connection, const BleConnectionCompareOption *option);
120 static void ReceivedControlData(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen);
203 static void DfxRecordBleConnectSuccess(uint32_t pId, ConnBleConnection *connection, ConnectStatistics *statistics) in DfxRecordBleConnectSuccess() argument
212 connection->protocol == BLE_GATT ? SOFTBUS_HISYSEVT_CONN_TYPE_BLE : SOFTBUS_HISYSEVT_CONN_TYPE_COC; in DfxRecordBleConnectSuccess()
217 .connectionId = (int32_t)connection->connectionId, in DfxRecordBleConnectSuccess()
219 .connProtocol = connection->protocol, in DfxRecordBleConnectSuccess()
222 .peerBleMac = connection->addr, in DfxRecordBleConnectSuccess()
306 static int32_t BleConvert2ConnectionInfo(ConnBleConnection *connection, ConnectionInfo *info) in BleConvert2ConnectionInfo() argument
308 info->isAvailable = connection->state == BLE_CONNECTION_STATE_EXCHANGED_BASIC_INFO ? 1 : 0; in BleConvert2ConnectionInfo()
309 info->isServer = connection in BleConvert2ConnectionInfo()
340 BleNotifyDeviceConnectResult(const ConnBleDevice *device, ConnBleConnection *connection, int32_t reason, bool isReuse) BleNotifyDeviceConnectResult() argument
386 BleReuseConnection(ConnBleDevice *device, ConnBleConnection *connection) BleReuseConnection() argument
483 ConnBleConnection *connection = ConnBleCreateConnection( BleConnectDeviceDirectly() local
645 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleClientConnectTimeoutOnConnectingState() local
672 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleClientConnected() local
699 BleTryReuseServerOrRetryConnect(ConnBleConnection *connection, ConnBleDevice *connectingDevice, const char *anomizeAddress) BleTryReuseServerOrRetryConnect() argument
726 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleClientConnectFailed() local
815 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleServerAccepted() local
876 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleConnectionClosed() local
910 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleConnectionResume() local
932 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleDisconnectRequest() local
942 ConnBleConnection *connection = ConnBleGetConnectionById(ctx->connectionId); BleDataReceived() local
985 ReceivedControlData(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen) ReceivedControlData() argument
1021 ConnBleConnection *connection = ConnBleGetClientConnectionByUdid(udid, (BleProtocolType)protocol); BleReuseConnectionCommon() local
1059 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); ConflictOnConnectSuccessed() local
1121 ConnBleConnection *connection = ConnBleGetConnectionByAddr( BleReset() local
1171 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleKeepAliveTimeout() local
1195 ConnBleSaveConnection(ConnBleConnection *connection) ConnBleSaveConnection() argument
1217 ConnBleRemoveConnection(ConnBleConnection *connection) ConnBleRemoveConnection() argument
1241 ConnectionCompareByConnectId(ConnBleConnection *connection, const BleConnectionCompareOption *option) ConnectionCompareByConnectId() argument
1246 ConnectionCompareByAddress(ConnBleConnection *connection, const BleConnectionCompareOption *option) ConnectionCompareByAddress() argument
1255 ConnectionCompareByUnderlayHandle(ConnBleConnection *connection, const BleConnectionCompareOption *option) ConnectionCompareByUnderlayHandle() argument
1266 ConnectionCompareByUdidIgnoreAddress(ConnBleConnection *connection, const BleConnectionCompareOption *option) ConnectionCompareByUdidIgnoreAddress() argument
1284 ConnectionCompareByUdidClientSide(ConnBleConnection *connection, const BleConnectionCompareOption *option) ConnectionCompareByUdidClientSide() argument
1403 ConnBleReturnConnection(ConnBleConnection **connection) ConnBleReturnConnection() argument
1424 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); NotifyReusedConnected() local
1441 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); ConnBleKeepAlive() local
1459 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); ConnBleRemoveKeepAlive() local
1824 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleDisconnectDevice() local
1856 ConnBleConnection *connection = ConnBleGetConnectionByUdid(NULL, hashStr, BLE_PROTOCOL_ANY); BleDisconnectDeviceNow() local
1871 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleGetConnectionInfo() local
1906 ConnBleConnection *connection = ConnBleGetConnectionByUdid(NULL, hashStr, option->bleOption.protocol); BleCheckActiveConnection() local
1925 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); BleUpdateConnection() local
2013 ConnBleConnection *connection = ConnBleGetConnectionById(connectionId); onPostBytesFinished() local
2103 ConnBleConnection *connection = ConnBleGetConnectionByHandle(underlayHandle, CONN_SIDE_ANY, BLE_GATT); ConflictPostBytes() local
2133 ConnBleConnection *connection = ConnBleGetConnectionByHandle(handle, CONN_SIDE_ANY, BLE_GATT); ConflictDisconnect() local
2252 ConnBleConnection *connection = ConnBleGetClientConnectionByUdid(udid, BLE_GATT); ConflictGetConnection() local
[all...]
/foundation/ability/ability_runtime/test/unittest/js_uiservice_uiext_connection_test/
H A Djs_uiservice_uiext_connection_test.cpp54 sptr<JSUIServiceUIExtConnection> connection = sptr<JSUIServiceUIExtConnection>::MakeSptr(env); in HWTEST_F() local
55 EXPECT_NE(connection, nullptr); in HWTEST_F()
60 connection->HandleOnAbilityConnectDone(element, remoteObject, resultCode); in HWTEST_F()
61 EXPECT_EQ(connection->napiAsyncTask_, nullptr); in HWTEST_F()
72 sptr<JSUIServiceUIExtConnection> connection = sptr<JSUIServiceUIExtConnection>::MakeSptr(env); in HWTEST_F() local
73 EXPECT_NE(connection, nullptr); in HWTEST_F()
77 connection->HandleOnAbilityDisconnectDone(element, resultCode); in HWTEST_F()
78 EXPECT_EQ(connection->serviceProxyObject_, nullptr); in HWTEST_F()
89 sptr<JSUIServiceUIExtConnection> connection = sptr<JSUIServiceUIExtConnection>::MakeSptr(env); in HWTEST_F() local
90 EXPECT_NE(connection, nullpt in HWTEST_F()
105 sptr<JSUIServiceUIExtConnection> connection = sptr<JSUIServiceUIExtConnection>::MakeSptr(env); HWTEST_F() local
121 sptr<JSUIServiceUIExtConnection> connection = sptr<JSUIServiceUIExtConnection>::MakeSptr(env); HWTEST_F() local
137 sptr<JSUIServiceUIExtConnection> connection = sptr<JSUIServiceUIExtConnection>::MakeSptr(env); HWTEST_F() local
151 sptr<JSUIServiceUIExtConnection> connection = sptr<JSUIServiceUIExtConnection>::MakeSptr(env); HWTEST_F() local
166 sptr<JSUIServiceUIExtConnection> connection = sptr<JSUIServiceUIExtConnection>::MakeSptr(env); HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/connection/br/src/
H A Dsoftbus_conn_br_connection.c118 ConnBrConnection *connection = ConnBrGetConnectionByAddr(copyMac, CONN_SIDE_CLIENT); in BrConnectStatusCallback() local
119 CONN_CHECK_AND_RETURN_LOGE(connection != NULL, CONN_BR, in BrConnectStatusCallback()
120 "connection not exist, mac=%{public}s, result=%{public}d, status=%{public}d", in BrConnectStatusCallback()
126 ConnBrReturnConnection(&connection); in BrConnectStatusCallback()
132 ListAdd(&connection->connectProcessStatus->list, &callbackStatus->node); in BrConnectStatusCallback()
134 "status=%{public}d", anomizeAddress, connection->connectionId, result, status); in BrConnectStatusCallback()
135 ConnBrReturnConnection(&connection); in BrConnectStatusCallback()
138 static int32_t StartBrClientConnect(ConnBrConnection *connection, const char *anomizeAddress) in StartBrClientConnect() argument
141 int32_t status = ConvertBtMacToBinary(connection->addr, BT_MAC_LEN, binaryAddr, BT_ADDR_LEN); in StartBrClientConnect()
144 "error=%{public}d", connection in StartBrClientConnect()
186 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); StartClientConnect() local
246 ConnBrConnection *connection = ConnBrCreateConnection(mac, CONN_SIDE_SERVER, socketHandle); CreateAndSaveConnection() local
267 ConnBrConnection *connection = CreateAndSaveConnection(socketHandle); StartServerServe() local
299 ConnBrConnection *connection = (ConnBrConnection *)SoftBusCalloc(sizeof(ConnBrConnection)); ConnBrCreateConnection() local
336 ConnBrOccupy(ConnBrConnection *connection) ConnBrOccupy() argument
354 ConnBrFreeConnection(ConnBrConnection *connection) ConnBrFreeConnection() argument
374 ConnBrConnect(ConnBrConnection *connection) ConnBrConnect() argument
392 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); NotifyUpdateConnectionRc() local
444 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); BrUpdateConnectionRc() local
471 ConnBrUpdateConnectionRc(ConnBrConnection *connection, int32_t delta) ConnBrUpdateConnectionRc() argument
477 ConnBrDisconnectNow(ConnBrConnection *connection) ConnBrDisconnectNow() argument
514 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); NotifyReferenceRequest() local
556 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); BrOnOccupyRelease() local
573 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); BrOnReferenceRequest() local
609 ConnBrOnReferenceRequest(ConnBrConnection *connection, const cJSON *json) ConnBrOnReferenceRequest() argument
626 ConnBrOnReferenceResponse(ConnBrConnection *connection, const cJSON *json) ConnBrOnReferenceResponse() argument
810 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); WaitNegotiationClosingTimeoutHandler() local
830 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); RetryNotifyReferenceHandler() local
[all...]
H A Dsoftbus_conn_br_trans.c103 "br connection read return, connection closed. connId=%{public}u, socketHandle=%{public}d", in ConnBrTransReadOneFrame()
115 "br connection read return, connectionId=%{public}u, socketHandle=%{public}d, error=%{public}d", in ConnBrTransReadOneFrame()
228 "br pack ctl message failed: memcpy connection header failed, connId=%{public}u, method=%{public}d", in ConnBrPackCtlMessage()
273 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); in ConnBrPostBytes() local
274 if (connection == NULL) { in ConnBrPostBytes()
276 "br post bytes failed: connection is not exist, connectionId=%{public}u, pid=%{public}d, " in ConnBrPostBytes()
282 int32_t status = SoftBusMutexLock(&connection->lock); in ConnBrPostBytes()
288 ConnBrReturnConnection(&connection); in ConnBrPostBytes()
292 enum ConnBrConnectionState state = connection in ConnBrPostBytes()
354 SendAckUnsafe(const ConnBrConnection *connection) SendAckUnsafe() argument
395 WaitAck(ConnBrConnection *connection) WaitAck() argument
468 ConnBrConnection *connection = ConnBrGetConnectionById(sendNode->connectionId); SendHandlerLoop() local
[all...]
H A Dsoftbus_conn_br_manager.c76 static void ReceivedControlData(ConnBrConnection *connection, const uint8_t *data, uint32_t dataLen);
138 static void DfxRecordBrConnectSuccess(uint32_t pId, ConnBrConnection *connection, ConnectStatistics *statistics) in DfxRecordBrConnectSuccess() argument
150 .connectionId = connection->connectionId, in DfxRecordBrConnectSuccess()
151 .peerBrMac = connection->addr, in DfxRecordBrConnectSuccess()
205 static int32_t Convert2ConnectionInfo(ConnBrConnection *connection, ConnectionInfo *info) in Convert2ConnectionInfo() argument
207 info->isAvailable = connection->state == BR_CONNECTION_STATE_CONNECTED ? 1 : 0; in Convert2ConnectionInfo()
208 info->isServer = connection->side == CONN_SIDE_SERVER ? 1 : 0; in Convert2ConnectionInfo()
210 if (strcpy_s(info->brInfo.brMac, BT_MAC_LEN, connection->addr) != EOK) { in Convert2ConnectionInfo()
268 const ConnBrDevice *device, ConnBrConnection *connection, bool isReuse, int32_t reason) in NotifyDeviceConnectResult()
277 if (connection in NotifyDeviceConnectResult()
267 NotifyDeviceConnectResult( const ConnBrDevice *device, ConnBrConnection *connection, bool isReuse, int32_t reason) NotifyDeviceConnectResult() argument
352 ConnBrConnection *connection = ConnBrCreateConnection(device->addr, CONN_SIDE_CLIENT, INVALID_SOCKET_HANDLE); ConnectDeviceDirectly() local
441 BrReuseConnection(ConnBrDevice *device, ConnBrConnection *connection) BrReuseConnection() argument
498 ConnBrConnection *connection = ConnBrGetConnectionById(device->connectionId); AttempReuseConnect() local
590 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); ServerAccepted() local
635 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); ClientConnected() local
680 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); IsNeedWaitCallbackError() local
706 AuthenticationFailedAndRetry(ConnBrConnection *connection, ConnBrDevice *connectingDevice, const char *anomizeAddress) AuthenticationFailedAndRetry() argument
737 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); ClientConnectFailed() local
822 ConnBrConnection *connection = ConnBrGetConnectionById(ctx->connectionId); DataReceived() local
846 ReceivedControlData(ConnBrConnection *connection, const uint8_t *data, uint32_t dataLen) ReceivedControlData() argument
889 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); ConnectionException() local
919 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); ConnectionResume() local
935 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); DisconnectRequest() local
983 ConnBrConnection *connection = ConnBrGetConnectionByAddr(g_brManager.connecting->addr, CONN_SIDE_CLIENT); Reset() local
1334 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); OnPostByteFinshed() local
1359 ConnBrSaveConnection(ConnBrConnection *connection) ConnBrSaveConnection() argument
1381 ConnBrRemoveConnection(ConnBrConnection *connection) ConnBrRemoveConnection() argument
1474 ConnBrConnection *connection = *connectionPtr; ConnBrReturnConnection() local
1539 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); BrDisconnectDevice() local
1563 ConnBrConnection *connection = ConnBrGetConnectionByAddr(option->brOption.brMac, option->brOption.sideType); BrDisconnectDeviceNow() local
1577 ConnBrConnection *connection = ConnBrGetConnectionById(connectionId); BrGetConnectionInfo() local
1607 ConnBrConnection *connection = ConnBrGetConnectionByAddr(option->brOption.brMac, option->brOption.sideType); BrCheckActiveConnection() local
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/provider/src/
H A Dgeneral_controller_provider_impl.cpp25 auto connection = connection_; in Insert() local
26 if (connection == nullptr) { in Insert()
27 LOG_ERROR("connection is nullptr"); in Insert()
30 auto proxy = connection->GetDataShareProxy(uri_, token_); in Insert()
41 auto connection = connection_; in Update() local
42 if (connection == nullptr) { in Update()
43 LOG_ERROR("connection is nullptr"); in Update()
46 auto proxy = connection->GetDataShareProxy(uri_, token_); in Update()
56 auto connection = connection_; in Delete() local
57 if (connection in Delete()
72 auto connection = connection_; InsertEx() local
88 auto connection = connection_; UpdateEx() local
104 auto connection = connection_; DeleteEx() local
120 auto connection = connection_; Query() local
136 auto connection = connection_; RegisterObserver() local
154 auto connection = connection_; UnregisterObserver() local
171 auto connection = connection_; NotifyChange() local
184 GeneralControllerProviderImpl(std::shared_ptr<DataShareConnection> connection, const Uri &uri, const sptr<IRemoteObject> &token) GeneralControllerProviderImpl() argument
[all...]
H A Dext_special_controller.cpp24 auto connection = connection_; in OpenFile() local
25 if (connection == nullptr) { in OpenFile()
26 LOG_ERROR("connection is nullptr"); in OpenFile()
29 auto proxy = connection->GetDataShareProxy(uri_, token_); in OpenFile()
39 auto connection = connection_; in OpenRawFile() local
40 if (connection == nullptr) { in OpenRawFile()
41 LOG_ERROR("connection is nullptr"); in OpenRawFile()
44 auto proxy = connection->GetDataShareProxy(uri_, token_); in OpenRawFile()
54 auto connection = connection_; in GetType() local
55 if (connection in GetType()
69 auto connection = connection_; BatchInsert() local
85 auto connection = connection_; BatchUpdate() local
100 auto connection = connection_; InsertExt() local
115 auto connection = connection_; ExecuteBatch() local
130 auto connection = connection_; NormalizeUri() local
145 auto connection = connection_; DenormalizeUri() local
160 auto connection = connection_; GetFileTypes() local
173 ExtSpecialController(std::shared_ptr<DataShareConnection> connection, const Uri &uri, const sptr<IRemoteObject> &token) ExtSpecialController() argument
[all...]
/foundation/communication/dsoftbus/tests/core/connection/ble/
H A Dble_service_connection_test.cpp117 ConnBleConnection connection; in HWTEST_F() local
123 connection.underlayerHandle = INVALID_UNDERLAY_HANDLE; in HWTEST_F()
124 connection.connectionId = 1; in HWTEST_F()
125 SoftBusMutexInit(&connection.lock, nullptr); in HWTEST_F()
126 ret = ConnGattServerDisconnect(&connection); in HWTEST_F()
129 connection.underlayerHandle = 1; in HWTEST_F()
130 connection.connectionId = 1; in HWTEST_F()
131 SoftBusMutexInit(&connection.lock, nullptr); in HWTEST_F()
133 ret = ConnGattServerDisconnect(&connection); in HWTEST_F()
136 SoftBusMutexInit(&connection in HWTEST_F()
161 ConnBleConnection connection; HWTEST_F() local
194 ConnBleConnection connection; HWTEST_F() local
228 ConnBleConnection connection; HWTEST_F() local
271 ConnBleConnection *connection = HWTEST_F() local
319 ConnBleConnection *connection = HWTEST_F() local
350 ConnBleConnection *connection = HWTEST_F() local
464 ConnBleConnection *connection = ConnBleCreateConnection(bleAddr, BLE_GATT, CONN_SIDE_SERVER, 1, false); HWTEST_F() local
486 ConnBleConnection *connection = ConnBleCreateConnection(bleAddr, BLE_GATT, CONN_SIDE_SERVER, 11, false); HWTEST_F() local
[all...]
H A Dconnection_ble_manager_test.cpp132 void LegacyBleReturnConnection(ConnBleConnection **connection) in LegacyBleReturnConnection() argument
134 (void)connection; in LegacyBleReturnConnection()
203 ConnBleConnection *connection = in HWTEST_F() local
205 ASSERT_NE(connection, NULL); in HWTEST_F()
206 connection->underlayerHandle = 3; in HWTEST_F()
207 int32_t ret = ConnBleSaveConnection(connection); in HWTEST_F()
209 g_transEventListener.onPostBytesFinished(connection->connectionId, len, pid, flag, module, seq, error); in HWTEST_F()
227 ConnBleConnection *connection = in HWTEST_F() local
229 ASSERT_NE(connection, NULL); in HWTEST_F()
230 int32_t ret = strcpy_s(connection in HWTEST_F()
270 ConnBleConnection *connection = HWTEST_F() local
357 ConnBleConnection *connection = HWTEST_F() local
385 ConnBleConnection *connection = HWTEST_F() local
435 ConnBleConnection *connection = HWTEST_F() local
730 ConnBleConnection connection; HWTEST_F() local
773 ConnBleConnection connection; HWTEST_F() local
799 ConnBleConnection *connection = (ConnBleConnection *)SoftBusCalloc(sizeof(ConnBleConnection)); HWTEST_F() local
845 ConnBleConnection *connection = (ConnBleConnection *)SoftBusCalloc(sizeof(ConnBleConnection)); HWTEST_F() local
902 ConnBleConnection *connection = (ConnBleConnection *)SoftBusCalloc(sizeof(ConnBleConnection)); HWTEST_F() local
938 ConnBleConnection *connection = ConnBleCreateConnection(bleMac, BLE_GATT, HWTEST_F() local
[all...]
/foundation/ability/ability_runtime/test/unittest/js_ui_service_extension_context_first_test/
H A Djs_ui_service_extension_context_first_test.cpp93 JSUIServiceExtensionConnection connection(env_); in HWTEST_F()
94 connection.SetConnectionId(COMMECTION_ID); in HWTEST_F()
95 EXPECT_EQ(connection.GetConnectionId(), COMMECTION_ID); in HWTEST_F()
107 JSUIServiceExtensionConnection connection(env_); in HWTEST_F()
111 connection.jsConnectionObject_ = nullptr; in HWTEST_F()
112 connection.HandleOnAbilityConnectDone(*element, token, resultCode); in HWTEST_F()
113 EXPECT_EQ(connection.jsConnectionObject_, nullptr); in HWTEST_F()
125 JSUIServiceExtensionConnection connection(env_); in HWTEST_F()
133 connection.SetJsConnectionObject(jsConnectionObject); in HWTEST_F()
134 connection in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_single_ver_natural_store_testcase.h43 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
46 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
49 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
52 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
55 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
58 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
61 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
64 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
67 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
70 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
[all...]
H A Ddistributeddb_storage_rd_single_ver_natural_store_testcase.cpp38 RdSingleVerNaturalStoreConnection *&connection) in SyncDatabaseOperate001()
42 DataBaseCommonPutOperate(store, connection, option); in SyncDatabaseOperate001()
53 RdSingleVerNaturalStoreConnection *&connection) in SyncDatabaseOperate003()
57 DataBaseCommonDeleteOperate(store, connection, option); in SyncDatabaseOperate003()
68 RdSingleVerNaturalStoreConnection *&connection) in SyncDatabaseOperate005()
72 DataBaseCommonGetOperate(store, connection, option); in SyncDatabaseOperate005()
83 RdSingleVerNaturalStoreConnection *&connection) in SyncDatabaseOperate006()
107 EXPECT_EQ(connection->Put(option, key1, value1), E_OK); in SyncDatabaseOperate006()
108 EXPECT_EQ(connection->Put(option, key2, value2), E_OK); in SyncDatabaseOperate006()
109 EXPECT_EQ(connection in SyncDatabaseOperate006()
37 SyncDatabaseOperate001(RdSingleVerNaturalStore *&store, RdSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate001() argument
52 SyncDatabaseOperate003(RdSingleVerNaturalStore *&store, RdSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate003() argument
67 SyncDatabaseOperate005(RdSingleVerNaturalStore *&store, RdSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate005() argument
82 SyncDatabaseOperate006(RdSingleVerNaturalStore *&store, RdSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate006() argument
148 DataBaseCommonPutOperate(RdSingleVerNaturalStore *&store, RdSingleVerNaturalStoreConnection *&connection, IOption option) DataBaseCommonPutOperate() argument
237 DataBaseCommonDeleteOperate(RdSingleVerNaturalStore *&store, RdSingleVerNaturalStoreConnection *&connection, IOption option) DataBaseCommonDeleteOperate() argument
281 DataBaseCommonGetOperate(RdSingleVerNaturalStore *&store, RdSingleVerNaturalStoreConnection *&connection, IOption option) DataBaseCommonGetOperate() argument
[all...]
H A Ddistributeddb_storage_single_ver_natural_store_testcase.cpp47 SQLiteSingleVerNaturalStoreConnection *&connection) in GetSyncData001()
64 EXPECT_EQ(connection->Put(option, key1, value1), E_OK); in GetSyncData001()
87 SQLiteSingleVerNaturalStoreConnection *&connection) in GetSyncData002()
104 EXPECT_EQ(connection->Put(option, key, value), E_OK); in GetSyncData002()
126 SQLiteSingleVerNaturalStoreConnection *&connection) in GetSyncData003()
152 EXPECT_EQ(connection->Put(option, key1, value1), E_OK); in GetSyncData003()
169 SQLiteSingleVerNaturalStoreConnection *&connection) in GetSyncData004()
179 EXPECT_EQ(connection->Put(option, key, value), E_OK); in GetSyncData004()
233 SQLiteSingleVerNaturalStoreConnection *&connection) in GetSyncData005()
242 EXPECT_EQ(connection in GetSyncData005()
46 GetSyncData001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) GetSyncData001() argument
86 GetSyncData002(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) GetSyncData002() argument
125 GetSyncData003(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) GetSyncData003() argument
168 GetSyncData004(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) GetSyncData004() argument
232 GetSyncData005(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) GetSyncData005() argument
270 GetSyncData006(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) GetSyncData006() argument
307 PutSyncData001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) PutSyncData001() argument
402 PutSyncData002(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) PutSyncData002() argument
486 PutSyncData003(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) PutSyncData003() argument
564 PutMetaData001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) PutMetaData001() argument
577 GetMetaData001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) GetMetaData001() argument
595 DeleteMetaData001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) DeleteMetaData001() argument
613 GetCurrentMaxTimestamp001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) GetCurrentMaxTimestamp001() argument
676 LocalDatabaseOperate001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) LocalDatabaseOperate001() argument
691 LocalDatabaseOperate002(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) LocalDatabaseOperate002() argument
706 LocalDatabaseOperate003(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) LocalDatabaseOperate003() argument
721 SyncDatabaseOperate001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate001() argument
736 SyncDatabaseOperate002(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate002() argument
786 SyncDatabaseOperate003(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate003() argument
801 SyncDatabaseOperate004(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate004() argument
848 SyncDatabaseOperate005(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate005() argument
863 SyncDatabaseOperate006(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) SyncDatabaseOperate006() argument
924 ClearRemoteData001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) ClearRemoteData001() argument
994 DeleteUserKeyValue001(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) DeleteUserKeyValue001() argument
1038 MemoryDbDeleteUserKeyValue001( SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) MemoryDbDeleteUserKeyValue001() argument
1082 DeleteUserKeyValue002(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) DeleteUserKeyValue002() argument
1129 DeleteUserKeyValue003(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) DeleteUserKeyValue003() argument
1212 DeleteUserKeyValue004(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) DeleteUserKeyValue004() argument
1261 MemoryDbDeleteUserKeyValue004( SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) MemoryDbDeleteUserKeyValue004() argument
1307 DeleteUserKeyValue005(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) DeleteUserKeyValue005() argument
1364 MemoryDbDeleteUserKeyValue005( SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) MemoryDbDeleteUserKeyValue005() argument
1419 DeleteUserKeyValue006(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, const std::string &url) DeleteUserKeyValue006() argument
1564 TestMetaDataPutAndGet(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) TestMetaDataPutAndGet() argument
1669 DataBaseCommonPutOperate(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, IOption option) DataBaseCommonPutOperate() argument
1760 DataBaseCommonDeleteOperate(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, IOption option) DataBaseCommonDeleteOperate() argument
1804 DataBaseCommonGetOperate(SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection, IOption option) DataBaseCommonGetOperate() argument
1862 TestMetaDataDeleteByPrefixKey( SQLiteSingleVerNaturalStore *&store, SQLiteSingleVerNaturalStoreConnection *&connection) TestMetaDataDeleteByPrefixKey() argument
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/
H A Dbtm_acl.c160 BtmAclConnection *connection = MEM_CALLOC.alloc(sizeof(BtmAclConnection)); in AllocAclConnection() local
161 if (connection != NULL) { in AllocAclConnection()
162 connection->refCount = 0; in AllocAclConnection()
163 connection->isInitiator = false; in AllocAclConnection()
164 connection->timeoutTimer = AlarmCreate(NULL, false); in AllocAclConnection()
166 connection->remoteFeatures.bredr.featureStatus = REQUEST_NOT_COMPLETED; in AllocAclConnection()
167 connection->remoteFeatures.bredr.extendedFeatureStatus = REQUEST_NOT_COMPLETED; in AllocAclConnection()
168 connection->remoteFeatures.le.featureStatus = REQUEST_NOT_COMPLETED; in AllocAclConnection()
170 return connection; in AllocAclConnection()
173 static void FreeAclConnection(void *connection) in FreeAclConnection() argument
339 BtmAclConnection *connection = NULL; BtmAclFindConnectionByAddr() local
358 BtmAclConnection *connection = NULL; BtmAclFindLeConnectionByAddr() local
377 BtmAclConnection *connection = NULL; BtmAclFindConnectionByHandle() local
440 BtmAclConnection *connection = BtmAclFindConnectionByAddr(addr); BTM_AclConnect() local
473 BtmAclConnection *connection = (BtmAclConnection *)context; BtmAclTimeoutTask() local
516 BtmAclConnection *connection = BtmAclFindConnectionByAddr(&addr); BtmOnConnectionComplete() local
585 BtmAclConnection *connection = AllocAclConnection(); BtmOnConnectionrequest() local
823 BtmAclConnection *connection = BtmAclFindLeConnectionByAddr(addr); BTM_LeConnect() local
868 BtmAclConnection *connection = NULL; BtmRemoveAllConnectingLeConnection() local
885 BtmAclConnection *connection = BtmAclFindLeConnectionByAddr(addr); BtmUpdateLeConnectionOnConnectComplete() local
997 BtmAclConnection *connection = NULL; BtmGetLeConnectingAddr() local
1135 BtmUpdateLeConnectionOnEnhancedConnectComplete( BtmAclConnection *connection, uint8_t peerAddrType, const HciLeEnhancedConnectionCompleteEventParam *eventParam) BtmUpdateLeConnectionOnEnhancedConnectComplete() argument
1160 BtmAclConnection *connection = AllocAclConnection(); BtmAllocLeConnectionOnEnhancedConnectComplete() local
1207 BtmAclConnection *connection = BtmAclFindLeConnectionByAddr(addr); BtmUpdateConnectionInfoOnLeEnhancedConnectionComplete() local
1324 BtmAclConnection *connection = BtmAclFindConnectionByHandle(connectionHandle); BTM_GetAclTranspot() local
1340 BtmAclConnection *connection = BtmAclFindConnectionByHandle(connectionHandle); BTM_AclDisconnect() local
1363 BtmAclConnection *connection = BtmAclFindConnectionByHandle(eventParam->connectionHandle); BtmOnDisconnectComplete() local
1445 BtmAclConnection *connection = BtmAclFindConnectionByHandle(eventParam->connectionHandle); BtmOnLeReadRemoteFeaturesComplete() local
1478 BtmAclConnection *connection = BtmAclFindConnectionByHandle(eventParam->connectionHandle); BtmOnReadRemoteVersionInformationComplete() local
1527 BtmAclConnection *connection = BtmAclFindConnectionByHandle(eventParam->connectionHandle); BtmOnReadRemoteSupportedFeaturesComplete() local
1582 BtmAclConnection *connection = BtmAclFindConnectionByHandle(eventParam->connectionHandle); BtmOnReadRemoteExtendedFeaturesComplete() local
1635 BtmAclConnection *connection = BtmAclFindConnectionByHandle(returnParam->handle); BtmOnReadRssiComplete() local
1716 BtmAclConnection *connection = BtmAclFindConnectionByAddr(addr); BtmGetAclHandleByAddress() local
1730 BtmAclConnection *connection = BtmAclFindLeConnectionByAddr(addr); BtmGetLeAclHandleByAddress() local
1744 BtmAclConnection *connection = BtmAclFindConnectionByHandle(handle); BtmGetAclAddressByHandle() local
1763 BtmAclConnection *connection = BtmAclFindConnectionByHandle(connectionHandle); BTM_AclAddRef() local
1779 BtmReleaseConnection(BtmAclConnection *connection) BtmReleaseConnection() argument
1811 BtmAclConnection *connection = BtmAclFindConnectionByHandle(connectionHandle); BTM_AclRelease() local
1834 BtmAclConnection *connection = BtmAclFindLeConnectionByAddr(addr); BTM_ReadRssi() local
1857 BtmAclConnection *connection = BtmAclFindConnectionByHandle(connectionHandle); BTM_GetLeConnectionAddress() local
1875 BtmAclConnection *connection = BtmAclFindConnectionByHandle(eventParam->connectionHandle); BtmOnEncryptionChange() local
1890 BtmAclConnection *connection = BtmAclFindConnectionByAddr(addr); BTM_IsSecureConnection() local
1909 BtmAclConnection *connection = NULL; BtmCloseAclConnectionByTransport() local
1961 BtmAclConnection *connection = BtmAclFindConnectionByAddr(addr); BTM_AclCancelConnect() local
1993 BtmAclConnection *connection = BtmAclFindLeConnectionByAddr(addr); BTM_LeCancelConnect() local
2029 BtmAclConnection *connection = NULL; BTM_IsRemoteDeviceSupportHostSecureSimplePairing() local
2066 BtmAclConnection *connection = NULL; BTM_IsRemoteDeviceSupportConnectionParametersRequest() local
2103 BtmAclConnection *connection = NULL; BTM_IsRemoteDeviceSupportEdrAcl2MbMode() local
2139 BtmAclConnection *connection = NULL; BTM_IsRemoteDeviceSupportEdrAcl3MbMode() local
2372 BtmAclConnection *connection = BtmAclFindConnectionByAddr(addr); BTM_ChangeConnectionPacketType() local
[all...]
/foundation/communication/netstack/test/unittest/tlssocket/server/
H A Dtls_socket_server_mock_branch_test.cpp38 TLSSocketServer::Connection *connection; member in OHOS::NetStack::TlsSocketServer::TlsSocketServerMockBranchTest
41 connection = new TLSSocketServer::Connection();
46 delete connection;
47 connection = nullptr;
54 connection->ssl_ = nullptr; in HWTEST_F()
55 EXPECT_FALSE(connection->Close()); in HWTEST_F()
63 connection->ssl_ = (SSL *)ssl; in HWTEST_F()
64 EXPECT_FALSE(connection->Close()); in HWTEST_F()
72 connection->ssl_ = (SSL *)ssl; in HWTEST_F()
73 connection in HWTEST_F()
[all...]
H A Dtls_socket_server_branch_test.cpp94 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F() local
95 EXPECT_TRUE(connection != nullptr); in HWTEST_F()
96 tlsSocketServer->AddConnect(socketFd, connection); in HWTEST_F()
99 auto ret = connection->Send(data); in HWTEST_F()
104 auto value = connection->Recv(buffer, maxBufferSize); in HWTEST_F()
107 ret = connection->Close(); in HWTEST_F()
111 ret = connection->SetAlpnProtocols(alpnProtocols); in HWTEST_F()
114 auto stringVector = connection->GetCipherSuite(); in HWTEST_F()
117 auto protocol = connection->GetProtocol(); in HWTEST_F()
120 ret = connection in HWTEST_F()
132 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
193 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
218 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
259 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
317 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
334 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
351 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
442 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
461 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
521 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
553 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
570 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
630 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
640 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
[all...]
/foundation/communication/netstack/test/unittest/tls_test/server/
H A Dtls_socket_server_mock_branch_test.cpp38 TLSSocketServer::Connection *connection; member in OHOS::NetStack::TlsSocketServer::TlsSocketServerMockBranchTest
41 connection = new TLSSocketServer::Connection();
46 delete connection;
47 connection = nullptr;
54 connection->ssl_ = nullptr; in HWTEST_F()
55 EXPECT_FALSE(connection->Close()); in HWTEST_F()
63 connection->ssl_ = (SSL *)ssl; in HWTEST_F()
64 EXPECT_FALSE(connection->Close()); in HWTEST_F()
72 connection->ssl_ = (SSL *)ssl; in HWTEST_F()
73 connection in HWTEST_F()
[all...]
H A Dtls_socket_server_branch_test.cpp94 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F() local
95 EXPECT_TRUE(connection != nullptr); in HWTEST_F()
96 tlsSocketServer->AddConnect(socketFd, connection); in HWTEST_F()
99 auto ret = connection->Send(data); in HWTEST_F()
104 auto value = connection->Recv(buffer, maxBufferSize); in HWTEST_F()
107 ret = connection->Close(); in HWTEST_F()
111 ret = connection->SetAlpnProtocols(alpnProtocols); in HWTEST_F()
114 auto stringVector = connection->GetCipherSuite(); in HWTEST_F()
117 auto protocol = connection->GetProtocol(); in HWTEST_F()
120 ret = connection in HWTEST_F()
132 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
193 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
218 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
259 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
317 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
334 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
351 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
442 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
461 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
521 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
553 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
570 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
630 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
640 auto connection = std::make_shared<TLSSocketServer::Connection>(); HWTEST_F() local
[all...]
/foundation/window/window_manager/test/systemtest/extension/
H A Dmodal_system_ui_extension_test.cpp60 auto connection = new(std::nothrow)ModalSystemUiExtension(); in HWTEST_F() local
61 if (connection == nullptr) { in HWTEST_F()
65 ASSERT_FALSE(connection->CreateModalUIExtension(want)); in HWTEST_F()
66 delete connection; in HWTEST_F()
89 auto connection = sptr<ModalSystemUiExtension::DialogAbilityConnection>::MakeSptr(want); in HWTEST_F() local
90 ASSERT_NE(connection, nullptr); in HWTEST_F()
93 connection->OnAbilityConnectDone(element, nullptr, 0); in HWTEST_F()
96 connection->OnAbilityConnectDone(element, remoteObject, 0); in HWTEST_F()
99 connection->OnAbilityConnectDone(element, remoteObject, 0); in HWTEST_F()
112 auto connection in HWTEST_F() local
126 auto connection = sptr<ModalSystemUiExtension::DialogAbilityConnection>::MakeSptr(want); HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/connection/ble/include/
H A Dsoftbus_conn_ble_connection.h57 BLE_CONNECTION_STATE_CONNECTING = 0, // client connection init state
58 BLE_CONNECTION_STATE_CONNECTED, // server connection init state
107 // ble connection may be devide the data to several packet, so we should assemble them together
123 // NOTICE: fields below are inner ones for helping connect progress, they are invalid after connection established
127 // ble Quick connection fails due to scan failures
167 int32_t (*bleClientConnect)(ConnBleConnection *connection);
168 int32_t (*bleClientDisconnect)(ConnBleConnection *connection, bool grace, bool refreshGatt);
169 int32_t (*bleClientSend)(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen, int32_t module);
170 int32_t (*bleClientUpdatePriority)(ConnBleConnection *connection, ConnectBlePriority priority);
173 int32_t (*bleServerSend)(ConnBleConnection *connection, cons
[all...]
/foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/
H A Dchannel_manager.cpp43 std::shared_ptr<Connection> connection; in GetConnection() local
46 connection = std::make_shared<SoftBusConnection>(); in GetConnection()
51 connection = std::make_shared<TcpConnection>(); in GetConnection()
58 return connection; in GetConnection()
62 * server (start listen) or client (start connection)
81 std::shared_ptr<Connection> connection = GetConnection(request.linkType); in CreateChannel() local
82 connection->SetConnectionListener(connectionListener_); in CreateChannel()
86 connectionMap_.insert(std::pair<ChannelRequest, std::shared_ptr<Connection>>(request, connection)); in CreateChannel()
95 return connection->StartListen(request, channelListener); in CreateChannel()
98 return connection in CreateChannel()
112 std::shared_ptr<Connection> connection = GetConnection(request.linkType); CreateChannel() local
156 std::shared_ptr<Connection> connection = it->second; DestroyChannel() local
[all...]
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/
H A Dchannel_manager.cpp43 std::shared_ptr<Connection> connection; in GetConnection() local
46 connection = std::make_shared<SoftBusConnection>(); in GetConnection()
51 connection = std::make_shared<TcpConnection>(); in GetConnection()
58 return connection; in GetConnection()
62 * server (start listen) or client (start connection)
81 std::shared_ptr<Connection> connection = GetConnection(request.linkType); in CreateChannel() local
82 connection->SetConnectionListener(connectionListener_); in CreateChannel()
86 connectionMap_.insert(std::pair<ChannelRequest, std::shared_ptr<Connection>>(request, connection)); in CreateChannel()
95 return connection->StartListen(request, channelListener); in CreateChannel()
98 return connection in CreateChannel()
112 std::shared_ptr<Connection> connection = GetConnection(request.linkType); CreateChannel() local
156 std::shared_ptr<Connection> connection = it->second; DestroyChannel() local
[all...]
/foundation/communication/dsoftbus/tests/core/connection/ble/mock/
H A Dconnection_ble_manager_mock.cpp135 int32_t LegacyBleSaveConnection(ConnBleConnection *connection) in LegacyBleSaveConnection() argument
137 return GetConnectionBleInterface()->LegacyBleSaveConnection(connection); in LegacyBleSaveConnection()
145 int32_t ConnGattClientConnect(ConnBleConnection *connection) in ConnGattClientConnect() argument
147 return GetConnectionBleInterface()->ConnGattClientConnect(connection); in ConnGattClientConnect()
150 int32_t ConnGattClientDisconnect(ConnBleConnection *connection, bool grace, bool refreshGatt) in ConnGattClientDisconnect() argument
152 return GetConnectionBleInterface()->ConnGattClientDisconnect(connection, grace, refreshGatt); in ConnGattClientDisconnect()
155 int32_t ConnGattClientSend(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen, int32_t module) in ConnGattClientSend() argument
157 return GetConnectionBleInterface()->ConnGattClientSend(connection, data, dataLen, module); in ConnGattClientSend()
160 int32_t ConnGattClientUpdatePriority(ConnBleConnection *connection, ConnectBlePriority priority) in ConnGattClientUpdatePriority() argument
162 return GetConnectionBleInterface()->ConnGattClientUpdatePriority(connection, priorit in ConnGattClientUpdatePriority()
175 ConnGattServerSend(ConnBleConnection *connection, const uint8_t *data, uint32_t dataLen, int32_t module) ConnGattServerSend() argument
180 ConnGattServerConnect(ConnBleConnection *connection) ConnGattServerConnect() argument
185 ConnGattServerDisconnect(ConnBleConnection *connection) ConnGattServerDisconnect() argument
[all...]

Completed in 21 milliseconds

12345678910