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

Fix isolation tester

add_worker_query_again
Onder Kalaci 2022-02-16 18:34:02 +01:00
parent 8b04e37b73
commit bfd5ca0216
2 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -14,7 +14,6 @@
#include "distributed/citus_safe_lib.h" #include "distributed/citus_safe_lib.h"
#include "distributed/connection_management.h" #include "distributed/connection_management.h"
#include "distributed/metadata_cache.h" #include "distributed/metadata_cache.h"
#include "distributed/run_from_same_connection.h"
#include "distributed/worker_manager.h" #include "distributed/worker_manager.h"
#include "postmaster/postmaster.h" #include "postmaster/postmaster.h"
@ -235,11 +234,9 @@ GetConnParams(ConnectionHashKey *key, char ***keywords, char ***values,
char nodePortString[12] = ""; char nodePortString[12] = "";
StringInfo applicationName = makeStringInfo(); StringInfo applicationName = makeStringInfo();
appendStringInfo(applicationName, "%s%ld", CITUS_APPLICATION_NAME_PREFIX, appendStringInfo(applicationName, "%s%ld", CITUS_APPLICATION_NAME_PREFIX,
GetGlobalPID()); GetGlobalPID());
/* /*
* This function has three sections: * This function has three sections:
* - Initialize the keywords and values (to be copied later) of global parameters * - Initialize the keywords and values (to be copied later) of global parameters

7
src/backend/distributed/test/run_from_same_connection.c
View File

@ -119,10 +119,11 @@ start_session_level_connection_to_node(PG_FUNCTION_ARGS)
values[0] = nodeNameString; values[0] = nodeNameString;
keywords[1] = "port"; keywords[1] = "port";
char *portSTR = (char *) palloc(10);
pg_ultoa_n(nodePort, portSTR);
values[1] = portSTR; StringInfo str = makeStringInfo();
appendStringInfo(str, "%d", nodePort);
values[1] = str->data;
keywords[2] = "dbname"; keywords[2] = "dbname";
values[2] = (char *) CurrentDatabaseName(); values[2] = (char *) CurrentDatabaseName();