| /dports/databases/pgpool-II-43/pgpool-II-4.3.0/src/watchdog/ |
| H A D | watchdog.c | 2095 char *clusterCommand = NULL; in process_IPC_execute_cluster_command() local
2146 pfree(clusterCommand); in process_IPC_execute_cluster_command()
2152 if (clusterCommand) in process_IPC_execute_cluster_command()
2153 pfree(clusterCommand); in process_IPC_execute_cluster_command()
4071 char *clusterCommand = NULL; in wd_execute_cluster_command_processor() local
4196 pfree(clusterCommand); in wd_execute_cluster_command_processor()
4858 if (clusterCommand == NULL || clusterCommand->commandStatus != COMMAND_IN_PROGRESS) in watchdog_internal_command_packet_processor()
4893 if (clusterCommand->commandReplyFromCount >= clusterCommand->commandSendToCount) in watchdog_internal_command_packet_processor()
4948 if (WD_TIME_DIFF_SEC(currTime, clusterCommand->commandTime) >= clusterCommand->commandTimeoutSecs) in check_for_current_command_timeout()
4977 WDCommandData *clusterCommand; in issue_watchdog_internal_command() local
[all …]
|
| H A D | wd_internal_commands.c | 281 wd_execute_cluster_command(char* clusterCommand, List *argsList) in wd_execute_cluster_command() argument
286 char *func = get_wd_exec_cluster_command_json(clusterCommand, argsList, in wd_execute_cluster_command()
|
| H A D | wd_json_data.c | 807 get_wd_exec_cluster_command_json(char *clusterCommand, List *args_list, in get_wd_exec_cluster_command_json() argument
820 jw_put_string(jNode, "Command", clusterCommand); in get_wd_exec_cluster_command_json()
850 char **clusterCommand, List **args_list) in parse_wd_exec_cluster_command_json() argument
879 *clusterCommand = pstrdup(ptr); in parse_wd_exec_cluster_command_json()
|
| /dports/databases/pgpool-II-42/pgpool-II-4.2.3/src/watchdog/ |
| H A D | watchdog.c | 2048 char *clusterCommand = NULL; in process_IPC_execute_cluster_command() local
2089 pfree(clusterCommand); in process_IPC_execute_cluster_command()
2095 if (clusterCommand) in process_IPC_execute_cluster_command()
2096 pfree(clusterCommand); in process_IPC_execute_cluster_command()
4011 char *clusterCommand = NULL; in wd_execute_cluster_command_processor() local
4068 pfree(clusterCommand); in wd_execute_cluster_command_processor()
4702 if (clusterCommand == NULL || clusterCommand->commandStatus != COMMAND_IN_PROGRESS) in watchdog_internal_command_packet_processor()
4737 if (clusterCommand->commandReplyFromCount >= clusterCommand->commandSendToCount) in watchdog_internal_command_packet_processor()
4792 if (WD_TIME_DIFF_SEC(currTime, clusterCommand->commandTime) >= clusterCommand->commandTimeoutSecs) in check_for_current_command_timeout()
4821 WDCommandData *clusterCommand; in issue_watchdog_internal_command() local
[all …]
|
| H A D | wd_internal_commands.c | 279 wd_execute_cluster_command(char* clusterCommand, in wd_execute_cluster_command() argument
285 char *func = get_wd_exec_cluster_command_json(clusterCommand, nArgs, wdExecCommandArg, in wd_execute_cluster_command()
|
| H A D | wd_json_data.c | 807 get_wd_exec_cluster_command_json(char *clusterCommand, int nArgs, in get_wd_exec_cluster_command_json() argument
820 jw_put_string(jNode, "Command", clusterCommand); in get_wd_exec_cluster_command_json()
847 char **clusterCommand, in parse_wd_exec_cluster_command_json() argument
874 *clusterCommand = pstrdup(ptr); in parse_wd_exec_cluster_command_json()
|
| /dports/databases/pgpool-II-41/pgpool-II-4.1.10/src/watchdog/ |
| H A D | watchdog.c | 4545 if (clusterCommand == NULL || clusterCommand->commandStatus != COMMAND_IN_PROGRESS) in watchdog_internal_command_packet_processor()
4578 clusterCommand->commandReplyFromCount++; in watchdog_internal_command_packet_processor()
4580 if (clusterCommand->commandReplyFromCount >= clusterCommand->commandSendToCount) in watchdog_internal_command_packet_processor()
4635 if (WD_TIME_DIFF_SEC(currTime, clusterCommand->commandTime) >= clusterCommand->commandTimeoutSecs) in check_for_current_command_timeout()
4664 WDCommandData *clusterCommand; in issue_watchdog_internal_command() local
4676 clusterCommand->commandPacket.len = 0; in issue_watchdog_internal_command()
4679 clusterCommand->sendToNode = wdNode; in issue_watchdog_internal_command()
4680 clusterCommand->commandSendToCount = 0; in issue_watchdog_internal_command()
4715 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
4749 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
[all …]
|
| /dports/databases/pgpool-II-37/pgpool-II-3.7.22/src/watchdog/ |
| H A D | watchdog.c | 4313 if (clusterCommand == NULL || clusterCommand->commandStatus != COMMAND_IN_PROGRESS) in watchdog_internal_command_packet_processor()
4346 clusterCommand->commandReplyFromCount++; in watchdog_internal_command_packet_processor()
4348 if (clusterCommand->commandReplyFromCount >= clusterCommand->commandSendToCount) in watchdog_internal_command_packet_processor()
4401 if (WD_TIME_DIFF_SEC(currTime,clusterCommand->commandTime) >= clusterCommand->commandTimeoutSecs) in check_for_current_command_timeout()
4428 WDCommandData *clusterCommand; in issue_watchdog_internal_command() local
4440 clusterCommand->commandPacket.len = 0; in issue_watchdog_internal_command()
4443 clusterCommand->sendToNode = wdNode; in issue_watchdog_internal_command()
4444 clusterCommand->commandSendToCount = 0; in issue_watchdog_internal_command()
4478 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
4510 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
[all …]
|
| /dports/databases/pgpool-II-40/pgpool-II-4.0.17/src/watchdog/ |
| H A D | watchdog.c | 4504 if (clusterCommand == NULL || clusterCommand->commandStatus != COMMAND_IN_PROGRESS) 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()
4594 if (WD_TIME_DIFF_SEC(currTime, clusterCommand->commandTime) >= clusterCommand->commandTimeoutSecs) in check_for_current_command_timeout()
4623 WDCommandData *clusterCommand; in issue_watchdog_internal_command() local
4635 clusterCommand->commandPacket.len = 0; in issue_watchdog_internal_command()
4638 clusterCommand->sendToNode = wdNode; in issue_watchdog_internal_command()
4639 clusterCommand->commandSendToCount = 0; in issue_watchdog_internal_command()
4674 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
4708 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
[all …]
|
| /dports/databases/pgpool-II-36/pgpool-II-3.6.28/src/watchdog/ |
| H A D | watchdog.c | 4418 if (clusterCommand == NULL || clusterCommand->commandStatus != COMMAND_IN_PROGRESS) in watchdog_internal_command_packet_processor()
4452 clusterCommand->commandReplyFromCount++; in watchdog_internal_command_packet_processor()
4454 if (clusterCommand->commandReplyFromCount >= clusterCommand->commandSendToCount) in watchdog_internal_command_packet_processor()
4507 if (WD_TIME_DIFF_SEC(currTime,clusterCommand->commandTime) >= clusterCommand->commandTimeoutSecs) in check_for_current_command_timeout()
4534 WDCommandData *clusterCommand; in issue_watchdog_internal_command() local
4546 clusterCommand->commandPacket.len = 0; in issue_watchdog_internal_command()
4549 clusterCommand->sendToNode = wdNode; in issue_watchdog_internal_command()
4550 clusterCommand->commandSendToCount = 0; in issue_watchdog_internal_command()
4584 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
4616 clusterCommand->commandSendToCount++; in issue_watchdog_internal_command()
[all …]
|
| /dports/databases/pgpool-II-42/pgpool-II-4.2.3/src/include/watchdog/ |
| H A D | wd_json_data.h | 74 char **clusterCommand,
78 get_wd_exec_cluster_command_json(char *clusterCommand,int nArgs,
|
| H A D | wd_internal_commands.h | 40 extern WdCommandResult wd_execute_cluster_command(char* clusterCommand,
|
| /dports/databases/pgpool-II-43/pgpool-II-4.3.0/src/include/watchdog/ |
| H A D | wd_json_data.h | 75 char **clusterCommand, List **args_list);
78 get_wd_exec_cluster_command_json(char *clusterCommand,List *args_list,
|
| H A D | wd_internal_commands.h | 54 extern WdCommandResult wd_execute_cluster_command(char* clusterCommand,List *argsList);
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/ |
| H A D | cluster.c | 20 PreprocessClusterStmt(Node *node, const char *clusterCommand, in PreprocessClusterStmt() argument
|
| /dports/databases/redis-devel/redis-0e5b813/src/ |
| H A D | server.c | 567 {"forget",clusterCommand,3,
576 {"info",clusterCommand,2,
579 {"keyslot",clusterCommand,3,
582 {"meet",clusterCommand,-4,
585 {"myid",clusterCommand,2,
588 {"nodes",clusterCommand,2,
594 {"reset",clusterCommand,3,
600 {"setslot",clusterCommand,-4,
603 {"replicas",clusterCommand,3,
609 {"slots",clusterCommand,2,
[all …]
|
| H A D | server.h | 2956 void clusterCommand(client *c);
|
| /dports/biology/mothur/mothur-1.46.1/source/commands/ |
| H A D | shhhseqscommand.cpp | 163 Command* clusterCommand = new ClusterCommand(inputString); in driver() local
164 clusterCommand->execute(); in driver()
166 map<string, vector<string> > filenames = clusterCommand->getOutputFiles(); in driver()
171 delete clusterCommand; in driver()
|
| /dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
| H A D | commands.h | 119 extern List * PreprocessClusterStmt(Node *node, const char *clusterCommand,
|
| /dports/databases/redis5/redis-5.0.14/src/ |
| H A D | server.h | 2104 void clusterCommand(client *c);
|
| H A D | server.c | 280 {"cluster",clusterCommand,-2,"a",0,NULL,0,0,0,0,0},
|
| /dports/databases/redis6/redis-6.0.16/src/ |
| H A D | server.h | 2430 void clusterCommand(client *c);
|
| H A D | server.c | 794 {"cluster",clusterCommand,-2,
|
| H A D | cluster.c | 4330 void clusterCommand(client *c) { in clusterCommand() function
|
| /dports/editors/helix/helix-0.5.0/helix-syntax/languages/tree-sitter-c/examples/ |
| H A D | cluster.c | 4056 void clusterCommand(client *c) { in clusterCommand() function
|