Lines Matching refs:clusterCommand
502 …tandby(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
503 …voting(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
504 …inator(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
505 …orCord(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
506 …lizing(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
507 …oining(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
508 …oading(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
509 …achine(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
510 …_error(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
511 …lation(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand);
4397 WDCommandData *clusterCommand = lfirst(lc); in service_internal_command() local
4399 if (clusterCommand->commandStatus != COMMAND_IN_PROGRESS) in service_internal_command()
4402 finishedCommands = lappend(finishedCommands, clusterCommand); in service_internal_command()
4408 WDCommandNodeResult *nodeResult = &clusterCommand->nodeResults[i]; in service_internal_command()
4414 if (send_message_to_node(nodeResult->wdNode, &clusterCommand->commandPacket) == true) in service_internal_command()
4417 clusterCommand->commandSendToCount++; in service_internal_command()
4426 WDCommandData *clusterCommand = lfirst(lc); in service_internal_command() local
4428 g_cluster.clusterCommands = list_delete_ptr(g_cluster.clusterCommands, clusterCommand); in service_internal_command()
4429 MemoryContextDelete(clusterCommand->memoryContext); in service_internal_command()
4502 WDCommandData *clusterCommand = get_wd_cluster_command_from_reply(pkt); in watchdog_internal_command_packet_processor() local
4504 if (clusterCommand == NULL || clusterCommand->commandStatus != COMMAND_IN_PROGRESS) in watchdog_internal_command_packet_processor()
4519 WDCommandNodeResult *nodeRes = &clusterCommand->nodeResults[i]; in watchdog_internal_command_packet_processor()
4537 clusterCommand->commandReplyFromCount++; in watchdog_internal_command_packet_processor()
4539 if (clusterCommand->commandReplyFromCount >= clusterCommand->commandSendToCount) in watchdog_internal_command_packet_processor()
4545 clusterCommand->commandStatus = COMMAND_FINISHED_NODE_REJECTED; in watchdog_internal_command_packet_processor()
4551 clusterCommand->commandStatus = COMMAND_FINISHED_ALL_REPLIED; in watchdog_internal_command_packet_processor()
4553 watchdog_state_machine(WD_EVENT_COMMAND_FINISHED, wdNode, pkt, clusterCommand); in watchdog_internal_command_packet_processor()
4554 g_cluster.clusterCommands = list_delete_ptr(g_cluster.clusterCommands, clusterCommand); in watchdog_internal_command_packet_processor()
4555 MemoryContextDelete(clusterCommand->memoryContext); in watchdog_internal_command_packet_processor()
4562 clusterCommand->commandStatus = COMMAND_FINISHED_NODE_REJECTED; in watchdog_internal_command_packet_processor()
4563 watchdog_state_machine(WD_EVENT_COMMAND_FINISHED, wdNode, pkt, clusterCommand); in watchdog_internal_command_packet_processor()
4564 g_cluster.clusterCommands = list_delete_ptr(g_cluster.clusterCommands, clusterCommand); in watchdog_internal_command_packet_processor()
4565 MemoryContextDelete(clusterCommand->memoryContext); in watchdog_internal_command_packet_processor()
4586 WDCommandData *clusterCommand = lfirst(lc); in check_for_current_command_timeout() local
4588 if (clusterCommand->commandStatus != COMMAND_IN_PROGRESS) in check_for_current_command_timeout()
4591 finishedCommands = lappend(finishedCommands, clusterCommand); in check_for_current_command_timeout()
4594 if (WD_TIME_DIFF_SEC(currTime, clusterCommand->commandTime) >= clusterCommand->commandTimeoutSecs) in check_for_current_command_timeout()
4596 clusterCommand->commandStatus = COMMAND_FINISHED_TIMEOUT; in check_for_current_command_timeout()
4597 watchdog_state_machine(WD_EVENT_COMMAND_FINISHED, NULL, NULL, clusterCommand); in check_for_current_command_timeout()
4598 finishedCommands = lappend(finishedCommands, clusterCommand); in check_for_current_command_timeout()
4604 WDCommandData *clusterCommand = lfirst(lc); in check_for_current_command_timeout() local
4606 g_cluster.clusterCommands = list_delete_ptr(g_cluster.clusterCommands, clusterCommand); in check_for_current_command_timeout()
4607 MemoryContextDelete(clusterCommand->memoryContext); in check_for_current_command_timeout()
4623 WDCommandData *clusterCommand; in issue_watchdog_internal_command() local
4626 clusterCommand = create_command_object(0); in issue_watchdog_internal_command()
4628 clusterCommand->commandSource = COMMAND_SOURCE_LOCAL; in issue_watchdog_internal_command()
4629 clusterCommand->sourceWdNode = g_cluster.localNode; in issue_watchdog_internal_command()
4630 gettimeofday(&clusterCommand->commandTime, NULL); in issue_watchdog_internal_command()
4632 clusterCommand->commandTimeoutSecs = timeout_sec; in issue_watchdog_internal_command()
4633 clusterCommand->commandPacket.type = pkt->type; in issue_watchdog_internal_command()
4634 clusterCommand->commandPacket.command_id = pkt->command_id; in issue_watchdog_internal_command()
4635 clusterCommand->commandPacket.len = 0; in issue_watchdog_internal_command()
4636 clusterCommand->commandPacket.data = NULL; in issue_watchdog_internal_command()
4638 clusterCommand->sendToNode = wdNode; in issue_watchdog_internal_command()
4639 clusterCommand->commandSendToCount = 0; in issue_watchdog_internal_command()
4640 clusterCommand->commandReplyFromCount = 0; in issue_watchdog_internal_command()
4641 clusterCommand->commandStatus = COMMAND_IN_PROGRESS; in issue_watchdog_internal_command()
4643 allocate_resultNodes_in_command(clusterCommand); in issue_watchdog_internal_command()
4649 WDCommandNodeResult *nodeResult = &clusterCommand->nodeResults[i]; in issue_watchdog_internal_command()
4674 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
4685 WDCommandNodeResult *nodeRes = &clusterCommand->nodeResults[i]; in issue_watchdog_internal_command()
4696 MemoryContextDelete(clusterCommand->memoryContext); in issue_watchdog_internal_command()
4708 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
4713 clusterCommand->commandPacket.data = MemoryContextAlloc(clusterCommand->memoryContext, pkt->len); in issue_watchdog_internal_command()
4714 memcpy(clusterCommand->commandPacket.data, pkt->data, pkt->len); in issue_watchdog_internal_command()
4715 clusterCommand->commandPacket.len = pkt->len; in issue_watchdog_internal_command()
4721 g_cluster.clusterCommands = lappend(g_cluster.clusterCommands, clusterCommand); in issue_watchdog_internal_command()
4724 return clusterCommand->commandSendToCount; in issue_watchdog_internal_command()
5077 …machine(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine() argument
5221 watchdog_state_machine_loading(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5224 watchdog_state_machine_joining(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5227 watchdog_state_machine_initializing(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5230 watchdog_state_machine_coordinator(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5233 watchdog_state_machine_voting(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5236 watchdog_state_machine_standForCord(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5239 watchdog_state_machine_standby(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5243 watchdog_state_machine_nw_error(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5246 watchdog_state_machine_nw_isolation(event, wdNode, pkt, clusterCommand); in watchdog_state_machine()
5266 …loading(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_loading() argument
5374 …joining(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_joining() argument
5391 if (clusterCommand->commandPacket.type == WD_REQ_INFO_MESSAGE) in watchdog_state_machine_joining()
5451 …alizing(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_initializing() argument
5533 …ForCord(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_standForCord() argument
5545 if (clusterCommand->commandPacket.type == WD_STAND_FOR_COORDINATOR_MESSAGE) in watchdog_state_machine_standForCord()
5547 if (clusterCommand->commandStatus == COMMAND_FINISHED_ALL_REPLIED || in watchdog_state_machine_standForCord()
5548 clusterCommand->commandStatus == COMMAND_FINISHED_TIMEOUT) in watchdog_state_machine_standForCord()
5658 …dinator(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_coordinator() argument
5685 if (clusterCommand->commandPacket.type == WD_DECLARE_COORDINATOR_MESSAGE) in watchdog_state_machine_coordinator()
5687 if (clusterCommand->commandStatus == COMMAND_FINISHED_ALL_REPLIED || in watchdog_state_machine_coordinator()
5688 clusterCommand->commandStatus == COMMAND_FINISHED_TIMEOUT) in watchdog_state_machine_coordinator()
5694 clusterCommand->commandStatus == COMMAND_FINISHED_ALL_REPLIED ? in watchdog_state_machine_coordinator()
5698 clusterCommand->commandSendToCount, in watchdog_state_machine_coordinator()
5699 clusterCommand->commandReplyFromCount in watchdog_state_machine_coordinator()
5737 else if (clusterCommand->commandPacket.type == WD_IAM_COORDINATOR_MESSAGE) in watchdog_state_machine_coordinator()
5739 update_missed_beacon_count(clusterCommand,false); in watchdog_state_machine_coordinator()
5741 if (clusterCommand->commandStatus == COMMAND_FINISHED_ALL_REPLIED) in watchdog_state_machine_coordinator()
5746 clusterCommand->commandSendToCount, in watchdog_state_machine_coordinator()
5747 clusterCommand->commandReplyFromCount in watchdog_state_machine_coordinator()
5750 else if (clusterCommand->commandStatus == COMMAND_FINISHED_TIMEOUT) in watchdog_state_machine_coordinator()
5755 clusterCommand->commandSendToCount, in watchdog_state_machine_coordinator()
5756 clusterCommand->commandReplyFromCount in watchdog_state_machine_coordinator()
5759 else if (clusterCommand->commandStatus == COMMAND_FINISHED_NODE_REJECTED) in watchdog_state_machine_coordinator()
6063 …w_error(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_nw_error() argument
6132 …olation(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_nw_isolation() argument
6424 …_voting(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_voting() argument
6490 …standby(WD_EVENTS event, WatchdogNode * wdNode, WDPacketData * pkt, WDCommandData * clusterCommand) in watchdog_state_machine_standby() argument
6515 if (clusterCommand->commandPacket.type == WD_JOIN_COORDINATOR_MESSAGE) in watchdog_state_machine_standby()
6517 if (clusterCommand->commandStatus == COMMAND_FINISHED_ALL_REPLIED || in watchdog_state_machine_standby()
6518 clusterCommand->commandStatus == COMMAND_FINISHED_TIMEOUT) in watchdog_state_machine_standby()