PostgreSQL Source Code
git master
|
#include "postgres.h"
#include "fmgr.h"
#include "miscadmin.h"
#include "pgstat.h"
#include "varatt.h"
#include "test_shm_mq.h"
Go to the source code of this file.
Functions | |
PG_FUNCTION_INFO_V1 (test_shm_mq) | |
PG_FUNCTION_INFO_V1 (test_shm_mq_pipelined) | |
static void | verify_message (Size origlen, char *origdata, Size newlen, char *newdata) |
Datum | test_shm_mq (PG_FUNCTION_ARGS) |
Datum | test_shm_mq_pipelined (PG_FUNCTION_ARGS) |
Variables | |
PG_MODULE_MAGIC | |
static uint32 | we_message_queue = 0 |
PG_FUNCTION_INFO_V1 | ( | test_shm_mq | ) |
PG_FUNCTION_INFO_V1 | ( | test_shm_mq_pipelined | ) |
Datum test_shm_mq | ( | PG_FUNCTION_ARGS | ) |
Definition at line 43 of file test.c.
References data, dsm_detach(), ereport, errcode(), errmsg(), ERROR, len, PG_GETARG_INT32, PG_GETARG_INT64, PG_GETARG_TEXT_PP, PG_RETURN_VOID, res, shm_mq_receive(), shm_mq_send(), SHM_MQ_SUCCESS, test_shm_mq_setup(), VARDATA_ANY, VARSIZE_ANY_EXHDR, and verify_message().
Datum test_shm_mq_pipelined | ( | PG_FUNCTION_ARGS | ) |
Definition at line 132 of file test.c.
References CHECK_FOR_INTERRUPTS, data, dsm_detach(), ereport, errcode(), errmsg(), ERROR, len, MyLatch, PG_GETARG_BOOL, PG_GETARG_INT32, PG_GETARG_INT64, PG_GETARG_TEXT_PP, PG_RETURN_VOID, res, ResetLatch(), SHM_MQ_DETACHED, shm_mq_receive(), shm_mq_send(), SHM_MQ_SUCCESS, test_shm_mq_setup(), VARDATA_ANY, VARSIZE_ANY_EXHDR, verify_message(), WaitEventExtensionNew(), WaitLatch(), we_message_queue, WL_EXIT_ON_PM_DEATH, and WL_LATCH_SET.
Definition at line 258 of file test.c.
References ereport, errdetail(), errmsg(), ERROR, and i.
Referenced by test_shm_mq(), and test_shm_mq_pipelined().
|
static |
Definition at line 32 of file test.c.
Referenced by test_shm_mq_pipelined().