db/pgbackrest
1
0
Fork 0
mirror of https://github.com/pgbackrest/pgbackrest.git synced 2025-07-13 01:00:23 +02:00
Code Issues Releases Activity

Add process id to ProtocolParallelJob.

Browse Source 
This exposes the process that performed to job to the caller for logging purposes.
This commit is contained in:
David Steele
2019-04-09 11:01:35 -04:00
parent 4ace7edbd9
commit 8c202c77da
5 changed files with 42 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/protocol/parallelJob.c
View File

@ -18,6 +18,7 @@ struct ProtocolParallelJob
const Variant *key; // Unique key used to identify the job
const ProtocolCommand *command; // Command to be executed
unsigned int processId; // Process that executed this job
int code; // Non-zero result indicates an error
String *message; // Message if there was a error
const Variant *result; // Result if job was successful
@ -149,6 +150,37 @@ protocolParallelJobKey(const ProtocolParallelJob *this)
FUNCTION_TEST_RETURN(this->key);
}
/***********************************************************************************************************************************
Get/set process id
***********************************************************************************************************************************/
unsigned int
protocolParallelJobProcessId(const ProtocolParallelJob *this)
{
FUNCTION_TEST_BEGIN();
FUNCTION_TEST_PARAM(PROTOCOL_PARALLEL_JOB, this);
FUNCTION_TEST_END();
ASSERT(this != NULL);
FUNCTION_TEST_RETURN(this->processId);
}
void
protocolParallelJobProcessIdSet(ProtocolParallelJob *this, unsigned int processId)
{
FUNCTION_LOG_BEGIN(logLevelTrace);
FUNCTION_LOG_PARAM(PROTOCOL_PARALLEL_JOB, this);
FUNCTION_LOG_PARAM(UINT, processId);
FUNCTION_LOG_END();
ASSERT(this != NULL);
ASSERT(processId > 0);
this ->processId = processId;
FUNCTION_LOG_RETURN_VOID();
}
/***********************************************************************************************************************************
Get/set job result
***********************************************************************************************************************************/