| /external/tensorflow/tensorflow/compiler/jit/ |
| encapsulate_subgraphs_pass_test.cc | 812 Node* recv = local
815 Node* e = Binary(ops::NodeOut(recv, 0), ops::NodeOut(recv, 1),
858 Node* recv = local
861 Node* e = Binary(ops::NodeOut(recv, 0), ops::NodeOut(recv, 1),
862 b2.opts().WithName("E").WithControlInputs({recv, b}));
924 Node* recv = local
1076 Node* recv = local
1576 Node* recv = local
1622 Node* recv = local
[all...] |
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| hlo_verifier.cc | 322 Status ShapeVerifier::HandleRecv(HloInstruction* recv) {
323 TF_RET_CHECK(recv->users().size() == 1);
324 const HloInstruction* recv_done = recv->users().front();
326 TF_RETURN_IF_ERROR(CheckSameChannel(recv, recv_done));
327 return CheckShape(recv,
334 const HloInstruction* recv = recv_done->operand(0); local
335 TF_RET_CHECK(recv->opcode() == HloOpcode::kRecv);
336 TF_RETURN_IF_ERROR(CheckSameChannel(recv, recv_done));
337 return CheckShape(recv_done, recv->shape().tuple_shapes(0));
[all...] |
| hlo_dataflow_analysis_test.cc | 1184 auto recv = builder.AddInstruction( local
[all...] |
| /frameworks/native/libs/binder/tests/ |
| schd-dbg.cpp | 187 void recv(T& v) { function in class:Pipe
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| DatagramSocketTest.java | 169 DatagramPacket recv = new DatagramPacket(new byte[data.length], data.length); local
170 dgramSocket.receive(recv);
185 DatagramPacket recv = new DatagramPacket(new byte[data.length], data.length); local
186 dgramSocket.receive(recv);
187 assertTrue(Arrays.equals(recv.getData(), data));
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_ftplib.py | 40 self.baseclass.last_received_data += self.recv(1024)
333 def recv(self, buffer_size): member in class:.SSLConnection
335 return super(SSLConnection, self).recv(buffer_size)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_ftplib.py | 40 self.baseclass.last_received_data += self.recv(1024)
333 def recv(self, buffer_size): member in class:.SSLConnection
335 return super(SSLConnection, self).recv(buffer_size)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_ftplib.py | 40 self.baseclass.last_received_data += self.recv(1024)
333 def recv(self, buffer_size): member in class:.SSLConnection
335 return super(SSLConnection, self).recv(buffer_size)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_ftplib.py | 40 self.baseclass.last_received_data += self.recv(1024)
333 def recv(self, buffer_size): member in class:.SSLConnection
335 return super(SSLConnection, self).recv(buffer_size)
|
| /external/dhcpcd-6.8.2/ |
| dhcp6.h | 187 struct dhcp6_message *recv; member in struct:dhcp6_state
|
| /external/python/cpython2/Lib/test/ |
| test_ftplib.py | 40 self.baseclass.last_received_data += self.recv(1024)
345 def recv(self, buffer_size): member in class:.SSLConnection
347 return super(SSLConnection, self).recv(buffer_size)
|
| test_socket.py | 781 msg = self.cli_conn.recv(1024)
789 seg1 = self.cli_conn.recv(len(MSG) - 3)
790 seg2 = self.cli_conn.recv(1024)
819 read = self.cli_conn.recv(1024)
836 msg = sock.recv(1024)
846 msg = sock.recv(1024)
854 msg = self.cli_conn.recv(1024)
885 # Testing sendto() and Recv() over UDP
886 msg = self.serv.recv(len(MSG))
1147 def recv(self, size): member in class:FileObjectInterruptedTestCase.MockSocket
[all...] |
| /external/python/cpython3/Lib/test/ |
| test_ftplib.py | 56 self.baseclass.last_received_data += self.recv(1024).decode('ascii')
386 def recv(self, buffer_size): member in class:.SSLConnection
388 return super(SSLConnection, self).recv(buffer_size)
[all...] |
| /external/scapy/scapy/layers/ |
| bluetooth.py | 823 def recv(self, x=MTU): member in class:BluetoothL2CAPSocket
824 return L2CAP_CmdHdr(self.ins.recv(x))
849 def recv(self, x): member in class:BluetoothHCISocket
850 return HCI_Hdr(self.ins.recv(x))
912 def recv(self, x=512): member in class:BluetoothUserSocket
[all...] |
| inet6.py | 3264 def recv(self, x): member in class:_IPv6inIP
[all...] |
| /external/syslinux/core/lwip/src/include/lwip/ |
| sockets.h | 129 /* Flags we can use with send and recv. */
354 #define recv(a,b,c,d) lwip_recv(a,b,c,d) macro
|
| /external/syslinux/gpxe/src/include/gpxe/ |
| infiniband.h | 161 struct ib_work_queue recv; member in struct:ib_queue_pair
|
| /external/tensorflow/tensorflow/core/graph/ |
| graph_partition.cc | 58 bool recv_output_on_host; // The output of recv is on host
84 NodeDef* recv; member in struct:tensorflow::__anon39621::RecvInfo
120 // Return true iff we need to add the same device send/recv for 'edge'.
167 // Add a control edge from each input to each recv.
170 for (NodeDef* recv : recvs) {
172 recv->add_input(strings::StrCat("^", input));
207 // NOTE(yuanbyu): Only cast for cross-device send/recv.
246 // NOTE(yuanbyu): Only cast for cross-device send/recv.
259 // Add the recv node.
265 NodeDef* recv = gdef->add_node() local
1107 NodeDef* recv = local
[all...] |
| /external/tensorflow/tensorflow/core/grappler/costs/ |
| virtual_scheduler.cc | 216 const auto* recv = recv_manager_.GetCurrNode(); local
217 candidates.emplace_back(recv, node_state_->at(recv).time_ready);
225 // Note that there can be only 1 Send and only 1 Recv in candidates,
226 // at most; hence, score is 2 for Send, 1 for Recv, and 0 for a
412 const auto* recv = send_and_recv.second; local
414 curr_node_state.inputs.push_back(std::make_pair(recv, 0));
419 cached_recv_nodes[recv_node] = recv;
576 auto* recv = new NodeDef(); local
577 recv->set_name("Recv_" + src_name + "_on_" + SanitizedDeviceName(to))
[all...] |
| /external/v8/src/ |
| messages.cc | 1152 Handle<JSReceiver> recv = Handle<JSReceiver>::cast(receiver); local
[all...] |
| /external/wpa_supplicant_8/src/radius/ |
| radius.h | 205 u8 *recv; member in struct:radius_ms_mppe_keys
|
| /device/google/contexthub/sensorhal/ |
| hubconnection.cpp | 1629 uint8_t recv[256]; local
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_socket.py | 719 msg = self.cli_conn.recv(1024)
727 seg1 = self.cli_conn.recv(len(MSG) - 3)
728 seg2 = self.cli_conn.recv(1024)
757 read = self.cli_conn.recv(1024)
774 msg = sock.recv(1024)
784 msg = sock.recv(1024)
792 msg = self.cli_conn.recv(1024)
810 # Testing sendto() and Recv() over UDP
811 msg = self.serv.recv(len(MSG))
842 self.assertEqual(sd.recv(1), '')
1054 def recv(self, size): member in class:FileObjectInterruptedTestCase.MockSocket
[all...] |
| /external/syslinux/gpxe/src/drivers/infiniband/ |
| arbel.h | 303 struct arbelprm_recv_wqe recv; member in union:arbel_recv_wqe
331 struct arbel_recv_work_queue recv; member in struct:arbel_queue_pair
|
| hermon.h | 400 struct hermonprm_recv_wqe recv; member in union:hermon_recv_wqe
452 struct hermon_recv_work_queue recv; member in struct:hermon_queue_pair
|
