Try to find if the current connection is using the HTTP protocol.
SelectionKey key = protocolInfo.key;
SocketChannel socketChannel = (SocketChannel)key.channel();
ByteBuffer byteBuffer = protocolInfo.byteBuffer;
int loop = 0;
int bufferSize = 0;
int count = -1;
if (protocolInfo.bytesRead == 0) {
try {
while ( socketChannel.isOpen() &&
((count = socketChannel.read(byteBuffer))> -1)){
if ( count == 0 ){
loop++;
if (loop > 2){
break;
}
continue;
}
}
} catch (IOException ex){
;
} finally {
protocolInfo.bytesRead = count;
if ( count == -1 ){
return;
}
}
}
boolean isFound = false;
int curPosition = byteBuffer.position();
int curLimit = byteBuffer.limit();
// Rule a - If nothing, return to the Selector.
if (byteBuffer.position() == 0){
protocolInfo.byteBuffer = byteBuffer;
return;
}
byteBuffer.position(0);
byteBuffer.limit(curPosition);
int state=0;
int start=0;
int end= 0;
try {
byte c;
// Rule b - try to determine the context-root
while(byteBuffer.hasRemaining()) {
c = byteBuffer.get();
// State Machine
// 0 - Search for the first SPACE ' ' between the method and the
// the request URI
// 1 - Search for the second SPACE ' ' between the request URI
// and the method
switch(state) {
case 0: // Search for first ' '
if (c == 0x20){
state = 1;
start = byteBuffer.position();
}
break;
case 1: // Search for next ' '
if (c == 0x20){
state = 2;
end = byteBuffer.position() - 1;
byteBuffer.position(start);
byte[] requestURI = new byte[end-start];
byteBuffer.get(requestURI);
protocolInfo.requestURI = new String(requestURI);
}
break;
case 2: // Search for /
if (c == 0x2f){
protocolInfo.protocol =
protocolInfo.isSecure?"https":"http";
protocolInfo.byteBuffer = byteBuffer;
protocolInfo.socketChannel =
(SocketChannel)key.channel();
return;
}
break;
default:
throw new IllegalArgumentException("Unexpected state");
}
}
} catch (BufferUnderflowException bue) {
} finally {
byteBuffer.limit(curLimit);
byteBuffer.position(curPosition);
protocolInfo.bytesRead = byteBuffer.position();
}
return;
