Method run

src/main/java/core/packetproxy/ProxyUDPForward.java:36–57

()

	}

	@Override
	public void run() {
		try {

			while (true) {

				Endpoint client_endpoint = listen_socket.accept();
				log("accept");

				InetSocketAddress serverAddr = listen_info.getServer().getAddress();
				UDPSocketEndpoint server_endpoint = new UDPSocketEndpoint(serverAddr);

				DuplexAsync duplex = DuplexFactory.createDuplexAsync(client_endpoint, server_endpoint,
						listen_info.getServer().getEncoder());
				duplex.start();
				DuplexManager.getInstance().registerDuplex(duplex);
			}
		} catch (Exception e) {

			errWithStackTrace(e);
		}
	}

	public void close() throws Exception {
		listen_socket.close();