mirror of https://github.com/citusdata/citus.git
Remove READFUNCs (#3536)
We don't actually use these functions anymore since merging #1477.
Advantages of removing:
1. They add work whenever we add a new node.
2. They contain some usage of stdlib APIs that are banned by Microsoft.
Removing it means we don't have to replace those with safe ones.
(cherry picked from commit 2a9fccc7a0)
pull/3647/head
Jelte Fennema
parent
b451c31c4c
commit
e0736d3da7
|
|
@ -1700,8 +1700,7 @@ CheckNodeCopyAndSerialization(Node *node)
|
||||||
{
|
{
|
||||||
#ifdef USE_ASSERT_CHECKING
|
#ifdef USE_ASSERT_CHECKING
|
||||||
char *out = nodeToString(node);
|
char *out = nodeToString(node);
|
||||||
Node *deserializedNode = (Node *) stringToNode(out);
|
Node *nodeCopy = copyObject(node);
|
||||||
Node *nodeCopy = copyObject(deserializedNode);
|
|
||||||
char *outCopy = nodeToString(nodeCopy);
|
char *outCopy = nodeToString(nodeCopy);
|
||||||
|
|
||||||
pfree(out);
|
pfree(out);
|
||||||
|
|
|
||||||
|
|
@ -364,7 +364,7 @@ EqualUnsupportedCitusNode(const struct ExtensibleNode *a,
|
||||||
CopyNode##type, \
|
CopyNode##type, \
|
||||||
EqualUnsupportedCitusNode, \
|
EqualUnsupportedCitusNode, \
|
||||||
Out##type, \
|
Out##type, \
|
||||||
Read##type \
|
ReadUnsupportedCitusNode \
|
||||||
}
|
}
|
||||||
|
|
||||||
#define DEFINE_NODE_METHODS_NO_READ(type) \
|
#define DEFINE_NODE_METHODS_NO_READ(type) \
|
||||||
|
|
|
||||||
|
|
@ -11,445 +11,10 @@
|
||||||
*/
|
*/
|
||||||
#include "postgres.h"
|
#include "postgres.h"
|
||||||
|
|
||||||
#include <math.h>
|
|
||||||
|
|
||||||
#include "distributed/citus_nodefuncs.h"
|
#include "distributed/citus_nodefuncs.h"
|
||||||
#include "distributed/errormessage.h"
|
|
||||||
#include "distributed/log_utils.h"
|
|
||||||
#include "distributed/distributed_planner.h"
|
|
||||||
#include "distributed/multi_server_executor.h"
|
|
||||||
#include "nodes/parsenodes.h"
|
|
||||||
#include "nodes/readfuncs.h"
|
|
||||||
#include "utils/builtins.h"
|
|
||||||
|
|
||||||
|
|
||||||
/*
|
void
|
||||||
* Macros to simplify reading of different kinds of fields. Use these
|
|
||||||
* wherever possible to reduce the chance for silly typos. Note that these
|
|
||||||
* hard-wire conventions about the names of the local variables in a Read
|
|
||||||
* routine.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/* Macros for declaring appropriate local variables */
|
|
||||||
/* A few guys need only local_node */
|
|
||||||
static inline Node *
|
|
||||||
CitusSetTag(Node *node, int tag)
|
|
||||||
{
|
|
||||||
CitusNode *citus_node = (CitusNode *) node;
|
|
||||||
citus_node->citus_tag = tag;
|
|
||||||
return node;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/* *INDENT-OFF* */
|
|
||||||
#define READ_LOCALS_NO_FIELDS(nodeTypeName) \
|
|
||||||
nodeTypeName *local_node = (nodeTypeName *) CitusSetTag((Node *) node, T_##nodeTypeName)
|
|
||||||
|
|
||||||
/* And a few guys need only the pg_strtok support fields */
|
|
||||||
#if PG_VERSION_NUM >= 120000
|
|
||||||
#define READ_TEMP_LOCALS() \
|
|
||||||
const char *token; \
|
|
||||||
int length
|
|
||||||
#else
|
|
||||||
#define READ_TEMP_LOCALS() \
|
|
||||||
char *token; \
|
|
||||||
int length
|
|
||||||
#endif
|
|
||||||
|
|
||||||
/* ... but most need both */
|
|
||||||
#define READ_LOCALS(nodeTypeName) \
|
|
||||||
READ_LOCALS_NO_FIELDS(nodeTypeName); \
|
|
||||||
READ_TEMP_LOCALS()
|
|
||||||
|
|
||||||
/* Read an integer field (anything written as ":fldname %d") */
|
|
||||||
#define READ_INT_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = atoi(token)
|
|
||||||
|
|
||||||
/* Read an 64-bit integer field (anything written as ":fldname %d") */
|
|
||||||
#define READ_INT64_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = (int64) strtoll(token, NULL, 10)
|
|
||||||
|
|
||||||
/* Read an unsigned integer field (anything written as ":fldname %u") */
|
|
||||||
#define READ_UINT_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = atoui(token)
|
|
||||||
|
|
||||||
/* XXX: CITUS Read an uint64 field (anything written as ":fldname %u") */
|
|
||||||
#define READ_UINT64_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = atoull(token)
|
|
||||||
|
|
||||||
/* Read an OID field (don't hard-wire assumption that OID is same as uint) */
|
|
||||||
#define READ_OID_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = atooid(token)
|
|
||||||
|
|
||||||
/* Read a char field (ie, one ascii character) */
|
|
||||||
#define READ_CHAR_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = token[0]
|
|
||||||
|
|
||||||
/* Read an enumerated-type field that was written as an integer code */
|
|
||||||
#define READ_ENUM_FIELD(fldname, enumtype) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = (enumtype) atoi(token)
|
|
||||||
|
|
||||||
/* Read a float field */
|
|
||||||
#define READ_FLOAT_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = atof(token)
|
|
||||||
|
|
||||||
/* Read a boolean field */
|
|
||||||
#define READ_BOOL_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = strtobool(token)
|
|
||||||
|
|
||||||
/* Read a character-string field */
|
|
||||||
#define READ_STRING_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname = nullable_string(token, length)
|
|
||||||
|
|
||||||
/* Read a parse location field (and throw away the value, per notes above) */
|
|
||||||
#define READ_LOCATION_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
(void) token; /* in case not used elsewhere */ \
|
|
||||||
local_node->fldname = -1 /* set field to "unknown" */
|
|
||||||
|
|
||||||
/* Read a Node field */
|
|
||||||
#define READ_NODE_FIELD(fldname) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
(void) token; /* in case not used elsewhere */ \
|
|
||||||
local_node->fldname = nodeRead(NULL, 0)
|
|
||||||
|
|
||||||
/* Read an integer field (anything written as ":fldname %d") */
|
|
||||||
#define READ_ENUM_ARRAY(fldname, count, enumtype) \
|
|
||||||
token = pg_strtok(&length); /* skip :fldname */ \
|
|
||||||
token = pg_strtok(&length); /* skip ( */ \
|
|
||||||
{ \
|
|
||||||
int i = 0; \
|
|
||||||
for (i = 0; i < count; i++ ) \
|
|
||||||
{ \
|
|
||||||
token = pg_strtok(&length); /* get field value */ \
|
|
||||||
local_node->fldname[i] = (enumtype) atoi(token); \
|
|
||||||
} \
|
|
||||||
} \
|
|
||||||
token = pg_strtok(&length); /* skip ) */ \
|
|
||||||
(void) token
|
|
||||||
|
|
||||||
#define READ_INT_ARRAY(fldname, count) READ_ENUM_ARRAY(fldname, count, int32)
|
|
||||||
|
|
||||||
/* Routine exit */
|
|
||||||
#define READ_DONE() \
|
|
||||||
return;
|
|
||||||
|
|
||||||
/*
|
|
||||||
* NOTE: use atoi() to read values written with %d, or atoui() to read
|
|
||||||
* values written with %u in outfuncs.c. An exception is OID values,
|
|
||||||
* for which use atooid(). (As of 7.1, outfuncs.c writes OIDs as %u,
|
|
||||||
* but this will probably change in the future.)
|
|
||||||
*/
|
|
||||||
#define atoui(x) ((unsigned int) strtoul((x), NULL, 10))
|
|
||||||
|
|
||||||
#define atooid(x) ((Oid) strtoul((x), NULL, 10))
|
|
||||||
|
|
||||||
/* XXX: Citus */
|
|
||||||
#define atoull(x) ((uint64) pg_strtouint64((x), NULL, 10))
|
|
||||||
|
|
||||||
#define strtobool(x) ((*(x) == 't') ? true : false)
|
|
||||||
|
|
||||||
#define nullable_string(token,length) \
|
|
||||||
((length) == 0 ? NULL : debackslash(token, length))
|
|
||||||
|
|
||||||
|
|
||||||
static void
|
|
||||||
readJobInfo(Job *local_node)
|
|
||||||
{
|
|
||||||
READ_TEMP_LOCALS();
|
|
||||||
|
|
||||||
CitusSetTag((Node *) local_node, T_Job);
|
|
||||||
|
|
||||||
READ_UINT64_FIELD(jobId);
|
|
||||||
READ_NODE_FIELD(jobQuery);
|
|
||||||
READ_NODE_FIELD(taskList);
|
|
||||||
READ_NODE_FIELD(dependentJobList);
|
|
||||||
READ_BOOL_FIELD(subqueryPushdown);
|
|
||||||
READ_BOOL_FIELD(requiresMasterEvaluation);
|
|
||||||
READ_BOOL_FIELD(deferredPruning);
|
|
||||||
READ_NODE_FIELD(partitionKeyValue);
|
|
||||||
READ_NODE_FIELD(localPlannedStatements);
|
|
||||||
READ_BOOL_FIELD(parametersInJobQueryResolved);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadJob(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS_NO_FIELDS(Job);
|
|
||||||
|
|
||||||
readJobInfo(local_node);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadDistributedPlan(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(DistributedPlan);
|
|
||||||
|
|
||||||
READ_UINT64_FIELD(planId);
|
|
||||||
READ_ENUM_FIELD(modLevel, RowModifyLevel);
|
|
||||||
READ_BOOL_FIELD(hasReturning);
|
|
||||||
READ_BOOL_FIELD(routerExecutable);
|
|
||||||
|
|
||||||
READ_NODE_FIELD(workerJob);
|
|
||||||
READ_NODE_FIELD(masterQuery);
|
|
||||||
READ_UINT64_FIELD(queryId);
|
|
||||||
READ_NODE_FIELD(relationIdList);
|
|
||||||
READ_OID_FIELD(targetRelationId);
|
|
||||||
READ_NODE_FIELD(insertSelectQuery);
|
|
||||||
READ_STRING_FIELD(intermediateResultIdPrefix);
|
|
||||||
|
|
||||||
READ_NODE_FIELD(subPlanList);
|
|
||||||
READ_NODE_FIELD(usedSubPlanNodeList);
|
|
||||||
READ_BOOL_FIELD(fastPathRouterPlan);
|
|
||||||
|
|
||||||
READ_NODE_FIELD(planningError);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadDistributedSubPlan(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(DistributedSubPlan);
|
|
||||||
|
|
||||||
READ_UINT_FIELD(subPlanId);
|
|
||||||
READ_NODE_FIELD(plan);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadUsedDistributedSubPlan(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(UsedDistributedSubPlan);
|
|
||||||
|
|
||||||
READ_STRING_FIELD(subPlanId);
|
|
||||||
READ_INT_FIELD(locationMask);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadShardInterval(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(ShardInterval);
|
|
||||||
|
|
||||||
READ_OID_FIELD(relationId);
|
|
||||||
READ_CHAR_FIELD(storageType);
|
|
||||||
READ_OID_FIELD(valueTypeId);
|
|
||||||
READ_INT_FIELD(valueTypeLen);
|
|
||||||
READ_BOOL_FIELD(valueByVal);
|
|
||||||
READ_BOOL_FIELD(minValueExists);
|
|
||||||
READ_BOOL_FIELD(maxValueExists);
|
|
||||||
|
|
||||||
token = pg_strtok(&length); /* skip :minValue */
|
|
||||||
if (!local_node->minValueExists)
|
|
||||||
token = pg_strtok(&length); /* skip "<>" */
|
|
||||||
else
|
|
||||||
local_node->minValue = readDatum(local_node->valueByVal);
|
|
||||||
|
|
||||||
token = pg_strtok(&length); /* skip :maxValue */
|
|
||||||
if (!local_node->minValueExists)
|
|
||||||
token = pg_strtok(&length); /* skip "<>" */
|
|
||||||
else
|
|
||||||
local_node->maxValue = readDatum(local_node->valueByVal);
|
|
||||||
|
|
||||||
READ_UINT64_FIELD(shardId);
|
|
||||||
READ_INT_FIELD(shardIndex);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadMapMergeJob(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
|
|
||||||
READ_LOCALS(MapMergeJob);
|
|
||||||
|
|
||||||
readJobInfo(&local_node->job);
|
|
||||||
|
|
||||||
READ_NODE_FIELD(reduceQuery);
|
|
||||||
READ_ENUM_FIELD(partitionType, PartitionType);
|
|
||||||
READ_NODE_FIELD(partitionColumn);
|
|
||||||
READ_UINT_FIELD(partitionCount);
|
|
||||||
READ_INT_FIELD(sortedShardIntervalArrayLength);
|
|
||||||
|
|
||||||
int arrayLength = local_node->sortedShardIntervalArrayLength;
|
|
||||||
|
|
||||||
/* now build & read sortedShardIntervalArray */
|
|
||||||
local_node->sortedShardIntervalArray =
|
|
||||||
(ShardInterval**) palloc(arrayLength * sizeof(ShardInterval *));
|
|
||||||
|
|
||||||
for (int i = 0; i < arrayLength; ++i)
|
|
||||||
{
|
|
||||||
/* can't use READ_NODE_FIELD, no field names */
|
|
||||||
local_node->sortedShardIntervalArray[i] = nodeRead(NULL, 0);
|
|
||||||
}
|
|
||||||
|
|
||||||
READ_NODE_FIELD(mapTaskList);
|
|
||||||
READ_NODE_FIELD(mergeTaskList);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadShardPlacement(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(ShardPlacement);
|
|
||||||
|
|
||||||
READ_UINT64_FIELD(placementId);
|
|
||||||
READ_UINT64_FIELD(shardId);
|
|
||||||
READ_UINT64_FIELD(shardLength);
|
|
||||||
READ_ENUM_FIELD(shardState, ShardState);
|
|
||||||
READ_INT_FIELD(groupId);
|
|
||||||
READ_STRING_FIELD(nodeName);
|
|
||||||
READ_UINT_FIELD(nodePort);
|
|
||||||
READ_UINT_FIELD(nodeId);
|
|
||||||
/* so we can deal with 0 */
|
|
||||||
READ_INT_FIELD(partitionMethod);
|
|
||||||
READ_UINT_FIELD(colocationGroupId);
|
|
||||||
READ_UINT_FIELD(representativeValue);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadGroupShardPlacement(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(GroupShardPlacement);
|
|
||||||
|
|
||||||
READ_UINT64_FIELD(placementId);
|
|
||||||
READ_UINT64_FIELD(shardId);
|
|
||||||
READ_UINT64_FIELD(shardLength);
|
|
||||||
READ_ENUM_FIELD(shardState, ShardState);
|
|
||||||
READ_INT_FIELD(groupId);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadRelationShard(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(RelationShard);
|
|
||||||
|
|
||||||
READ_OID_FIELD(relationId);
|
|
||||||
READ_UINT64_FIELD(shardId);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadRelationRowLock(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(RelationRowLock);
|
|
||||||
|
|
||||||
READ_OID_FIELD(relationId);
|
|
||||||
READ_ENUM_FIELD(rowLockStrength, LockClauseStrength);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadTask(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(Task);
|
|
||||||
|
|
||||||
READ_ENUM_FIELD(taskType, TaskType);
|
|
||||||
READ_UINT64_FIELD(jobId);
|
|
||||||
READ_UINT_FIELD(taskId);
|
|
||||||
READ_NODE_FIELD(queryForLocalExecution);
|
|
||||||
READ_STRING_FIELD(queryStringLazy);
|
|
||||||
READ_OID_FIELD(anchorDistributedTableId);
|
|
||||||
READ_UINT64_FIELD(anchorShardId);
|
|
||||||
READ_NODE_FIELD(taskPlacementList);
|
|
||||||
READ_NODE_FIELD(dependentTaskList);
|
|
||||||
READ_UINT_FIELD(partitionId);
|
|
||||||
READ_UINT_FIELD(upstreamTaskId);
|
|
||||||
READ_NODE_FIELD(shardInterval);
|
|
||||||
READ_BOOL_FIELD(assignmentConstrained);
|
|
||||||
READ_NODE_FIELD(taskExecution);
|
|
||||||
READ_CHAR_FIELD(replicationModel);
|
|
||||||
READ_BOOL_FIELD(modifyWithSubquery);
|
|
||||||
READ_NODE_FIELD(relationShardList);
|
|
||||||
READ_NODE_FIELD(relationRowLockList);
|
|
||||||
READ_NODE_FIELD(rowValuesLists);
|
|
||||||
READ_BOOL_FIELD(partiallyLocalOrRemote);
|
|
||||||
READ_BOOL_FIELD(parametersInQueryStringResolved);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadLocalPlannedStatement(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(LocalPlannedStatement);
|
|
||||||
|
|
||||||
READ_UINT64_FIELD(shardId);
|
|
||||||
READ_UINT_FIELD(localGroupId);
|
|
||||||
READ_NODE_FIELD(localPlan);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadTaskExecution(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
ereport(ERROR, (errmsg("unexpected read request for TaskExecution node")));
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadDeferredErrorMessage(READFUNC_ARGS)
|
|
||||||
{
|
|
||||||
READ_LOCALS(DeferredErrorMessage);
|
|
||||||
|
|
||||||
READ_INT_FIELD(code);
|
|
||||||
READ_STRING_FIELD(message);
|
|
||||||
READ_STRING_FIELD(detail);
|
|
||||||
READ_STRING_FIELD(hint);
|
|
||||||
READ_STRING_FIELD(filename);
|
|
||||||
READ_INT_FIELD(linenumber);
|
|
||||||
READ_STRING_FIELD(functionname);
|
|
||||||
|
|
||||||
READ_DONE();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
READFUNC_RET
|
|
||||||
ReadUnsupportedCitusNode(READFUNC_ARGS)
|
ReadUnsupportedCitusNode(READFUNC_ARGS)
|
||||||
{
|
{
|
||||||
ereport(ERROR, (errmsg("not implemented")));
|
ereport(ERROR, (errmsg("not implemented")));
|
||||||
|
|
|
||||||
|
|
@ -29,35 +29,12 @@ extern CitusRTEKind GetRangeTblKind(RangeTblEntry *rte);
|
||||||
|
|
||||||
extern void RegisterNodes(void);
|
extern void RegisterNodes(void);
|
||||||
|
|
||||||
/*
|
|
||||||
* Define read functions for citus nodes in a way they're usable across
|
|
||||||
* several major versions. That requires some macro-uglyness as 9.6+ is quite
|
|
||||||
* different from before.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#define READFUNC_ARGS struct ExtensibleNode *node
|
#define READFUNC_ARGS struct ExtensibleNode *node
|
||||||
#define READFUNC_RET void
|
|
||||||
|
|
||||||
#define OUTFUNC_ARGS StringInfo str, const struct ExtensibleNode *raw_node
|
#define OUTFUNC_ARGS StringInfo str, const struct ExtensibleNode *raw_node
|
||||||
#define COPYFUNC_ARGS struct ExtensibleNode *target_node, const struct \
|
#define COPYFUNC_ARGS struct ExtensibleNode *target_node, const struct \
|
||||||
ExtensibleNode *source_node
|
ExtensibleNode *source_node
|
||||||
|
|
||||||
extern READFUNC_RET ReadJob(READFUNC_ARGS);
|
extern void ReadUnsupportedCitusNode(READFUNC_ARGS);
|
||||||
extern READFUNC_RET ReadDistributedPlan(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadDistributedSubPlan(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadUsedDistributedSubPlan(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadShardInterval(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadMapMergeJob(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadShardPlacement(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadRelationShard(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadRelationRowLock(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadTask(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadLocalPlannedStatement(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadTaskExecution(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadDeferredErrorMessage(READFUNC_ARGS);
|
|
||||||
extern READFUNC_RET ReadGroupShardPlacement(READFUNC_ARGS);
|
|
||||||
|
|
||||||
extern READFUNC_RET ReadUnsupportedCitusNode(READFUNC_ARGS);
|
|
||||||
|
|
||||||
extern void OutJob(OUTFUNC_ARGS);
|
extern void OutJob(OUTFUNC_ARGS);
|
||||||
extern void OutDistributedPlan(OUTFUNC_ARGS);
|
extern void OutDistributedPlan(OUTFUNC_ARGS);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue