PostgreSQL Source Code  git master
s_lock.c File Reference
#include "postgres.h"
#include <time.h>
#include <unistd.h>
#include "common/pg_prng.h"
#include "port/atomics.h"
#include "storage/s_lock.h"
#include "utils/wait_event.h"
Include dependency graph for s_lock.c:

Go to the source code of this file.

Macros

#define MIN_SPINS_PER_DELAY   10
 
#define MAX_SPINS_PER_DELAY   1000
 
#define NUM_DELAYS   1000
 
#define MIN_DELAY_USEC   1000L
 
#define MAX_DELAY_USEC   1000000L
 

Functions

static void s_lock_stuck (const char *file, int line, const char *func)
 
int s_lock (volatile slock_t *lock, const char *file, int line, const char *func)
 
void perform_spin_delay (SpinDelayStatus *status)
 
void finish_spin_delay (SpinDelayStatus *status)
 
void set_spins_per_delay (int shared_spins_per_delay)
 
int update_spins_per_delay (int shared_spins_per_delay)
 

Variables

static int spins_per_delay = DEFAULT_SPINS_PER_DELAY
 

Macro Definition Documentation

◆ MAX_DELAY_USEC

#define MAX_DELAY_USEC   1000000L

Definition at line 62 of file s_lock.c.

◆ MAX_SPINS_PER_DELAY

#define MAX_SPINS_PER_DELAY   1000

Definition at line 59 of file s_lock.c.

◆ MIN_DELAY_USEC

#define MIN_DELAY_USEC   1000L

Definition at line 61 of file s_lock.c.

◆ MIN_SPINS_PER_DELAY

#define MIN_SPINS_PER_DELAY   10

Definition at line 58 of file s_lock.c.

◆ NUM_DELAYS

#define NUM_DELAYS   1000

Definition at line 60 of file s_lock.c.

Function Documentation

◆ finish_spin_delay()

void finish_spin_delay ( SpinDelayStatus status)

Definition at line 192 of file s_lock.c.

193 {
194  if (status->cur_delay == 0)
195  {
196  /* we never had to delay */
199  }
200  else
201  {
204  }
205 }
#define Min(x, y)
Definition: c.h:991
#define Max(x, y)
Definition: c.h:985
#define MAX_SPINS_PER_DELAY
Definition: s_lock.c:59
#define MIN_SPINS_PER_DELAY
Definition: s_lock.c:58
static int spins_per_delay
Definition: s_lock.c:73

References SpinDelayStatus::cur_delay, Max, MAX_SPINS_PER_DELAY, Min, MIN_SPINS_PER_DELAY, and spins_per_delay.

Referenced by LockBufHdr(), LWLockWaitListLock(), s_lock(), and WaitBufHdrUnlocked().

◆ perform_spin_delay()

void perform_spin_delay ( SpinDelayStatus status)

Definition at line 132 of file s_lock.c.

133 {
134  /* CPU-specific delay each time through the loop */
135  SPIN_DELAY();
136 
137  /* Block the process every spins_per_delay tries */
138  if (++(status->spins) >= spins_per_delay)
139  {
140  if (++(status->delays) > NUM_DELAYS)
141  s_lock_stuck(status->file, status->line, status->func);
142 
143  if (status->cur_delay == 0) /* first time to delay? */
144  status->cur_delay = MIN_DELAY_USEC;
145 
146  /*
147  * Once we start sleeping, the overhead of reporting a wait event is
148  * justified. Actively spinning easily stands out in profilers, but
149  * sleeping with an exponential backoff is harder to spot...
150  *
151  * We might want to report something more granular at some point, but
152  * this is better than nothing.
153  */
154  pgstat_report_wait_start(WAIT_EVENT_SPIN_DELAY);
155  pg_usleep(status->cur_delay);
157 
158 #if defined(S_LOCK_TEST)
159  fprintf(stdout, "*");
160  fflush(stdout);
161 #endif
162 
163  /* increase delay by a random fraction between 1X and 2X */
164  status->cur_delay += (int) (status->cur_delay *
166  /* wrap back to minimum delay when max is exceeded */
167  if (status->cur_delay > MAX_DELAY_USEC)
168  status->cur_delay = MIN_DELAY_USEC;
169 
170  status->spins = 0;
171  }
172 }
static void const char fflush(stdout)
double pg_prng_double(pg_prng_state *state)
Definition: pg_prng.c:268
pg_prng_state pg_global_prng_state
Definition: pg_prng.c:34
#define fprintf
Definition: port.h:242
#define MIN_DELAY_USEC
Definition: s_lock.c:61
#define NUM_DELAYS
Definition: s_lock.c:60
#define MAX_DELAY_USEC
Definition: s_lock.c:62
static void s_lock_stuck(const char *file, int line, const char *func)
Definition: s_lock.c:80
#define SPIN_DELAY()
Definition: s_lock.h:791
void pg_usleep(long microsec)
Definition: signal.c:53
const char * file
Definition: s_lock.h:826
const char * func
Definition: s_lock.h:828
static void pgstat_report_wait_start(uint32 wait_event_info)
Definition: wait_event.h:88
static void pgstat_report_wait_end(void)
Definition: wait_event.h:104

References SpinDelayStatus::cur_delay, SpinDelayStatus::delays, fflush(), SpinDelayStatus::file, fprintf, SpinDelayStatus::func, SpinDelayStatus::line, MAX_DELAY_USEC, MIN_DELAY_USEC, NUM_DELAYS, pg_global_prng_state, pg_prng_double(), pg_usleep(), pgstat_report_wait_end(), pgstat_report_wait_start(), s_lock_stuck(), SPIN_DELAY, SpinDelayStatus::spins, spins_per_delay, and generate_unaccent_rules::stdout.

Referenced by LockBufHdr(), LWLockWaitListLock(), s_lock(), and WaitBufHdrUnlocked().

◆ s_lock()

int s_lock ( volatile slock_t lock,
const char *  file,
int  line,
const char *  func 
)

Definition at line 99 of file s_lock.c.

100 {
101  SpinDelayStatus delayStatus;
102 
103  init_spin_delay(&delayStatus, file, line, func);
104 
105  while (TAS_SPIN(lock))
106  {
107  perform_spin_delay(&delayStatus);
108  }
109 
110  finish_spin_delay(&delayStatus);
111 
112  return delayStatus.delays;
113 }
void perform_spin_delay(SpinDelayStatus *status)
Definition: s_lock.c:132
void finish_spin_delay(SpinDelayStatus *status)
Definition: s_lock.c:192
#define TAS_SPIN(lock)
Definition: s_lock.h:802
static void init_spin_delay(SpinDelayStatus *status, const char *file, int line, const char *func)
Definition: s_lock.h:832

References SpinDelayStatus::delays, finish_spin_delay(), init_spin_delay(), perform_spin_delay(), and TAS_SPIN.

Referenced by test_spinlock().

◆ s_lock_stuck()

static void s_lock_stuck ( const char *  file,
int  line,
const char *  func 
)
static

Definition at line 80 of file s_lock.c.

81 {
82  if (!func)
83  func = "(unknown)";
84 #if defined(S_LOCK_TEST)
85  fprintf(stderr,
86  "\nStuck spinlock detected at %s, %s:%d.\n",
87  func, file, line);
88  exit(1);
89 #else
90  elog(PANIC, "stuck spinlock detected at %s, %s:%d",
91  func, file, line);
92 #endif
93 }
#define PANIC
Definition: elog.h:42
#define elog(elevel,...)
Definition: elog.h:224
exit(1)

References elog, exit(), fprintf, and PANIC.

Referenced by perform_spin_delay().

◆ set_spins_per_delay()

void set_spins_per_delay ( int  shared_spins_per_delay)

Definition at line 213 of file s_lock.c.

214 {
215  spins_per_delay = shared_spins_per_delay;
216 }

References spins_per_delay.

Referenced by InitAuxiliaryProcess(), and InitProcess().

◆ update_spins_per_delay()

int update_spins_per_delay ( int  shared_spins_per_delay)

Definition at line 224 of file s_lock.c.

225 {
226  /*
227  * We use an exponential moving average with a relatively slow adaption
228  * rate, so that noise in any one backend's result won't affect the shared
229  * value too much. As long as both inputs are within the allowed range,
230  * the result must be too, so we need not worry about clamping the result.
231  *
232  * We deliberately truncate rather than rounding; this is so that single
233  * adjustments inside a backend can affect the shared estimate (see the
234  * asymmetric adjustment rules above).
235  */
236  return (shared_spins_per_delay * 15 + spins_per_delay) / 16;
237 }

References spins_per_delay.

Referenced by AuxiliaryProcKill(), and ProcKill().

Variable Documentation

◆ spins_per_delay

int spins_per_delay = DEFAULT_SPINS_PER_DELAY
static