Go to the source code of this file.
◆ CAC_state
◆ Port
◆ CAC_state
Enumerator |
---|
CAC_OK | |
CAC_STARTUP | |
CAC_SHUTDOWN | |
CAC_RECOVERY | |
CAC_NOTCONSISTENT | |
CAC_TOOMANY | |
Definition at line 71 of file libpq-be.h.
◆ pq_getkeepalivescount()
int pq_getkeepalivescount |
( |
Port * |
port | ) |
|
Definition at line 1792 of file pqcomm.c.
1795 if (
port == NULL ||
port->laddr.addr.ss_family == AF_UNIX)
1798 if (
port->keepalives_count != 0)
1799 return port->keepalives_count;
1801 if (
port->default_keepalives_count == 0)
1805 if (getsockopt(
port->sock, IPPROTO_TCP, TCP_KEEPCNT,
1806 (
char *) &
port->default_keepalives_count,
1810 (
errmsg(
"%s(%s) failed: %m",
"getsockopt",
"TCP_KEEPCNT")));
1811 port->default_keepalives_count = -1;
1815 return port->default_keepalives_count;
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
References ereport, errmsg(), LOG, and port.
Referenced by pq_setkeepalivescount(), and show_tcp_keepalives_count().
◆ pq_getkeepalivesidle()
int pq_getkeepalivesidle |
( |
Port * |
port | ) |
|
Definition at line 1623 of file pqcomm.c.
1625 #if defined(PG_TCP_KEEPALIVE_IDLE) || defined(SIO_KEEPALIVE_VALS)
1626 if (
port == NULL ||
port->laddr.addr.ss_family == AF_UNIX)
1629 if (
port->keepalives_idle != 0)
1630 return port->keepalives_idle;
1632 if (
port->default_keepalives_idle == 0)
1637 if (getsockopt(
port->sock, IPPROTO_TCP, PG_TCP_KEEPALIVE_IDLE,
1638 (
char *) &
port->default_keepalives_idle,
1642 (
errmsg(
"%s(%s) failed: %m",
"getsockopt", PG_TCP_KEEPALIVE_IDLE_STR)));
1643 port->default_keepalives_idle = -1;
1647 port->default_keepalives_idle = -1;
1651 return port->default_keepalives_idle;
References ereport, errmsg(), LOG, and port.
Referenced by pq_setkeepalivesidle(), and show_tcp_keepalives_idle().
◆ pq_getkeepalivesinterval()
int pq_getkeepalivesinterval |
( |
Port * |
port | ) |
|
Definition at line 1708 of file pqcomm.c.
1710 #if defined(TCP_KEEPINTVL) || defined(SIO_KEEPALIVE_VALS)
1711 if (
port == NULL ||
port->laddr.addr.ss_family == AF_UNIX)
1714 if (
port->keepalives_interval != 0)
1715 return port->keepalives_interval;
1717 if (
port->default_keepalives_interval == 0)
1722 if (getsockopt(
port->sock, IPPROTO_TCP, TCP_KEEPINTVL,
1723 (
char *) &
port->default_keepalives_interval,
1727 (
errmsg(
"%s(%s) failed: %m",
"getsockopt",
"TCP_KEEPINTVL")));
1728 port->default_keepalives_interval = -1;
1732 port->default_keepalives_interval = -1;
1736 return port->default_keepalives_interval;
References ereport, errmsg(), LOG, and port.
Referenced by pq_setkeepalivesinterval(), and show_tcp_keepalives_interval().
◆ pq_gettcpusertimeout()
int pq_gettcpusertimeout |
( |
Port * |
port | ) |
|
Definition at line 1867 of file pqcomm.c.
1869 #ifdef TCP_USER_TIMEOUT
1870 if (
port == NULL ||
port->laddr.addr.ss_family == AF_UNIX)
1873 if (
port->tcp_user_timeout != 0)
1874 return port->tcp_user_timeout;
1876 if (
port->default_tcp_user_timeout == 0)
1880 if (getsockopt(
port->sock, IPPROTO_TCP, TCP_USER_TIMEOUT,
1881 (
char *) &
port->default_tcp_user_timeout,
1885 (
errmsg(
"%s(%s) failed: %m",
"getsockopt",
"TCP_USER_TIMEOUT")));
1886 port->default_tcp_user_timeout = -1;
1890 return port->default_tcp_user_timeout;
References ereport, errmsg(), LOG, and port.
Referenced by pq_settcpusertimeout(), and show_tcp_user_timeout().
◆ pq_setkeepalivescount()
int pq_setkeepalivescount |
( |
int |
count, |
|
|
Port * |
port |
|
) |
| |
Definition at line 1822 of file pqcomm.c.
1824 if (
port == NULL ||
port->laddr.addr.ss_family == AF_UNIX)
1828 if (count ==
port->keepalives_count)
1831 if (
port->default_keepalives_count <= 0)
1843 count =
port->default_keepalives_count;
1845 if (setsockopt(
port->sock, IPPROTO_TCP, TCP_KEEPCNT,
1846 (
char *) &count,
sizeof(count)) < 0)
1849 (
errmsg(
"%s(%s) failed: %m",
"setsockopt",
"TCP_KEEPCNT")));
1853 port->keepalives_count = count;
1858 (
errmsg(
"%s(%s) not supported",
"setsockopt",
"TCP_KEEPCNT")));
int pq_getkeepalivescount(Port *port)
References ereport, errmsg(), LOG, port, pq_getkeepalivescount(), STATUS_ERROR, and STATUS_OK.
Referenced by assign_tcp_keepalives_count(), and StreamConnection().
◆ pq_setkeepalivesidle()
int pq_setkeepalivesidle |
( |
int |
idle, |
|
|
Port * |
port |
|
) |
| |
Definition at line 1658 of file pqcomm.c.
1660 if (
port == NULL ||
port->laddr.addr.ss_family == AF_UNIX)
1664 #if defined(PG_TCP_KEEPALIVE_IDLE) || defined(SIO_KEEPALIVE_VALS)
1665 if (idle ==
port->keepalives_idle)
1669 if (
port->default_keepalives_idle <= 0)
1681 idle =
port->default_keepalives_idle;
1683 if (setsockopt(
port->sock, IPPROTO_TCP, PG_TCP_KEEPALIVE_IDLE,
1684 (
char *) &idle,
sizeof(idle)) < 0)
1687 (
errmsg(
"%s(%s) failed: %m",
"setsockopt", PG_TCP_KEEPALIVE_IDLE_STR)));
1691 port->keepalives_idle = idle;
1693 return pq_setkeepaliveswin32(
port, idle,
port->keepalives_interval);
1699 (
errmsg(
"setting the keepalive idle time is not supported")));
int pq_getkeepalivesidle(Port *port)
References ereport, errmsg(), LOG, port, pq_getkeepalivesidle(), STATUS_ERROR, and STATUS_OK.
Referenced by assign_tcp_keepalives_idle(), and StreamConnection().
◆ pq_setkeepalivesinterval()
int pq_setkeepalivesinterval |
( |
int |
interval, |
|
|
Port * |
port |
|
) |
| |
Definition at line 1743 of file pqcomm.c.
1745 if (
port == NULL ||
port->laddr.addr.ss_family == AF_UNIX)
1748 #if defined(TCP_KEEPINTVL) || defined(SIO_KEEPALIVE_VALS)
1753 if (
port->default_keepalives_interval <= 0)
1767 if (setsockopt(
port->sock, IPPROTO_TCP, TCP_KEEPINTVL,
1771 (
errmsg(
"%s(%s) failed: %m",
"setsockopt",
"TCP_KEEPINTVL")));
1783 (
errmsg(
"%s(%s) not supported",
"setsockopt",
"TCP_KEEPINTVL")));
int pq_getkeepalivesinterval(Port *port)
References ereport, errmsg(), LOG, port, pq_getkeepalivesinterval(), STATUS_ERROR, and STATUS_OK.
Referenced by assign_tcp_keepalives_interval(), and StreamConnection().
◆ pq_settcpusertimeout()
int pq_settcpusertimeout |
( |
int |
timeout, |
|
|
Port * |
port |
|
) |
| |
Definition at line 1897 of file pqcomm.c.
1899 if (
port == NULL ||
port->laddr.addr.ss_family == AF_UNIX)
1902 #ifdef TCP_USER_TIMEOUT
1903 if (timeout ==
port->tcp_user_timeout)
1906 if (
port->default_tcp_user_timeout <= 0)
1918 timeout =
port->default_tcp_user_timeout;
1920 if (setsockopt(
port->sock, IPPROTO_TCP, TCP_USER_TIMEOUT,
1921 (
char *) &timeout,
sizeof(timeout)) < 0)
1924 (
errmsg(
"%s(%s) failed: %m",
"setsockopt",
"TCP_USER_TIMEOUT")));
1928 port->tcp_user_timeout = timeout;
1933 (
errmsg(
"%s(%s) not supported",
"setsockopt",
"TCP_USER_TIMEOUT")));
int pq_gettcpusertimeout(Port *port)
References ereport, errmsg(), LOG, port, pq_gettcpusertimeout(), STATUS_ERROR, and STATUS_OK.
Referenced by assign_tcp_user_timeout(), and StreamConnection().
◆ FrontendProtocol