Package org.apache.ambari.server.state.cluster

Examples of org.apache.ambari.server.state.cluster.ClusterImpl.addServiceComponentHost()

286
287
288
289
290
291
292
293
294
295
296
              + ", serviceComponentName=" + getName()
              + ", hostname=" + hostComponent.getHostName());
        }
        // FIXME need a better approach of caching components by host
        ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
        clusterImpl.addServiceComponentHost(hostComponent);
        this.hostComponents.put(hostComponent.getHostName(), hostComponent);
      } finally {
        readWriteLock.writeLock().unlock();
      }
    } finally {
View Full Code Here
327
328
329
330
331
332
333
334
335
336
337
        }
        ServiceComponentHost hostComponent =
            serviceComponentHostFactory.createNew(this, hostName, this.isClientComponent());
        // FIXME need a better approach of caching components by host
        ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
        clusterImpl.addServiceComponentHost(hostComponent);

        this.hostComponents.put(hostComponent.getHostName(), hostComponent);

        return hostComponent;
      } finally {
View Full Code Here
214
215
216
217
218
219
220
221
222
223
224
          + ", serviceComponentName=" + getName()
          + ", hostname=" + hostComponent.getHostName());
    }
    // FIXME need a better approach of caching components by host
    ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
    clusterImpl.addServiceComponentHost(hostComponent);
    this.hostComponents.put(hostComponent.getHostName(), hostComponent);
  }

  @Override
  public synchronized ServiceComponentHost addServiceComponentHost(
View Full Code Here
243
244
245
246
247
248
249
250
251
252
253
    }
    ServiceComponentHost hostComponent =
        serviceComponentHostFactory.createNew(this, hostName, true);
    // FIXME need a better approach of caching components by host
    ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
    clusterImpl.addServiceComponentHost(hostComponent);

    this.hostComponents.put(hostComponent.getHostName(), hostComponent);

    return hostComponent;
  }
View Full Code Here
243
244
245
246
247
248
249
250
251
252
253
    }
    ServiceComponentHost hostComponent =
        serviceComponentHostFactory.createNew(this, hostName, true);
    // FIXME need a better approach of caching components by host
    ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
    clusterImpl.addServiceComponentHost(hostComponent);

    this.hostComponents.put(hostComponent.getHostName(), hostComponent);

    return hostComponent;
  }
View Full Code Here
214
215
216
217
218
219
220
221
222
223
224
          + ", serviceComponentName=" + getName()
          + ", hostname=" + hostComponent.getHostName());
    }
    // FIXME need a better approach of caching components by host
    ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
    clusterImpl.addServiceComponentHost(hostComponent);
    this.hostComponents.put(hostComponent.getHostName(), hostComponent);
  }

  @Override
  public synchronized ServiceComponentHost addServiceComponentHost(
View Full Code Here
268
269
270
271
272
273
274
275
276
277
278
              + ", serviceComponentName=" + getName()
              + ", hostname=" + hostComponent.getHostName());
        }
        // FIXME need a better approach of caching components by host
        ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
        clusterImpl.addServiceComponentHost(hostComponent);
        this.hostComponents.put(hostComponent.getHostName(), hostComponent);
      } finally {
        readWriteLock.writeLock().unlock();
      }
    } finally {
View Full Code Here
306
307
308
309
310
311
312
313
314
315
316
              + ", hostname=" + hostName);
        }
        ServiceComponentHost hostComponent = serviceComponentHostFactory.createNew(this, hostName);
        // FIXME need a better approach of caching components by host
        ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
        clusterImpl.addServiceComponentHost(hostComponent);

        this.hostComponents.put(hostComponent.getHostName(), hostComponent);

        return hostComponent;
      } finally {
View Full Code Here
211
212
213
214
215
216
217
218
219
220
221
          + ", serviceComponentName=" + getName()
          + ", hostname=" + hostComponent.getHostName());
    }
    // FIXME need a better approach of caching components by host
    ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
    clusterImpl.addServiceComponentHost(hostComponent);
    this.hostComponents.put(hostComponent.getHostName(), hostComponent);
  }

  @Override
  public synchronized ServiceComponentHost addServiceComponentHost(
View Full Code Here
240
241
242
243
244
245
246
247
248
249
250
    }
    ServiceComponentHost hostComponent =
        serviceComponentHostFactory.createNew(this, hostName, this.isClientComponent());
    // FIXME need a better approach of caching components by host
    ClusterImpl clusterImpl = (ClusterImpl) service.getCluster();
    clusterImpl.addServiceComponentHost(hostComponent);

    this.hostComponents.put(hostComponent.getHostName(), hostComponent);

    return hostComponent;
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.