Method run

src/main/java/fielded/webserver/NanoHTTPD.java:100–135

()

		myThread = new Thread(new Runnable() {
			@Override
			public void run() {
				do {
					try {
						final Socket finalAccept = myServerSocket.accept();
						registerConnection(finalAccept);
						finalAccept.setSoTimeout(SOCKET_READ_TIMEOUT);
						final InputStream inputStream = finalAccept.getInputStream();
						asyncRunner.exec(new Runnable() {
							@Override
							public void run() {
								OutputStream outputStream = null;
								try {
									outputStream = finalAccept.getOutputStream();
									HTTPSession session = new HTTPSession(inputStream, outputStream, finalAccept.getInetAddress());
									while (!finalAccept.isClosed()) {
										session.execute();
									}
								} catch (Exception e) {
									// When the socket is closed by the client, we throw our own SocketException
									// to break the  "keep alive" loop above.
									if (!(e instanceof SocketException && "NanoHttpd Shutdown".equals(e.getMessage()))) {
										e.printStackTrace();
									}
								} finally {
									safeClose(outputStream);
									safeClose(inputStream);
									safeClose(finalAccept);
									unRegisterConnection(finalAccept);
								}
							}
						});
					} catch (IOException e) {
					}
				} while (!myServerSocket.isClosed());
			}
		});
		myThread.setDaemon(true);
		myThread.setName("NanoHttpd Main Listener");