Home
last modified time | relevance | path

Searched refs:recv (Results 1 – 25 of 141) sorted by relevance

123456

/aosp12/system/libbase/
H A Dcmsg_test.cpp58 unique_fd recv; member
75 ASSERT_EQ(1, ReceiveFileDescriptors(recv.get(), buf, 2, &received)); in TEST_P()
100 ASSERT_EQ(1, read(recv.get(), buf, 2)); in TEST_P()
109 ASSERT_EQ(-1, ReceiveFileDescriptors(recv.get(), buf, 1, &received)); in TEST_P()
118 ASSERT_EQ(1, ::recv(recv.get(), buf, sizeof(buf), MSG_PEEK)); in TEST_P()
122 ASSERT_EQ(1, ReceiveFileDescriptors(recv.get(), buf, 1, &received)); in TEST_P()
136 ASSERT_EQ(2, TEMP_FAILURE_RETRY(read(recv.get(), buf, 2))); in TEST_P()
140 ssize_t rc = ReceiveFileDescriptorVector(recv.get(), buf, 1, 1, &received1); in TEST_P()
146 rc = ReceiveFileDescriptors(recv.get(), buf, 1, &received2); in TEST_P()
172 ASSERT_EQ(1, ReceiveFileDescriptors(recv.get(), buf, 1, &received1)); in TEST_P()
[all …]
/aosp12/hardware/st/secure_element2/secure_element/1.0/esehal/src/
H A Diso7816_t1.c55 t1->recv.start = t1->recv.end = buf; in t1_init_recv_window()
56 t1->recv.size = n; in t1_init_recv_window()
62 return (ptrdiff_t)t1->recv.size - (t1->recv.end - t1->recv.start); in t1_recv_window_free_size()
74 t1->recv.end += n; in t1_recv_window_append()
81 return t1->recv.end - t1->recv.start; in t1_recv_window_size()
87 t1->recv.start = t1->recv.end; in t1_close_recv_window()
88 t1->recv.size = 0; in t1_close_recv_window()
184 if (t1->recv.next) in write_rblock()
650 t1->recv.start = t1->recv.end = NULL; in t1_clear_states()
651 t1->recv.size = 0; in t1_clear_states()
[all …]
H A Dlibse-gto.c188 …_transceive: ctx->t1.recv.end - ctx->t1.recv.start = %d\n", ctx->t1.recv.end - ctx->t1.recv.start); in se_gto_apdu_transmit()
189 dbg("isot1_transceive: ctx->t1.recv.size = %zu\n", ctx->t1.recv.size); in se_gto_apdu_transmit()
/aosp12/hardware/qcom/sm7150/gps/utils/
H A DLocIpc.h148 virtual ssize_t recv() const = 0;
151 inline bool recvData() const { return isRecvable() && (recv() > 0); } in recvData()
176 ssize_t recv(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb, int flags,
190 inline virtual ssize_t recv() const override { in recv() function
191 return mSock->recv(*this, mDataCb, 0, nullptr, nullptr); in recv()
H A DLocIpc.cpp69 ssize_t Sock::recv(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb, int flags, in recv() function in loc_util::Sock
164 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcLocalRecver
166 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
247 virtual ssize_t recv() const = 0;
275 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcInetTcpRecver
284 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size, mConnFd); in recv()
295 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcInetUdpRecver
297 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
/aosp12/hardware/qcom/sm8150p/gps/utils/
H A DLocIpc.cpp69 ssize_t Sock::recv(const shared_ptr<ILocIpcListener>& dataCb, int flags, struct sockaddr *srcAddr, in recv() function in loc_util::Sock
153 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcLocalRecver
155 return mSock->recv(mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
228 virtual ssize_t recv() const = 0;
254 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcInetTcpRecver
263 return mSock->recv(mDataCb, 0, (struct sockaddr*)&mAddr, &size, mConnFd); in recv()
274 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcInetUdpRecver
276 return mSock->recv(mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
304 inline virtual ssize_t recv() const override { return mService->recv(); } in recv() function in loc_util::LocIpcQcsiRecver
H A DLocIpc.h145 virtual ssize_t recv() const = 0;
148 inline bool recvData() const { return isRecvable() && (recv() > 0); } in recvData()
170 ssize_t recv(const shared_ptr<ILocIpcListener>& dataCb, int flags, struct sockaddr *srcAddr,
/aosp12/system/security/keystore2/src/
H A Denforcements.rs102 AuthRequestState::TimeStampedOpAuth(recv) | AuthRequestState::TimeStamp(recv) => { in get_auth_tokens()
103 let result = recv.recv().context("In get_auth_tokens: Sender disconnected.")?; in get_auth_tokens()
179 let recv = { in add_auth_token() localVariable
187 if let Some((_, recv)) = recv { in add_auth_token()
188 recv.add_auth_token(hat); in add_auth_token()
192 pub fn add_receiver(&self, challenge: i64, recv: TokenReceiver) { in add_receiver()
195 map.insert(challenge, recv); in add_receiver()
759 fn register_op_auth_receiver(&self, challenge: i64, recv: TokenReceiver) { in register_op_auth_receiver()
760 self.op_auth_map.add_receiver(challenge, recv); in register_op_auth_receiver()
H A Dasync_task.rs327 start_receiver.recv().unwrap(); in test_async_task()
355 let trace = trace_receiver.recv().unwrap(); in test_async_task()
372 receiver.recv().unwrap(); in test_async_task_chain()
387 done_receiver.recv().unwrap(); in test_async_task_panic()
419 done_receiver.recv().unwrap(); in test_async_task_idle()
440 done_receiver.recv().unwrap(); in test_async_task_idle()
522 idle_receiver.recv().unwrap(); in test_async_task_idle_panic()
530 done_receiver.recv().unwrap(); in test_async_task_idle_panic()
/aosp12/system/bt/gd/rust/hal/src/
H A Dhidl_hal.rs29 init_rx.recv().await.unwrap(); in provide_hidl_hal()
109 Some(cmd) = cmd_rx.recv() => ffi::send_command(&cmd.to_bytes()), in dispatch_outgoing()
110 Some(acl) = acl_rx.recv() => ffi::send_acl(&acl.to_bytes()), in dispatch_outgoing()
111 Some(iso) = iso_rx.recv() => ffi::send_iso(&iso.to_bytes()), in dispatch_outgoing()
H A Dsnoop.rs152 Some(cmd) = cmd_down_rx.recv() => { in provide_snooped_hal()
159 Some(acl) = acl_down_rx.recv() => { in provide_snooped_hal()
173 Some(iso) = iso_down_rx.recv() => { in provide_snooped_hal()
200 rx.lock().await.recv().await in consume()
/aosp12/hardware/qcom/sm7250/gps/utils/
H A DLocIpc.h183 virtual ssize_t recv() const = 0;
186 inline bool recvData() const { return isRecvable() && (recv() > 0); } in recvData()
211 ssize_t recv(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb, int flags,
225 inline virtual ssize_t recv() const override { in recv() function
226 return mSock->recv(*this, mDataCb, 0, nullptr, nullptr); in recv()
H A DLocIpc.cpp69 ssize_t Sock::recv(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb, int flags, in recv() function in loc_util::Sock
164 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcLocalRecver
166 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
247 virtual ssize_t recv() const = 0;
275 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcInetTcpRecver
284 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size, mConnFd); in recv()
295 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcInetUdpRecver
297 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
/aosp12/hardware/qcom/sm8150/gps/utils/
H A DLocIpc.h183 virtual ssize_t recv() const = 0;
186 inline bool recvData() const { return isRecvable() && (recv() > 0); } in recvData()
211 ssize_t recv(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb, int flags,
225 inline virtual ssize_t recv() const override { in recv() function
226 return mSock->recv(*this, mDataCb, 0, nullptr, nullptr); in recv()
H A DLocIpc.cpp69 ssize_t Sock::recv(const LocIpcRecver& recver, const shared_ptr<ILocIpcListener>& dataCb, int flags, in recv() function in loc_util::Sock
164 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcLocalRecver
166 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
247 virtual ssize_t recv() const = 0;
275 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcInetTcpRecver
284 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size, mConnFd); in recv()
295 inline virtual ssize_t recv() const override { in recv() function in loc_util::LocIpcInetUdpRecver
297 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
/aosp12/frameworks/base/tests/AmSlam/src/test/amslam/
H A DMainActivity.java118 public void onPingPongResponse(long send, long bounce, long recv, String remote) { in onPingPongResponse() argument
121 Log.e(TAG, "send " + send + ", bounce " + bounce + ", recv " + recv in onPingPongResponse()
127 mTotalTime += (recv - send); in onPingPongResponse()
129 mTotalPongTime += (recv - bounce); in onPingPongResponse()
/aosp12/system/bt/gd/hal/
H A Dhci_hal_host.cc399 RUN_NO_INTR(received_size = recv(sock_fd_, buf, kH4HeaderSize, 0)); in incoming_packet_received()
408 RUN_NO_INTR(received_size = recv(sock_fd_, buf + kH4HeaderSize, kHciEvtHeaderSize, 0)); in incoming_packet_received()
415 …payload_size = recv(sock_fd_, buf + kH4HeaderSize + kHciEvtHeaderSize, hci_evt_parameter_total_len… in incoming_packet_received()
437 RUN_NO_INTR(received_size = recv(sock_fd_, buf + kH4HeaderSize, kHciAclHeaderSize, 0)); in incoming_packet_received()
443 …RUN_NO_INTR(payload_size = recv(sock_fd_, buf + kH4HeaderSize + kHciAclHeaderSize, hci_acl_data_to… in incoming_packet_received()
466 RUN_NO_INTR(received_size = recv(sock_fd_, buf + kH4HeaderSize, kHciScoHeaderSize, 0)); in incoming_packet_received()
472 …RUN_NO_INTR(payload_size = recv(sock_fd_, buf + kH4HeaderSize + kHciScoHeaderSize, hci_sco_data_to… in incoming_packet_received()
490 RUN_NO_INTR(received_size = recv(sock_fd_, buf + kH4HeaderSize, kHciIsoHeaderSize, 0)); in incoming_packet_received()
496 …RUN_NO_INTR(payload_size = recv(sock_fd_, buf + kH4HeaderSize + kHciIsoHeaderSize, hci_iso_data_to… in incoming_packet_received()
/aosp12/art/test/179-nonvirtual-jni/
H A Dnonvirtual-call.cc26 JNIEnv* env, jclass, jclass lookup, jclass caller, jobject recv) { in Java_Main_callSayHiMethodNonvirtualWith() argument
28 env->CallNonvirtualVoidMethod(recv, caller, meth); in Java_Main_callSayHiMethodNonvirtualWith()
/aosp12/system/core/libcutils/
H A Dsockets_test.cpp49 EXPECT_EQ(3, recv(server, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
60 EXPECT_EQ(3, recv(client, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
69 EXPECT_EQ(11, recv(server, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
/aosp12/art/test/1982-no-virtuals-structural-redefinition/src/art/
H A DTest1982.java59 private static void readReflective(String msg, Field[] fields, Object recv) throws Exception { in readReflective() argument
63 f.toString() + " on " + printGeneric(recv) + " = " + printGeneric(f.get(recv))); in readReflective()
/aosp12/system/logging/logd/
H A Dlogd_test.cpp535 content_wrap = recv(fd, msg_wrap.buf, sizeof(msg_wrap), 0) > 0; in timeout_negative()
540 content_timeout = recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in timeout_negative()
543 recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in timeout_negative()
650 content_wrap = recv(fd, msg_wrap.buf, sizeof(msg_wrap), 0) > 0; in TEST()
655 content_timeout = recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in TEST()
658 recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in TEST()
756 bool read_one = recv(fd, msg.buf, sizeof(msg), 0) > 0; in TEST()
769 recv_ret = recv(fd, msg.buf, sizeof(msg), 0); in TEST()
/aosp12/system/bt/tools/scripts/
H A Dbtsnoop_live.py237 snoop_id = btsnoop_sock.recv(SNOOP_ID)
245 snoop_hdr = btsnoop_sock.recv(SNOOP_HDR)
258 data_frag = btsnoop_sock.recv(olen - len(snoop_data))
/aosp12/frameworks/rs/
H A DrsFifoSocket.cpp71 size_t ret = ::recv(sv[0], retData, retBytes, MSG_WAITALL); in writeWaitReturn()
82 size_t ret = ::recv(sv[1], data, bytes, MSG_WAITALL); in read()
/aosp12/system/bt/gd/rust/facade/helpers/
H A Dlib.rs43 while let Some(payload) = clone_rx.lock().await.recv().await { in stream_grpc()
64 while let Some(payload) = clone_rx.lock().await.recv().await { in stream_runnable()
/aosp12/system/bt/gd/rust/link/src/acl/classic/
H A Dmod.rs156 Some(req) = req_rx.recv() => { in provide_acl_manager()
179 Some(evt) = evt_rx.recv() => { in provide_acl_manager()
275 Some(evt) = core.evt_rx.recv() => { in run_connection()
286 Some(req) = req_rx.recv() => { in run_connection()

123456