blob: a995d0c2a050e3c68b35b00f3561c512244e9a56 [file]
/*-------------------------------------------------------------------------
*
* cdbpq.h
*
* IDENTIFICATION
* src/include/cdb/cdbpq.h
*-------------------------------------------------------------------------
*/
#ifndef _CDBPQ_H_
#define _CDBPQ_H_
#include "postgres_ext.h"
#include "libpq-int.h"
/* Interface for dispatching stmts from QD to qExecs.
*
* See cdbtm.h for valid flag values.
*/
extern int PQsendGpQuery_shared(PGconn *conn,
char *query,
int query_len,
bool nonblock);
extern PGcmdQueueEntry *pqAllocCmdQueueEntry(PGconn *conn);
extern void pqRecycleCmdQueueEntry(PGconn *conn, PGcmdQueueEntry *entry);
extern void pqAppendCmdQueueEntry(PGconn *conn, PGcmdQueueEntry *entry);
#endif