/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/rfnoc/ |
H A D | chdr_tx_data_xport.cpp | 105 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 D | issue-2718.rs | 103 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 D | McastLoopbackTest.java | 18 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 D | core_dns.cpp | 617 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 D | m_dns.cpp | 773 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 D | rfnoc_block_logpwr_tb.sv | 245 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 D | util.c | 100 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 D | util.c | 100 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 D | tds_checks.c | 90 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 D | packet.c | 134 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 D | tds_checks.c | 92 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 D | packet.c | 132 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 D | tds_checks.c | 94 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 D | packet.c | 137 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 D | tds_checks.c | 94 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 D | packet.c | 137 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 D | Interop_OpenVPN.c | 185 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 D | Interop_OpenVPN.c | 185 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 D | loadbsl.c | 110 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 D | socket.cpp | 205 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 D | memcapable.cc | 637 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 D | memcapable.cc | 637 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 D | dns_base.py | 130 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 D | Proto_OpenVPN.c | 582 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 D | io.cc | 85 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()
|