Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit4a3bb96

Browse files
committed
Try to ensure that stats collector's receive buffer size is at least 100KB.
Back-patch of commit8b0b630.Discussion:https://postgr.es/m/22173.1494788088@sss.pgh.pa.us
1 parent78e4fb8 commit4a3bb96

File tree

1 file changed

+32
-0
lines changed

1 file changed

+32
-0
lines changed

‎src/backend/postmaster/pgstat.c

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,9 @@
9696
#definePGSTAT_POLL_LOOP_COUNT(PGSTAT_MAX_WAIT_TIME / PGSTAT_RETRY_DELAY)
9797
#definePGSTAT_INQ_LOOP_COUNT(PGSTAT_INQ_INTERVAL / PGSTAT_RETRY_DELAY)
9898

99+
/* Minimum receive buffer size for the collector's socket. */
100+
#definePGSTAT_MIN_RCVBUF(100 * 1024)
101+
99102

100103
/* ----------
101104
* The initial size hints for the hash tables used in the collector.
@@ -527,6 +530,35 @@ pgstat_init(void)
527530
gotostartup_failed;
528531
}
529532

533+
/*
534+
* Try to ensure that the socket's receive buffer is at least
535+
* PGSTAT_MIN_RCVBUF bytes, so that it won't easily overflow and lose
536+
* data. Use of UDP protocol means that we are willing to lose data under
537+
* heavy load, but we don't want it to happen just because of ridiculously
538+
* small default buffer sizes (such as 8KB on older Windows versions).
539+
*/
540+
{
541+
intold_rcvbuf;
542+
intnew_rcvbuf;
543+
ACCEPT_TYPE_ARG3rcvbufsize=sizeof(old_rcvbuf);
544+
545+
if (getsockopt(pgStatSock,SOL_SOCKET,SO_RCVBUF,
546+
(char*)&old_rcvbuf,&rcvbufsize)<0)
547+
{
548+
elog(LOG,"getsockopt(SO_RCVBUF) failed: %m");
549+
/* if we can't get existing size, always try to set it */
550+
old_rcvbuf=0;
551+
}
552+
553+
new_rcvbuf=PGSTAT_MIN_RCVBUF;
554+
if (old_rcvbuf<new_rcvbuf)
555+
{
556+
if (setsockopt(pgStatSock,SOL_SOCKET,SO_RCVBUF,
557+
(char*)&new_rcvbuf,sizeof(new_rcvbuf))<0)
558+
elog(LOG,"setsockopt(SO_RCVBUF) failed: %m");
559+
}
560+
}
561+
530562
pg_freeaddrinfo_all(hints.ai_family,addrs);
531563

532564
return;

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp