Home
last modified time | relevance | path

Searched refs:send (Results 1 – 25 of 584) sorted by relevance

12345678910>>...24

/ohos5.0/drivers/hdf_core/framework/tools/hcs-view/hcsVSCode/
H A Dextension.js26 send('whiteCutImg', whiteCutImg);
28 send('circleImg', circleImg);
34 send('nodeIconImg', nodeIconImg);
36 send('attrIconImg', attrIconImg);
38 send('rootIconImg', rootIconImg);
49 send('upCutImg', upCutImg);
51 send('downCut', downCutImg);
120 send('freshfiledata', {
124 send('parse', e.uri.fsPath);
138 send('filedata', {
[all …]
/ohos5.0/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);
185 send->msg_code = INVALID_MESSAGE; in connect_message()
259 (send)->msg_code = INVALID_MESSAGE; \
295 (void)send; in proc_exchange_response_message()
298 send->msg_code = INVALID_MESSAGE; in proc_exchange_response_message()
367 struct message *send) in proc_inform_message() argument
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_common.c353 pktSendCnt = pcb->send.unackList.count + pcb->send.unrecvList.nodeNum + in FillpAckSendPcb()
354 pcb->send.itemWaitTokenLists.nodeNum + pcb->send.redunList.nodeNum; in FillpAckSendPcb()
357 pcb->send.inSendBytes); in FillpAckSendPcb()
358 pcb->send.inSendBytes = 0; in FillpAckSendPcb()
452 pcb->send.nackRandomNum++; in FillpSendRepaetNack()
474 struct FillpPktNack *nack = pcb->send.retryNackQueue[pcb->send.retryIndex]; in FillpSendNack()
482 pcb->send.retryNackQueue[pcb->send.retryIndex] = nack; in FillpSendNack()
504 pcb->send.retryIndex++; in FillpSendNack()
506 pcb->send.retryIndex = pcb->send.retryIndex % pcb->statistics.nack.historyNackQueueLen; in FillpSendNack()
706 pcb->send.tailProtect.judgeThreshold = pcb->send.tailProtect.minJudgeThreshold; in FillpAjustTlpParameterByRtt()
[all …]
H A Dfillp_flow_control.c204 … pcb->send.unrecvList.nodeNum + pcb->send.itemWaitTokenLists.nodeNum + pcb->send.redunList.nodeNum; in FillpFcTailProtected()
207 unsendSize += pcb->send.unSendList.size; in FillpFcTailProtected()
213 tailProtect = &pcb->send.tailProtect; in FillpFcTailProtected()
222 pcb->send.unSendList.size, pcb->send.unackList.count, ackSeqNum); in FillpFcTailProtected()
277 if (pcb->send.slowStart) { in FillpFcInit()
280 … FILLP_LOGDBG("slowStart:%u init_rate:%u", pcb->send.slowStart, pcb->send.flowControl.sendRate); in FillpFcInit()
288 pcb->send.flowControl.sendTime = 0; in FillpFcInit()
289 pcb->send.flowControl.sendRateLimit = 0; in FillpFcInit()
290 pcb->send.flowControl.remainBytes = 0; in FillpFcInit()
294 pcb->send.tailProtect.lastPackSeq = 0; in FillpFcInit()
[all …]
H A Dfillp_flow_control_alg0.c32 struct FillpFlowControl *flowControl = &pcb->send.flowControl; in FillpAlg0CalSendInterval()
55 alg->flowControl = &pcb->send.flowControl; in FillpAlg0FlowControlInit()
101 pcb->send.flowControl.fcAlg = alg; in FillpAlg0FcInit()
105 pcb->send.tailProtect.judgeThreshold = FILLP_ONE_FIFTH_OF_RTT; in FillpAlg0FcInit()
106 pcb->send.retramistRto = (FILLP_ULLONG)pcb->rtt; in FillpAlg0FcInit()
107 pcb->send.flowControl.sendRate = FILLP_FC0_DEFAULT_RATE; in FillpAlg0FcInit()
122 if (pcb->send.flowControl.fcAlg == FILLP_NULL_PTR) { in FillpAlg0FcDeinit()
132 pcb->send.flowControl.fcAlg = FILLP_NULL_PTR; in FillpAlg0FcDeinit()
158 struct FillpFlowControl *flowControl = &pcb->send.flowControl; in FillpAlg0FcHandleInit()
168 pcb->send.tailProtect.judgeThreshold = FILLP_ONE_FIFTH_OF_RTT; in FillpAlg0FcHandleInit()
[all …]
H A Dfillp_input.c319 FillpNumIsbigger(pcb->send.seqNum, (pktHdr->seqNum + pcb->send.pktSendCache))) { in FillpCheckNackSeq()
462 (seqPktNum.beginPktNum + 1), pcb->send.unrecvList.nodeNum, pcb->send.unackList.count); in FillpNackInput()
465 FILLP_LOGDBG("recv NACK send seqnum = %u,send pkt = %u", pcb->send.seqNum, pcb->send.pktNum); in FillpNackInput()
480 if (pcb->send.unrecvList.nodeNum) { in FillpNackInput()
565 FillpNumIsbigger(pcb->send.seqNum, (ackSeqNum + pcb->send.pktSendCache))) { in FillpCheckPackNumber()
568 FILLP_GET_SOCKET(pcb)->index, ackSeqNum, pcb->send.seqNum, pcb->send.ackSeqNum, in FillpCheckPackNumber()
569 pcb->send.unSendList.size, pcb->send.unrecvList.nodeNum, pcb->send.unackList.count, in FillpCheckPackNumber()
570 … pcb->send.itemWaitTokenLists.nodeNum, pcb->send.redunList.nodeNum, pcb->send.curItemCount, in FillpCheckPackNumber()
705 pcb->send.packSameAckNum++; in MoveUnackToUnrecvByPackInfo()
712 pcb->send.packSameAckNum = 0; in MoveUnackToUnrecvByPackInfo()
[all …]
H A Dfillp_output.c33 struct FillpSendPcb *sendPcb = &pcb->send; in FillpMoveRedundantItemToUnrecvList()
65 item->seqNum = pcb->send.seqNum; in FillpGetSendItem()
114 pcb->send.unSendList.size, pcb->send.unackList.count, pcb->send.unrecvList.nodeNum, in FillpDoneSendAllData()
115 pcb->send.redunList.nodeNum, pcb->send.itemWaitTokenLists.nodeNum, in FillpDoneSendAllData()
116 pcb->send.curItemCount); in FillpDoneSendAllData()
135 struct FillpSendPcb *sendPcb = &pcb->send; in FillpBeforeSendItem()
272 pcb->send.pktNum); in FillpBuildDataPkt()
339 pcb->send.unackList.count++; in FillpAddToUnackList()
346 … struct Hlist *list = &pcb->send.pktSeqMap.hashMap[item->pktNum & pcb->send.pktSeqMap.hashModSize]; in FillpAddToPktSeqHash()
368 fpcb->send.preItem = (void *)item; in FillpItemRetrans()
[all …]
/ohos5.0/docs/zh-cn/application-dev/dfx/
H A Dappfreeze-guidelines.md285 …Current Running:start at 2017-08-08 05:06:18.145,Event send thread 1561,send time =2017-08-08 05:0…
289 …No.1 Event send thread 1561,send time 2017-08-08 05:06:18.039,handle time 2017-08-08 05:06:21.539,…
291 …No.1:Event{send thread=1566,send time=2017-08-0805:06:21.062,handle time=2017-08-0805:06:21.062,id…
325 …Current Running:start at 2017-08-08 05:06:18.144, Event {send thread 1561,send time =2017-08-08 05…
329 …No.1 Event send thread 1561,send time 2017-08-08 05:06:18.039,handle time 2017-08-08 05:06:21.539,…
331 …No.1:Event{send thread=1566,send time=2017-08-0805:06:21.062,handle time=2017-08-0805:06:21.062,id…
332 …No.2 Event send thread 1566,send time 2017-08-08 05:06:24.369,handle time 2017-08-08 05:06:24.369,…
530 …No. 1 : Event { send thread = 35862, send time = 2024-08-08 12:17:25.526, handle time = 2024-08-08…
531 …No. 2 : Event { send thread = 35862, send time = 2024-08-08 12:17:28.526, handle time = 2024-08-08…
532 …No. 3 : Event { send thread = 35862, send time = 2024-08-08 12:17:31.526, handle time = 2024-08-08…
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_multi_threaded.rs33 sender.send(()).unwrap();
42 sender.send(()).unwrap();
56 let (send, recv) = mpsc::sync_channel(TASK_NUM);
61 $fn(&runtime, send.clone());
96 sender.send(()).unwrap(); in chained_spawn()
104 let (send, recv) = mpsc::sync_channel(TASK_NUM); in chained_spawn()
108 let sender = send.clone(); in chained_spawn()
140 sender.send(()).unwrap(); in chained_spawn()
147 let (send, recv) = mpsc::sync_channel(TASK_NUM); in chained_spawn()
150 let sender = send.clone(); in chained_spawn()
H A Dsync_benchmarks.rs101 let (send, recv) = mpsc::sync_channel(TASK_NUM); in std_multi_threaded_ping()
104 let sender = send.clone(); in std_multi_threaded_ping()
107 sender.send(()).unwrap(); in std_multi_threaded_ping()
119 let (send, recv) = mpsc::sync_channel(TASK_NUM); in std_multi_threaded_ping_pong()
122 let done_send = send.clone(); in std_multi_threaded_ping_pong()
130 send2.send(()).unwrap(); in std_multi_threaded_ping_pong()
133 send1.send(()).unwrap(); in std_multi_threaded_ping_pong()
136 done_send.send(()).unwrap(); in std_multi_threaded_ping_pong()
/ohos5.0/base/request/request/services/src/service/client/
H A Dmanager.rs38 if self.tx.send(event).is_err() { in send_event()
93 if let Err(err) = tx.send(ClientEvent::SendResponse( in run()
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(ErrorCode::ChannelNotOpen); in handle_subscribe()
170 let _ = tx.send(ErrorCode::ErrOk); in handle_unsubscribe()
178 let _ = tx.send(ErrorCode::Other); in handle_unsubscribe()
192 let _ = tx.send(ClientEvent::Shutdown); in handle_process_terminated()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dmpsc_test.rs35 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_test()
36 assert!(tx.send(2).is_ok()); in sdv_unbounded_send_recv_test()
54 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_drop_test()
55 assert!(tx.send(2).is_ok()); in sdv_unbounded_send_recv_drop_test()
70 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_try_recv_test()
86 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_timeout_test()
112 assert!(tx.send(1).await.is_ok()); in sdv_bounded_send_recv_test()
113 assert!(tx.send(2).await.is_ok()); in sdv_bounded_send_recv_test()
133 assert!(tx.send(1).await.is_ok()); in sdv_bounded_send_recv_drop_test()
196 assert!(tx.send(1).is_err()); in sdv_mpsc_is_closed()
[all …]
/ohos5.0/docs/zh-cn/application-dev/arkts-utils/
H A Dmakeobserved-sendable.md43 @Local send: SendableData = UIUtils.makeObserved(new SendableData());
47 Text(this.send.name)
50 this.send.name += "0";
56 // 所以这里只是将`this.send`的属性`name`传给子线程操作。
57 taskpool.execute(threadGetData, this.send.name).then(val => {
58 // 和@Local一起使用，可以观察this.send的变化
59 this.send = UIUtils.makeObserved(val as SendableData);
/ohos5.0/docs/en/application-dev/dfx/
H A Dappfreeze-guidelines.md285 …Current Running:start at 2017-08-08 05:06:18.145,Event send thread 1561,send time =2017-08-08 05:0…
289 …No.1 Event send thread 1561,send time 2017-08-08 05:06:18.039,handle time 2017-08-08 05:06:21.539,…
291 …No.1:Event{send thread=1566,send time=2017-08-0805:06:21.062,handle time=2017-08-0805:06:21.062,id…
325 …Current Running:start at 2017-08-08 05:06:18.144, Event {send thread 1561,send time =2017-08-08 05…
329 …No.1 Event send thread 1561,send time 2017-08-08 05:06:18.039,handle time 2017-08-08 05:06:21.539,…
331 …No.1:Event{send thread=1566,send time=2017-08-0805:06:21.062,handle time=2017-08-0805:06:21.062,id…
332 …No.2 Event send thread 1566,send time 2017-08-08 05:06:24.369,handle time 2017-08-08 05:06:24.369,…
530 …No. 1 : Event { send thread = 35862, send time = 2024-08-08 12:17:25.526, handle time = 2024-08-08…
531 …No. 2 : Event { send thread = 35862, send time = 2024-08-08 12:17:28.526, handle time = 2024-08-08…
532 …No. 3 : Event { send thread = 35862, send time = 2024-08-08 12:17:31.526, handle time = 2024-08-08…
[all …]
/ohos5.0/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 … 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 …d_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 …ld_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()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dpcb.c65 if (!OS_SOCK_OPS_FUNC_VALID(osSock, send)) { in SpungePcbSend()
72 if (size != (FILLP_INT) osSock->ioSock->ops->send(osSock->ioSock, in SpungePcbSend()
162 FILLP_BOOL send = FILLP_FALSE; in SpungePcbSendmsg() local
182 send = FILLP_TRUE; in SpungePcbSendmsg()
189 if ((conn->iovCount < UDP_MAX_SEG) && (fpcb->isLast == FILLP_FALSE) && send == FILLP_FALSE) { in SpungePcbSendmsg()
224 pcb->fpcb.send.pktStartNum = FILLP_CRYPTO_RAND(); in SpungePcbNew()
225 pcb->fpcb.send.seqStartNum = FILLP_CRYPTO_RAND(); in SpungePcbNew()
230 pcb->rateControl.send.curMaxRateLimitation = 0; in SpungePcbNew()
231 pcb->rateControl.send.weight = 0; in SpungePcbNew()
268 pcb->fpcb.send.slowStart = slowStart; in SpungePcbSetSlowStart()
[all …]
H A Dspunge_core.c89 bytesExpected += pcb->fpcb.send.flowControl.remainBytes; in SpungeCalExpectedBytes()
97 sock->index, pcb->fpcb.send.unrecvList.nodeNum, pcb->fpcb.send.unackList.count); in SpungeCalExpectedBytes()
107 pcb->fpcb.send.flowControl.remainBytes = 0; in SpungeDoSendUpdate()
149 pcb->fpcb.send.flowControl.remainBytes = bytesExpected; in SpungeDoSendCycle()
155 if ((pcb->fpcb.send.flowControl.remainBytes) || (!HLIST_EMPTY(&pcb->fpcb.send.unSendList)) || in SpungeDoSendCycle()
156 (pcb->fpcb.send.redunList.nodeNum) || (pcb->fpcb.send.unrecvList.nodeNum)) { in SpungeDoSendCycle()
1091 calcSendTotalRate = inst->rateControl.send.maxRate; in FillpServerSendRateAdjustment()
1099 *connSendCalLimit = inst->rateControl.send.maxRate; in FillpServerSendRateAdjustment()
1164 pcb->fpcb.send.flowControl.sendRateLimit = pcb->rateControl.send.curMaxRateLimitation; in FillpCalculateFairness()
1341 (void)SYS_ARCH_SEM_POST(&fpcb->send.sendSem); in SpungeItemRouteByToken()
[all …]
/ohos5.0/docs/en/application-dev/reference/apis-basic-services-kit/
H A Derrorcode-CommonEventService.md13 …ode is reported when the **Action** attribute in the **want** object is null for the event to send.
16 The **Action** attribute in the **want** object is null for the event to send.
24 A sandbox application cannot send common events.
27 This error code is reported when an attempt is made to send a common event from a sandbox applicati…
33 Check whether the application used to send a common event is a sandbox application. If so, switch t…
47 Do not send common events too frequently.
52 A third-party application cannot send system common events.
55 This error code is reported when the application cannot send system common events.
61 Make sure the application to send system common events is a system application or system service.
95 Failed to send the message to the common event service.
[all …]
/ohos5.0/base/tee/tee_client/
H A DREADME_zh.md85 hdc file send cadaemon.json /system/profile/
86 hdc file send cadaemon.cfg /system/etc/init/
87 hdc file send libteec.so /system/lib/
88 hdc file send libcadaemon.so /system/lib/
89 hdc file send tlogcat /system/bin/
90 hdc file send libteec_vendor.so /vendor/lib/
91 hdc file send teecd /vendor/bin/
/ohos5.0/foundation/communication/netstack/interfaces/kits/js/
H A D@ohos.net.socket.d.ts486 send(options: UDPSendOptions, callback: AsyncCallback<void>): void;
509 send(options: UDPSendOptions): Promise<void>;
1180 send(options: TCPSendOptions, callback: AsyncCallback<void>): void;
1203 send(options: TCPSendOptions): Promise<void>;
2144 send(data: string, callback: AsyncCallback<void>): void;
2173 send(data: string): Promise<void>;
2490 send(options: TCPSendOptions, callback: AsyncCallback<void>): void;
2503 send(options: TCPSendOptions): Promise<void>;
2781 send(data: string, callback: AsyncCallback<void>): void;
2796 send(data: string): Promise<void>;
/ohos5.0/base/security/device_auth/frameworks/deviceauth_lite/source/key_agreement/
H A Dpake_client.c79 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()
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->payload = send_data; in send_pake_end_request()
271 send->challenge = challenge; in build_end_request_data()
272 send->epk = pake_client->self_epk; in build_end_request_data()
[all …]
/ohos5.0/docs/zh-cn/application-dev/network/
H A Dwebsocket-connection.md5 …t()方法创建WebSocket对象，然后通过connect()方法连接到服务器。当连接成功后，客户端会收到open事件的回调，之后客户端就可以通过send()方法与服务器进行通信。当服务器发信息…
19 | send() | 通过WebSocket连接发送数据。 |
50 // 当收到on('open')事件时，可以通过send()方法与服务器进行通信
51 ws.send("Hello, server!", (err: BusinessError, value: boolean) => {
53 console.log("Message send successfully");
55 console.log("Failed to send the message. Err:" + JSON.stringify(err));
/ohos5.0/docs/en/application-dev/arkts-utils/
H A Dmakeobserved-sendable.md43 @Local send: SendableData = UIUtils.makeObserved(new SendableData());
47 Text(this.send.name)
50 this.send.name += "0";
56 // Therefore, only the'name' attribute of'this.send' is transferred to the subthread.
57 taskpool.execute(threadGetData, this.send.name).then(val => {
58 // Used together with @Local to observe the change of this.send.
59 this.send = UIUtils.makeObserved(val as SendableData);
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dstreams.rs87 send: ActiveState,
154 send: ActiveState::WaitHeaders,
159 (Open: $eos: expr, $state: expr, $send: expr) => {
161 H2StreamState::RemoteHalfClosed($send.clone())
164 send: $send.clone(),
378 .send(window_update) in window_update_conn()
398 .send(window_update) in window_update_streams()
584 send: ActiveState::WaitHeaders, in send_headers_frame()
617 send: ActiveState::WaitData, in send_data_frame()
675 send, in recv_headers()
[all …]

12345678910>>...24