Home
last modified time | relevance | path

Searched refs:send (Results 1 - 25 of 37) sorted by relevance

12

/base/security/device_auth/frameworks/deviceauth_lite/source/schedule/
H A Ddistribution.c34 struct message *receive, struct message *send);
36 struct message *receive, struct message *send);
38 struct message *receive, struct message *send);
40 struct message *receive, struct message *send);
42 struct message *receive, struct message *send);
47 struct message *receive, struct message *send);
50 struct message *receive, struct message *send);
152 struct message *receive, struct message *send) in proc_message()
157 int32_t ret = G_DISTRIBUTION_MESSAGE[i].func(handle, nav, receive, send); in proc_message()
165 int32_t connect_message(struct hichain *handle, struct header_analysis *nav, struct message *send) in connect_message() argument
151 proc_message(struct hichain *handle, struct header_analysis *nav, struct message *receive, struct message *send) proc_message() argument
264 proc_pake_response_message(struct hichain *handle, struct header_analysis *nav, struct message *receive, struct message *send) proc_pake_response_message() argument
289 proc_exchange_response_message(struct hichain *handle, struct header_analysis *nav, struct message *receive, struct message *send) proc_exchange_response_message() argument
307 proc_sts_response_message(struct hichain *handle, struct header_analysis *nav, struct message *receive, struct message *send) proc_sts_response_message() argument
331 proc_remove_request_message(struct hichain *handle, struct header_analysis *nav, struct message *receive, struct message *send) proc_remove_request_message() argument
346 proc_remove_response_message(struct hichain *handle, struct header_analysis *nav, struct message *receive, struct message *send) proc_remove_response_message() argument
366 proc_inform_message(struct hichain *handle, struct header_analysis *nav, struct message *receive, struct message *send) proc_inform_message() argument
[all...]
/base/request/request/services/src/service/client/
H A Dmanager.rs38 if self.tx.send(event).is_err() {
93 if let Err(err) = tx.send(ClientEvent::SendResponse(
100 error!("send response error, {}", err);
113 tx.send(ClientEvent::SendNotifyData(subscribe_type, notify_data))
115 error!("send notify data error, {}", err);
135 let _ = tx.send(Ok(*fd)); in handle_open_channel()
139 let _ = tx.send(Ok(fd)); in handle_open_channel()
143 let _ = tx.send(Err(ErrorCode::Other)); in handle_open_channel()
159 let _ = tx.send(ErrorCode::ErrOk); in handle_subscribe()
162 let _ = tx.send(ErrorCod in handle_subscribe()
[all...]
/base/security/device_auth/frameworks/deviceauth_lite/source/auth_info/
H A Dremove_auth_info.c30 static int32_t build_remove_response_data(const struct hichain *hichain, remove_response_data *send);
32 int32_t send_remove_response(const struct hichain *hichain, struct message *receive, struct message *send) in send_remove_response() argument
37 send->msg_code = INFORM_MESSAGE; in send_remove_response()
58 send->payload = send_data; in send_remove_response()
59 send->msg_code = REMOVE_AUTHINFO_RESPONSE; in send_remove_response()
64 send->msg_code = INFORM_MESSAGE; in send_remove_response()
98 static int32_t build_remove_response_data(const struct hichain *hichain, remove_response_data *send) in build_remove_response_data() argument
109 HICHAIN_REMOVE_INFO_RESPONSE, &send->cipher); in build_remove_response_data()
H A Dremove_auth_info_client.c28 int32_t build_remove_request_data(struct remove_auth_info_client *auth_info_client, remove_request_data *send);
29 int32_t send_remove_request(const struct hichain *hichain, struct message *send) in send_remove_request() argument
49 send->payload = request_data; in send_remove_request()
50 send->msg_code = REMOVE_AUTHINFO_REQUEST; in send_remove_request()
71 int32_t build_remove_request_data(struct remove_auth_info_client *auth_info_client, remove_request_data *send) in build_remove_request_data() argument
118 send->cipher = payload; in build_remove_request_data()
147 int32_t send_remove_request(const struct hichain *hichain, struct message *send) in send_remove_request() argument
151 (void)send; in send_remove_request()
H A Dexchange_auth_info_client.c36 static int32_t build_exchange_request(const struct hichain *hichain, exchange_request_data *send);
44 int32_t send_exchange_request(const struct hichain *hichain, struct message *send) in send_exchange_request() argument
49 send->msg_code = INFORM_MESSAGE; in send_exchange_request()
58 send->msg_code = INFORM_MESSAGE; in send_exchange_request()
63 send->payload = send_data; in send_exchange_request()
64 send->msg_code = EXCHANGE_REQUEST; in send_exchange_request()
130 static int32_t build_exchange_request(const struct hichain *hichain, exchange_request_data *send) in build_exchange_request() argument
176 ret = encrypt_payload((struct var_buffer *)key, &plain, HICHAIN_EXCHANGE_REQUEST, &send->cipher); in build_exchange_request()
409 int32_t send_exchange_request(const struct hichain *hichain, struct message *send) in send_exchange_request() argument
413 (void)send; in send_exchange_request()
[all...]
/base/security/device_auth/frameworks/deviceauth_lite/source/key_agreement/
H A Dpake_client.c76 int32_t send_pake_start_request(struct pake_client *pake_client, struct message *send) in send_pake_start_request() argument
79 check_ptr_return_val(send, HC_INPUT_ERROR); in send_pake_start_request()
92 send->msg_code = INFORM_MESSAGE; in send_pake_start_request()
95 send->msg_code = PAKE_REQUEST; in send_pake_start_request()
96 send->payload = send_data; in send_pake_start_request()
102 int32_t send_pake_end_request(struct pake_client *pake_client, const struct message *receive, struct message *send) in send_pake_end_request() argument
106 check_ptr_return_val(send, HC_INPUT_ERROR); in send_pake_end_request()
122 send->msg_code = INFORM_MESSAGE; in send_pake_end_request()
125 send->msg_code = PAKE_CLIENT_CONFIRM; in send_pake_end_request()
126 send in send_pake_end_request()
251 struct pake_end_request_data *send = (struct pake_end_request_data *)data; build_end_request_data() local
[all...]
H A Dsts_client.c342 struct sts_end_request_data *send = (struct sts_end_request_data *)data; in build_end_request_data() local
377 if (memcpy_s(send->auth_data.auth_data, sizeof(send->auth_data.auth_data), in build_end_request_data()
382 send->auth_data.length = out_auth_data.length; in build_end_request_data()
425 int32_t send_sts_start_request(struct sts_client *sts_client, struct message *send) in send_sts_start_request() argument
428 check_ptr_return_val(send, HC_INPUT_ERROR); in send_sts_start_request()
441 send->msg_code = INFORM_MESSAGE; in send_sts_start_request()
444 send->msg_code = AUTH_START_REQUEST; in send_sts_start_request()
445 send->payload = send_data; in send_sts_start_request()
451 int32_t send_sts_end_request(struct sts_client *sts_client, const struct message *receive, struct message *send) in send_sts_end_request() argument
[all...]
/base/request/request/services/src/service/run_count/
H A Dmanager.rs38 if self.tx.send(event).is_err() {
121 let _ = tx.send(ErrorCode::ErrOk); in subscribe_run_count()
126 let _ = tx.send(ErrorCode::ErrOk); in unsubscribe_run_count()
128 let _ = tx.send(ErrorCode::Other); in unsubscribe_run_count()
/base/security/device_auth/frameworks/deviceauth_lite/inc/schedule/
H A Ddistribution.h70 struct message *send);
71 int32_t connect_message(struct hichain *handle, struct header_analysis *nav, struct message *send);
/base/security/device_auth/frameworks/deviceauth_lite/inc/key_agreement/
H A Dpake_client.h54 int32_t send_pake_start_request(struct pake_client *pake_client, struct message *send);
55 int32_t send_pake_end_request(struct pake_client *pake_client, const struct message *receive, struct message *send);
H A Dsts_client.h55 int32_t send_sts_start_request(struct sts_client *sts_client, struct message *send);
56 int32_t send_sts_end_request(struct sts_client *sts_client, const struct message *receive, struct message *send);
/base/request/request/services/src/manage/
H A Dtask_manager.rs188 let _ = tx.send(self.create(msg.config)); in handle_service_event()
191 let _ = tx.send(self.start(uid, task_id)); in handle_service_event()
194 let _ = tx.send(self.stop(uid, task_id)); in handle_service_event()
197 let _ = tx.send(self.pause(uid, task_id)); in handle_service_event()
200 let _ = tx.send(self.resume(uid, task_id)); in handle_service_event()
203 let _ = tx.send(self.remove(uid, task_id)); in handle_service_event()
206 let _ = tx.send(self.query_all_task()); in handle_service_event()
209 let _ = tx.send(self.query_one_task(task_id)); in handle_service_event()
259 let _ = tx.send(self.check_subscriber(task_id, token_id)); in handle_task_event()
356 if self.tx.send(even
[all...]
/base/security/device_auth/frameworks/deviceauth_lite/inc/auth_info/
H A Dexchange_auth_info_client.h27 int32_t send_exchange_request(const struct hichain *hichain, struct message *send);
H A Dremove_auth_info.h28 int32_t send_remove_response(const struct hichain *hichain, struct message *receive, struct message *send);
H A Dremove_auth_info_client.h40 int32_t send_remove_request(const struct hichain *hichain, struct message *send);
/base/security/device_auth/frameworks/deviceauth_lite/source/
H A Dhichain.c54 static void encap_inform_message(int32_t error_code, struct message *send);
153 struct message send = { INFORM_MESSAGE, 0, 0 }; in receive_data() local
169 ret = proc_message(hichain, &nav, &receive, &send); in receive_data()
173 ret = connect_message(hichain, &nav, &send); in receive_data()
176 encap_inform_message(ret, &send); in receive_data()
179 ret = build_send_data_by_struct(&send, &send_data, &send_data_len); in receive_data()
185 LOGI("Had no message to send"); in receive_data()
188 LOGE("build send data failed, error code is %d", ret); in receive_data()
192 set_result(hichain, receive.msg_code, send.msg_code, ret, errorCode); in receive_data()
195 destroy_send_data(&send); in receive_data()
517 encap_inform_message(int32_t error_code, struct message *send) encap_inform_message() argument
545 struct message send = { triggered_pake_client() local
587 struct message send = { triggered_sts_client() local
[all...]
/base/startup/appspawn/test/unittest/
H A Dgencoverage.sh58 hdc file send $@
90 hdc file send ${ohos_root}/out/${product_name}/tests/unittest/appspawn/appspawn_l2/AppSpawn_ut ${ut_target_path}/
/base/startup/init/services/modules/init_context/
H A Dinit_context.c133 PLUGIN_LOGV("send cmd '%s'", buffer); in SubInitExecuteCmd()
134 int ret = send(subInfo->sendFd, buffer, len, 0); in SubInitExecuteCmd()
136 PLUGIN_LOGI("Failed to send cmd %s to %d, need fork new chip init process", name, subInfo->type); in SubInitExecuteCmd()
139 ret = send(subInfo->sendFd, buffer, len, 0); in SubInitExecuteCmd()
141 PLUGIN_CHECK(ret > 0, return errno, "Failed to send cmd %s to %d errno %d", name, subInfo->type, errno); in SubInitExecuteCmd()
217 ret = send(subInfo->sendFd, buffer, len, 0); in HandleRecvMessage()
218 PLUGIN_CHECK(ret > 0, return, "Failed to send result to %d errno %d", subInfo->type, errno); in HandleRecvMessage()
/base/msdp/device_status/utils/ipc/src/
H A Dstream_client.cpp66 ssize_t number = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
82 FI_HILOGE("Too many times to send :%{public}d/%{public}d, size:%{public}d/%{public}d, fd:%{public}d", in SendMsg()
H A Dstream_session.cpp61 ssize_t count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
/base/request/request/services/src/manage/scheduler/queue/
H A Dkeeper.rs92 let _ = tx.send(TaskManagerEvent::Schedule(ScheduleEvent::Unload));
/base/msdp/device_status/intention/ipc/socket/src/
H A Dsocket_session.cpp78 ssize_t count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/
H A Dstream_session.rs133 libc::send(self.fd as c_int, buf.add(idx) as *const libc::c_void, rem_size, in session_send_msg()
/base/startup/init/test/unittest/tools/
H A Dprepare_testdata.sh79 hdc file send ${ohos_root}/out/${product_name}/tests/unittest/startup/init/init_unittest /data/init_ut/init_unittest
/base/sensors/sensor/utils/common/src/
H A Dsensor_basic_data_channel.cpp161 length = send(sendFd_, vaddr, size, MSG_DONTWAIT | MSG_NOSIGNAL); in SendData()

Completed in 10 milliseconds

12