ipcCommand = create_command_object(data_len);
ipcCommand->sourceIPCSocket = sock;
ipcCommand->commandSource = COMMAND_SOURCE_IPC;
+ ipcCommand->sourceWdNode = g_cluster.localNode;
ipcCommand->sourcePacket.type = type;
ipcCommand->sourcePacket.len = data_len;
gettimeofday(&ipcCommand->commandTime, NULL);
{
MemoryContext oldCxt;
ereport(DEBUG1,
- (errmsg("proceeding with the failover command [%s] request from pgpool-II node \"%s\"",
+ (errmsg("proceeding with the failover command [%s] request from %s",
func_name,
- ipcCommand->sourceWdNode->nodeName),
+ ipcCommand->commandSource == COMMAND_SOURCE_IPC?
+ "local pgpool-II":ipcCommand->sourceWdNode->nodeName),
errdetail("no similar failover is in progress")));
/*
* okay now ask all nodes to start failover