/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ha/ |
H A D | SshFenceByTcpPort.java | 86 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 D | ClientCache.java | 84 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 D | ClientServiceDelegate.java | 163 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 D | Mgr.cc | 134 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 D | TicketXact.cc | 26 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 D | RMCommunicator.java | 146 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 D | NNHAServiceTarget.java | 73 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | zone.go | 34 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 D | structs_test.go | 1529 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 D | MockRMWithCustomAMLauncher.java | 65 InetSocketAddress serviceAddr = in createAMLauncher() local 70 SecurityUtil.setTokenService(amRmToken, serviceAddr); in createAMLauncher()
|