26 void (*comm_reset) (void);
28 int (*flush_if_writable) (void);
29 bool (*is_send_pending) (void);
30 int (*putmessage) (
char msgtype,
const char *s,
size_t len);
31 void (*putmessage_noblock) (
char msgtype,
const char *s,
size_t len);
32 void (*startcopyout) (void);
33 void (*endcopyout) (
bool errorAbort);
38 #define pq_comm_reset() (PqCommMethods->comm_reset()) 39 #define pq_flush() (PqCommMethods->flush()) 40 #define pq_flush_if_writable() (PqCommMethods->flush_if_writable()) 41 #define pq_is_send_pending() (PqCommMethods->is_send_pending()) 42 #define pq_putmessage(msgtype, s, len) \ 43 (PqCommMethods->putmessage(msgtype, s, len)) 44 #define pq_putmessage_noblock(msgtype, s, len) \ 45 (PqCommMethods->putmessage_noblock(msgtype, s, len)) 46 #define pq_startcopyout() (PqCommMethods->startcopyout()) 47 #define pq_endcopyout(errorAbort) (PqCommMethods->endcopyout(errorAbort)) 59 unsigned short portNumber,
const char *unixSocketDir,
89 extern bool ssl_loaded_verify_locations;
129 char *
buf,
int size);
void StreamClose(pgsocket sock)
ssize_t secure_raw_write(Port *port, const void *ptr, size_t len)
WaitEventSet * FeBeWaitSet
bool pq_is_reading_msg(void)
int StreamServerPort(int family, const char *hostName, unsigned short portNumber, const char *unixSocketDir, pgsocket ListenSocket[], int MaxListen)
int secure_initialize(bool isServerStart)
PGDLLIMPORT char * ssl_passphrase_command
ssize_t secure_read(Port *port, void *ptr, size_t len)
void pq_startmsgread(void)
PGDLLIMPORT bool ssl_passphrase_command_supports_reload
int pq_putbytes(const char *s, size_t len)
bool SSLPreferServerCiphers
bool secure_loaded_verify_locations(void)
int StreamConnection(pgsocket server_fd, Port *port)
int pq_getbyte_if_available(unsigned char *c)
int run_ssl_passphrase_command(const char *prompt, bool is_server_start, char *buf, int size)
static pgsocket ListenSocket[MAXLISTEN]
ssize_t secure_open_gssapi(Port *port)
void secure_close(Port *port)
char * ssl_dh_params_file
void RemoveSocketFiles(void)
const PGDLLIMPORT PQcommMethods * PqCommMethods
bool check_ssl_key_file_permissions(const char *ssl_key_file, bool isServerStart)
ssize_t secure_write(Port *port, void *ptr, size_t len)
void TouchSocketFiles(void)
int ssl_min_protocol_version
void secure_destroy(void)
ssize_t secure_raw_read(Port *port, void *ptr, size_t len)
int ssl_max_protocol_version
int pq_getbytes(char *s, size_t len)
int pq_getstring(StringInfo s)
int pq_getmessage(StringInfo s, int maxlen)
int secure_open_server(Port *port)