/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/att/ |
H A D | att_receive.c | 38 AttConnectInfo *connect; member 337 if (connect == NULL) { in AttErrorResponse() 390 if (connect == NULL) { in AttExchangeMTURequest() 437 if (connect == NULL) { in AttExchangeMTUResponse() 461 connect->mtu = Min(connect->sendMtu, attExchangeMTUObj.mtuSize); in AttExchangeMTUResponse() 489 if (connect == NULL) { in AttFindInformationRequest() 561 if (connect == NULL) { in AttFindInformationResponse() 626 if (connect == NULL) { in AttFindByTypeValueRequest() 712 if (connect == NULL) { in AttFindByTypeValueResponse() 774 if (connect == NULL) { in AttReadByTypeRequest() [all …]
|
H A D | att_receive.h | 40 void AttErrorResponse(AttConnectInfo *connect, const Buffer *buffer); 48 void AttExchangeMTURequest(AttConnectInfo *connect, const Buffer *buffer); 56 void AttExchangeMTUResponse(AttConnectInfo *connect, const Buffer *buffer); 96 void AttReadByTypeRequest(AttConnectInfo *connect, const Buffer *buffer); 112 void AttReadRequest(AttConnectInfo *connect, const Buffer *buffer); 120 void AttReadResponse(AttConnectInfo *connect, const Buffer *buffer); 128 void AttReadBlobRequest(AttConnectInfo *connect, const Buffer *buffer); 136 void AttReadBlobResponse(AttConnectInfo *connect, const Buffer *buffer); 176 void AttWriteRequest(AttConnectInfo *connect, const Buffer *buffer); 184 void AttWriteResponse(AttConnectInfo *connect, const Buffer *buffer); [all …]
|
H A D | att_common.c | 129 if (connect == NULL) { in AttTransactionTimeOutAsync() 232 *connect = NULL; in AttGetConnectInfoIndexByAclHandle() 267 *connect = NULL; in AttGetConnectInfoIndexByCid() 298 *connect = NULL; in AttGetConnectInfoIndexByCidOutIndex() 331 *connect = NULL; in AttGetConnectInfoIndexByConnectHandle() 929 if (connect == NULL) { in LeRecvSendDataCallbackAsync() 1004 if (connect == NULL) { in BREDRRecvSendDataCallbackAsync() 1146 if (connect == NULL) { in ClientCallbackBTBADPARAM() 1223 if (connect != NULL) { in AttRecvDataAsync() 1299 if (connect != NULL) { in AttRecvLeDataAsync() [all …]
|
H A D | att_send_request.c | 198 if (connect == NULL) { in AttExchangeMTURequestAsync() 287 if (connect == NULL) { in AttFindInformationRequestAsync() 377 if (connect == NULL) { in AttFindByTypeValueRequestAsync() 486 if (connect == NULL) { in AttReadByTypeRequestAsync() 607 if (connect == NULL) { in AttReadRequestAsync() 688 if (connect == NULL) { in AttReadBlobRequestAsync() 782 if (connect == NULL) { in AttReadMultipleRequestAsync() 908 if (connect == NULL) { in AttReadByGroupTypeRequestAsync() 1027 if (connect == NULL) { in AttWriteRequestAsync() 1127 if (connect == NULL) { in AttWriteCommandAsync() [all …]
|
H A D | att_send_response.c | 95 if (connect == NULL) { in AttAssignMTU() 100 if (connect->mtuFlag) { in AttAssignMTU() 109 *mtu = connect->mtu; in AttAssignMTU() 135 if (connect == NULL) { in AttErrorResponseAsync() 238 if (connect == NULL) { in AttExchangeMTUResponseAsync() 251 connect->mtu = Min(connect->receiveMtu, exchangeMtuResPtr->mtu); in AttExchangeMTUResponseAsync() 375 if (connect == NULL) { in AttFindInformationResponseAsync() 494 if (connect == NULL) { in AttFindByTypeValueResponseAsync() 611 if (connect == NULL) { in AttReadByTypeResponseAsync() 744 if (connect == NULL) { in AttReadResponseAsync() [all …]
|
H A D | att_connect.c | 263 if (connect == NULL) { in DisconnectRespCallbackAsync() 393 connect->aclHandle = 0; in AttClearConnectInfo() 398 connect->mtu = 0; in AttClearConnectInfo() 401 connect->sendMtu = 0; in AttClearConnectInfo() 404 (void)memset_s(&connect->addr, sizeof(connect->addr), 0, sizeof(BtAddr)); in AttClearConnectInfo() 792 if (*connect == NULL) { in AttCopyToConnectInfo() 1458 if (connect == NULL) { in L2cifBREDRDisconnectReqCallBackAsync() 1534 if (connect == NULL) { in LeDisconnectReqCallBackAsync() 1781 if (connect == NULL) { in AttLeDisconnectedAsync() 2686 &(connect->addr), connect->aclHandle, connect->AttConnectID.bredrcid, &connecting); in InitiativeDisconnect() [all …]
|
H A D | att_common.h | 133 typedef void (*recvDataFunction)(AttConnectInfo *connect, const Buffer *buffer); 238 AttConnectInfo *connect; member 272 void AttGetConnectInfoIndexByCid(uint16_t cid, AttConnectInfo **connect); 382 int AttSendSequenceScheduling(const AttConnectInfo *connect); 389 void AttReceiveSequenceScheduling(const AttConnectInfo *connect); 451 void ClientCallbackBTBADPARAM(const AttConnectInfo *connect); 458 void ServerCallbackBTBADPARAM(const AttConnectInfo *connect); 466 void ClientCallbackReturnValue(int ret, const AttConnectInfo *connect); 474 void ServerCallbackReturnValue(int ret, const AttConnectInfo *connect); 495 int AttResponseSendData(const AttConnectInfo *connect, const Packet *packet); [all …]
|
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/sdp/ |
H A D | sdp_connect.c | 103 connect = NULL; in SdpFreeConnectInfo() 203 if ((connect->lcid == lcid) && (connect->outConnState != SDP_STATE_IDLE)) { in SdpFindConnectByCid() 204 return connect; in SdpFindConnectByCid() 292 connect->lcid = lcid; in SdpConnectReqCallbackTask() 300 AlarmSet(connect->timer, SDP_CONNECT_TIMEOUT, SdpConnectTimeout, connect); in SdpConnectReqCallbackTask() 346 if ((connect != NULL) && (connect->flag)) { in SdpConfigReqCallbackTask() 399 if (connect == NULL) { in SdpConnectRspCallbackTask() 405 connect->lcid = lcid; in SdpConnectRspCallbackTask() 470 if ((connect != NULL) && (connect->flag)) { in SdpConfigRspCallbackTask() 596 connect->flag = true; in SdpSendConnectRequest() [all …]
|
/ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/connect_count/ |
H A D | connect_count.cpp | 40 for (auto &connect : connectList_) { in AddConnect() local 41 if (connect->callingTokenId == callingTokenId && connect->networkId == networkId) { in AddConnect() 42 connect->num++; in AddConnect() 47 connectList_.insert(connect); in AddConnect() 53 for (auto &connect : connectList_) { in CheckCount() local 64 for (auto &connect : connectList_) { in RemoveAllConnect() local 66 connect->listener->OnStatus(connect->networkId, ON_STATUS_OFFLINE); in RemoveAllConnect() 114 for (auto &connect : connectList_) { in GetNetworkIds() local 125 for (auto &connect : connectList_) { in NotifyRemoteReverseObj() local 126 if (connect->networkId == networkId && connect->listener != nullptr) { in NotifyRemoteReverseObj() [all …]
|
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/ |
H A D | distributed_sched_connect_test.cpp | 152 if (connect == nullptr) { in AddSession() 168 if (connect == nullptr) { in RemoveSession() 179 if (connect == nullptr) { in AddConnectInfo() 197 if (connect == nullptr) { in RemoveConnectInfo() 291 RemoveSession(connect); 328 RemoveSession(connect); 365 RemoveSession(connect); 402 RemoveConnectInfo(connect); 469 RemoveSession(connect); 542 RemoveSession(connect); [all …]
|
H A D | distributed_sched_adapter_test.cpp | 76 const sptr<IRemoteObject> connect = nullptr; variable 93 const sptr<IRemoteObject> connect = nullptr; variable 207 const sptr<IRemoteObject> connect = nullptr; variable 224 const sptr<IRemoteObject> connect = nullptr; variable 256 const sptr<IRemoteObject> connect = nullptr; variable 258 distributedSchedAdapter_->ProcessCalleeDied(connect); 273 const sptr<IRemoteObject> connect = nullptr; variable 274 distributedSchedAdapter_->ProcessCalleeDied(connect); 304 const sptr<IRemoteObject> connect = nullptr; variable 323 const sptr<IRemoteObject> connect = nullptr; variable [all …]
|
/ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/src/ |
H A D | call_container.cpp | 83 CHECK_POINTER(connect); in AddCallRecord() 84 CHECK_POINTER(connect->AsObject()); in AddCallRecord() 88 RemoveConnectDeathRecipient(connect); in AddCallRecord() 91 AddConnectDeathRecipient(connect); in AddCallRecord() 92 callRecord->SetConCallBack(connect); in AddCallRecord() 111 CHECK_POINTER_AND_RETURN(connect, false); in RemoveCallRecord() 117 RemoveConnectDeathRecipient(connect); in RemoveCallRecord() 190 CHECK_POINTER(connect); in AddConnectDeathRecipient() 191 CHECK_POINTER(connect->AsObject()); in AddConnectDeathRecipient() 214 CHECK_POINTER(connect); in RemoveConnectDeathRecipient() [all …]
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/call_container_test/ |
H A D | call_container_test.cpp | 78 abilityRequest.connect = new AbilityConnectCallback(); 81 abilityRequest.connect, abilityRequest.callerToken); 116 bool result = callContainer->RemoveCallRecord(connect); 134 abilityRequest.connect = new AbilityConnectCallback(); 214 abilityRequest.connect = new AbilityConnectCallback(); 253 abilityRequest.connect = new AbilityConnectCallback(); 276 abilityRequest.connect = new AbilityConnectCallback(); 299 abilityRequest.connect = new AbilityConnectCallback(); 320 callContainer->AddConnectDeathRecipient(connect); 336 callContainer->AddConnectDeathRecipient(connect); [all …]
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/frameworks_kits_ability_ability_runtime_test/ |
H A D | local_call_container_ut_test.cpp | 164 localCallRecord->remoteObject_ = connect; 402 connect->container_ = localCallContainer; 405 connect->localCallRecord_ = localCallRecord; 406 connect->OnAbilityConnectDone(elementName, connect, code); 424 connect->container_ = localCallContainer; 429 connect->OnAbilityConnectDone(elementName, connect, code); 460 connect->container_ = localCallContainer; 584 connect->container_ = localCallContainer; 587 connect->OnAbilityConnectDone(elementName, connect, code); 607 connect->container_ = localCallContainer; [all …]
|
/ohos5.0/docs/zh-cn/application-dev/quick-start/ |
H A D | arkts-new-persistencev2.md | 30 ### connect:创建或获取储存的数据 33 static connect<T extends object>( 51 >3、同一个key,connect不同类型的数据会导致应用异常,应用需要确保类型匹配; 99 >手动持久化当前内存中不处于connect状态的key是无意义的。 154 // 对于需要换connect对象的prop属性,需要加@Local修饰(不建议对属性换connect的对象) 166 Button('Page1 connect the key Sample') 169 // 不建议对prop属性换connect的对象 181 // 如果处于connect状态,持久化key为Sample的键值对 220 // 对于需要换connect对象的prop属性,需要加@Local修饰(不建议对属性换connect的对象) 227 Button('Page2 connect the key Sample1') [all …]
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/ability_record_test/ |
H A D | ability_record_test_call.cpp | 158 abilityRequest.connect = new AbilityConnectCallback(); 176 abilityRequest.connect = new AbilityConnectCallback(); 179 abilityRequest.connect, abilityRequest.callerToken); 212 abilityRequest.connect = new AbilityConnectCallback(); 227 EXPECT_EQ(abilityRecord_->ReleaseCall(connect), false); 244 abilityRequest.connect = connect; 247 abilityRequest.connect, abilityRequest.callerToken); 250 EXPECT_EQ(abilityRecord_->ReleaseCall(connect), true); 305 abilityRequest.connect = new AbilityConnectCallback(); 327 abilityRequest.connect = new AbilityConnectCallback(); [all …]
|
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/ |
H A D | distributed_sched_adapter.cpp | 67 const sptr<IRemoteObject>& connect, const sptr<IRemoteObject>& callerToken) in ConnectAbility() argument 102 iface_cast<AAFwk::IAbilityConnection>(connect)); in DisconnectAbility() 155 if (connect == nullptr) { in ProcessConnectDied() 160 auto callback = [connect] () { in ProcessConnectDied() 161 DistributedSchedService::GetInstance().ProcessConnectDied(connect); in ProcessConnectDied() 174 if (connect == nullptr) { in ProcessCalleeDied() 179 auto callback = [connect] () { in ProcessCalleeDied() 180 DistributedSchedService::GetInstance().ProcessCalleeDied(connect); in ProcessCalleeDied() 213 if (connect == nullptr) { in ProcessCallerDied() 218 auto callback = [connect, deviceType] () { in ProcessCallerDied() [all …]
|
/ohos5.0/docs/zh-cn/application-dev/network/ |
H A D | socket-connection.md | 134 tcp.on('connect', () => { 135 console.log("on connect"); 183 tcp.off('connect'); 267 tcpServer.off("connect"); 367 client.on('connect', () => { 399 client.off('connect'); 489 server.off('connect'); 585 tlsTwoWay.off('connect'); 646 tlsTwoWay.off('connect'); 690 tcp.on('connect', () => { [all …]
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
H A D | happy_eyeballs.rs | 113 async fn connect(&mut self) -> Result<TcpStream, io::Error> { in connect() method 116 match connect(addr, self.timeout).await { in connect() 176 pub(crate) async fn connect(mut self) -> io::Result<TcpStream> { in connect() method 178 None => self.preferred_addr.connect().await, in connect() 180 let preferred_fut = self.preferred_addr.connect(); in connect() 181 let second_fut = second_addrs.addrs.connect(); in connect() 190 let preferred_fut = self.preferred_addr.connect(); in connect() 193 let second_fut = second_addrs.addrs.connect(); in connect() 210 let preferred_fut = self.preferred_addr.connect(); in connect() 234 fn connect( in connect() function [all …]
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/extension_manager_client_test/ |
H A D | extension_manager_client_test.cpp | 112 sptr<IRemoteObject> connect; variable 114 auto result = client->ConnectServiceExtensionAbility(want, connect, userId); 126 sptr<IRemoteObject> connect; variable 129 auto result = client->ConnectServiceExtensionAbility(want, connect, callerToken, userId); 141 sptr<IRemoteObject> connect; variable 143 auto result = client->ConnectExtensionAbility(want, connect, userId); 154 sptr<IRemoteObject> connect; variable 155 auto result = client->DisconnectAbility(connect); 168 sptr<IRemoteObject> connect; variable 171 … auto result = client->ConnectEnterpriseAdminExtensionAbility(want, connect, callerToken, userId);
|
/ohos5.0/docs/zh-cn/release-notes/changelogs/OpenHarmony_5.0.0.36/ |
H A D | changelogs-network.md | 3 ## cl.network.1 webSocket.connect接口新增2302998错误码 11 为规范元服务请求域名范围,提升元服务上架审核效率和平台合规经营安全性,当用户使用元服务时,将根据该元服务的域名配置进行域名访问;若是访问未配置域名,则connect接口会返回该错误码。 17 API version 11及以下元服务应用访问未配置域名,connect接口不会有任何影响。 20 12开始,元服务应用访问未配置域名,connect接口抛出该错误码,详情见docs仓[接口文档](../../../application-dev/reference/apis-network-ki… 38 开发者在进行元服务应用开发时,涉及webSocket.connect接口建立连接是,先到[AppGallery Connect](https://developer.huawei.com/consu… 42 开发者在进行元服务应用开发时,若遇到webSocket.connect接口失败,请用catch捕获错误;若webSocket.connect接口失败错误码是2302998,可以到[AppGaller…
|
/ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/js/ |
H A D | NapiRemoteObjectTest.js | 89 let connect = { 104 connectId = featureAbility.connectAbility(want, connect) 127 let connect = { 141 connectId = featureAbility.connectAbility(want, connect) 163 let connect = { 177 connectId = featureAbility.connectAbility(want, connect) 200 let connect = { 214 connectId = featureAbility.connectAbility(want, connect) 237 let connect = { 251 connectId = featureAbility.connectAbility(want, connect)
|
/ohos5.0/foundation/ability/form_fwk/services/src/ |
H A D | form_ams_helper.cpp | 70 const Want &want, const sptr<AAFwk::IAbilityConnection> &connect) in ConnectServiceAbility() argument 78 return IN_PROCESS_CALL(ams->ConnectAbility(want, connect, nullptr)); in ConnectServiceAbility() 85 ErrCode FormAmsHelper::DisconnectServiceAbility(const sptr<AAFwk::IAbilityConnection> &connect) in DisconnectServiceAbility() argument 93 return IN_PROCESS_CALL(ams->DisconnectAbility(connect)); in DisconnectServiceAbility() 101 ErrCode FormAmsHelper::DisconnectServiceAbilityDelay(const sptr<AAFwk::IAbilityConnection> &connect… in DisconnectServiceAbilityDelay() argument 107 auto disConnectAbilityFunc = [connect]() { in DisconnectServiceAbilityDelay() 108 FormAmsHelper::GetInstance().DisconnectAbilityTask(connect); in DisconnectServiceAbilityDelay() 145 void FormAmsHelper::DisconnectAbilityTask(const sptr<AAFwk::IAbilityConnection> &connect) in DisconnectAbilityTask() argument 152 IN_PROCESS_CALL_WITHOUT_RET(ams->DisconnectAbility(connect)); in DisconnectAbilityTask()
|
/ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/extension_manager/src/ |
H A D | extension_manager_client.cpp | 96 const sptr<IRemoteObject> &connect, int32_t userId) in ConnectServiceExtensionAbility() argument 107 …return abms->ConnectAbilityCommon(want, connect, nullptr, AppExecFwk::ExtensionAbilityType::SERVIC… in ConnectServiceExtensionAbility() 112 const sptr<IRemoteObject> &connect, const sptr<IRemoteObject> &callerToken, int32_t userId) in ConnectServiceExtensionAbility() argument 124 want, connect, callerToken, AppExecFwk::ExtensionAbilityType::SERVICE, userId, false); in ConnectServiceExtensionAbility() 128 const sptr<IRemoteObject> &connect, const sptr<IRemoteObject> &callerToken, int32_t userId) in ConnectEnterpriseAdminExtensionAbility() argument 140 … want, connect, callerToken, AppExecFwk::ExtensionAbilityType::ENTERPRISE_ADMIN, userId, true); in ConnectEnterpriseAdminExtensionAbility() 143 …tensionManagerClient::ConnectExtensionAbility(const Want &want, const sptr<IRemoteObject> &connect, in ConnectExtensionAbility() argument 156 …return abms->ConnectAbilityCommon(want, connect, nullptr, AppExecFwk::ExtensionAbilityType::UNSPEC… in ConnectExtensionAbility() 159 ErrCode ExtensionManagerClient::DisconnectAbility(const sptr<IRemoteObject> &connect) in DisconnectAbility() argument 165 return abms->DisconnectAbility(connect); in DisconnectAbility()
|
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/ |
H A D | distributed_sched_adapter.h | 44 int32_t ConnectAbility(const OHOS::AAFwk::Want& want, const sptr<IRemoteObject>& connect, 46 int32_t DisconnectAbility(const sptr<IRemoteObject>& connect); 49 void ProcessConnectDied(const sptr<IRemoteObject>& connect); 55 …int32_t ReleaseAbility(const sptr<IRemoteObject>& connect, const AppExecFwk::ElementName &element); 56 int32_t StartAbilityByCall(const OHOS::AAFwk::Want& want, const sptr<IRemoteObject>& connect, 58 void ProcessCallerDied(const sptr<IRemoteObject>& connect, int32_t deviceType); 59 void ProcessCalleeDied(const sptr<IRemoteObject>& connect);
|