/foundation/communication/netmanager_base/services/netstatsmanager/src/ |
H A D | net_stats_history.cpp | 23 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, uint64_t start, uint64_t end) in GetHistory() argument 30 return handler->ReadStatsData(recv, start, end); in GetHistory() 33 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, uint64_t start, uint64_t end) in GetHistory() argument 40 return handler->ReadStatsData(recv, uid, start, end); in GetHistory() 43 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, const std::string &iface, uint64_t start, in GetHistory() argument 51 return handler->ReadStatsData(recv, iface, start, end); in GetHistory() 54 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, const std::string &iface, uint32_t uid, in GetHistory() argument 62 return handler->ReadStatsData(recv, iface, uid, start, end); in GetHistory() 65 int32_t NetStatsHistory::GetHistoryByIdent(std::vector<NetStatsInfo> &recv, const std::string &ident, uint64_t start, in GetHistoryByIdent() argument 73 return handler->ReadStatsDataByIdent(recv, iden in GetHistoryByIdent() 76 GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, const std::string &ident, uint64_t start, uint64_t end) GetHistory() argument [all...] |
/third_party/node/deps/v8/src/regexp/ |
H A D | regexp-utils.cc | 40 V8_INLINE bool HasInitialRegExpMap(Isolate* isolate, JSReceiver recv) { in HasInitialRegExpMap() argument 41 return recv.map() == isolate->regexp_function()->initial_map(); in HasInitialRegExpMap() 47 Handle<JSReceiver> recv, in SetLastIndex() 51 if (HasInitialRegExpMap(isolate, *recv)) { in SetLastIndex() 52 JSRegExp::cast(*recv).set_last_index(*value_as_object, in SetLastIndex() 54 return recv; in SetLastIndex() 57 isolate, recv, isolate->factory()->lastIndex_string(), value_as_object, in SetLastIndex() 63 Handle<JSReceiver> recv) { in GetLastIndex() 64 if (HasInitialRegExpMap(isolate, *recv)) { in GetLastIndex() 65 return handle(JSRegExp::cast(*recv) in GetLastIndex() 46 SetLastIndex(Isolate* isolate, Handle<JSReceiver> recv, uint64_t value) SetLastIndex() argument 62 GetLastIndex(Isolate* isolate, Handle<JSReceiver> recv) GetLastIndex() argument [all...] |
/third_party/libuv/test/ |
H A D | test-ipc-send-recv.c | 51 union handles recv; member 61 union handles recv; member 94 union handles* recv; in recv_cb() local 103 recv = &ctx.recv; in recv_cb() 105 recv = &ctx.recv2; in recv_cb() 124 r = uv_pipe_init(ctx.channel.loop, &recv->pipe, 0); in recv_cb() 126 r = uv_tcp_init(ctx.channel.loop, &recv->tcp); in recv_cb() 131 r = uv_accept(handle, &recv->stream); in recv_cb() 294 uv_close(&ctx2.recv in write2_cb() 308 union handles* recv; read_cb() local [all...] |
/third_party/node/src/api/ |
H A D | callback.cc | 172 Local<Object> recv, in InternalMakeCallback() 177 CHECK(!recv.IsEmpty()); in InternalMakeCallback() 213 ret = hook_cb->Call(context, recv, args.length(), &args[0]); in InternalMakeCallback() 215 ret = callback->Call(context, recv, argc, argv); in InternalMakeCallback() 234 Local<Object> recv, in MakeCallback() 241 return MakeCallback(isolate, recv, method_string, argc, argv, asyncContext); in MakeCallback() 245 Local<Object> recv, in MakeCallback() 252 Environment::GetCurrent(recv->GetCreationContext().ToLocalChecked()); in MakeCallback() 257 if (!recv->Get(isolate->GetCurrentContext(), symbol).ToLocal(&callback_v)) in MakeCallback() 265 return MakeCallback(isolate, recv, callbac in MakeCallback() 170 InternalMakeCallback(Environment* env, Local<Object> resource, Local<Object> recv, const Local<Function> callback, int argc, Local<Value> argv[], async_context asyncContext) InternalMakeCallback() argument 233 MakeCallback(Isolate* isolate, Local<Object> recv, const char* method, int argc, Local<Value> argv[], async_context asyncContext) MakeCallback() argument 244 MakeCallback(Isolate* isolate, Local<Object> recv, Local<String> symbol, int argc, Local<Value> argv[], async_context asyncContext) MakeCallback() argument 268 MakeCallback(Isolate* isolate, Local<Object> recv, Local<Function> callback, int argc, Local<Value> argv[], async_context asyncContext) MakeCallback() argument 299 MakeSyncCallback(Isolate* isolate, Local<Object> recv, Local<Function> callback, int argc, Local<Value> argv[]) MakeSyncCallback() argument 327 MakeCallback(Isolate* isolate, Local<Object> recv, const char* method, int argc, Local<Value>* argv) MakeCallback() argument 338 MakeCallback(Isolate* isolate, Local<Object> recv, Local<String> symbol, int argc, Local<Value>* argv) MakeCallback() argument 349 MakeCallback(Isolate* isolate, Local<Object> recv, Local<Function> callback, int argc, Local<Value>* argv) MakeCallback() argument [all...] |
/foundation/communication/netmanager_base/services/netstatsmanager/include/ |
H A D | net_stats_history.h | 31 int32_t GetHistory(std::vector<NetStatsInfo> &recv, uint64_t start = 0, uint64_t end = LONG_MAX); 32 int32_t GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, uint64_t start = 0, uint64_t end = LONG_MAX); 33 int32_t GetHistory(std::vector<NetStatsInfo> &recv, const std::string &iface, uint64_t start = 0, 35 int32_t GetHistory(std::vector<NetStatsInfo> &recv, const std::string &iface, uint32_t uid, uint64_t start = 0, 37 int32_t GetHistoryByIdent(std::vector<NetStatsInfo> &recv, const std::string &ident, uint64_t start = 0, 39 int32_t GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, const std::string &ident, uint64_t start = 0,
|
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/ |
H A D | ut_net_quota_policy.cpp | 110 NetQuotaPolicy recv; in HWTEST_F() local 111 ret = NetQuotaPolicy::Unmarshalling(parcel, recv); in HWTEST_F() 113 EXPECT_EQ(recv.networkmatchrule.simId, data.networkmatchrule.simId); in HWTEST_F() 114 EXPECT_EQ(recv.networkmatchrule.ident, data.networkmatchrule.ident); in HWTEST_F() 132 std::vector<NetQuotaPolicy> recv; in HWTEST_F() local 133 ret = NetQuotaPolicy::Unmarshalling(parcel, recv); in HWTEST_F() 135 std::for_each(recv.begin(), recv.end(), [this](const auto &cv) { in HWTEST_F()
|
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
H A D | fillp_common.c | 173 FILLP_LOGINF("cost between send-recv: last seq:%u, cost:%lld, size:%u", item->seqNum, in LogForMsgRTT() 375 pack.lostSeq = pcb->recv.seqNum; in FillpSendAdhocpack() 385 struct SkipList *recvList = &pcb->recv.recvList; in FillpUploadRecvBox() 399 1.startSeq = recv.seqNum : This pkt is we expected in FillpUploadRecvBox() 400 2.startSeq < recv.seqNum : This pkt has been recved in FillpUploadRecvBox() 401 3.startSeq > recv.seqNum : There is a gap between this pkt and last recved one in FillpUploadRecvBox() 403 if (start_seq != pcb->recv.seqNum) { in FillpUploadRecvBox() 410 pcb->recv.seqNum = item->seqNum; in FillpUploadRecvBox() 411 pcb->recv.recvBytes -= item->dataLen; in FillpUploadRecvBox() 430 if ((pcb->recv in FillpUploadRecvBox() [all...] |
/third_party/protobuf/ruby/src/main/java/com/google/protobuf/jruby/ |
H A D | RubyEnum.java | 51 public static IRubyObject lookup(ThreadContext context, IRubyObject recv, IRubyObject number) { in lookup() argument 52 RubyEnumDescriptor rubyEnumDescriptorescriptor = (RubyEnumDescriptor) getDescriptor(context, recv); in lookup() 67 public static IRubyObject resolve(ThreadContext context, IRubyObject recv, IRubyObject name) { in resolve() argument 68 RubyEnumDescriptor rubyEnumDescriptorescriptor = (RubyEnumDescriptor) getDescriptor(context, recv); in resolve() 83 public static IRubyObject getDescriptor(ThreadContext context, IRubyObject recv) { in getDescriptor() argument 84 return ((RubyModule) recv).getInstanceVariable(Utils.DESCRIPTOR_INSTANCE_VAR); in getDescriptor()
|
/third_party/node/test/addons/make-callback/ |
H A D | test.js | 22 const recv = { 25 assert.strictEqual(recv, this); 30 assert.strictEqual(recv, this); 36 assert.strictEqual(makeCallback(recv, 'one'), 42); 37 assert.strictEqual(makeCallback(recv, 'two', 1337), 42);
|
H A D | binding.cc | 13 auto recv = args[0].As<v8::Object>(); in MakeCallback() local 22 node::MakeCallback(isolate, recv, method, argv.size(), argv.data(), in MakeCallback() 27 node::MakeCallback(isolate, recv, method, argv.size(), argv.data(), in MakeCallback()
|
/third_party/lwip/test/unit/ip4/ |
H A D | test_ip4.c | 87 fail_unless(lwip_stats.ip_frag.recv == 1); in START_TEST() 94 fail_unless(lwip_stats.ip_frag.recv == 2); in START_TEST() 101 fail_unless(lwip_stats.ip_frag.recv == 3); in START_TEST() 108 fail_unless(lwip_stats.ip_frag.recv == 4); in START_TEST() 115 fail_unless(lwip_stats.ip_frag.recv == 5); in START_TEST() 122 fail_unless(lwip_stats.ip_frag.recv == 6); in START_TEST() 129 fail_unless(lwip_stats.ip_frag.recv == 7); in START_TEST() 136 fail_unless(lwip_stats.ip_frag.recv == 8); in START_TEST() 143 fail_unless(lwip_stats.ip_frag.recv == 9); in START_TEST()
|
/foundation/multimodalinput/input/intention/ipc/socket/src/ |
H A D | socket_connection.cpp | 32 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
|
/foundation/arkui/ace_engine/frameworks/component_test/core/ |
H A D | action.cpp | 25 static void DecomposeTap(EventMatrix& recv, const NG::PointF& point) in DecomposeTap() argument 32 recv = std::move(pointerEventMatrix); in DecomposeTap() 35 static void DecomposeDoubleTap(EventMatrix& recv, const NG::PointF& point) in DecomposeDoubleTap() argument 45 recv = std::move(pointerEventMatrix); in DecomposeDoubleTap() 48 static void DecomposePress(EventMatrix& recv, const NG::PointF& point, uint32_t duration) in DecomposePress() argument 56 recv = std::move(pointerEventMatrix); in DecomposePress() 120 void ClickAction::Decompose(EventMatrix& recv) const in Decompose() 124 DecomposeTap(recv, point_); in Decompose() 127 DecomposeDoubleTap(recv, point_); in Decompose() 130 DecomposePress(recv, point in Decompose() [all...] |
/foundation/arkui/ace_engine/interfaces/napi/kits/component_test/ |
H A D | js_component_test_utils.cpp | 89 bool CheckAndParseStr(napi_env env, napi_value arg, std::string& recv, std::string& errMsg) in CheckAndParseStr() argument 111 recv = message.get(); in CheckAndParseStr() 115 bool CheckAndParseInt32(napi_env env, napi_value arg, int32_t& recv, std::string& errMsg) in CheckAndParseInt32() argument 129 napi_get_value_int32(env, arg, &recv); in CheckAndParseInt32() 133 bool CheckAndParseUInt32(napi_env env, napi_value arg, uint32_t& recv, std::string& errMsg) in CheckAndParseUInt32() argument 147 napi_get_value_uint32(env, arg, &recv); in CheckAndParseUInt32() 151 bool CheckAndParseBool(napi_env env, napi_value arg, bool& recv, std::string& errMsg) in CheckAndParseBool() argument 165 napi_get_value_bool(env, arg, &recv); in CheckAndParseBool()
|
/third_party/ltp/utils/sctp/func_tests/ |
H A D | test_1_to_1_shutdown.c | 150 error = recv(acpt_sk[0], msgbuf, 100, 0); in main() 152 tst_brkm(TBROK, tst_exit, "recv on a SHUTDOWN received socket " in main() 161 error = recv(clnt_sk[0], msgbuf, 100, 0); in main() 163 tst_brkm(TBROK, tst_exit, "recv on a SHUT_WR socket with no " in main() 173 error = recv(clnt_sk[1], msgbuf, 100, 0); in main() 175 tst_brkm(TBROK, tst_exit, "recv on a SHUT_RD socket " in main() 191 error = recv(clnt_sk[1], msgbuf, 100, 0); in main() 193 tst_brkm(TBROK, tst_exit, "recv on a SHUT_RD socket " in main() 202 error = recv(acpt_sk[2], msgbuf, 100, 0); in main() 204 tst_brkm(TBROK, tst_exit, "recv o in main() [all...] |
/third_party/node/test/parallel/ |
H A D | test-event-emitter-get-max-listeners.js | 17 const recv = {}; 18 EventEmitter.prototype.on.call(recv, 'event', () => {}); 19 EventEmitter.prototype.on.call(recv, 'event', () => {});
|
H A D | test-socket-writes-before-passed-to-tls-socket.js | 12 const recv = []; 14 recv.push(chunk); 19 const clientHelloFstByte = Buffer.concat(recv).subarray(HEAD.length, HEAD.length + 1);
|
/third_party/toybox/porting/liteos_a/toys/net/ |
H A D | ping.c | 49 unsigned long sent, recv, fugit, min, max; 56 lostret = TT.sent > TT.recv ? ((TT.sent-TT.recv)*100)/(TT.sent?TT.sent:1) : 0; in summary() 60 TT.sent, TT.recv, lostret); in summary() 62 TT.min, TT.max, TT.fugit/(TT.recv?TT.recv:1)); in summary() 202 if (0>=(waitms = tW-tnow) || !(TT.sent-TT.recv)) break; in ping_main() 241 TT.recv++; in ping_main()
|
/third_party/node/test/node-api/test_worker_terminate/ |
H A D | test_worker_terminate.c | 8 napi_value recv; in Test() local 12 NODE_API_CALL(env, napi_get_cb_info(env, info, &argc, argv, &recv, NULL)); in Test() 20 status = napi_call_function(env, recv, argv[0], 0, NULL, NULL); in Test()
|
/third_party/node/test/node-api/test_async_context/ |
H A D | test.js | 42 const recv = {}; 43 makeCallback(resourceWrap, recv, function callback() { 49 assert.strictEqual(this, recv);
|
/third_party/node/test/node-api/test_make_callback_recurse/ |
H A D | binding.c | 10 napi_value recv = args[0]; in MakeCallback() local 14 recv, func, 0 /* argc */, NULL /* argv */, NULL /* result */); in MakeCallback() 29 return recv; in MakeCallback()
|
/foundation/arkui/ace_engine/interfaces/napi/kits/measure/ |
H A D | js_measure.cpp | 90 ResourceInfo recv; in HandleIntStyle() local 91 if (!ParseResourceParam(env, fontStyleNApi, recv)) { in HandleIntStyle() 94 if (!ParseString(recv, fontStyleStr)) { in HandleIntStyle() 120 ResourceInfo recv; in HandleStringType() local 121 if (!ParseResourceParam(env, ParameterNApi, recv)) { in HandleStringType() 124 if (!ParseString(recv, ParameterStr)) { in HandleStringType() 154 ResourceInfo recv; in HandleDimensionType() local 155 if (!ParseResourceParam(env, ParameterNApi, recv)) { in HandleDimensionType() 158 if (!ParseString(recv, ParameterStr)) { in HandleDimensionType() 161 if (!ParseIntegerToString(recv, ParameterSt in HandleDimensionType() [all...] |
/third_party/node/deps/v8/src/builtins/ |
H A D | builtins-regexp.cc | 21 CHECK_RECEIVER(JSReceiver, recv, "RegExp.prototype.toString"); in BUILTIN() 23 if (*recv == isolate->regexp_function()->prototype()) { in BUILTIN() 34 JSReceiver::GetProperty(isolate, recv, in BUILTIN() 47 JSReceiver::GetProperty(isolate, recv, in BUILTIN()
|
/third_party/toybox/toys/net/ |
H A D | ping.c | 55 unsigned long sent, recv, fugit, min, max; 64 TT.sent, TT.recv, ((TT.sent-TT.recv)*100)/(TT.sent?TT.sent:1)); in summary() 65 if (TT.recv) in summary() 67 TT.min, TT.fugit/TT.recv, TT.max); in summary() 236 if (0>=(waitms = tW-tnow) || !(TT.sent-TT.recv)) break; in ping_main() 275 TT.recv++; in ping_main()
|
/foundation/communication/netmanager_base/frameworks/js/napi/netpolicy/src/ |
H A D | napi_net_policy.cpp | 146 napi_value recv = nullptr; in CompleteSetPolicyByUid() local 149 napi_get_undefined(env, &recv); in CompleteSetPolicyByUid() 156 napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteSetPolicyByUid() 183 napi_value recv = nullptr; in CompleteGetUidsByPolicy() local 186 napi_get_undefined(env, &recv); in CompleteGetUidsByPolicy() 189 napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetUidsByPolicy() 210 napi_value recv = nullptr; in CompleteGetPolicyByUid() local 213 napi_get_undefined(env, &recv); in CompleteGetPolicyByUid() 216 napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetPolicyByUid() 255 napi_value recv in CompleteNetPolicyResultCode() local 285 napi_value recv = nullptr; CompleteOn() local 313 napi_value recv = nullptr; CompleteOff() local 531 napi_value recv = nullptr; CompleteSetBackgroundPolicy() local [all...] |