Home
last modified time | relevance | path

Searched refs:QUEUE_HEAD (Results 1 – 25 of 253) sorted by relevance

1234567891011

/dports/databases/postgresql96-server/postgresql-9.6.24/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql96-plpython/postgresql-9.6.24/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql10-docs/postgresql-10.19/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql10-server/postgresql-10.19/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql10-pltcl/postgresql-10.19/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql11-client/postgresql-11.14/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql10-client/postgresql-10.19/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql10-contrib/postgresql-10.19/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql11-docs/postgresql-11.14/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql10-plpython/postgresql-10.19/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql11-server/postgresql-11.14/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head)
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0);
979 head = QUEUE_HEAD; in Resume()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in ISpeechRecognitionGrammarFileConstraintFactory()
1355 queue_head = QUEUE_HEAD; in from()
1414 QUEUE_HEAD = queue_head; in from()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in Commands()
1491 QueuePosition min = QUEUE_HEAD; in Type()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in from()
1784 head = QUEUE_HEAD; in from()
[all …]
/dports/databases/postgresql12-client/postgresql-12.9/src/backend/commands/
H A Dasync.c261 #define QUEUE_HEAD (asyncQueueControl->head)
474 SET_QUEUE_POS(QUEUE_HEAD, 0, 0);
978 head = QUEUE_HEAD;
1246 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1;
1354 queue_head = QUEUE_HEAD;
1413 QUEUE_HEAD = queue_head;
1449 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD);
1490 QueuePosition min = QUEUE_HEAD;
1561 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD))
1783 head = QUEUE_HEAD;
[all …]
/dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql96-client/postgresql-9.6.24/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql96-plperl/postgresql-9.6.24/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql96-contrib/postgresql-9.6.24/src/backend/commands/
H A Dasync.c262 #define QUEUE_HEAD (asyncQueueControl->head) macro
475 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
979 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1247 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1355 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1414 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1450 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1491 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1562 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1784 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/commands/
H A Dasync.c261 #define QUEUE_HEAD (asyncQueueControl->head)
474 SET_QUEUE_POS(QUEUE_HEAD, 0, 0);
978 head = QUEUE_HEAD;
1246 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1;
1354 queue_head = QUEUE_HEAD;
1413 QUEUE_HEAD = queue_head;
1449 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD);
1490 QueuePosition min = QUEUE_HEAD;
1561 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD))
1783 head = QUEUE_HEAD;
[all …]
/dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/commands/
H A Dasync.c261 #define QUEUE_HEAD (asyncQueueControl->head) macro
474 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
978 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1246 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1354 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1413 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1449 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1490 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1561 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1783 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql12-server/postgresql-12.9/src/backend/commands/
H A Dasync.c261 #define QUEUE_HEAD (asyncQueueControl->head) macro
474 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
978 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1246 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1354 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1413 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1449 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1490 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1561 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1783 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]
/dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/commands/
H A Dasync.c261 #define QUEUE_HEAD (asyncQueueControl->head) macro
474 SET_QUEUE_POS(QUEUE_HEAD, 0, 0); in AsyncShmemInit()
978 head = QUEUE_HEAD; in Exec_ListenPreCommit()
1246 nexthead = QUEUE_POS_PAGE(QUEUE_HEAD) + 1; in asyncQueueIsFull()
1354 queue_head = QUEUE_HEAD; in asyncQueueAddEntries()
1413 QUEUE_HEAD = queue_head; in asyncQueueAddEntries()
1449 int headPage = QUEUE_POS_PAGE(QUEUE_HEAD); in asyncQueueUsage()
1490 QueuePosition min = QUEUE_HEAD; in asyncQueueFillWarning()
1561 if (!QUEUE_POS_EQUAL(pos, QUEUE_HEAD)) in SignalBackends()
1783 head = QUEUE_HEAD; in asyncQueueReadAllNotifications()
[all …]

1234567891011