Home
last modified time | relevance | path

Searched refs:workerPort (Results 1 – 25 of 39) sorted by relevance

12

/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/
H A Dshard_rebalancer.c203 uint32 workerPort);
662 worker->workerPort); in GetResponsiveWorkerList()
1246 workerKey.port = workerPort; in WorkerShardSize()
1466 workerKey.port = workerPort; in AddToWorkerShardIdSet()
1669 sourceNode->workerPort, in UpdateShardPlacement()
1671 targetNode->workerPort, in UpdateShardPlacement()
1680 sourceNode->workerPort, in UpdateShardPlacement()
1682 targetNode->workerPort, in UpdateShardPlacement()
1694 sourceNode->workerPort, in UpdateShardPlacement()
1707 sourceNode->workerPort, in UpdateShardPlacement()
[all …]
H A Dworker_node_manager.c652 workerLhs->workerPort, workerRhs->workerPort); in WorkerNodeCompare()
H A Dcitus_create_restore_point.c127 workerNode->workerPort); in OpenConnectionsToAllWorkerNodes()
H A Ddelete_protocol.c525 uint32 workerPort = shardPlacement->nodePort; in ExecuteDropShardPlacementCommandRemotely() local
535 workerPort), in ExecuteDropShardPlacementCommandRemotely()
/dports/www/gohugo/hugo-0.91.2/vendor/github.com/evanw/esbuild/lib/npm/
H A Dnode.ts393 let { port1: mainPort, port2: workerPort } = new worker_threads.MessageChannel();
395 workerData: { workerPort, defaultWD, esbuildVersion: ESBUILD_VERSION },
396 transferList: [workerPort],
495 let workerPort: import('worker_threads').MessagePort = worker_threads!.workerData.workerPort;
525 workerPort.postMessage({ id, resolve: await service.build(args[0]) });
529 workerPort.postMessage({ id, resolve: await service.transform(args[0], args[1]) });
533 workerPort.postMessage({ id, resolve: await service.formatMessages(args[0], args[1]) });
537 … workerPort.postMessage({ id, resolve: await service.analyzeMetafile(args[0], args[1]) });
544 workerPort.postMessage({ id, reject, properties: extractProperties(reject) });
/dports/devel/esbuild/esbuild-0.12.23/lib/npm/
H A Dnode.ts388 let { port1: mainPort, port2: workerPort } = new worker_threads.MessageChannel();
390 workerData: { workerPort, defaultWD, esbuildVersion: ESBUILD_VERSION },
391 transferList: [workerPort],
487 let workerPort: import('worker_threads').MessagePort = worker_threads!.workerData.workerPort;
516 workerPort.postMessage({ id, resolve: await service.build(args[0]) });
518 workerPort.postMessage({ id, resolve: await service.transform(args[0], args[1]) });
520 workerPort.postMessage({ id, resolve: await service.formatMessages(args[0], args[1]) });
525 workerPort.postMessage({ id, reject, properties: extractProperties(reject) });
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/transaction/
H A Dworker_transaction.c81 int nodePort = workerNode->workerPort; in SendCommandToWorkersAsUser()
180 int nodePort = workerNode->workerPort; in SendBareCommandListToMetadataWorkers()
296 int nodePort = workerNode->workerPort; in OpenConnectionsToWorkersInParallel()
369 int nodePort = workerNode->workerPort; in SendCommandToWorkersParamsInternal()
614 int workerPort = metadataNode->workerPort; in ErrorIfAnyMetadataNodeOutOfSync() local
617 workerName, workerPort), in ErrorIfAnyMetadataNodeOutOfSync()
H A Dcitus_dist_stat_activity.c339 int nodePort = workerNode->workerPort; in CitusStatActivity()
447 int nodePort = workerNode->workerPort; in GetLocalNodeCitusDistStat()
548 citusDistStat->master_query_host_port = initiatorWorkerNode->workerPort; in ReplaceInitiatorNodeIdentifier()
H A Dtransaction_recovery.c146 int nodePort = workerNode->workerPort; in RecoverWorkerTransactions()
H A Dlock_graph.c105 int nodePort = workerNode->workerPort; in BuildGlobalWaitGraph()
H A Dbackend_data.c249 int nodePort = workerNode->workerPort; in get_global_active_transactions()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/test/
H A Dshard_rebalancer.c411 uint32 workerPort = JsonFieldValueUInt32Default(workerNodeJson, in JsonArrayToWorkerTestInfoList() local
421 workerNode->workerPort = workerPort; in JsonArrayToWorkerTestInfoList()
592 escapedSourceName->data, sourceNode->workerPort, in PlacementUpdateListToJsonArray()
593 escapedTargetName->data, targetNode->workerPort); in PlacementUpdateListToJsonArray()
620 uint32 workerPort = PG_GETARG_INT32(1); in worker_node_responsive() local
627 workerPort); in worker_node_responsive()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/
H A Dnode_metadata.c562 newWorkerNode->workerPort); in SetUpDistributedTableDependencies()
577 newWorkerNode->workerPort); in SetUpDistributedTableDependencies()
624 newWorkerNode->workerPort, in PropagateNodeWideObjects()
666 ActivateNode(workerNode->workerName, workerNode->workerPort); in citus_activate_node()
1171 searchedNode->workerPort = nodePort; in FindWorkerNode()
1487 coordinator->workerPort))); in AddNodeMetadata()
1603 worker->workerName, worker->workerPort, in SetWorkerColumnOptional()
1613 workerNode->workerName, workerNode->workerPort, in SetWorkerColumnOptional()
1614 worker->workerName, worker->workerPort, in SetWorkerColumnOptional()
1615 worker->workerName, worker->workerPort))); in SetWorkerColumnOptional()
[all …]
H A Dmetadata_sync.c438 workerNode->workerPort, in SyncMetadataSnapshotToNode()
447 workerNode->workerName, workerNode->workerPort, in SyncMetadataSnapshotToNode()
473 workerNode->workerPort, in DropMetadataSnapshotOnNode()
800 workerNode->workerPort, in NodeListInsertCommand()
1786 workerNode->workerPort))); in SyncMetadataToNodes()
1804 workerNode->workerPort); in SyncMetadataToNodes()
H A Dmetadata_cache.c3337 workerNode->workerPort = currentNode->workerPort; in InitializeWorkerNodeCache()
3354 workerNode->workerPort))); in InitializeWorkerNodeCache()
3504 const uint32 *workerPort = &(worker->workerPort); in WorkerNodeHashCode() local
3509 result = 37 * result + tag_hash(workerPort, sizeof(uint32)); in WorkerNodeHashCode()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/connection/
H A Dlocally_reserved_shared_connections.c402 if (ConnectionAvailableToNode(workerNode->workerName, workerNode->workerPort, in EnsureConnectionPossibilityForNode()
426 workerNode->workerPort, in EnsureConnectionPossibilityForNode()
448 WaitLoopForSharedConnection(workerNode->workerName, workerNode->workerPort); in EnsureConnectionPossibilityForNode()
454 workerNode->workerPort); in EnsureConnectionPossibilityForNode()
/dports/databases/pg_citus/citus-10.2.3/src/test/regress/
H A Dpg_regress_multi.pl379 my $workerPort = $masterPort + $workerIndex;
380 push(@workerPorts, $workerPort);
388 my $workerPort = $followerCoordPort + $workerIndex;
389 push(@followerWorkerPorts, $workerPort);
854 my $workerPort = $workerPorts[$offset];
857 …D", catfile($TMP_CHECKDIR, "follower.$followerPort", "data"), "--host=$host", "--port=$workerPort",
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/
H A Dreference_table_utils.c186 newWorkerNode->workerPort))); in EnsureReferenceTablesExistOnAllNodesExtended()
272 uint32 nodePort = workerNode->workerPort; in WorkersWithoutReferenceTablePlacement()
309 workerNode->workerPort, in CopyShardPlacementToWorkerNodeQuery()
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/test/util/
H A Dintegration.py220 workerPort = list(m.pbmanager.dispatchers.values())[
231 "127.0.0.1", workerPort, "local1", "localpw", worker_dir.path,
235 "127.0.0.1", workerPort, "local1", "localpw", worker_dir.path,
/dports/databases/pg_citus/citus-10.2.3/src/include/distributed/
H A Dworker_manager.h47 uint32 workerPort; /* node's port */ member
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/
H A Ddependencies.c120 uint32 nodePort = workerNode->workerPort; in EnsureDependenciesExistOnAllNodes()
H A Dtruncate.c456 int nodePort = workerNode->workerPort; in AcquireDistributedLockOnRelations()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/
H A Ddistributed_intermediate_results.c668 sourceNode->workerPort); in QueryStringForFragmentsTransfer()
671 sourceNode->workerPort, queryString->data))); in QueryStringForFragmentsTransfer()
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/
H A Dintermediate_result_pruning.c431 workerNode->workerName, workerNode->workerPort); in LogIntermediateResultMulticastSummary()
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/master/
H A DMaster.scala390 id, workerHost, workerPort, workerRef, cores, memory, workerWebUiUrl) =>
392 workerHost, workerPort, cores, Utils.megabytesToString(memory)))
398 val worker = new WorkerInfo(id, workerHost, workerPort, cores, memory,

12