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

valgrind tests fix

pull/2155/head
mehmet furkan şahin 2018-05-08 18:20:05 +03:00
parent a63e628120
commit d35f2725bf
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -818,8 +818,7 @@ DefaultCitusNoticeProcessor(void *arg, const char *message)
MultiConnection *connection = (MultiConnection *) arg;
char *nodeName = connection->hostname;
uint32 nodePort = connection->port;
char *chompedMessage = pchomp(message);
char *trimmedMessage = TrimLogLevel(chompedMessage);
char *trimmedMessage = TrimLogLevel(message);
char *level = strtok((char *) message, ":");
ereport(CitusNoticeLogLevel, (errmsg("%s", trimmedMessage),
@ -829,7 +828,7 @@ DefaultCitusNoticeProcessor(void *arg, const char *message)
/*
* TrimLogLevel makes a copy of the string with the leading log level
* TrimLogLevel returns a copy of the string with the leading log level
* and spaces removed such as
* From:
* INFO: "normal2_102070": scanned 0 of 0 pages...
@ -839,17 +838,18 @@ DefaultCitusNoticeProcessor(void *arg, const char *message)
char *
TrimLogLevel(const char *message)
{
char *chompedMessage = pchomp(message);
size_t n;
n = 0;
while (n < strlen(message) && message[n] != ':')
while (n < strlen(chompedMessage) && chompedMessage[n] != ':')
{
n++;
}
do {
n++;
} while (n < strlen(message) && message[n] == ' ');
} while (n < strlen(chompedMessage) && chompedMessage[n] == ' ');
return pstrdup(message + n);
return chompedMessage + n;
}