public int run(String[] args) throws Exception { Configuration conf = getConf(); int port = conf.getInt("wmr.server.bind.port", 50100); SubmissionDatabase.connect(conf); JobServiceHandler service = new JobServiceHandler(new Configuration()); JobService.Processor processor = new JobService.Processor(service); TServerTransport transport = new TServerSocket(port); TServer server = new TSimpleServer(new Args(transport).processor(processor)); server.serve(); return 0; }
@Override public void startServer(final TProcessor processor, final TProtocolFactory protoFactory) throws Exception { serverThread = new Thread() { public void run() { try { // Transport TServerSocket socket = new TServerSocket(PORT); TTransportFactory factory = new TSaslServerTransport.Factory( WRAPPED_MECHANISM, SERVICE, HOST, WRAPPED_PROPS, new TestSaslCallbackHandler(PASSWORD)); server = new TSimpleServer(new Args(socket).processor(processor).transportFactory(factory).protocolFactory(protoFactory)); // Run it LOGGER.debug("Starting the server on port {}", PORT); server.serve(); } catch (Exception e) { e.printStackTrace(); fail(); } } }; serverThread.start(); Thread.sleep(1000); }
private static int testProcessor(TProcessor processor, List<ToIntFunction<HostAndPort>> clients) throws Exception { try (TServerSocket serverTransport = new TServerSocket(0)) { TProtocolFactory protocolFactory = new Factory(); TTransportFactory transportFactory = new TFramedTransport.Factory(); TServer server = new TSimpleServer(new Args(serverTransport) .protocolFactory(protocolFactory) .transportFactory(transportFactory) .processor(processor)); Thread serverThread = new Thread(server::serve); try { serverThread.start(); int localPort = serverTransport.getServerSocket().getLocalPort(); HostAndPort address = HostAndPort.fromParts("localhost", localPort); int sum = 0; for (ToIntFunction<HostAndPort> client : clients) { sum += client.applyAsInt(address); } return sum; } finally { server.stop(); serverThread.interrupt(); } } }
private static int testProcessor(TProcessor processor, List<ToIntFunction<HostAndPort>> clients) throws Exception { try (TServerSocket serverTransport = new TServerSocket(0)) { TProtocolFactory protocolFactory = new TBinaryProtocol.Factory(); TTransportFactory transportFactory = new TFramedTransport.Factory(); TServer server = new TSimpleServer(new Args(serverTransport) .protocolFactory(protocolFactory) .transportFactory(transportFactory) .processor(processor)); Thread serverThread = new Thread(server::serve); try { serverThread.start(); int localPort = serverTransport.getServerSocket().getLocalPort(); HostAndPort address = HostAndPort.fromParts("localhost", localPort); int sum = 0; for (ToIntFunction<HostAndPort> client : clients) { sum += client.applyAsInt(address); } return sum; } finally { server.stop(); serverThread.interrupt(); } } }
private void secure(Asker.Processor processor) { try { /* * Use TSSLTransportParameters to setup the required SSL parameters. In this example * we are setting the keystore and the keystore password. Other things like algorithms, * cipher suites, client auth etc can be set. */ TSSLTransportFactory.TSSLTransportParameters params = new TSSLTransportFactory.TSSLTransportParameters(); // The Keystore contains the private key params.setKeyStore(keyStore, keyPass, null, null); /* * Use any of the TSSLTransportFactory to get a server transport with the appropriate * SSL configuration. You can use the default settings if properties are set in the command line. * Ex: -Djavax.net.ssl.keyStore=.keystore and -Djavax.net.ssl.keyStorePassword=thrift * * Note: You need not explicitly call open(). The underlying server socket is bound on return * from the factory class. */ TServerTransport serverTransport = TSSLTransportFactory.getServerSocket(port, 0, null, params); TServer server = new TSimpleServer(new Args(serverTransport).processor(processor)); // Use this for a multi threaded server // TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(serverTransport).processor(processor)); System.out.println("Starting the secure server..."); server.serve(); } catch (Exception e) { e.printStackTrace(); } }
/** * Start extension by communicating with osquery core and starting thrift * server * * @param name * name of extension * @param version * version of extension * @param sdkVersion * version of the osquery SDK used to build this extension * @param minSdkVersion * minimum version of the osquery SDK that you can use * @throws IOException * @throws ExtensionException */ public void startExtension(String name, String version, String sdkVersion, String minSdkVersion) throws IOException, ExtensionException { ExtensionManager.Client client = new ClientManager(EXTENSION_SOCKET).getClient(); InternalExtensionInfo info = new InternalExtensionInfo(name, version, sdkVersion, minSdkVersion); try { ExtensionStatus status = client.registerExtension(info, registry); if (status.getCode() == 0) { this.uuid = status.uuid; Processor<PluginManager> processor = new Processor<PluginManager>(this); String serverSocketPath = EXTENSION_SOCKET + "." + String.valueOf(uuid); File socketFile = new File(serverSocketPath); if (socketFile.exists()) { socketFile.delete(); } AFUNIXServerSocket socket = AFUNIXServerSocket.bindOn(new AFUNIXSocketAddress(socketFile)); socketFile.setExecutable(true, false); socketFile.setWritable(true, false); socketFile.setReadable(true, false); TServerSocket transport = new TServerSocket(socket); TTransportFactory transportFactory = new TTransportFactory(); TProtocolFactory protocolFactory = new TBinaryProtocol.Factory(); TServer server = new TSimpleServer(new Args(transport).processor(processor) .transportFactory(transportFactory).protocolFactory(protocolFactory)); // Run it System.out.println("Starting the server..."); server.serve(); } else { throw new ExtensionException(1, status.getMessage(), uuid); } } catch (TException e) { throw new ExtensionException(1, "Could not connect to socket", uuid); } }
public static void simple(Calculator.Processor<CalculatorHandler> processor) throws Exception { TNonblockingServerSocket serverTransport = new TNonblockingServerSocket(9090); TServer server = new TNonblockingServer(new TNonblockingServer.Args(serverTransport).processor(processor)); // TServerTransport serverTransport = new TServerSocket(9090); // TServer server = new TSimpleServer(new Args(serverTransport).processor(processor)); // Use this for a multithreaded server // TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(serverTransport).processor(processor)); System.out.println("Starting the simple server..."); server.serve(); }
public static void secure(Calculator.Processor<CalculatorHandler> processor) throws Exception { /* * Use TSSLTransportParameters to setup the required SSL parameters. In this * example we are setting the keystore and the keystore password. Other things * like algorithms, cipher suites, client auth etc can be set. */ TSSLTransportParameters params = new TSSLTransportParameters(); // The Keystore contains the private key params.setKeyStore("../../lib/java/test/.keystore", "thrift", null, null); /* * Use any of the TSSLTransportFactory to get a server transport with the * appropriate SSL configuration. You can use the default settings if properties * are set in the command line. Ex: -Djavax.net.ssl.keyStore=.keystore and * -Djavax.net.ssl.keyStorePassword=thrift * * Note: You need not explicitly call open(). The underlying server socket is * bound on return from the factory class. */ TServerTransport serverTransport = TSSLTransportFactory.getServerSocket(9091, 0, null, params); TServer server = new TSimpleServer(new Args(serverTransport).processor(processor)); // Use this for a multi threaded server // TServer server = new TThreadPoolServer(new // TThreadPoolServer.Args(serverTransport).processor(processor)); System.out.println("Starting the secure server..."); server.serve(); }
public static void simplePrimaryServer (LoadBalancerInvoker.Processor processor, int portNum) { try { TServerTransport serverTransport = new TServerSocket (portNum); TServer server = new TSimpleServer (new Args (serverTransport).processor (processor)); System.out.println ("Starting the simple server..."); server.serve (); } catch (Exception e) { e.printStackTrace (); } }
public static void simpleSecondaryServer (LoadBalancer.Processor processor, int portNum) { try { TServerTransport serverTransport = new TServerSocket (portNum); TServer server = new TSimpleServer (new Args (serverTransport).processor (processor)); System.out.println ("Starting the simple server..."); server.serve (); } catch (Exception e) { e.printStackTrace (); } }
public void run() { log.info("Starting up!"); try { serverTransport = new TServerSocket(bindAddress); server = new TSimpleServer(new Args(serverTransport).processor(processor)); server.serve(); // blocks until stop() is called. // timer and timer task should be stopped at this point writeToStorage(); } catch (TTransportException e) { log.error("Couldn't start Configurator {}", this, e); } }
public static void simple(PacketService.Processor processor) { try { TServerTransport serverTransport = new TServerSocket(9888); server = new TSimpleServer(new Args(serverTransport).processor(processor)); // Use this for a multithreaded server // TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(serverTransport).processor(processor)); System.out.println("Starting the outbound server..."); server.serve(); } catch (Exception e) { e.printStackTrace(); } }
public static void simple(Calculator.Processor processor) { try { TServerTransport serverTransport = new TServerSocket(9090); TServer server = new TSimpleServer(new Args(serverTransport).processor(processor)); // Use this for a multithreaded server // TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(serverTransport).processor(processor)); System.out.println("Starting the simple server..."); server.serve(); } catch (Exception e) { e.printStackTrace(); } }
public static void secure(Calculator.Processor processor) { try { /* * Use TSSLTransportParameters to setup the required SSL parameters. In this example * we are setting the keystore and the keystore password. Other things like algorithms, * cipher suites, client auth etc can be set. */ TSSLTransportParameters params = new TSSLTransportParameters(); // The Keystore contains the private key params.setKeyStore("../../lib/java/test/.keystore", "thrift", null, null); /* * Use any of the TSSLTransportFactory to get a server transport with the appropriate * SSL configuration. You can use the default settings if properties are set in the command line. * Ex: -Djavax.net.ssl.keyStore=.keystore and -Djavax.net.ssl.keyStorePassword=thrift * * Note: You need not explicitly call open(). The underlying server socket is bound on return * from the factory class. */ TServerTransport serverTransport = TSSLTransportFactory.getServerSocket(9091, 0, null, params); TServer server = new TSimpleServer(new Args(serverTransport).processor(processor)); // Use this for a multi threaded server // TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(serverTransport).processor(processor)); System.out.println("Starting the secure server..."); server.serve(); } catch (Exception e) { e.printStackTrace(); } }
/** * */ protected AbstractThriftServer(int port, AbstractAccumuloClient aac, TProcessor processor) throws RebarException { try { this.aac = aac; this.serverXport = new TServerSocket(port); this.args = new Args(this.serverXport); this.args.processor(processor); this.server = new TSimpleServer(this.args); } catch (TTransportException e) { throw new RebarException(e); } }