Home
last modified time | relevance | path

Searched refs:serviceAddr (Results 1 – 25 of 88) sorted by relevance

1234

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ha/
H A DSshFenceByTcpPort.java86 InetSocketAddress serviceAddr = target.getAddress(); in tryFence() local
87 String host = serviceAddr.getHostName(); in tryFence()
91 session = createSession(serviceAddr.getHostName(), args); in tryFence()
109 return doFence(session, serviceAddr); in tryFence()
131 private boolean doFence(Session session, InetSocketAddress serviceAddr) in doFence() argument
133 int port = serviceAddr.getPort(); in doFence()
150 rc = execCommand(session, "nc -z " + serviceAddr.getHostName() + in doFence()
151 " " + serviceAddr.getPort()); in doFence()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/main/java/org/apache/hadoop/mapred/
H A DClientCache.java84 final String serviceAddr = conf.get(JHAdminConfig.MR_HISTORY_ADDRESS); in instantiateHistoryProxy() local
85 if (StringUtils.isEmpty(serviceAddr)) { in instantiateHistoryProxy()
88 LOG.debug("Connecting to HistoryServer at: " + serviceAddr); in instantiateHistoryProxy()
90 LOG.debug("Connected to HistoryServer at: " + serviceAddr); in instantiateHistoryProxy()
96 NetUtils.createSocketAddr(serviceAddr), conf); in instantiateHistoryProxy()
H A DClientServiceDelegate.java163 InetSocketAddress serviceAddr = null; in getProxy() local
191 serviceAddr = NetUtils.createSocketAddrForHost( in getProxy()
197 ConverterUtils.convertFromYarn(clientToAMToken, serviceAddr); in getProxy()
200 LOG.debug("Connecting to " + serviceAddr); in getProxy()
201 final InetSocketAddress finalServiceAddr = serviceAddr; in getProxy()
221 LOG.info("Could not connect to " + serviceAddr + in getProxy()
294 MRClientProtocol instantiateAMProxy(final InetSocketAddress serviceAddr) in instantiateAMProxy() argument
296 LOG.trace("Connecting to ApplicationMaster at: " + serviceAddr); in instantiateAMProxy()
300 serviceAddr, conf); in instantiateAMProxy()
302 LOG.trace("Connected to ApplicationMaster at: " + serviceAddr); in instantiateAMProxy()
/dports/benchmarks/polygraph/polygraph-4.13.0/src/kerberos/
H A DMgr.cc134 bool Mgr::createGssContext(const NetAddr &serviceAddr, CltXact &reason) { in createGssContext() argument
137 theGssContextQueue.push_back(make_pair(&serviceAddr, &reason)); in createGssContext()
151 theGssContextQueue.push_back(make_pair(&serviceAddr, &reason)); in createGssContext()
162 return startCreateGssContext(serviceAddr, reason); in createGssContext()
165 bool Mgr::startCreateGssContext(const NetAddr &serviceAddr, CltXact &reason) { in startCreateGssContext() argument
168 if (!x->configure(*this, theCCache, serviceAddr, reason)) { in startCreateGssContext()
248 const NetAddr &serviceAddr = *theGssContextQueue.front().first; in restartCreateGssContext() local
251 if (!startCreateGssContext(serviceAddr, reason)) in restartCreateGssContext()
H A DTicketXact.cc26 bool TicketXact::configure(Mgr &owner, CCache &ccache, const NetAddr &serviceAddr, CltXact &aReason… in configure() argument
28 theServiceName = "HTTP/" + serviceAddr.addrA() + '@' + owner.realm(); in configure()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/
H A DRMCommunicator.java146 InetSocketAddress serviceAddr = null; in register() local
148 serviceAddr = clientService.getBindAddress(); in register()
153 if (serviceAddr != null) { in register()
154 request.setHost(serviceAddr.getHostName()); in register()
155 request.setRpcPort(serviceAddr.getPort()); in register()
158 + serviceAddr.getHostName() + ":" + clientService.getHttpPort()); in register()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/tools/
H A DNNHAServiceTarget.java73 String serviceAddr = in NNHAServiceTarget() local
75 if (serviceAddr == null) { in NNHAServiceTarget()
79 this.addr = NetUtils.createSocketAddr(serviceAddr, in NNHAServiceTarget()
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/whyrusleeping/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/sysutils/consul/consul-1.10.3/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/consul/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/serf/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/serf/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/serf/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/serf/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/vendor/github.com/hashicorp/go-discover/provider/mdns/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/go-discover/provider/mdns/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/sysutils/nomad/nomad-1.1.0/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/serf/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/sysutils/serf/serf-0.8.5/vendor/github.com/hashicorp/mdns/
H A Dzone.go34 serviceAddr string // Fully qualified service address member
125 serviceAddr: fmt.Sprintf("%s.%s.", trimDot(service), trimDot(domain)),
141 case m.serviceAddr:
167 Ptr: m.serviceAddr,
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/agent/structs/
H A Dstructs_test.go1529 Address: serviceAddr,
1533 lanAddr: serviceAddr,
1535 wanAddr: serviceAddr,
1540 Address: serviceAddr,
1550 lanAddr: serviceAddr,
1557 Address: serviceAddr,
1567 lanAddr: serviceAddr,
1674 lanAddr: serviceAddr,
1676 wanAddr: serviceAddr,
1700 lanAddr: serviceAddr,
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/
H A DMockRMWithCustomAMLauncher.java65 InetSocketAddress serviceAddr = in createAMLauncher() local
70 SecurityUtil.setTokenService(amRmToken, serviceAddr); in createAMLauncher()

1234