Examples of addServer()

Examples of fr.dyade.aaa.agent.conf.A3CMLDomain.addServer()

1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
          // 3rd, Generate A3CMLConfig base.
          logmon.log(BasicLevel.WARN, "Generate default configuration");
          A3CMLDomain d = new A3CMLDomain(ADMIN_DOMAIN, SimpleNetwork.class.getName());
          A3CMLServer s = new A3CMLServer((short) 0, ADMIN_SERVER, "localhost");
          s.networks.addElement(new A3CMLNetwork(ADMIN_DOMAIN, 27300));
          d.addServer(s);
          a3config = new A3CMLConfig();
          a3config.addDomain(d);
          a3config.addServer(s);
        }
      }
View Full Code Here

Examples of io.druid.client.selector.ServerSelector.addServer()

195
196
197
198
199
200
201
202
203
204
205
      QueryableDruidServer queryableDruidServer = clients.get(server.getName());
      if (queryableDruidServer == null) {
        queryableDruidServer = addServer(baseView.getInventoryValue(server.getName()));
      }
      selector.addServer(queryableDruidServer);
    }
  }

  private void serverRemovedSegment(DruidServerMetadata server, DataSegment segment)
  {
View Full Code Here

Examples of io.druid.client.selector.ServerSelector.addServer()

1378
1379
1380
1381
1382
1383
1384
1385
1386
1387
1388
        ServerSelector selector = new ServerSelector(
            expectation.getSegment(),
            new HighestPriorityTierSelectorStrategy(new RandomServerSelectorStrategy())
        );
        selector.addServer(new QueryableDruidServer(lastServer, null));

        final PartitionChunk<ServerSelector> chunk;
        if (numChunks == 1) {
          chunk = new SingleElementPartitionChunk<>(selector);
        } else {
View Full Code Here

Examples of io.druid.client.selector.ServerSelector.addServer()

107
108
109
110
111
112
113
114
115
116
117
    QueryableDruidServer queryableDruidServer1 = new QueryableDruidServer(
        new DruidServer("test1", "localhost", 0, "historical", DruidServer.DEFAULT_TIER, 0),
        client1
    );
    serverSelector.addServer(queryableDruidServer1);
    QueryableDruidServer queryableDruidServer2 = new QueryableDruidServer(
        new DruidServer("test1", "localhost", 0, "historical", DruidServer.DEFAULT_TIER, 0),
        client2
    );
    serverSelector.addServer(queryableDruidServer2);
View Full Code Here

Examples of io.druid.client.selector.ServerSelector.addServer()

112
113
114
115
116
117
118
119
120
121
122
    serverSelector.addServer(queryableDruidServer1);
    QueryableDruidServer queryableDruidServer2 = new QueryableDruidServer(
        new DruidServer("test1", "localhost", 0, "historical", DruidServer.DEFAULT_TIER, 0),
        client2
    );
    serverSelector.addServer(queryableDruidServer2);

    TimeBoundaryQuery query = Druids.newTimeBoundaryQueryBuilder().dataSource("test").build();
    HashMap<String,List> context = new HashMap<String, List>();
    Sequence s1 = client1.run(query, context);
    Assert.assertEquals(1, client1.getNumOpenConnections());
View Full Code Here

Examples of io.druid.client.selector.ServerSelector.addServer()

195
196
197
198
199
200
201
202
203
204
205
    QueryableDruidServer queryableDruidServer1 = new QueryableDruidServer(
        new DruidServer("test1", "localhost", 0, "historical", DruidServer.DEFAULT_TIER, 0),
        client1
    );
    serverSelector.addServer(queryableDruidServer1);

    TimeBoundaryQuery query = Druids.newTimeBoundaryQueryBuilder().dataSource("test").build();
    HashMap<String,List> context = new HashMap<String, List>();
    cancellationFuture.set(new StatusResponseHolder(HttpResponseStatus.OK, new StringBuilder("cancelled")));
    Sequence results = client1.run(query, context);
View Full Code Here

Examples of net.rubyeye.xmemcached.XMemcachedClient.addServer()

80
81
82
83
84
85
86
87
88
89
90
    server.start();
    InetSocketAddress serverAddress = server.getServerAddress();
    XMemcachedClient client = new XMemcachedClient();
    client.setConnectionPoolSize(5);
    client.setEnableHeartBeat(false);
    client.addServer(serverAddress);
    synchronized (this) {
      while (server.sessionCounter.get() < 5) {
        this.wait(1000);
      }
    }
View Full Code Here

Examples of net.rubyeye.xmemcached.XMemcachedClient.addServer()

118
119
120
121
122
123
124
125
126
127
128
    XMemcachedClient client = new XMemcachedClient();
    client.setConnectionPoolSize(5);
    client.setEnableHeartBeat(false);
    //disable heal session.
    client.setEnableHealSession(false);
    client.addServer(serverAddress);
    synchronized (this) {
      while (server.sessionCounter.get() < 5) {
        this.wait(1000);
      }
    }
View Full Code Here

Examples of net.rubyeye.xmemcached.XMemcachedClient.addServer()

79
80
81
82
83
84
85
86
87
88
89
    server.start();
    InetSocketAddress serverAddress = server.getServerAddress();
    XMemcachedClient client = new XMemcachedClient();
    client.setConnectionPoolSize(5);
    client.setEnableHeartBeat(false);
    client.addServer(serverAddress);
    synchronized (this) {
      while (server.sessionCounter.get() < 5) {
        this.wait(1000);
      }
    }
View Full Code Here

Examples of org.apache.jmeter.protocol.http.control.DNSCacheManager.addServer()

118
119
120
121
122
123
124
125
126
127
128
        configureTestElement(dnsRes);
        if (dnsRes instanceof DNSCacheManager) {
            DNSCacheManager dnsCacheManager = (DNSCacheManager) dnsRes;
            for (int i = 0; i < dnsServersTableModel.getRowCount(); i++) {
                String server = (String) dnsServersTableModel.getRowData(i)[0];
                dnsCacheManager.addServer(server);
            }
            dnsCacheManager.setClearEachIteration(clearEachIteration.isSelected());
            if (providerDNSradioGroup.isSelected(custResButton.getModel())) {
                dnsCacheManager.setCustomResolver(true);
            } else {
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.