Home
last modified time | relevance | path

Searched refs:recv_packet (Results 1 – 25 of 173) sorted by relevance

1234567

/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/rfnoc/
H A Dchdr_tx_data_xport.cpp105 chdr::chdr_packet_writer::uptr recv_packet = pkt_factory.make_generic(); in configure_flow_ctrl() local
113 auto recv_cb = [&recv_packet, epids](frame_buff::uptr& buff, in configure_flow_ctrl()
116 recv_packet->refresh(buff->data()); in configure_flow_ctrl()
117 const auto header = recv_packet->get_chdr_header(); in configure_flow_ctrl()
172 auto recv_strs = [&recv_io, &recv_packet]() -> stream_buff_params_t { in configure_flow_ctrl()
180 recv_packet->refresh(buff->data()); in configure_flow_ctrl()
182 recv_packet->get_chdr_header().get_pkt_type() == chdr::PKT_TYPE_STRS); in configure_flow_ctrl()
184 strs.deserialize(recv_packet->get_payload_const_ptr_as<uint64_t>(), in configure_flow_ctrl()
185 recv_packet->get_payload_size() / sizeof(uint64_t), in configure_flow_ctrl()
186 recv_packet->conv_to_host<uint64_t>()); in configure_flow_ctrl()
/dports/lang/rust/rustc-1.58.1-src/src/test/ui/regions/
H A Dissue-2718.rs103 pub fn recv<T:Send>(mut p: recv_packet<T>) -> Option<T> { in recv()
186 pub struct recv_packet<T:Send> { struct
190 impl<T:Send> Drop for recv_packet<T> { implementation
203 impl<T:Send> recv_packet<T> { impl
209 pub fn recv_packet<T:Send>(p: *const packet<T>) -> recv_packet<T> { in recv_packet() function
210 recv_packet { in recv_packet()
215 pub fn entangle<T:Send>() -> (send_packet<T>, recv_packet<T>) { in entangle()
217 (send_packet(p), recv_packet(p)) in entangle()
258 pub type pong = ::pipes::recv_packet<pingpong::pong>;
279 pub type ping = ::pipes::recv_packet<pingpong::ping>;
/dports/net/jgroups/jgroups-2.12.0/tests/other/org/jgroups/tests/
H A DMcastLoopbackTest.java18 DatagramPacket send_packet, recv_packet; in main() local
59 recv_packet=new DatagramPacket(recv_buf, recv_buf.length); in main()
62 mcast_sock.receive(recv_packet); in main()
63 System.out.println("-- received " + new String(recv_packet.getData(), 0, 8) + in main()
64 " from " + recv_packet.getSocketAddress()); in main()
/dports/irc/inspircd/inspircd-3.11.0/src/coremods/
H A Dcore_dns.cpp617 Packet recv_packet; in OnEventHandlerRead() local
622 recv_packet.Fill(buffer, length); in OnEventHandlerRead()
648 recv_packet.error = ERROR_MALFORMED; in OnEventHandlerRead()
649 request->OnError(&recv_packet); in OnEventHandlerRead()
656 request->OnError(&recv_packet); in OnEventHandlerRead()
658 else if (!(recv_packet.flags & QUERYFLAGS_QR) || (recv_packet.flags & QUERYFLAGS_RCODE)) in OnEventHandlerRead()
689 recv_packet.error = error; in OnEventHandlerRead()
690 request->OnError(&recv_packet); in OnEventHandlerRead()
692 else if (recv_packet.answers.empty()) in OnEventHandlerRead()
697 request->OnError(&recv_packet); in OnEventHandlerRead()
[all …]
/dports/irc/anope/anope-2.0.9/modules/
H A Dm_dns.cpp773 Packet recv_packet(this, from); in HandlePacket() local
777 recv_packet.Fill(packet_buffer, length); in HandlePacket()
785 if (!(recv_packet.flags & QUERYFLAGS_QR)) in HandlePacket()
789 else if (recv_packet.questions.empty()) in HandlePacket()
871 request->OnError(&recv_packet); in HandlePacket()
903 recv_packet.error = error; in HandlePacket()
904 request->OnError(&recv_packet); in HandlePacket()
906 else if (recv_packet.questions.empty() || recv_packet.answers.empty()) in HandlePacket()
909 recv_packet.error = ERROR_NO_RECORDS; in HandlePacket()
910 request->OnError(&recv_packet); in HandlePacket()
[all …]
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/fpga/usrp3/lib/rfnoc/blocks/rfnoc_block_logpwr/
H A Drfnoc_block_logpwr_tb.sv245 ChdrPacket_t sent_packet, recv_packet; register
265 blk_ctrl.get_chdr(port, recv_packet);
267 recv_packet.data,
268 recv_packet.data_bytes()
273 expected_header.length = recv_packet.header.length;
274 `ASSERT_ERROR(expected_header == recv_packet.header,
279 `ASSERT_ERROR(sent_packet.timestamp == recv_packet.timestamp,
284 `ASSERT_ERROR(sent_packet.metadata.size() == recv_packet.metadata.size(),
287 `ASSERT_ERROR(sent_packet.metadata[i] == recv_packet.metadata[i],
/dports/databases/freetds-devel/freetds-dev.1.3.7/src/pool/
H A Dutil.c100 if (packet_len > tds->recv_packet->capacity) { in pool_packet_read()
103 packet = tds_realloc_packet(tds->recv_packet, packet_len); in pool_packet_read()
107 tds->recv_packet = packet; in pool_packet_read()
115 assert(packet_len <= tds->recv_packet->capacity); in pool_packet_read()
116 assert(tds->in_len < tds->recv_packet->capacity); in pool_packet_read()
/dports/databases/freetds/freetds-1.3.4/src/pool/
H A Dutil.c100 if (packet_len > tds->recv_packet->capacity) { in pool_packet_read()
103 packet = tds_realloc_packet(tds->recv_packet, packet_len); in pool_packet_read()
107 tds->recv_packet = packet; in pool_packet_read()
115 assert(packet_len <= tds->recv_packet->capacity); in pool_packet_read()
116 assert(tds->in_len < tds->recv_packet->capacity); in pool_packet_read()
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/dbapi/driver/ftds100/freetds/tds/
H A Dtds_checks.c90 tds_check_packet_extra(tds->recv_packet); in tds_check_tds_extra()
95 if (tds->conn->recv_packet) in tds_check_tds_extra()
96 assert(tds->conn->recv_pos <= tds->conn->recv_packet->len); in tds_check_tds_extra()
100 assert(tds->in_len <= tds->recv_packet->capacity); in tds_check_tds_extra()
110 assert(tds->in_buf == tds->recv_packet->buf || tds->in_buf == tds->recv_packet->buf + 16); in tds_check_tds_extra()
111 assert(tds->recv_packet->capacity > 0); in tds_check_tds_extra()
H A Dpacket.c134 TDSPACKET *packet = conn->recv_packet; in tds_packet_read()
233 conn->recv_packet = packet; in tds_packet_read()
248 conn->recv_packet = packet; in tds_packet_read()
258 conn->recv_packet = NULL; in tds_packet_read()
430 packet = conn->recv_packet; in tds_connection_network()
432 conn->recv_packet = NULL; in tds_connection_network()
557 tds_packet_cache_add(conn, tds->recv_packet); in tds_read_packet()
561 tds->recv_packet = packet; in tds_read_packet()
619 if (TDS_UNLIKELY(pktlen > tds->recv_packet->capacity)) { in tds_read_packet()
620 TDSPACKET *packet = tds_realloc_packet(tds->recv_packet, pktlen); in tds_read_packet()
[all …]
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/dbapi/driver/ftds95/freetds/tds/
H A Dtds_checks.c92 tds_check_packet_extra(tds->recv_packet); in tds_check_tds_extra()
97 if (tds->conn->recv_packet) in tds_check_tds_extra()
98 assert(tds->conn->recv_pos <= tds->conn->recv_packet->len); in tds_check_tds_extra()
102 assert(tds->in_len <= tds->recv_packet->capacity); in tds_check_tds_extra()
112 assert(tds->in_buf == tds->recv_packet->buf || tds->in_buf == tds->recv_packet->buf + 16); in tds_check_tds_extra()
113 assert(tds->recv_packet->capacity > 0); in tds_check_tds_extra()
H A Dpacket.c132 TDSPACKET *packet = conn->recv_packet; in tds_packet_read()
231 conn->recv_packet = packet; in tds_packet_read()
246 conn->recv_packet = packet; in tds_packet_read()
256 conn->recv_packet = NULL; in tds_packet_read()
428 packet = conn->recv_packet; in tds_connection_network()
430 conn->recv_packet = NULL; in tds_connection_network()
556 tds_packet_cache_add(conn, tds->recv_packet); in tds_read_packet()
560 tds->recv_packet = packet; in tds_read_packet()
618 if (TDS_UNLIKELY(pktlen > tds->recv_packet->capacity)) { in tds_read_packet()
619 TDSPACKET *packet = tds_realloc_packet(tds->recv_packet, pktlen); in tds_read_packet()
[all …]
/dports/databases/freetds-devel/freetds-dev.1.3.7/src/tds/
H A Dtds_checks.c94 tds_check_packet_extra(tds->recv_packet); in tds_check_tds_extra()
99 if (tds->conn->recv_packet) in tds_check_tds_extra()
100 …assert(tds->conn->recv_pos <= tds->conn->recv_packet->data_len + tds->conn->recv_packet->data_star… in tds_check_tds_extra()
108 assert(tds->in_len <= tds->recv_packet->capacity); in tds_check_tds_extra()
118 …assert(tds->in_buf == tds->recv_packet->buf || tds->in_buf == tds->recv_packet->buf + sizeof(TDS72… in tds_check_tds_extra()
119 assert(tds->recv_packet->capacity > 0); in tds_check_tds_extra()
H A Dpacket.c137 TDSPACKET *packet = conn->recv_packet; in tds_packet_read()
240 conn->recv_packet = packet; in tds_packet_read()
260 conn->recv_packet = packet; in tds_packet_read()
271 conn->recv_packet = NULL; in tds_packet_read()
406 packet = conn->recv_packet; in tds_connection_network()
407 conn->recv_packet = NULL; in tds_connection_network()
552 tds_packet_cache_add(conn, tds->recv_packet); in tds_read_packet()
556 tds->recv_packet = packet; in tds_read_packet()
616 if (TDS_UNLIKELY(pktlen > tds->recv_packet->capacity)) { in tds_read_packet()
617 TDSPACKET *packet = tds_realloc_packet(tds->recv_packet, pktlen); in tds_read_packet()
[all …]
/dports/databases/freetds/freetds-1.3.4/src/tds/
H A Dtds_checks.c94 tds_check_packet_extra(tds->recv_packet); in tds_check_tds_extra()
99 if (tds->conn->recv_packet) in tds_check_tds_extra()
100 …assert(tds->conn->recv_pos <= tds->conn->recv_packet->data_len + tds->conn->recv_packet->data_star… in tds_check_tds_extra()
108 assert(tds->in_len <= tds->recv_packet->capacity); in tds_check_tds_extra()
118 …assert(tds->in_buf == tds->recv_packet->buf || tds->in_buf == tds->recv_packet->buf + sizeof(TDS72… in tds_check_tds_extra()
119 assert(tds->recv_packet->capacity > 0); in tds_check_tds_extra()
H A Dpacket.c137 TDSPACKET *packet = conn->recv_packet; in tds_packet_read()
240 conn->recv_packet = packet; in tds_packet_read()
260 conn->recv_packet = packet; in tds_packet_read()
271 conn->recv_packet = NULL; in tds_packet_read()
406 packet = conn->recv_packet; in tds_connection_network()
407 conn->recv_packet = NULL; in tds_connection_network()
552 tds_packet_cache_add(conn, tds->recv_packet); in tds_read_packet()
556 tds->recv_packet = packet; in tds_read_packet()
616 if (TDS_UNLIKELY(pktlen > tds->recv_packet->capacity)) { in tds_read_packet()
617 TDSPACKET *packet = tds_realloc_packet(tds->recv_packet, pktlen); in tds_read_packet()
[all …]
/dports/security/softether-devel/v4.36-9754/src/Cedar/
H A DInterop_OpenVPN.c185 OPENVPN_PACKET *recv_packet; in OvsProceccRecvPacket() local
203 if (recv_packet != NULL) in OvsProceccRecvPacket()
206 if (recv_packet->OpCode != OPENVPN_P_DATA_V1 && recv_packet->MySessionId != 0) in OvsProceccRecvPacket()
208 Debug("RECV PACKET: %u %I64u\n", recv_packet->KeyId, recv_packet->MySessionId); in OvsProceccRecvPacket()
212 Debug(" PKT %u %u\n", recv_packet->OpCode, recv_packet->KeyId); in OvsProceccRecvPacket()
235 se->Channels[recv_packet->KeyId] = c; in OvsProceccRecvPacket()
256 c = se->Channels[recv_packet->KeyId]; in OvsProceccRecvPacket()
263 OvsDeleteFromSendingControlPacketList(c, recv_packet->NumAck, recv_packet->AckPacketId); in OvsProceccRecvPacket()
294 data = recv_packet->Data; in OvsProceccRecvPacket()
295 size = recv_packet->DataSize; in OvsProceccRecvPacket()
[all …]
/dports/security/softether/v4.38-9760/src/Cedar/
H A DInterop_OpenVPN.c185 OPENVPN_PACKET *recv_packet; in OvsProceccRecvPacket() local
203 if (recv_packet != NULL) in OvsProceccRecvPacket()
206 if (recv_packet->OpCode != OPENVPN_P_DATA_V1 && recv_packet->MySessionId != 0) in OvsProceccRecvPacket()
208 Debug("RECV PACKET: %u %I64u\n", recv_packet->KeyId, recv_packet->MySessionId); in OvsProceccRecvPacket()
212 Debug(" PKT %u %u\n", recv_packet->OpCode, recv_packet->KeyId); in OvsProceccRecvPacket()
235 se->Channels[recv_packet->KeyId] = c; in OvsProceccRecvPacket()
256 c = se->Channels[recv_packet->KeyId]; in OvsProceccRecvPacket()
263 OvsDeleteFromSendingControlPacketList(c, recv_packet->NumAck, recv_packet->AckPacketId); in OvsProceccRecvPacket()
294 data = recv_packet->Data; in OvsProceccRecvPacket()
295 size = recv_packet->DataSize; in OvsProceccRecvPacket()
[all …]
/dports/devel/mspdebug/mspdebug-493f38b/drivers/
H A Dloadbsl.c110 static int recv_packet(transport_t trans, uint8_t *data, int max_len) in recv_packet() function
177 r = recv_packet(trans, data, 4); in version_check()
226 recv_packet(trans, NULL, 0) < 0) { in rx_password()
315 r = recv_packet(dev->trans, mem, plen); in loadbsl_readmem()
376 recv_packet(dev->trans, NULL, 0) < 0) { in loadbsl_erase()
385 recv_packet(dev->trans, NULL, 0) < 0) { in loadbsl_erase()
/dports/devel/pecl-swoole/swoole-4.8.5/core-tests/src/coroutine/
H A Dsocket.cpp205 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
241 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
252 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
287 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
316 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
352 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
386 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
439 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
470 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
503 ssize_t l = sock.recv_packet(RECV_TIMEOUT); in TEST()
[all …]
/dports/databases/p5-Memcached-libmemcached/Memcached-libmemcached-1.001801/src/libmemcached/clients/
H A Dmemcapable.cc637 execute(recv_packet(&rsp)); in receive_binary_noop()
659 execute(recv_packet(&rsp)); in test_binary_quit_impl()
717 execute(recv_packet(&rsp)); in test_binary_set_impl()
728 execute(recv_packet(&rsp)); in test_binary_set_impl()
738 execute(recv_packet(&rsp)); in test_binary_set_impl()
808 execute(recv_packet(&rsp)); in binary_set_item()
876 execute(recv_packet(&rsp)); in test_binary_replace_impl()
902 execute(recv_packet(&rsp)); in test_binary_delete_impl()
951 execute(recv_packet(&rsp)); in test_binary_get_impl()
1078 execute(recv_packet(&rsp)); in test_binary_version()
[all …]
/dports/databases/libmemcached/libmemcached-1.0.18/clients/
H A Dmemcapable.cc637 execute(recv_packet(&rsp)); in receive_binary_noop()
659 execute(recv_packet(&rsp)); in test_binary_quit_impl()
717 execute(recv_packet(&rsp)); in test_binary_set_impl()
728 execute(recv_packet(&rsp)); in test_binary_set_impl()
738 execute(recv_packet(&rsp)); in test_binary_set_impl()
808 execute(recv_packet(&rsp)); in binary_set_item()
876 execute(recv_packet(&rsp)); in test_binary_replace_impl()
902 execute(recv_packet(&rsp)); in test_binary_delete_impl()
951 execute(recv_packet(&rsp)); in test_binary_get_impl()
1078 execute(recv_packet(&rsp)); in test_binary_version()
[all …]
/dports/net/samba412/samba-4.12.15/python/samba/tests/
H A Ddns_base.py130 recv_packet = s.recv(2048, 0)
132 print(self.hexdump(recv_packet))
133 response = ndr.ndr_unpack(dns.name_packet, recv_packet)
134 return (response, recv_packet)
156 recv_packet = s.recv(0xffff + 2, 0)
158 print(self.hexdump(recv_packet))
159 response = ndr.ndr_unpack(dns.name_packet, recv_packet[2:])
167 self.assertEquals(my_packet, recv_packet[2:])
168 return (response, recv_packet[2:])
/dports/security/softether5/SoftEtherVPN-5.02.5180/src/Cedar/
H A DProto_OpenVPN.c582 OPENVPN_PACKET *recv_packet; in OvsProceccRecvPacket() local
634 if (recv_packet == NULL) in OvsProceccRecvPacket()
640 c = se->Channels[recv_packet->KeyId]; in OvsProceccRecvPacket()
642 if (recv_packet->OpCode != OPENVPN_P_DATA_V1) in OvsProceccRecvPacket()
646 recv_packet->PacketId, recv_packet->OpCode, recv_packet->KeyId, recv_packet->MySessionId); in OvsProceccRecvPacket()
663 c = OvsNewChannel(se, recv_packet->KeyId); in OvsProceccRecvPacket()
668 se->Channels[recv_packet->KeyId] = c; in OvsProceccRecvPacket()
689 OvsDeleteFromSendingControlPacketList(c, recv_packet->NumAck, recv_packet->AckPacketId); in OvsProceccRecvPacket()
718 Copy(c->IvRecv, recv_packet->Data, sizeof(recv_packet->PacketId)); in OvsProceccRecvPacket()
726 …size = OvsDecrypt(c->CipherDecrypt, c->MdRecv, c->IvRecv, data, recv_packet->Data, recv_packet->Da… in OvsProceccRecvPacket()
[all …]
/dports/devel/gearmand/gearmand-1.0.6/libgearman-server/
H A Dio.cc85 if (connection->recv_packet != NULL) in _connection_close()
87 gearmand_packet_free(connection->recv_packet); in _connection_close()
88 connection->recv_packet= NULL; in _connection_close()
362 connection->recv_packet= NULL; in gearmand_connection_init()
635 connection->recv_packet= packet; in gearman_io_recv()
637 connection->recv_packet->reset(GEARMAN_MAGIC_TEXT, GEARMAN_COMMAND_TEXT); in gearman_io_recv()
649 size_t recv_size= con->protocol->unpack(connection->recv_packet, in gearman_io_recv()
737 packet= connection->recv_packet; in gearman_io_recv()
738 connection->recv_packet= NULL; in gearman_io_recv()

1234567