external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

export LookupShardTransferMode

pull/4136/head
Nils Dijk 2020-09-02 15:23:00 +02:00
parent 6e4862c57f
commit bbf42063a7
No known key found for this signature in database
GPG Key ID: CA1177EF9434F241
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/backend/distributed/operations/repair_shards.c
View File

@ -44,7 +44,6 @@
#include "utils/palloc.h" #include "utils/palloc.h"
/* local function forward declarations */ /* local function forward declarations */
static char LookupShardTransferMode(Oid shardReplicationModeOid);
static void ErrorIfTableCannotBeReplicated(Oid relationId); static void ErrorIfTableCannotBeReplicated(Oid relationId);
static void RepairShardPlacement(int64 shardId, const char *sourceNodeName, static void RepairShardPlacement(int64 shardId, const char *sourceNodeName,
int32 sourceNodePort, const char *targetNodeName, int32 sourceNodePort, const char *targetNodeName,
@ -226,7 +225,7 @@ ErrorIfTableCannotBeReplicated(Oid relationId)
* LookupShardTransferMode maps the oids of citus.shard_transfer_mode enum * LookupShardTransferMode maps the oids of citus.shard_transfer_mode enum
* values to a char. * values to a char.
*/ */
static char char
LookupShardTransferMode(Oid shardReplicationModeOid) LookupShardTransferMode(Oid shardReplicationModeOid)
{ {
char shardReplicationMode = 0; char shardReplicationMode = 0;

1
src/include/distributed/coordinator_protocol.h
View File

@ -176,5 +176,6 @@ extern ShardPlacement * SearchShardPlacementInList(List *shardPlacementList,
extern ShardPlacement * SearchShardPlacementInListOrError(List *shardPlacementList, extern ShardPlacement * SearchShardPlacementInListOrError(List *shardPlacementList,
const char *nodeName, const char *nodeName,
uint32 nodePort); uint32 nodePort);
extern char LookupShardTransferMode(Oid shardReplicationModeOid);
#endif /* COORDINATOR_PROTOCOL_H */ #endif /* COORDINATOR_PROTOCOL_H */