Home
last modified time | relevance | path

Searched refs:packet_id (Results 1 – 25 of 892) sorted by relevance

12345678910>>...36

/dports/misc/py-molequeue/molequeue-0.9.0/python/molequeue/
H A Dclient.py100 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 Dclient.py100 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 Dpackets.h89 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 Dgibber-r-multicast-sender.c110 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 Dreliable.c113 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 Dreliable.c113 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 Dreliable.c113 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 Dp2p_socket_type.h57 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 Dp2p_socket_type.h57 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 Dsent_packet.cc20 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 Dsent_packet.cc20 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 Dsent_packet.cc20 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 Dsent_packet.cc20 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 Dsimulated_network.h29 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 Dsimulated_network.h28 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 Dsimulated_network.h28 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 Dsimulated_network.h28 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 Dframe_collector.cc59 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 Dsender.cc230 *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 Dframe_collector.cc59 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 Dsender.cc229 *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 Dcheck-gibber-r-multicast-packet.c12 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 Dclient.c87 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 Darvgvcp.c67 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 Darvgvcp.c67 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 …]

12345678910>>...36