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

style improvemen

push_tail
Onder Kalaci 2021-11-25 11:33:02 +01:00
parent 698dae9ac8
commit 2e1b066463
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/distributed/connection/connection_management.c
View File

@ -57,7 +57,7 @@ static void StartConnectionEstablishment(MultiConnection *connectionn,
ConnectionHashKey *key); ConnectionHashKey *key);
static MultiConnection * FindAvailableConnection(dlist_head *connections, uint32 flags); static MultiConnection * FindAvailableConnection(dlist_head *connections, uint32 flags);
#ifdef USE_ASSERT_CHECKING #ifdef USE_ASSERT_CHECKING
static void EnsureSingleMultipleMetadataConnectionExists(dlist_head *connections); static void EnsureSingleMetadataConnectionExists(dlist_head *connections);
#endif #endif
static void FreeConnParamsHashEntryFields(ConnParamsHashEntry *entry); static void FreeConnParamsHashEntryFields(ConnParamsHashEntry *entry);
static void AfterXactHostConnectionHandling(ConnectionHashEntry *entry, bool isCommit); static void AfterXactHostConnectionHandling(ConnectionHashEntry *entry, bool isCommit);
@ -483,7 +483,7 @@ FindAvailableConnection(dlist_head *connections, uint32 flags)
* checks. * checks.
*/ */
#ifdef USE_ASSERT_CHECKING #ifdef USE_ASSERT_CHECKING
EnsureSingleMultipleMetadataConnectionExists(connections); EnsureSingleMetadataConnectionExists(connections);
#endif #endif
/* /*
@ -516,7 +516,7 @@ FindAvailableConnection(dlist_head *connections, uint32 flags)
metadataConnection->useForMetadataOperations = true; metadataConnection->useForMetadataOperations = true;
#ifdef USE_ASSERT_CHECKING #ifdef USE_ASSERT_CHECKING
EnsureSingleMultipleMetadataConnectionExists(connections); EnsureSingleMetadataConnectionExists(connections);
#endif #endif
return metadataConnection; return metadataConnection;
@ -529,11 +529,11 @@ FindAvailableConnection(dlist_head *connections, uint32 flags)
#ifdef USE_ASSERT_CHECKING #ifdef USE_ASSERT_CHECKING
/* /*
* EnsureSingleMultipleMetadataConnectionExists throws an error if the * EnsureSingleMetadataConnectionExists throws an error if the
* input connection dlist contains more than one metadata connections. * input connection dlist contains more than one metadata connections.
*/ */
static void static void
EnsureSingleMultipleMetadataConnectionExists(dlist_head *connections) EnsureSingleMetadataConnectionExists(dlist_head *connections)
{ {
bool foundMetadataConnection = false; bool foundMetadataConnection = false;
dlist_iter iter; dlist_iter iter;

2
src/include/distributed/connection_management.h
View File

@ -63,7 +63,7 @@ enum MultiConnectionMode
* *
* With this flag, we guarantee that there is a single metadata connection. * With this flag, we guarantee that there is a single metadata connection.
* But note that this connection can be used for any other operation. * But note that this connection can be used for any other operation.
* In other words, this connection is not only reserved for metadata * In other words, this connection is not exclusively reserved for metadata
* operations. * operations.
*/ */
REQUIRE_METADATA_CONNECTION = 1 << 5, REQUIRE_METADATA_CONNECTION = 1 << 5,