Examples of startServer()

Examples of bbejeck.nio.channels.AsyncServerSocket.startServer()

28
29
30
31
32
33
34
35
36
37
38
        FutureTask<Long> asyncFutureTask = new FutureTask<>(new Callable<Long>() {
            @Override
            public Long call() throws Exception {
                Stopwatch stopwatch = new Stopwatch();
                stopwatch.start();
                asyncServerSocket.startServer();
                stopwatch.stop();
                return stopwatch.elapsedMillis();
            }
        });
        System.out.println("Starting the AsyncSocketServer Test");
View Full Code Here

Examples of bbejeck.nio.sockets.PlainServerSocket.startServer()

50
51
52
53
54
55
56
57
58
59
60
        FutureTask<Long> plainFutureTask = new FutureTask<>(new Callable<Long>() {
            @Override
            public Long call() throws Exception {
                Stopwatch stopwatch = new Stopwatch();
                stopwatch.start();
                serverSocket.startServer();
                stopwatch.stop();
                return stopwatch.elapsedTime(TimeUnit.SECONDS);
            }
        });
View Full Code Here

Examples of bixo.fetcher.SimulationWebServerForTests.startServer()

78
79
80
81
82
83
84
85
86
87
88
    public void testCircularRedirect() throws Exception {
        BaseFetcher fetcher = RobotUtils.createFetcher(ConfigUtils.BIXO_TEST_AGENT, 1);
        BaseRobotsParser parser = new SimpleRobotRulesParser();
       
        SimulationWebServerForTests webServer = new SimulationWebServerForTests();
        Server server = webServer.startServer(new CircularRedirectResponseHandler(), 8089);
       
        try {
            BaseRobotRules rules = RobotUtils.getRobotRules(fetcher, parser, new URL("http://localhost:8089/robots.txt"));
            Assert.assertTrue(rules.isAllowAll());
        } finally {
View Full Code Here

Examples of bixo.fetcher.SimulationWebServerForTests.startServer()

94
95
96
97
98
99
100
101
102
103
104
    public void testRedirectToHtml() throws Exception {
        BaseFetcher fetcher = RobotUtils.createFetcher(ConfigUtils.BIXO_TEST_AGENT, 1);
        BaseRobotsParser parser = new SimpleRobotRulesParser();
       
        SimulationWebServerForTests webServer = new SimulationWebServerForTests();
        Server server = webServer.startServer(new RedirectToTopResponseHandler(), 8089);
       
        try {
            BaseRobotRules rules = RobotUtils.getRobotRules(fetcher, parser, new URL("http://localhost:8089/robots.txt"));
            Assert.assertTrue(rules.isAllowAll());
        } finally {
View Full Code Here

Examples of com.caucho.server.cluster.ClusterServer.startServer()

996
997
998
999
1000
1001
1002
1003
1004
1005
1006
      if (clusterServer == null)
        throw new ConfigException(L().l("server-id '{0}' has no matching <server> definition.",
                                        _serverId));


      Server server = clusterServer.startServer(_networkServer);

      assert(server == _server);

      if (_stage != null)
        _server.setStage(_stage);
View Full Code Here

Examples of com.intellij.javascript.karma.server.KarmaServerRegistry.startServer()

70
71
72
73
74
75
76
77
78
79
80
    if (server != null && server.getRestarter().isRestartRequired()) {
      server.shutdownAsync();
      server = null;
    }
    if (server == null) {
      registry.startServer(
        serverSettings,
        new CatchingConsumer<KarmaServer, Exception>() {
          @Override
          public void consume(KarmaServer server) {
            RunnerAndConfigurationSettings configuration = myExecutionEnvironment.getRunnerAndConfigurationSettings();
View Full Code Here

Examples of com.jointhegrid.ironcount.httpserver.ICHTTPServer.startServer()

27
28
29
30
31
32
33
34
35
36
37
    w.classloaderUrls = new ArrayList<URL>();
    w.classloaderUrls.add( new URL("http://localhost:8766/") );

    ICHTTPServer serv = new ICHTTPServer();
    serv.docBase="/home/edward/ironcount/src/test/resources/urlload";
    serv.startServer();

    Properties p = System.getProperties();
    p.put(WorkloadManager.ZK_SERVER_LIST, "localhost:8888");
    WorkloadManager m = new WorkloadManager(p);
    m.init();
View Full Code Here

Examples of com.linkedin.d2.balancer.util.LoadBalancerEchoServer.startServer()

782
783
784
785
786
787
788
789
790
791
792
  }

  private static LoadBalancerEchoServer startEchoServer(int echoServerPort, String cluster,String... services) throws Exception
  {
    LoadBalancerEchoServer echoServer = new LoadBalancerEchoServer(ZK_HOST, ZK_PORT, ECHO_SERVER_HOST, echoServerPort, "http","/d2", cluster, services);
    echoServer.startServer();
    echoServer.markUp();

    return echoServer;
  }
View Full Code Here

Examples of com.linkedin.d2.balancer.util.LoadBalancerEchoServer.startServer()

791
792
793
794
795
796
797
798
799
800
801
  }

  private static LoadBalancerEchoServer startEchoServer(int echoServerPort, String cluster, Map<Integer, Double> partitionWeight, String... services) throws Exception
  {
    LoadBalancerEchoServer echoServer = new LoadBalancerEchoServer(ZK_HOST, ZK_PORT, ECHO_SERVER_HOST, echoServerPort, "http", "/d2", cluster, partitionWeight, services);
    echoServer.startServer();
    echoServer.markUp();
    return echoServer;
  }

  private static ClusterProperties getClusterProperties(ZKConnection zkclient, String cluster) throws IOException, URISyntaxException, PropertyStoreException
View Full Code Here

Examples of com.linkedin.d2.balancer.util.LoadBalancerEchoServer.startServer()

74
75
76
77
78
79
80
81
82
83
84
                                                          int echoServerPort,
                                                          String cluster,
                                                          String... services) throws Exception
  {
    LoadBalancerEchoServer echoServer = new LoadBalancerEchoServer(zkHost, zkPort, echoServerHost, echoServerPort, "http","/d2", cluster, services);
    echoServer.startServer();
    echoServer.markUp();

    assertFalse(echoServer.isStopped());

    return echoServer;
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.