Searched refs:PktHdr (Results 1 – 12 of 12) sorted by relevance
/dports/databases/pgbouncer/pgbouncer-1.16.0/include/ |
H A D | proto.h | 34 struct PktHdr { struct 40 bool get_header(struct MBuf *data, PktHdr *pkt) _MUSTCHECK; argument 43 void log_server_error(const char *note, PktHdr *pkt); 44 void parse_server_error(PktHdr *pkt, const char **level_p, const char **msg_p); 50 bool answer_authreq(PgSocket *server, PktHdr *pkt) _MUSTCHECK; 58 static inline bool incomplete_pkt(const PktHdr *pkt) in incomplete_pkt() 75 static inline char pkt_desc(const PktHdr *pkt) in pkt_desc()
|
H A D | client.h | 21 bool handle_auth_query_response(PgSocket *client, PktHdr *pkt);
|
H A D | admin.h | 18 bool admin_handle_client(PgSocket *client, PktHdr *pkt) _MUSTCHECK;
|
H A D | bouncer.h | 101 typedef struct PktHdr PktHdr; typedef
|
/dports/net/py-dpkt/dpkt-1.9.6/dpkt/ |
H A D | snoop.py | 32 class PktHdr(dpkt.Packet): class 138 self._PktHdr = PktHdr() 156 PktHdr.__hdr_len__ + pkt_len + pad_len, 184 PktHdr.__hdr_len__ + pkt_len + pad_len, 269 self._ph = PktHdr 297 pkt = PktHdr(buf)
|
H A D | pcap.py | 145 class PktHdr(dpkt.Packet): class 162 class LEPktHdr(PktHdr): 214 self._PktHdr = PktHdr() 283 self.__ph = PktHdr 350 buf = self.__f.read(PktHdr.__hdr_len__) 421 assert buf1 == data[FileHdr.__hdr_len__ + PktHdr.__hdr_len__:]
|
/dports/databases/pgbouncer/pgbouncer-1.16.0/src/ |
H A D | server.c | 25 static bool load_parameter(PgSocket *server, PktHdr *pkt, bool startup) in load_parameter() 80 static void kill_pool_logins_server_error(PgPool *pool, PktHdr *errpkt) in kill_pool_logins_server_error() 90 static bool handle_server_startup(PgSocket *server, PktHdr *pkt) in handle_server_startup() 247 static bool handle_server_work(PgSocket *server, PktHdr *pkt) in handle_server_work() 513 PktHdr pkt; in server_proto()
|
H A D | proto.c | 31 bool get_header(struct MBuf *data, PktHdr *pkt) in get_header() 144 void parse_server_error(PktHdr *pkt, const char **level_p, const char **msg_p) in parse_server_error() 165 void log_server_error(const char *note, PktHdr *pkt) in log_server_error() 450 bool answer_authreq(PgSocket *server, PktHdr *pkt) in answer_authreq()
|
H A D | client.c | 383 bool handle_auth_query_response(PgSocket *client, PktHdr *pkt) { in handle_auth_query_response() 522 static bool decide_startup_pool(PgSocket *client, PktHdr *pkt) in decide_startup_pool() 688 static bool handle_client_startup(PgSocket *client, PktHdr *pkt) in handle_client_startup() 881 static bool handle_client_work(PgSocket *client, PktHdr *pkt) in handle_client_work() 976 PktHdr pkt; in client_proto()
|
H A D | takeover.c | 257 PktHdr pkt; in takeover_parse_data()
|
H A D | admin.c | 1457 bool admin_handle_client(PgSocket *admin, PktHdr *pkt) in admin_handle_client()
|
/dports/comms/thebridge/thebridge-1.09/src/ |
H A D | conference.c | 1755 if(fwrite(&PktHdr,sizeof(PktHdr),1,pMasterCS->fp) != 1) { in RTP_Data() 1785 PktHdr.Flags = htonl(PktHdr.Flags); in RTP_Data() 1787 if(fwrite(&PktHdr,sizeof(PktHdr),1,pMasterCS->fp) != 1 || in RTP_Data() 4780 if(fwrite(&PktHdr,sizeof(PktHdr),1,pCS->fp) != 1) { in StopRecording() 5791 if(fread(&PktHdr,sizeof(PktHdr),1,pFIO->fp) != 1) { in SendAudioFromFile() 5803 PktHdr.Flags = ntohl(PktHdr.Flags); in SendAudioFromFile() 5804 PktHdr.Len = ntohl(PktHdr.Len); in SendAudioFromFile() 5807 PktHdr.Len,PktHdr.Flags)); in SendAudioFromFile() 5833 if(PktHdr.Len > CONF_BUF_SIZE || PktHdr.Len < 0) { in SendAudioFromFile() 6040 if(fwrite(&PktHdr,sizeof(PktHdr),1,pFIO->fp) != 1 || in FileRecord() [all …]
|