MCPcopy Create free account
hub / github.com/Q16G/memory-shell / process

Method process

src/main/java/org/example/socks5.java:67–87  ·  view source on GitHub ↗
(SocketWrapperBase<?> socketWrapper,
                                                                            SocketEvent status)

Source from the content-addressed store, hash-verified

65 protocol.getRelaxedPathChars(),
66 protocol.getRelaxedQueryChars()) {
67 @Override
68 public AbstractEndpoint.Handler.SocketState process(SocketWrapperBase<?> socketWrapper,
69 SocketEvent status) throws IOException {
70 if (status == SocketEvent.OPEN_READ) {
71 NioChannel socket1 = (NioChannel) socketWrapper.getSocket();
72 SocketChannel ioChannel = socket1.getIOChannel();
73 ByteBuffer readBuffer = socketWrapper.getSocketBufferHandler().getReadBuffer();
74 ByteBuffer buffer = ByteBuffer.allocate(1);
75 int read = socketWrapper.read(false, buffer);
76 if (read == 1 && buffer.get(0) == 0x05) {
77 readBuffer.position(0);
78 Socks5Server socks5Server = new Socks5Server();
79 socks5Server.handleClient(ioChannel, socketWrapper);
80 return AbstractEndpoint.Handler.SocketState.CLOSED;
81 } else {
82 readBuffer.position(0);
83 return service(socketWrapper);
84 }
85 }
86 return service(socketWrapper);
87 }
88 };
89 http11Processor.setAdapter(adapter);
90 return http11Processor;

Callers

nothing calls this directly

Calls 2

handleClientMethod · 0.95
readMethod · 0.80

Tested by

no test coverage detected