Package: TunnelServer

TunnelServer

name	instruction	branch	complexity	line	method
TunnelServer()	M: 3 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
main(String[])	M: 53 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 14 C: 0 0%	M: 1 C: 0 0%
static {...}	M: 5 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%

Coverage

1: /*
2: * Copyright (c) 2009, 2020 Oracle and/or its affiliates. All rights reserved.
3: *
4: * This program and the accompanying materials are made available under the
5: * terms of the Eclipse Distribution License v. 1.0, which is available at
6: * http://www.eclipse.org/org/documents/edl-v10.php.
7: *
8: * SPDX-License-Identifier: BSD-3-Clause
9: */
10:
11: package org.glassfish.grizzly.samples.tunnel;
12:
13: import java.io.IOException;
14: import java.util.logging.Logger;
15:
16: import org.glassfish.grizzly.filterchain.FilterChainBuilder;
17: import org.glassfish.grizzly.filterchain.TransportFilter;
18: import org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler;
19: import org.glassfish.grizzly.nio.transport.TCPNIOTransport;
20: import org.glassfish.grizzly.nio.transport.TCPNIOTransportBuilder;
21:
22: /**
23: * Simple tunneling server
24: *
25: * @author Alexey Stashok
26: */
27: public class TunnelServer {
28: private static final Logger logger = Logger.getLogger(TunnelServer.class.getName());
29:
30: public static final String HOST = "localhost";
31: public static final int PORT = 7777;
32:
33: public static final String REDIRECT_HOST = "localhost";
34: public static final int REDIRECT_PORT = 5001;
35:
36: public static void main(String[] args) throws IOException {
37: // Create TCP transport
38: final TCPNIOTransport transport = TCPNIOTransportBuilder.newInstance().build();
39:
40: // Create a FilterChain using FilterChainBuilder
41: FilterChainBuilder filterChainBuilder = FilterChainBuilder.stateless();
42: // Add TransportFilter, which is responsible
43: // for reading and writing data to the connection
44: filterChainBuilder.add(new TransportFilter());
45: filterChainBuilder.add(new TunnelFilter(TCPNIOConnectorHandler.builder(transport).build(), REDIRECT_HOST, REDIRECT_PORT));
46:
47: transport.setProcessor(filterChainBuilder.build());
48:
49: // Set async write queue size limit
50: transport.getAsyncQueueIO().getWriter().setMaxPendingBytesPerConnection(256 * 1024);
51:
52: try {
53: // binding transport to start listen on certain host and port
54: transport.bind(HOST, PORT);
55:
56: // start the transport
57: transport.start();
58:
59: logger.info("Press any key to stop the server...");
60: System.in.read();
61: } finally {
62: logger.info("Stopping transport...");
63: // stop the transport
64: transport.shutdownNow();
65:
66: logger.info("Stopped transport...");
67: }
68: }
69: }