Home
last modified time | relevance | path

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 Drun_from_same_connection.c90 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 Dintermediate_results.c40 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 DHFSXCatalogKey.java49 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 DHFSPlusCatalogKey.java58 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 Dmetadata_sync.c154 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 Dnode_metadata.c173 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 Dcitus_tools.c543 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 Dmetadata_sync.h31 extern void StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort);