Method run

src/main/java/core/packetproxy/Simplex.java:194–314

()

	}

	@Override
	public void run() {
		if (in == null) {

			return;
		}
		ByteArrayOutputStream bout = new ByteArrayOutputStream();
		ExecutorService executor = Executors.newSingleThreadExecutor();
		Callable<Integer> readTask = new Callable<Integer>() {

			public Integer call() throws Exception {
				int ret;
				try {

					ret = in.read(input_data);
				} catch (SSLException e) {

					// System.err.println(String.format("SSLException: %s", e.getMessage()));
					ret = -1; // should be finished
				} catch (SocketException e) {

					// System.err.println(String.format("SocketException: %s", e.getMessage()));
					ret = -1; // should be finished
				}
				return ret;
			}
		};

		try {

			while (!flag_break_loop) {

				Future<Integer> future = executor.submit(readTask);
				int timeout = bout.size() > 0 ? TIMEOUT : 24 * 60 * 60 * 1000;
				int length = future.get(timeout, TimeUnit.MILLISECONDS);
				if (length == -1) {

					break;
				}

				bout.write(input_data, 0, length);
				while (bout.size() > 0) {

					int accepted_input_size = callOnPacketReceived(bout.toByteArray());
					if (accepted_input_size < 0 || accepted_input_size > bout.size()) {

						break;
					}
					byte[] accepted_array = ArrayUtils.subarray(bout.toByteArray(), 0, accepted_input_size);
					byte[] unaccepted_array = ArrayUtils.subarray(bout.toByteArray(), accepted_input_size, bout.size());
					bout.reset();
					bout.write(unaccepted_array);

					callOnChunkArrived(accepted_array);

					for (byte[] pass_through_data = callOnChunkPassThrough(); pass_through_data != null
							&& pass_through_data.length > 0; pass_through_data = callOnChunkPassThrough()) {