mirror of https://github.com/citusdata/citus.git
Use a fixed application_name while connecting to remote nodes
Citus heavily relies on application_name, see `IsCitusInitiatedRemoteBackend()`. But if the user set the application name, such as export PGAPPNAME=test_name, Citus uses that name while connecting to the remote node. With this commit, we ensure that Citus always connects with the "citus" user name to the remote nodes.pull/5657/head
parent
9bc0fd9479
commit
b26eeaecd3
|
@ -72,8 +72,8 @@ InitConnParams()
|
||||||
/*
|
/*
|
||||||
* ResetConnParams frees all strings in the keywords and parameters arrays,
|
* ResetConnParams frees all strings in the keywords and parameters arrays,
|
||||||
* sets their elements to null, and resets the ConnParamsSize to zero before
|
* sets their elements to null, and resets the ConnParamsSize to zero before
|
||||||
* adding back any hardcoded global connection settings (at present, only the
|
* adding back any hardcoded global connection settings (at present, there
|
||||||
* fallback_application_name of 'citus').
|
* are no).
|
||||||
*/
|
*/
|
||||||
void
|
void
|
||||||
ResetConnParams()
|
ResetConnParams()
|
||||||
|
@ -89,8 +89,6 @@ ResetConnParams()
|
||||||
ConnParams.size = 0;
|
ConnParams.size = 0;
|
||||||
|
|
||||||
InvalidateConnParamsHashEntries();
|
InvalidateConnParamsHashEntries();
|
||||||
|
|
||||||
AddConnParam("fallback_application_name", CITUS_APPLICATION_NAME);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -253,14 +251,16 @@ GetConnParams(ConnectionHashKey *key, char ***keywords, char ***values,
|
||||||
"port",
|
"port",
|
||||||
"dbname",
|
"dbname",
|
||||||
"user",
|
"user",
|
||||||
"client_encoding"
|
"client_encoding",
|
||||||
|
"application_name"
|
||||||
};
|
};
|
||||||
const char *runtimeValues[] = {
|
const char *runtimeValues[] = {
|
||||||
key->hostname,
|
key->hostname,
|
||||||
nodePortString,
|
nodePortString,
|
||||||
key->database,
|
key->database,
|
||||||
key->user,
|
key->user,
|
||||||
GetDatabaseEncodingName()
|
GetDatabaseEncodingName(),
|
||||||
|
CITUS_APPLICATION_NAME
|
||||||
};
|
};
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|
Loading…
Reference in New Issue