File Manager

Hackfut Security File Manager

Current Path: /opt/td-agent/embedded/include/postgresql/server/storage

opt / td-agent / embedded / include / postgresql / server / storage /

📁 ..
📄 backendid.h(1.1 KB)
📄 barrier.h(674 B)
📄 block.h(3.21 KB)
📄 buf.h(1.06 KB)
📄 buf_internals.h(12.24 KB)
📄 buffile.h(1.67 KB)
📄 bufmgr.h(9 KB)
📄 bufpage.h(14.91 KB)
📄 checksum.h(666 B)
📄 checksum_impl.h(8.59 KB)
📄 copydir.h(561 B)
📄 dsm.h(1.95 KB)
📄 dsm_impl.h(2.12 KB)
📄 fd.h(4.27 KB)
📄 freespace.h(1.36 KB)
📄 fsm_internals.h(2.26 KB)
📄 indexfsm.h(795 B)
📄 ipc.h(2.67 KB)
📄 item.h(469 B)
📄 itemid.h(4.24 KB)
📄 itemptr.h(3.93 KB)
📄 large_object.h(3.6 KB)
📄 latch.h(6.55 KB)
📄 lmgr.h(4.19 KB)
📄 lock.h(22.89 KB)
📄 lockdefs.h(1.86 KB)
📄 lwlock.h(9.19 KB)
📄 lwlocknames.h(2.42 KB)
📄 off.h(1.58 KB)
📄 pg_sema.h(2.39 KB)
📄 pg_shmem.h(2.23 KB)
📄 pmsignal.h(2.1 KB)
📄 pos.h(1.56 KB)
📄 predicate.h(2.56 KB)
📄 predicate_internals.h(16.96 KB)
📄 proc.h(10.81 KB)
📄 procarray.h(3.5 KB)
📄 procsignal.h(1.9 KB)
📄 reinit.h(592 B)
📄 relfilenode.h(3.81 KB)
📄 s_lock.h(28.64 KB)
📄 shm_mq.h(2.59 KB)
📄 shm_toc.h(2.01 KB)
📄 shmem.h(2.63 KB)
📄 sinval.h(5.41 KB)
📄 sinvaladt.h(1.58 KB)
📄 smgr.h(5.96 KB)
📄 spin.h(2.42 KB)
📄 standby.h(3.35 KB)
📄 standbydefs.h(2.25 KB)

Editing: shm_mq.h

/*-------------------------------------------------------------------------
 *
 * shm_mq.h
 *	  single-reader, single-writer shared memory message queue
 *
 * Portions Copyright (c) 1996-2016, PostgreSQL Global Development Group
 * Portions Copyright (c) 1994, Regents of the University of California
 *
 * src/include/storage/shm_mq.h
 *
 *-------------------------------------------------------------------------
 */
#ifndef SHM_MQ_H
#define SHM_MQ_H

#include "postmaster/bgworker.h"
#include "storage/dsm.h"
#include "storage/proc.h"

/* The queue itself, in shared memory. */
struct shm_mq;
typedef struct shm_mq shm_mq;

/* Backend-private state. */
struct shm_mq_handle;
typedef struct shm_mq_handle shm_mq_handle;

/* Descriptors for a single write spanning multiple locations. */
typedef struct
{
	const char *data;
	Size		len;
} shm_mq_iovec;

/* Possible results of a send or receive operation. */
typedef enum
{
	SHM_MQ_SUCCESS,				/* Sent or received a message. */
	SHM_MQ_WOULD_BLOCK,			/* Not completed; retry later. */
	SHM_MQ_DETACHED				/* Other process has detached queue. */
} shm_mq_result;

/*
 * Primitives to create a queue and set the sender and receiver.
 *
 * Both the sender and the receiver must be set before any messages are read
 * or written, but they need not be set by the same process.  Each must be
 * set exactly once.
 */
extern shm_mq *shm_mq_create(void *address, Size size);
extern void shm_mq_set_receiver(shm_mq *mq, PGPROC *);
extern void shm_mq_set_sender(shm_mq *mq, PGPROC *);

/* Accessor methods for sender and receiver. */
extern PGPROC *shm_mq_get_receiver(shm_mq *);
extern PGPROC *shm_mq_get_sender(shm_mq *);

/* Set up backend-local queue state. */
extern shm_mq_handle *shm_mq_attach(shm_mq *mq, dsm_segment *seg,
			  BackgroundWorkerHandle *handle);

/* Associate worker handle with shm_mq. */
extern void shm_mq_set_handle(shm_mq_handle *, BackgroundWorkerHandle *);

/* Break connection. */
extern void shm_mq_detach(shm_mq *);

/* Get the shm_mq from handle. */
extern shm_mq *shm_mq_get_queue(shm_mq_handle *mqh);

/* Send or receive messages. */
extern shm_mq_result shm_mq_send(shm_mq_handle *mqh,
			Size nbytes, const void *data, bool nowait);
extern shm_mq_result shm_mq_sendv(shm_mq_handle *mqh,
			 shm_mq_iovec *iov, int iovcnt, bool nowait);
extern shm_mq_result shm_mq_receive(shm_mq_handle *mqh,
			   Size *nbytesp, void **datap, bool nowait);

/* Wait for our counterparty to attach to the queue. */
extern shm_mq_result shm_mq_wait_for_attach(shm_mq_handle *mqh);

/* Smallest possible queue. */
extern PGDLLIMPORT const Size shm_mq_minimum_size;

#endif   /* SHM_MQ_H */

Hackfut Security File Manager

Editing: shm_mq.h

Upload File

Create Folder