Home
last modified time | relevance | path

Searched refs:connect (Results 1 – 25 of 805) sorted by relevance

12345678910>>...33

/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/att/
H A Datt_receive.c38 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 Datt_receive.h40 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 Datt_common.c129 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 Datt_send_request.c198 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 Datt_send_response.c95 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 Datt_connect.c263 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 Datt_common.h133 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 Dsdp_connect.c103 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 Dconnect_count.cpp40 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 Ddistributed_sched_connect_test.cpp152 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 Ddistributed_sched_adapter_test.cpp76 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 Dcall_container.cpp83 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 Dcall_container_test.cpp78 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 Dlocal_call_container_ut_test.cpp164 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 Darkts-new-persistencev2.md30 ### 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 Dability_record_test_call.cpp158 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 Ddistributed_sched_adapter.cpp67 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 Dsocket-connection.md134 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 Dhappy_eyeballs.rs113 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 Dextension_manager_client_test.cpp112 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 Dchangelogs-network.md3 ## 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 DNapiRemoteObjectTest.js89 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 Dform_ams_helper.cpp70 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 Dextension_manager_client.cpp96 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 Ddistributed_sched_adapter.h44 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);

12345678910>>...33