Package de.fhkn.in.uce.core.socketlistener

Examples of de.fhkn.in.uce.core.socketlistener.SocketListener

69
70
71
72
73
74
75
76
        Map<UUID, BlockingQueue<Socket>> connIDToQueue = new ConcurrentHashMap<UUID, BlockingQueue<Socket>>();
        // has to be unbounded
        Executor controlConnectionHandlerExecutor = Executors.newCachedThreadPool();
        // has to be unbounded
        Executor relayExecutor = Executors.newCachedThreadPool();
        socketListener = new SocketListener(port, ServerSocketFactory.getDefault(), Executors.newCachedThreadPool(),
                new MessageDispatcherTaskFactory(connIDToQueue, controlConnectionHandlerExecutor, relayExecutor));
    }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
                        STUNErrorCode.INSUFFICIENT_CAPACITY, "Insufficient Capacity");
                controlConnectionWriter.writeMessage(errorResponse);
            } else {
                // TODO listener tasks in threadpool, listener also in pool?
                logger.info("Created allocation on {}", peerSS.getLocalSocketAddress());
                SocketListener peerSocketListener = new SocketListener(peerSS, Executors.newCachedThreadPool(),
                        new PeerHandlerTaskFactory(connIDToQueue, controlConnectionWriter, relayExecutor));
                controlConnectionHandlerExecutor.execute(new RefreshMessageHandlerTask(controlConnection,
                        controlConnectionWriter, lifetime, peerSocketListener));
                peerSocketListener.start();
                Message successResponse = relayAllocationMessage.buildSuccessResponse();
                successResponse.addAttribute(new XorMappedAddress(new InetSocketAddress(peerSS.getInetAddress(), peerSS
                        .getLocalPort())));
                successResponse.addAttribute(new EndpointClass(EndpointCategory.RELAY));
                successResponse.addAttribute(new RelayingLifetime(lifetime));
View Full Code Here
99
100
101
102
103
104
105
    private SocketListener createSocketListener(final InetSocketAddress listenerAddress) throws IOException {
        final ServerSocket serverSocket = new ServerSocket();
        serverSocket.setReuseAddress(true);
        serverSocket.bind(listenerAddress);
        return new SocketListener(serverSocket, this.handleExecutor, this.handleMessageTaskFactory);
    }
View Full Code Here
80
81
82
83
84
85
86
87
88
89
        this.startUserCleaner();
    }

    private void startMessageHandler() throws Exception {
        final ServerSocket listenerSocket = new ServerSocket(this.listenerPort);
        final SocketListener socketListener = new SocketListener(listenerSocket, this.handlerExecutor,
                this.handleMessageTaskFactory);
        this.socketListenerExecutor.execute(socketListener);
        logger.info("Message handling started, mediator is listening on port {}", this.listenerPort); //$NON-NLS-1$
    }
View Full Code Here
TOP

Related Classes of de.fhkn.in.uce.core.socketlistener.SocketListener

  • de.fhkn.in.uce.mediator.Mediator
  • de.fhkn.in.uce.relaying.server.RelayAllocationHandler
  • de.fhkn.in.uce.relaying.server.RelayServer
  • de.fhkn.in.uce.stun.server.StunServer
  • java.net.InetSocketAddress
  • java.net.Socket
    • Copyright © 2018 www.massapicom. 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.