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

Style fix

preventConflictingFlags
Onder Kalaci 2020-04-07 14:40:24 +02:00
parent 9311b4b953
commit ab345ab4fb
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/commands/utility_hook.c
View File

@ -53,6 +53,7 @@
#include "distributed/multi_explain.h" #include "distributed/multi_explain.h"
#include "distributed/multi_physical_planner.h" #include "distributed/multi_physical_planner.h"
#include "distributed/resource_lock.h" #include "distributed/resource_lock.h"
#include "distributed/shared_connection_stats.h"
#include "distributed/transmit.h" #include "distributed/transmit.h"
#include "distributed/version_compat.h" #include "distributed/version_compat.h"
#include "distributed/worker_transaction.h" #include "distributed/worker_transaction.h"
@ -63,7 +64,6 @@
#include "utils/builtins.h" #include "utils/builtins.h"
#include "utils/lsyscache.h" #include "utils/lsyscache.h"
#include "utils/syscache.h" #include "utils/syscache.h"
#include "distributed/shared_connection_stats.h"
bool EnableDDLPropagation = true; /* ddl propagation is enabled */ bool EnableDDLPropagation = true; /* ddl propagation is enabled */
PropSetCmdBehavior PropagateSetCommands = PROPSETCMD_NONE; /* SET prop off */ PropSetCmdBehavior PropagateSetCommands = PROPSETCMD_NONE; /* SET prop off */

3
src/backend/distributed/connection/shared_connection_stats.c
View File

@ -209,7 +209,8 @@ RemoveInactiveNodesFromSharedConnections(void)
while ((connectionEntry = (SharedConnStatsHashEntry *) hash_seq_search(&status)) != 0) while ((connectionEntry = (SharedConnStatsHashEntry *) hash_seq_search(&status)) != 0)
{ {
SharedConnStatsHashKey connectionKey = connectionEntry->key; SharedConnStatsHashKey connectionKey = connectionEntry->key;
WorkerNode *workerNode = FindWorkerNode(connectionKey.hostname, connectionKey.port); WorkerNode *workerNode = FindWorkerNode(connectionKey.hostname,
connectionKey.port);
if (workerNode == NULL || !workerNode->isActive) if (workerNode == NULL || !workerNode->isActive)
{ {