Home
last modified time | relevance | path

Searched refs:recv (Results 1 - 25 of 60) sorted by relevance

123

/base/msdp/device_status/intention/ipc/socket/src/
H A Dsocket_connection.cpp32 std::function<void(NetPacket&)> recv, in SocketConnection()
34 : socketFd_(socketFd), recv_(recv), onDisconnected_(onDisconnected) in SocketConnection()
45 std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected) in Connect()
53 return std::make_shared<SocketConnection>(sockFd, recv, onDisconnected); in Connect()
63 numRead = ::recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in OnReadable()
69 FI_HILOGD("recv was interrupted, read again"); in OnReadable()
75 FI_HILOGE("recv failed:%{public}s", ::strerror(errno)); in OnReadable()
31 SocketConnection(int32_t socketFd, std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected) SocketConnection() argument
44 Connect(std::function<int32_t()> socket, std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected) Connect() argument
/base/msdp/device_status/intention/ipc/socket/include/
H A Dsocket_connection.h35 std::function<void(NetPacket&)> recv,
47 std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected);
/base/msdp/device_status/test/fuzztest/ipcsocket_fuzzer/
H A Dipcsocket_fuzzer.cpp90 auto recv = [](const NetPacket &pkt) { in SocketConnectionFuzzTest() local
100 SocketConnection socketConnection(1, recv, onDisconnected); in SocketConnectionFuzzTest()
108 Msdp::DeviceStatus::SocketConnection::Connect(socket, recv, onDisconnected); in SocketConnectionFuzzTest()
/base/request/request/services/src/service/run_count/
H A Dmanager.rs94 let recv = match self.rx.recv().await {
97 error!("RunCountManager recv error {:?}", e);
102 match recv {
/base/request/request/services/src/manage/
H A Dnotifier.rs152 let info = client_rx.recv().await.unwrap(); in ut_notify_progress()
162 let info = client_rx.recv().await.unwrap(); in ut_notify_progress()
209 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume()
222 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume()
259 let info = client_rx.recv().await.unwrap(); in ut_notify_remove()
297 let info = client_rx.recv().await.unwrap(); in ut_notify_completed()
335 let info = client_rx.recv().await.unwrap(); in ut_notify_failed()
375 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume_completed()
380 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume_completed()
413 let info = client_rx.recv() in ut_notify_pause_resume_failed()
[all...]
H A Daccount.rs288 let msg = rx.recv().await.unwrap(); in ut_account_check_oh()
311 let msg = rx.recv().await.unwrap(); in ut_account_update()
/base/sensors/medical_sensor/frameworks/native/medical_sensor/src/
H A Dmy_file_descriptor_listener.cpp51 int32_t len = recv(fileDescriptor, receiveDataBuff_, maxLen, NULL); in OnReadable()
66 len = recv(fileDescriptor, receiveDataBuff_, maxLen, NULL); in OnReadable()
/base/request/request/frameworks/js/napi/src/legacy/
H A Drequest_manager.cpp83 napi_ref recv{}; in CallFunctionAsync()
84 data->generator_(data->env_, &recv, argc, argv); in CallFunctionAsync()
88 napi_get_reference_value(data->env_, recv, &thiz); in CallFunctionAsync()
92 napi_delete_reference(data->env_, recv); in CallFunctionAsync()
114 [descriptor](napi_env env, napi_ref *recv, int &argc, napi_value *argv) { in OnTaskDone()
115 *recv = descriptor.this_; in OnTaskDone()
123 [descriptor, errMsg](napi_env env, napi_ref *recv, int &argc, napi_value *argv) { in OnTaskDone()
124 *recv = descriptor.this_; in OnTaskDone()
/base/security/certificate_framework/frameworks/js/napi/certificate/src/
H A Dnapi_common.cpp72 napi_value recv = nullptr; in ReturnCallbackResult() local
74 napi_get_undefined(env, &recv); in ReturnCallbackResult()
75 napi_call_function(env, recv, func, CALLBACK_NUM, params, &callFuncRet); in ReturnCallbackResult()
H A Dnapi_cert_chain_validator.cpp96 napi_value recv = nullptr; in ReturnCallbackResult() local
98 napi_get_undefined(env, &recv); in ReturnCallbackResult()
99 napi_call_function(env, recv, func, ARGS_SIZE_TWO, params, &callFuncRet); in ReturnCallbackResult()
/base/request/request/services/src/service/client/
H A Dmanager.rs74 let recv = match self.rx.recv().await {
77 error!("ClientManager recv error {:?}", e);
82 match recv {
H A Dmod.rs62 error!("open channel fail, recv none");
78 error!("subscribe fail, recv none");
180 let recv = match self.rx.recv().await {
183 error!("ClientManager recv error {:?}", e);
187 match recv {
361 let ret = self.server_sock_fd.recv(&mut buf).await;
367 error!("message len bad, send {:?}, recv {:?}", message.len(), len);
/base/msdp/device_status/frameworks/native/src/
H A Dfd_listener.cpp42 ssize_t size = recv(fd, szBuf, MAX_PACKET_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnReadable()
/base/sensors/sensor/frameworks/native/src/
H A Dfd_listener.cpp46 ssize_t size = recv(fd, szBuf, MAX_DATA_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnReadable()
/base/hiviewdfx/hilog/frameworks/libhilog/socket/
H A Dsocket.cpp126 return TEMP_FAILURE_RETRY(recv(socketHandler, buffer, bufferLen, flags)); in Recv()
H A Dsocket_server.cpp75 return TEMP_FAILURE_RETRY(recv(socketHandler, buffer, bufferLen, flags)); in Recv()
/base/security/device_security_level/test/dslm_unit_test/
H A Ddslm_msg_lib_test.cpp561 auto recv = [](const DeviceIdentify *devId, uint32_t status, int32_t level) -> int32_t { return 0; }; in HWTEST_F() local
562 EXPECT_TRUE(InitDeviceStatusManager(queue, "??", recv)); in HWTEST_F()
568 auto recv = [](const DeviceIdentify *devId, uint32_t status, int32_t level) -> int32_t { return 0; }; in HWTEST_F() local
569 EXPECT_TRUE(InitDeviceStatusManager(queue, "??", recv)); in HWTEST_F()
/base/security/crypto_framework/frameworks/js/napi/crypto/src/
H A Dnapi_sign.cpp321 napi_value recv = nullptr; in ReturnInitCallbackResult() local
323 napi_get_undefined(env, &recv); in ReturnInitCallbackResult()
324 napi_call_function(env, recv, func, ARGS_SIZE_ONE, params, &callFuncRet); in ReturnInitCallbackResult()
348 napi_value recv = nullptr; in ReturnUpdateCallbackResult() local
350 napi_get_undefined(env, &recv); in ReturnUpdateCallbackResult()
351 napi_call_function(env, recv, func, ARGS_SIZE_ONE, params, &callFuncRet); in ReturnUpdateCallbackResult()
375 napi_value recv = nullptr; in ReturnDoFinalCallbackResult() local
377 napi_get_undefined(env, &recv); in ReturnDoFinalCallbackResult()
378 napi_call_function(env, recv, func, ARGS_SIZE_TWO, params, &callFuncRet); in ReturnDoFinalCallbackResult()
H A Dnapi_key_agreement.cpp177 napi_value recv = nullptr; in ReturnCallbackResult() local
179 napi_get_undefined(env, &recv); in ReturnCallbackResult()
180 napi_call_function(env, recv, func, ARGS_SIZE_TWO, params, &callFuncRet); in ReturnCallbackResult()
H A Dnapi_rand.cpp96 napi_value recv = nullptr; in ReturnCallbackResult() local
98 napi_get_undefined(env, &recv); in ReturnCallbackResult()
99 napi_call_function(env, recv, func, ARGS_SIZE_TWO, params, &callFuncRet); in ReturnCallbackResult()
/base/request/request/frameworks/js/napi/include/legacy/
H A Drequest_manager.h42 using ArgsGenerator = std::function<void(napi_env env, napi_ref *recv, int &argc, napi_value *argv)>;
/base/startup/appspawn/test/unittest/
H A Dgencoverage.sh113 hdc file recv ${file} ${ohos_init}/${file:27}
/base/startup/init/test/unittest/tools/
H A Dprepare_testdata.sh102 hdc file recv ${file} ${ohos_init}/${file:23}
/base/print/print_fwk/frameworks/helper/print_helper/include/
H A Dnapi_print_utils.h69 static napi_value CallFunction(napi_env env, napi_value recv, napi_value func, size_t argc, const napi_value *argv);
/base/powermgr/battery_manager/charger/src/
H A Dbattery_thread.cpp142 ssize_t len = recv(ueventFd_, msg, UEVENT_MSG_LEN, 0); in UeventCallback()
144 BATTERY_HILOGI(FEATURE_CHARGING, "recv return msg is invalid, len: %{public}zd", len); in UeventCallback()

Completed in 12 milliseconds

123