| /dports/devel/py-aiortc/aiortc-1.2.1/tests/ |
| H A D | test_rtcrtpsender.py | 289 queue_packet = queue.get_nowait()
290 if queue_packet.sequence_number == packet.sequence_number:
291 found_rtx = queue_packet
341 queue_packet = queue.get_nowait()
342 if queue_packet.payload_type == 101:
343 found_rtx = queue_packet
|
| /dports/security/py-asyncssh/asyncssh-2.8.1/tests/ |
| H A D | util.py | 230 self.queue_packet(exc)
277 def queue_packet(self, data): member in ConnectionStub
288 self._peer.queue_packet(Byte(pkttype) + b''.join(args))
294 self._peer.queue_packet(None)
298 self.queue_packet(None)
|
| /dports/net/ortp/ortp-1.0.2-0/src/ |
| H A D | rtpparse.c | 32 static bool_t queue_packet(queue_t *q, int maxrqsz, mblk_t *mp, rtp_header_t *rtp, int *discarded, … in queue_packet() function
264 …queue_packet(&session->rtp.tev_rq,session->rtp.jittctl.params.max_packets,mp,rtp,&discarded,&dupli… in rtp_session_rtp_parse()
332 …if (queue_packet(&session->rtp.rq,session->rtp.jittctl.params.max_packets,mp,rtp,&discarded,&dupli… in rtp_session_rtp_parse()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/include/ |
| H A D | replication_threads_api.h | 191 int queue_packet(const char* buf, ulong event_len);
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/include/ |
| H A D | replication_threads_api.h | 195 int queue_packet(const char* buf, ulong event_len);
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/include/ |
| H A D | replication_threads_api.h | 195 int queue_packet(const char* buf, ulong event_len);
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/include/ |
| H A D | replication_threads_api.h | 195 int queue_packet(const char* buf, ulong event_len);
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/include/ |
| H A D | replication_threads_api.h | 195 int queue_packet(const char* buf, ulong event_len);
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/include/ |
| H A D | replication_threads_api.h | 195 int queue_packet(const char* buf, ulong event_len);
|
| /dports/security/openconnect/openconnect-8.10/ |
| H A D | esp.c | 261 queue_packet(&vpninfo->incoming_queue, newpkt); in esp_mainloop()
263 queue_packet(&vpninfo->incoming_queue, pkt); in esp_mainloop()
323 queue_packet(&vpninfo->oncp_control_queue, this); in esp_mainloop()
|
| H A D | mainloop.c | 42 queue_packet(q, new); in queue_new_packet()
82 if (queue_packet(&vpninfo->outgoing_queue, out_pkt) + in tun_mainloop()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/group_replication/include/ |
| H A D | replication_threads_api.h | 190 int queue_packet(const char *buf, ulong event_len);
|
| /dports/x11/xpra/xpra-4.3/xpra/server/window/ |
| H A D | windowicon_source.py | 163 self.queue_packet(packet, wait_for_more=True)
241 self.queue_packet(packet, wait_for_more=True)
|
| /dports/multimedia/mkvtoolnix/mkvtoolnix-65.0.0/src/input/ |
| H A D | teletext_to_srt_packet_converter.h | 89 void queue_packet(packet_cptr const &new_packet);
|
| H A D | teletext_to_srt_packet_converter.cpp | 362 queue_packet(new_packet); in queue_page_content()
409 teletext_to_srt_packet_converter_c::queue_packet(packet_cptr const &new_packet) { in queue_packet() function in teletext_to_srt_packet_converter_c
|
| /dports/net/ptunnel/PingTunnel/ |
| H A D | ptunnel.c | 730 …queue_packet(fwd_sock, cur->pkt_type, 0, 0, cur->id_no, cur->id_no, &cur->my_seq, cur->send_ring, … in pt_proxy()
759 …queue_packet(fwd_sock, cur->pkt_type, cur->buf, bytes, cur->id_no, cur->icmp_id, &cur->my_seq, cur… in pt_proxy()
806 …queue_packet(fwd_sock, cur->pkt_type, 0, 0, cur->id_no, cur->icmp_id, &cur->my_seq, cur->send_ring… in pt_proxy()
1016 …queue_packet(icmp_sock, cur->pkt_type, cur->buf, sizeof(challenge_t), cur->id_no, cur->icmp_id, &c… in handle_packet()
1047 …queue_packet(icmp_sock, cur->pkt_type, (char*)challenge, sizeof(challenge_t), cur->id_no, cur->icm… in handle_packet()
1205 int queue_packet(int icmp_sock, uint8_t type, char *buf, int num_bytes, uint16_t id_no, uint16_t … in queue_packet() function
1573 …queue_packet(icmp_sock, cur->pkt_type, 0, 0, cur->id_no, cur->icmp_id, &cur->my_seq, cur->send_rin… in send_termination_msg()
1574 …queue_packet(icmp_sock, cur->pkt_type, 0, 0, cur->id_no, cur->icmp_id, &cur->my_seq, cur->send_rin… in send_termination_msg()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/src/handlers/ |
| H A D | applier_handler.cc | 148 error= channel_interface.queue_packet((const char*)p->payload, p->len); in handle_event()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/src/handlers/ |
| H A D | applier_handler.cc | 148 error= channel_interface.queue_packet((const char*)p->payload, p->len); in handle_event()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/src/handlers/ |
| H A D | applier_handler.cc | 148 error= channel_interface.queue_packet((const char*)p->payload, p->len); in handle_event()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/src/handlers/ |
| H A D | applier_handler.cc | 148 error= channel_interface.queue_packet((const char*)p->payload, p->len); in handle_event()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/src/handlers/ |
| H A D | applier_handler.cc | 148 error= channel_interface.queue_packet((const char*)p->payload, p->len); in handle_event()
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/src/handlers/ |
| H A D | applier_handler.cc | 148 error= channel_interface.queue_packet((const char*)p->payload, p->len); in handle_event()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/group_replication/src/handlers/ |
| H A D | applier_handler.cc | 121 error = channel_interface.queue_packet((const char *)p->payload, p->len); in handle_event()
|
| /dports/x11/xpra/xpra-4.3/xpra/server/source/ |
| H A D | clipboard_connection.py | 124 self.queue_packet(packet)
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/src/ |
| H A D | replication_threads_api.cc | 210 Replication_thread_api::queue_packet(const char* buf, ulong event_len) in queue_packet() function in Replication_thread_api
|