Lines Matching refs:shared_state
81 static repmgrdSharedState *shared_state = NULL; variable
194 shared_state = NULL; in repmgr_shmem_startup()
201 shared_state = ShmemInitStruct("repmgrd shared state", in repmgr_shmem_startup()
209 shared_state->lock = &(GetNamedLWLockTranche(TRANCHE_NAME))->lock; in repmgr_shmem_startup()
211 shared_state->lock = LWLockAssign(); in repmgr_shmem_startup()
214 shared_state->local_node_id = UNKNOWN_NODE_ID; in repmgr_shmem_startup()
215 shared_state->repmgrd_pid = UNKNOWN_PID; in repmgr_shmem_startup()
216 memset(shared_state->repmgrd_pidfile, 0, MAXPGPATH); in repmgr_shmem_startup()
217 shared_state->repmgrd_paused = false; in repmgr_shmem_startup()
218 shared_state->current_electoral_term = 0; in repmgr_shmem_startup()
219 shared_state->upstream_node_id = UNKNOWN_NODE_ID; in repmgr_shmem_startup()
221 shared_state->upstream_last_seen = POSTGRES_EPOCH_JDATE; in repmgr_shmem_startup()
222 shared_state->voting_status = VS_NO_VOTE; in repmgr_shmem_startup()
223 shared_state->candidate_node_id = UNKNOWN_NODE_ID; in repmgr_shmem_startup()
224 shared_state->follow_new_primary = false; in repmgr_shmem_startup()
242 if (!shared_state) in set_local_node_id()
278 LWLockAcquire(shared_state->lock, LW_EXCLUSIVE); in set_local_node_id()
281 if (shared_state->local_node_id == UNKNOWN_NODE_ID) in set_local_node_id()
283 shared_state->local_node_id = local_node_id; in set_local_node_id()
287 if (stored_node_id == shared_state->local_node_id) in set_local_node_id()
291 shared_state->repmgrd_paused = false; in set_local_node_id()
295 shared_state->repmgrd_paused = true; in set_local_node_id()
299 LWLockRelease(shared_state->lock); in set_local_node_id()
310 if (!shared_state) in get_local_node_id()
313 LWLockAcquire(shared_state->lock, LW_SHARED); in get_local_node_id()
314 local_node_id = shared_state->local_node_id; in get_local_node_id()
315 LWLockRelease(shared_state->lock); in get_local_node_id()
327 if (!shared_state) in standby_set_last_updated()
330 LWLockAcquire(shared_state->lock, LW_EXCLUSIVE); in standby_set_last_updated()
331 shared_state->last_updated = last_updated; in standby_set_last_updated()
332 LWLockRelease(shared_state->lock); in standby_set_last_updated()
345 if (!shared_state) in standby_get_last_updated()
348 LWLockAcquire(shared_state->lock, LW_SHARED); in standby_get_last_updated()
349 last_updated = shared_state->last_updated; in standby_get_last_updated()
350 LWLockRelease(shared_state->lock); in standby_get_last_updated()
361 if (!shared_state) in set_upstream_last_seen()
369 LWLockAcquire(shared_state->lock, LW_EXCLUSIVE); in set_upstream_last_seen()
371 shared_state->upstream_last_seen = GetCurrentTimestamp(); in set_upstream_last_seen()
372 shared_state->upstream_node_id = upstream_node_id; in set_upstream_last_seen()
373 LWLockRelease(shared_state->lock); in set_upstream_last_seen()
386 if (!shared_state) in get_upstream_last_seen()
389 LWLockAcquire(shared_state->lock, LW_SHARED); in get_upstream_last_seen()
391 last_seen = shared_state->upstream_last_seen; in get_upstream_last_seen()
393 LWLockRelease(shared_state->lock); in get_upstream_last_seen()
418 if (!shared_state) in get_upstream_node_id()
421 LWLockAcquire(shared_state->lock, LW_SHARED); in get_upstream_node_id()
422 upstream_node_id = shared_state->upstream_node_id; in get_upstream_node_id()
423 LWLockRelease(shared_state->lock); in get_upstream_node_id()
434 if (!shared_state) in set_upstream_node_id()
442 LWLockAcquire(shared_state->lock, LW_SHARED); in set_upstream_node_id()
443 local_node_id = shared_state->local_node_id; in set_upstream_node_id()
444 LWLockRelease(shared_state->lock); in set_upstream_node_id()
451 LWLockAcquire(shared_state->lock, LW_EXCLUSIVE); in set_upstream_node_id()
452 shared_state->upstream_node_id = upstream_node_id; in set_upstream_node_id()
453 LWLockRelease(shared_state->lock); in set_upstream_node_id()
469 if (!shared_state) in notify_follow_primary()
477 LWLockAcquire(shared_state->lock, LW_SHARED); in notify_follow_primary()
480 if (shared_state->local_node_id != UNKNOWN_NODE_ID) in notify_follow_primary()
485 shared_state->local_node_id); in notify_follow_primary()
490 shared_state->local_node_id, in notify_follow_primary()
494 LWLockRelease(shared_state->lock); in notify_follow_primary()
495 LWLockAcquire(shared_state->lock, LW_EXCLUSIVE); in notify_follow_primary()
497 shared_state->candidate_node_id = primary_node_id; in notify_follow_primary()
498 shared_state->follow_new_primary = true; in notify_follow_primary()
501 LWLockRelease(shared_state->lock); in notify_follow_primary()
512 if (!shared_state) in get_new_primary()
515 LWLockAcquire(shared_state->lock, LW_SHARED); in get_new_primary()
517 if (shared_state->follow_new_primary == true) in get_new_primary()
518 new_primary_node_id = shared_state->candidate_node_id; in get_new_primary()
520 LWLockRelease(shared_state->lock); in get_new_primary()
532 if (!shared_state) in reset_voting_status()
535 LWLockAcquire(shared_state->lock, LW_SHARED); in reset_voting_status()
538 if (shared_state->local_node_id != UNKNOWN_NODE_ID) in reset_voting_status()
540 LWLockRelease(shared_state->lock); in reset_voting_status()
541 LWLockAcquire(shared_state->lock, LW_EXCLUSIVE); in reset_voting_status()
543 shared_state->voting_status = VS_NO_VOTE; in reset_voting_status()
544 shared_state->candidate_node_id = UNKNOWN_NODE_ID; in reset_voting_status()
545 shared_state->follow_new_primary = false; in reset_voting_status()
548 LWLockRelease(shared_state->lock); in reset_voting_status()
563 if (!shared_state) in get_repmgrd_pid()
566 LWLockAcquire(shared_state->lock, LW_SHARED); in get_repmgrd_pid()
567 repmgrd_pid = shared_state->repmgrd_pid; in get_repmgrd_pid()
568 LWLockRelease(shared_state->lock); in get_repmgrd_pid()
582 if (!shared_state) in get_repmgrd_pidfile()
587 LWLockAcquire(shared_state->lock, LW_SHARED); in get_repmgrd_pidfile()
588 strncpy(repmgrd_pidfile, shared_state->repmgrd_pidfile, MAXPGPATH); in get_repmgrd_pidfile()
589 LWLockRelease(shared_state->lock); in get_repmgrd_pidfile()
603 if (!shared_state) in set_repmgrd_pid()
623 LWLockAcquire(shared_state->lock, LW_EXCLUSIVE); in set_repmgrd_pid()
625 shared_state->repmgrd_pid = repmgrd_pid; in set_repmgrd_pid()
626 memset(shared_state->repmgrd_pidfile, 0, MAXPGPATH); in set_repmgrd_pid()
630 strncpy(shared_state->repmgrd_pidfile, repmgrd_pidfile, MAXPGPATH); in set_repmgrd_pid()
633 LWLockRelease(shared_state->lock); in set_repmgrd_pid()
644 if (!shared_state) in repmgrd_is_running()
647 LWLockAcquire(shared_state->lock, LW_SHARED); in repmgrd_is_running()
648 repmgrd_pid = shared_state->repmgrd_pid; in repmgrd_is_running()
649 LWLockRelease(shared_state->lock); in repmgrd_is_running()
675 if (!shared_state) in repmgrd_pause()
683 LWLockAcquire(shared_state->lock, LW_EXCLUSIVE); in repmgrd_pause()
684 shared_state->repmgrd_paused = pause; in repmgrd_pause()
685 LWLockRelease(shared_state->lock); in repmgrd_pause()
701 LWLockAcquire(shared_state->lock, LW_SHARED); in repmgrd_pause()
704 shared_state->local_node_id, in repmgrd_pause()
706 LWLockRelease(shared_state->lock); in repmgrd_pause()
726 if (!shared_state) in repmgrd_is_paused()
729 LWLockAcquire(shared_state->lock, LW_SHARED); in repmgrd_is_paused()
730 is_paused = shared_state->repmgrd_paused; in repmgrd_is_paused()
731 LWLockRelease(shared_state->lock); in repmgrd_is_paused()
742 if (!shared_state) in get_wal_receiver_pid()