Home
last modified time | relevance | path

Searched refs:PktHdr (Results 1 – 12 of 12) sorted by relevance

/dports/databases/pgbouncer/pgbouncer-1.16.0/include/
H A Dproto.h34 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 Dclient.h21 bool handle_auth_query_response(PgSocket *client, PktHdr *pkt);
H A Dadmin.h18 bool admin_handle_client(PgSocket *client, PktHdr *pkt) _MUSTCHECK;
H A Dbouncer.h101 typedef struct PktHdr PktHdr; typedef
/dports/net/py-dpkt/dpkt-1.9.6/dpkt/
H A Dsnoop.py32 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 Dpcap.py145 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 Dserver.c25 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 Dproto.c31 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 Dclient.c383 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 Dtakeover.c257 PktHdr pkt; in takeover_parse_data()
H A Dadmin.c1457 bool admin_handle_client(PgSocket *admin, PktHdr *pkt) in admin_handle_client()
/dports/comms/thebridge/thebridge-1.09/src/
H A Dconference.c1755 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 …]