/dports/misc/py-molequeue/molequeue-0.9.0/python/molequeue/ |
H A D | client.py | 100 self.packet_id = packet_id 106 self.packet_id = packet_id 148 packet_id = self._next_packet_id() 154 self._send_request(packet_id, jsonrpc) 167 packet_id = self._next_packet_id() 173 self._send_request(packet_id, jsonrpc) 198 packet_id = self._next_packet_id() 203 self._send_request(packet_id, jsonrpc) 223 def _on_response(self, packet_id, msg): argument 239 packet_id = self._next_packet_id() [all …]
|
/dports/misc/molequeue/molequeue-0.9.0/python/molequeue/ |
H A D | client.py | 100 self.packet_id = packet_id 106 self.packet_id = packet_id 148 packet_id = self._next_packet_id() 154 self._send_request(packet_id, jsonrpc) 167 packet_id = self._next_packet_id() 173 self._send_request(packet_id, jsonrpc) 198 packet_id = self._next_packet_id() 203 self._send_request(packet_id, jsonrpc) 223 def _on_response(self, packet_id, msg): argument 239 packet_id = self._next_packet_id() [all …]
|
/dports/games/quadra/quadra-1.3.0/include/ |
H A D | packets.h | 89 packet_id = P_FINDGAME; in Packet_findgame() 99 packet_id = P_WANTJOIN; in Packet_wantjoin() 201 packet_id = P_CHAT; in Packet_chat() 244 packet_id = P_PLAYER; in Packet_player() 277 packet_id = P_PAUSE; in Packet_pause() 308 packet_id = P_STAT; in Packet_stat() 380 packet_id = P_DEAD; in Packet_dead() 460 packet_id = P_LINES; in Packet_lines() 517 packet_id = P_GONE; in Packet_gone() 556 packet_id = P_MOVES; in Packet_moves() [all …]
|
/dports/net-im/telepathy-salut/telepathy-salut-0.8.1/lib/gibber/ |
H A D | gibber-r-multicast-sender.c | 110 guint32 packet_id; member 335 info->packet_id = ack->packet_id; in update_sender_acks() 518 guint32 packet_id = packet->data.repair_request.packet_id; in gibber_r_multicast_sender_group_push_packet() local 623 guint32 packet_id; member 651 result->packet_id = packet_id; in packet_info_new() 878 packet_id = info->packet_id; in packet_info_try_gc() 1038 info->packet_id); in request_repair() 1450 info->packet_id = senderinfo->packet_id; in update_acks() 1466 info->packet_id = senderinfo->packet_id; in update_acks() 1765 guint32 packet_id) in gibber_r_multicast_sender_update_end() argument [all …]
|
/dports/security/openvpn-devel/openvpn-0033811e0215af76f469d78912c95a2f59813454/src/openvpn/ |
H A D | reliable.c | 113 if (ack->packet_id[i] == pid) in reliable_ack_packet_id_present() 145 ack->packet_id[ack->len++] = pid; in reliable_ack_acknowledge_packet_id() 183 ack->packet_id[ack->len++] = pid; in reliable_ack_read() 245 ack->packet_id[i++] = ack->packet_id[j++]; in reliable_ack_write() 449 if (e->active && e->packet_id == id) in reliable_not_replay() 519 min_id = e->packet_id; in reliable_get_buf_output_sequenced() 544 if (e->active && e->packet_id == rel->packet_id) in reliable_get_buf_sequenced() 598 if (!best || reliable_pid_min(e->packet_id, best->packet_id)) in reliable_send() 694 e->packet_id = pid; in reliable_mark_active_incoming() 726 e->packet_id = rel->packet_id++; in reliable_mark_active_outgoing() [all …]
|
/dports/security/openvpn/openvpn-2.5.6/src/openvpn/ |
H A D | reliable.c | 113 if (ack->packet_id[i] == pid) in reliable_ack_packet_id_present() 145 ack->packet_id[ack->len++] = pid; in reliable_ack_acknowledge_packet_id() 183 ack->packet_id[ack->len++] = pid; in reliable_ack_read() 245 ack->packet_id[i++] = ack->packet_id[j++]; in reliable_ack_write() 437 if (e->active && e->packet_id == id) in reliable_not_replay() 507 min_id = e->packet_id; in reliable_get_buf_output_sequenced() 532 if (e->active && e->packet_id == rel->packet_id) in reliable_get_buf_sequenced() 581 if (!best || reliable_pid_min(e->packet_id, best->packet_id)) in reliable_send() 676 e->packet_id = pid; in reliable_mark_active_incoming() 707 e->packet_id = rel->packet_id++; in reliable_mark_active_outgoing() [all …]
|
/dports/security/openvpn-mbedtls/openvpn-2.5.6/src/openvpn/ |
H A D | reliable.c | 113 if (ack->packet_id[i] == pid) in reliable_ack_packet_id_present() 145 ack->packet_id[ack->len++] = pid; in reliable_ack_acknowledge_packet_id() 183 ack->packet_id[ack->len++] = pid; in reliable_ack_read() 245 ack->packet_id[i++] = ack->packet_id[j++]; in reliable_ack_write() 437 if (e->active && e->packet_id == id) in reliable_not_replay() 507 min_id = e->packet_id; in reliable_get_buf_output_sequenced() 532 if (e->active && e->packet_id == rel->packet_id) in reliable_get_buf_sequenced() 581 if (!best || reliable_pid_min(e->packet_id, best->packet_id)) in reliable_send() 676 e->packet_id = pid; in reliable_mark_active_incoming() 707 e->packet_id = rel->packet_id++; in reliable_mark_active_outgoing() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/public/cpp/ |
H A D | p2p_socket_type.h | 57 P2PSendPacketMetrics(uint64_t packet_id, in P2PSendPacketMetrics() 60 : packet_id(packet_id), in P2PSendPacketMetrics() 64 uint64_t packet_id = 0; member 93 uint64_t packet_id) in P2PPacketInfo() 96 packet_id(packet_id) {} in P2PPacketInfo() 99 uint64_t packet_id; member
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/services/network/public/cpp/ |
H A D | p2p_socket_type.h | 57 P2PSendPacketMetrics(uint64_t packet_id, in P2PSendPacketMetrics() 60 : packet_id(packet_id), in P2PSendPacketMetrics() 64 uint64_t packet_id = 0; member 93 uint64_t packet_id) in P2PPacketInfo() 96 packet_id(packet_id) {} in P2PPacketInfo() 99 uint64_t packet_id; member
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/rtc_base/network/ |
H A D | sent_packet.cc | 20 SentPacket::SentPacket(int64_t packet_id, int64_t send_time_ms) in SentPacket() argument 21 : packet_id(packet_id), send_time_ms(send_time_ms) {} in SentPacket() 22 SentPacket::SentPacket(int64_t packet_id, in SentPacket() argument 25 : packet_id(packet_id), send_time_ms(send_time_ms), info(info) {} in SentPacket()
|
/dports/net-im/tg_owt/tg_owt-d578c76/src/rtc_base/network/ |
H A D | sent_packet.cc | 20 SentPacket::SentPacket(int64_t packet_id, int64_t send_time_ms) in SentPacket() argument 21 : packet_id(packet_id), send_time_ms(send_time_ms) {} in SentPacket() 22 SentPacket::SentPacket(int64_t packet_id, in SentPacket() argument 25 : packet_id(packet_id), send_time_ms(send_time_ms), info(info) {} in SentPacket()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/rtc_base/network/ |
H A D | sent_packet.cc | 20 SentPacket::SentPacket(int64_t packet_id, int64_t send_time_ms) in SentPacket() argument 21 : packet_id(packet_id), send_time_ms(send_time_ms) {} in SentPacket() 22 SentPacket::SentPacket(int64_t packet_id, in SentPacket() argument 25 : packet_id(packet_id), send_time_ms(send_time_ms), info(info) {} in SentPacket()
|
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/rtc_base/network/ |
H A D | sent_packet.cc | 20 SentPacket::SentPacket(int64_t packet_id, int64_t send_time_ms) in SentPacket() argument 21 : packet_id(packet_id), send_time_ms(send_time_ms) {} in SentPacket() 22 SentPacket::SentPacket(int64_t packet_id, in SentPacket() argument 25 : packet_id(packet_id), send_time_ms(send_time_ms), info(info) {} in SentPacket()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/api/test/ |
H A D | simulated_network.h | 29 PacketInFlightInfo(size_t size, int64_t send_time_us, uint64_t packet_id) in PacketInFlightInfo() 30 : size(size), send_time_us(send_time_us), packet_id(packet_id) {} in PacketInFlightInfo() 35 uint64_t packet_id; member 41 : receive_time_us(receive_time_us), packet_id(source.packet_id) {} in PacketDeliveryInfo() 43 uint64_t packet_id; member
|
/dports/net-im/tg_owt/tg_owt-d578c76/src/api/test/ |
H A D | simulated_network.h | 28 PacketInFlightInfo(size_t size, int64_t send_time_us, uint64_t packet_id) in PacketInFlightInfo() 29 : size(size), send_time_us(send_time_us), packet_id(packet_id) {} in PacketInFlightInfo() 34 uint64_t packet_id; member 40 : receive_time_us(receive_time_us), packet_id(source.packet_id) {} in PacketDeliveryInfo() 42 uint64_t packet_id; member
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/api/test/ |
H A D | simulated_network.h | 28 PacketInFlightInfo(size_t size, int64_t send_time_us, uint64_t packet_id) in PacketInFlightInfo() 29 : size(size), send_time_us(send_time_us), packet_id(packet_id) {} in PacketInFlightInfo() 34 uint64_t packet_id; member 40 : receive_time_us(receive_time_us), packet_id(source.packet_id) {} in PacketDeliveryInfo() 42 uint64_t packet_id; member
|
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/api/test/ |
H A D | simulated_network.h | 28 PacketInFlightInfo(size_t size, int64_t send_time_us, uint64_t packet_id) in PacketInFlightInfo() 29 : size(size), send_time_us(send_time_us), packet_id(packet_id) {} in PacketInFlightInfo() 34 uint64_t packet_id; member 40 : receive_time_us(receive_time_us), packet_id(source.packet_id) {} in PacketDeliveryInfo() 42 uint64_t packet_id; member
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/cast/streaming/ |
H A D | frame_collector.cc | 59 if (part.packet_id >= chunks_.size()) { in CollectRtpPacket() 62 << part.packet_id << " (should be less than " << chunks_.size() << ")."; in CollectRtpPacket() 67 if (chunks_[part.packet_id].has_data()) { in CollectRtpPacket() 75 if (part.packet_id == FramePacketId{0}) { in CollectRtpPacket() 91 PayloadChunk& chunk = chunks_[part.packet_id]; in CollectRtpPacket() 117 for (int packet_id = 0; packet_id < frame_packet_count; ++packet_id) { in GetMissingPackets() local 118 if (!chunks_[packet_id].has_data()) { in GetMissingPackets() 120 PacketNack{frame_.frame_id, static_cast<FramePacketId>(packet_id)}); in GetMissingPackets()
|
H A D | sender.cc | 230 *chosen.slot->frame, chosen.packet_id, buffer); in GetRtpPacketForImmediateSend() 231 chosen.slot->send_flags.Clear(chosen.packet_id); in GetRtpPacketForImmediateSend() 424 slot->send_flags.Set(packet_id); in OnReceiverIsMissingPackets() 429 if (nack_it->packet_id == kAllPacketsLost) { in OnReceiverIsMissingPackets() 430 for (FramePacketId packet_id = 0; packet_id < range_end; ++packet_id) { in OnReceiverIsMissingPackets() local 431 HandleIndividualNack(packet_id); in OnReceiverIsMissingPackets() 436 if (nack_it->packet_id < range_end) { in OnReceiverIsMissingPackets() 437 HandleIndividualNack(nack_it->packet_id); in OnReceiverIsMissingPackets() 462 if (packet_id < slot->send_flags.size()) { in ChooseNextRtpPacketNeedingSend() 463 return {slot, packet_id}; in ChooseNextRtpPacketNeedingSend() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/streaming/ |
H A D | frame_collector.cc | 59 if (part.packet_id >= chunks_.size()) { in CollectRtpPacket() 62 << part.packet_id << " (should be less than " << chunks_.size() << ")."; in CollectRtpPacket() 67 if (chunks_[part.packet_id].has_data()) { in CollectRtpPacket() 75 if (part.packet_id == FramePacketId{0}) { in CollectRtpPacket() 91 PayloadChunk& chunk = chunks_[part.packet_id]; in CollectRtpPacket() 117 for (int packet_id = 0; packet_id < frame_packet_count; ++packet_id) { in GetMissingPackets() local 118 if (!chunks_[packet_id].has_data()) { in GetMissingPackets() 120 PacketNack{frame_.frame_id, static_cast<FramePacketId>(packet_id)}); in GetMissingPackets()
|
H A D | sender.cc | 229 *chosen.slot->frame, chosen.packet_id, buffer); in GetRtpPacketForImmediateSend() 230 chosen.slot->send_flags.Clear(chosen.packet_id); in GetRtpPacketForImmediateSend() 423 slot->send_flags.Set(packet_id); in OnReceiverIsMissingPackets() 428 if (nack_it->packet_id == kAllPacketsLost) { in OnReceiverIsMissingPackets() 429 for (FramePacketId packet_id = 0; packet_id < range_end; ++packet_id) { in OnReceiverIsMissingPackets() local 430 HandleIndividualNack(packet_id); in OnReceiverIsMissingPackets() 435 if (nack_it->packet_id < range_end) { in OnReceiverIsMissingPackets() 436 HandleIndividualNack(nack_it->packet_id); in OnReceiverIsMissingPackets() 461 if (packet_id < slot->send_flags.size()) { in ChooseNextRtpPacketNeedingSend() 462 return {slot, packet_id}; in ChooseNextRtpPacketNeedingSend() [all …]
|
/dports/net-im/telepathy-salut/telepathy-salut-0.8.1/lib/gibber/tests/ |
H A D | check-gibber-r-multicast-packet.c | 12 guint32 packet_id; member 65 guint32 packet_id = 1200; in test_data_packet() local 81 gibber_r_multicast_packet_set_packet_id (a, packet_id); in test_data_packet() 87 senders[i].sender_id, senders[i].packet_id, NULL); in test_data_packet() 102 COMPARE (packet_id); in test_data_packet() 115 g_assert (senders[i].packet_id == s->packet_id); in test_data_packet() 146 guint32 packet_id = 1200; in test_attempt_join_packet() local 159 gibber_r_multicast_packet_set_packet_id (a, packet_id); in test_attempt_join_packet() 164 senders[i].sender_id, senders[i].packet_id, NULL); in test_attempt_join_packet() 180 COMPARE (packet_id); in test_attempt_join_packet() [all …]
|
/dports/devel/aws-c-mqtt/aws-c-mqtt-0.7.8/source/ |
H A D | client.c | 87 uint16_t packet_id; member 145 timeout_task_arg->packet_id = packet_id; in s_schedule_timeout_task() 1718 packet_id, in s_subscribe_send() 1821 packet_id, in s_subscribe_complete() 1973 packet_id, in s_subscribe_single_complete() 2069 packet_id, in aws_mqtt_client_connection_subscribe() 2118 packet_id, in s_subscribe_local_send() 2149 packet_id, in s_subscribe_local_complete() 2232 packet_id, in aws_mqtt_client_connection_subscribe_local() 2299 packet_id, in s_resubscribe_send() [all …]
|
/dports/devel/libaravis/aravis-ARAVIS_0_5_12/src/ |
H A D | arvgvcp.c | 67 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_read_memory_cmd() 101 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_read_memory_ack() 134 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_write_memory_cmd() 153 guint16 packet_id, in arv_gvcp_packet_new_write_memory_ack() argument 168 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_write_memory_ack() 187 guint16 packet_id, in arv_gvcp_packet_new_read_register_cmd() argument 202 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_read_register_cmd() 221 guint16 packet_id, in arv_gvcp_packet_new_read_register_ack() argument 236 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_read_register_ack() 257 guint16 packet_id, in arv_gvcp_packet_new_write_register_cmd() argument [all …]
|
/dports/multimedia/aravis/aravis-ARAVIS_0_5_12/src/ |
H A D | arvgvcp.c | 67 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_read_memory_cmd() 101 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_read_memory_ack() 134 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_write_memory_cmd() 153 guint16 packet_id, in arv_gvcp_packet_new_write_memory_ack() argument 168 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_write_memory_ack() 187 guint16 packet_id, in arv_gvcp_packet_new_read_register_cmd() argument 202 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_read_register_cmd() 221 guint16 packet_id, in arv_gvcp_packet_new_read_register_ack() argument 236 packet->header.id = g_htons (packet_id); in arv_gvcp_packet_new_read_register_ack() 257 guint16 packet_id, in arv_gvcp_packet_new_write_register_cmd() argument [all …]
|