Searched refs:nodeNameString (Results 1 – 8 of 8) sorted by relevance
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/test/ |
H A D | run_from_same_connection.c | 90 char *nodeNameString = text_to_cstring(nodeName); in start_session_level_connection_to_node() local 94 nodeNameString) != 0 || in start_session_level_connection_to_node() 107 singleConnection = GetNodeConnection(connectionFlags, nodeNameString, nodePort); in start_session_level_connection_to_node() 113 elog(ERROR, "failed to connect to %s:%d", nodeNameString, (int) nodePort); in start_session_level_connection_to_node()
|
H A D | intermediate_results.c | 40 char *nodeNameString = text_to_cstring(nodeNameText); in store_intermediate_result_on_node() local 49 WorkerNode *workerNode = FindWorkerNodeOrError(nodeNameString, nodePort); in store_intermediate_result_on_node()
|
/dports/sysutils/hfsexplorer/hfsexplorer-hfsexplorer-0.23.1/src/java/org/catacombae/hfs/types/hfsx/ |
H A D | HFSXCatalogKey.java | 49 public HFSXCatalogKey(int parentIDInt, String nodeNameString, in HFSXCatalogKey() argument 52 super(parentIDInt, nodeNameString); in HFSXCatalogKey()
|
/dports/sysutils/hfsexplorer/hfsexplorer-hfsexplorer-0.23.1/src/java/org/catacombae/hfs/types/hfsplus/ |
H A D | HFSPlusCatalogKey.java | 58 public HFSPlusCatalogKey(int parentIDInt, String nodeNameString) { in HFSPlusCatalogKey() argument 60 nodeName = new HFSUniStr255(nodeNameString); in HFSPlusCatalogKey()
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/ |
H A D | metadata_sync.c | 154 char *nodeNameString = text_to_cstring(nodeName); in start_metadata_sync_to_node() local 156 StartMetadataSyncToNode(nodeNameString, nodePort); in start_metadata_sync_to_node() 167 StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort) in StartMetadataSyncToNode() argument 169 char *escapedNodeName = quote_literal_cstr(nodeNameString); in StartMetadataSyncToNode() 180 WorkerNode *workerNode = FindWorkerNode(nodeNameString, nodePort); in StartMetadataSyncToNode() 202 nodeNameString, nodePort))); in StartMetadataSyncToNode() 297 char *nodeNameString = text_to_cstring(nodeName); in stop_metadata_sync_to_node() local 305 errmsg("node (%s,%d) does not exist", nodeNameString, nodePort))); in stop_metadata_sync_to_node() 312 nodeNameString, nodePort))); in stop_metadata_sync_to_node() 321 nodeNameString, nodePort))); in stop_metadata_sync_to_node() [all …]
|
H A D | node_metadata.c | 173 char *nodeNameString = text_to_cstring(nodeName); in citus_set_coordinator_host() local 194 AddNodeMetadata(nodeNameString, nodePort, &nodeMetadata, in citus_set_coordinator_host() 208 UpdateNodeLocation(coordinatorNode->nodeId, nodeNameString, nodePort); in citus_set_coordinator_host() 231 char *nodeNameString = text_to_cstring(nodeName); in citus_add_node() local 260 int nodeId = AddNodeMetadata(nodeNameString, nodePort, &nodeMetadata, in citus_add_node() 271 ActivateNode(nodeNameString, nodePort); in citus_add_node() 300 char *nodeNameString = text_to_cstring(nodeName); in citus_add_inactive_node() local 314 int nodeId = AddNodeMetadata(nodeNameString, nodePort, &nodeMetadata, in citus_add_inactive_node() 343 char *nodeNameString = text_to_cstring(nodeName); in citus_add_secondary_node() local 358 int nodeId = AddNodeMetadata(nodeNameString, nodePort, &nodeMetadata, in citus_add_secondary_node()
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/ |
H A D | citus_tools.c | 543 StringInfo nodeNameString = nodeNameArray[commandIndex]; in CreateTupleStore() local 545 text *nodeNameText = cstring_to_text_with_len(nodeNameString->data, in CreateTupleStore() 546 nodeNameString->len); in CreateTupleStore()
|
/dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
H A D | metadata_sync.h | 31 extern void StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort);
|