| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/client/ |
| H A D | StandaloneAppClient.scala | 106 val masterRef = rpcEnv.setupEndpointRef(masterAddress, Master.ENDPOINT_NAME) constant
107 masterRef.send(RegisterApplication(appDescription, self))
146 case Some(masterRef) => masterRef.send(message)
156 case RegisteredApplication(appId_, masterRef) =>
164 master = Some(masterRef)
185 case MasterChanged(masterRef, masterWebUiUrl) =>
186 logInfo("Master has changed, new master is at " + masterRef.address.toSparkURL)
187 master = Some(masterRef)
189 masterRef.send(MasterChangeAcknowledged(appId.get))
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/worker/ |
| H A D | Worker.scala | 199 private def changeMaster(masterRef: RpcEndpointRef, uiUrl: String) {
201 activeMasterUrl = masterRef.address.toSparkURL
203 master = Some(masterRef)
262 case Some(masterRef) =>
269 val masterAddress = masterRef.address
361 case RegisteredWorker(masterRef, masterWebUiUrl) =>
364 changeMaster(masterRef, masterWebUiUrl)
383 masterRef.send(WorkerLatestState(workerId, execs.toList, drivers.keys.toSeq))
428 case MasterChanged(masterRef, masterWebUiUrl) =>
430 changeMaster(masterRef, masterWebUiUrl)
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/kernel/blocks/backup/ |
| H A D | BackupProxy.cpp | 283 ss.masterRef = req->senderRef; in execDEFINE_BACKUP_REQ()
328 sendSignal(ss.masterRef, GSN_DEFINE_BACKUP_CONF, in sendDEFINE_BACKUP_CONF()
334 sendSignal(ss.masterRef, GSN_DEFINE_BACKUP_REF, in sendDEFINE_BACKUP_CONF()
359 ss.masterRef = req->senderRef; in execSTART_BACKUP_REQ()
401 sendSignal(ss.masterRef, GSN_START_BACKUP_CONF, in sendSTART_BACKUP_CONF()
407 sendSignal(ss.masterRef, GSN_START_BACKUP_REF, in sendSTART_BACKUP_CONF()
432 ss.masterRef = req->senderRef; in execSTOP_BACKUP_REQ()
473 sendSignal(ss.masterRef, GSN_STOP_BACKUP_CONF, in sendSTOP_BACKUP_CONF()
479 sendSignal(ss.masterRef, GSN_STOP_BACKUP_REF, in sendSTOP_BACKUP_CONF()
504 ss.masterRef = req->senderRef; in execABORT_BACKUP_ORD()
|
| H A D | BackupProxy.hpp | 85 Uint32 masterRef; member
106 Uint32 masterRef; member
126 Uint32 masterRef; member
147 Uint32 masterRef; member
|
| /dports/graphics/libetonyek01/libetonyek-0.1.10/src/lib/ |
| H A D | KEY6Parser.cpp | 109 const optional<unsigned> &masterRef = readRef(get(msg), 17); in parseSlide() local
111 if (!master && masterRef) in parseSlide()
113 if (m_masterSlides.find(get(masterRef))!=m_masterSlides.end()) in parseSlide()
114 masterSlide=m_masterSlides.find(get(masterRef))->second; in parseSlide()
116 masterSlide=parseSlide(get(masterRef), true); in parseSlide()
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| H A D | AllocNodeId.cpp | 131 refToNode(sig->masterRef), refToBlock(sig->masterRef)); in printALLOC_NODEID_REF()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| H A D | AllocNodeId.cpp | 131 refToNode(sig->masterRef), refToBlock(sig->masterRef)); in printALLOC_NODEID_REF()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| H A D | AllocNodeId.cpp | 131 refToNode(sig->masterRef), refToBlock(sig->masterRef)); in printALLOC_NODEID_REF()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| H A D | AllocNodeId.cpp | 131 refToNode(sig->masterRef), refToBlock(sig->masterRef)); in printALLOC_NODEID_REF()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| H A D | AllocNodeId.cpp | 131 refToNode(sig->masterRef), refToBlock(sig->masterRef)); in printALLOC_NODEID_REF()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| H A D | AllocNodeId.cpp | 131 refToNode(sig->masterRef), refToBlock(sig->masterRef)); in printALLOC_NODEID_REF()
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| /dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 81 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| /dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/src/common/debugger/signaldata/ |
| H A D | MasterLCP.cpp | 72 refToNode(sig->masterRef), refToBlock(sig->masterRef), in printMASTER_LCP_REQ()
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/include/kernel/signaldata/ |
| H A D | DihAddFrag.hpp | 59 Uint32 masterRef; member in DihAddFragReq
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/include/kernel/signaldata/ |
| H A D | DihAddFrag.hpp | 59 Uint32 masterRef; member in DihAddFragReq
|