Hello Jeanfrancois,
Thanks for the fix, it seems to be working fine.
Now I have a problem reading actuall data from the request
I took ArpSSLTest and tried to implement reading of request data.
here is my code for the MyAsyncFilter inner class
private class MyAsyncFilter implements AsyncFilter {
public boolean doFilter(AsyncExecutor executor) {
System.out.println("DO_FILTER");
AsyncTask asyncTask = executor.getAsyncTask();
AsyncHandler asyncHandler = executor.getAsyncHandler();
DefaultProcessorTask processorTask = (DefaultProcessorTask)
asyncTask.getProcessorTask();
Request request = processorTask.getRequest();
String requestURI = request.requestURI().toString();
System.out.println("New incoming to service: " + requestURI);
int contentLenght = request.getContentLength();
System.out.println("CONTENT LENGHT - "+contentLenght);
ByteChunk byteChunk = new ByteChunk(contentLenght);
String inStr = "";
try {
int readBytes = 0;
while ( readBytes < contentLenght ) {
readBytes += request.doRead( byteChunk );
inStr += byteChunk.toString();
}
} catch ( IOException e ) {
e.printStackTrace();
}
System.out.println(inStr);
processorTask.invokeAdapter();
return false;
}
}
As and output of these system out's I get
DO_FILTER
New incoming to service: /
CONTENT LENGHT - 14
Here as a last line I get 14 squares printed
So System.out.println(inStr); does not print out
Hello. Client#
but instead I get wierd output.
Also I was debugging and something strange happened,
I don't understand what is going on.
If I put debug poing on System.out.println(inStr); line
run in debug mode and stop at that line and do not continue.
After some time second
DO_FILTER
New incoming to service: /
CONTENT LENGHT - 14
are printed, then I continue debugging and I get those squares printed again
and finially I get
Hello. Client# printed out. Here is full output after this kind of
debugging.(squres won't paste, I think these are zero bytes)
DO_FILTER
New incoming to service: /
CONTENT LENGHT - 14
DO_FILTER
New incoming to service: /
CONTENT LENGHT - 14
//here 14 squares get printed out
Hello. Client#
I'm now sure what is going on, I'm completly new with using SSL,
can you give me a pointer or help me how to read data coming with the
request?
Also I tried running without arp with my EmbeddedSSLServer I posted in that
previous post,
funny thing happens, I go to
https://localhost:8282/test?dgfd=eee
browser prompts me for certificate and after that in my Adapters service
method I get
CONTENT LENGHT = -1
Same thing happens without SSL support, so I guess I'm not aproaching
reading of the reqest data in the right manner, is there any example for it?
Thanks.
Jeanfrancois Arcand-2 wrote:
>
> Salut,
>
> fixed!
>
> Thanks!
>
> -- jeanfrancois
>
> Jeanfrancois Arcand wrote:
>> Salut,
>>
>> OK working on it. Fix for tonight :-)
>>
>> A+
>>
>> -- Jeanfrancois
>>
>> Danijel wrote:
>>> Salut Jeanfrancois,
>>>
>>> I posted the issues it's #93.
>>> Thanks for your help, can't wait for the bug fix, it's kind of holding
>>> me
>>> down on continuing my grizzly usage.
>>>
>>> --
>>> Danijel
>>>
>>>
>>> Jeanfrancois Arcand-2 wrote:
>>>> Salut,
>>>>
>>>> Danijel wrote:
>>>>> Hello,
>>>>>
>>>>> I'm trying to do some async request processing, but I get an error.
>>>>>
>>>>> I tried to code some ARP using Brian McCallister example
>>>>> (http://kasparov.skife.org/blog/src/java/grizzly-arp-basic.html) as a
>>>>> starting point, I added some of my own code like a ResumeThead and
>>>>> TransactionHandler so that I can send response before scheduler call
>>>>> if I
>>>>> have a response ready.
>>>>>
>>>>> Now, my code works fine in a HTTP version, but same code in a HTTPS
>>>>> version
>>>>> fails and throws SEVERE
>>>>> exception, only difference beetween the two is that HTTPS version uses
>>>>> SSLSelectorThread.
>>>>
>>>>
>>>>
>>>>> I tested this both with grizzly-http-webserver jars in version 1.7.1
>>>>> and
>>>>> 1.7.2.
>>>>>
>>>>> Finally I downloaded 1.7.2 source code from SVN and did some
>>>>> debugging.
>>>>>
>>>>> Here what I found:
>>>>>
>>>>> When execution comes to DefaultProtocolChain::executeProtocolFilter
>>>>> method I
>>>>> see that in my protocol chain there are 2 filters SSLReadFilter and
>>>>> SSLAsyncProtocolFilter
>>>>>
>>>>> SSLReadFilter executes fine but SSLAsyncProtocolFilter fails,
>>>>> and it fails in AsyncProtocolFilter:: execute method at
>>>>> nextBuffer.clear();
>>>>>
>>>>> /**
>>>>> * Switch ByteBuffer since we are asynchronous.
>>>>> */
>>>>> ByteBuffer nextBuffer = inputStream.getByteBuffer();
>>>>> nextBuffer.clear();
>>>>>
>>>>> This inputStream.getByteBuffer(); returns null, and there for I get
>>>>> NullPointerException
>>>>> inputStream's inputBB buffer exists but byteBuffer does not, it's null
>>>>>
>>>>> Any ideas how to solve this?
>>>>>
>>>>> I'll put code of my main SSLApp class below and here is my output.
>>>> Looks like a bug. Can you file an issue here:
>>>>
>>>> https://grizzly.dev.java.net/issues/
>>>>
>>>> so this time I don't forget to reply.
>>>>
>>>> I will take a look as soon as possible...I'm at a php conference and
>>>> well, this is a little boring so I might fix the issue today. If not,
>>>> tomorrow for sure as your issue is most probably reproducible using
>>>> GlassFish v3, which means they will file an issue as well :-)!
>>>>
>>>> A+
>>>>
>>>> -- Jeanfrancois
>>>>
>>>>
>>>>
>>>>
>>>>
>>>>> Mar 12, 2008 7:49:39 PM com.sun.grizzly.http.SelectorThread
>>>>> displayConfiguration
>>>>> INFO: Grizzly configuration for port 8282
>>>>> maxThreads: 5
>>>>> minThreads: 5
>>>>> ByteBuffer size: 8192
>>>>> useDirectByteBuffer: false
>>>>> useByteBufferView: false
>>>>> maxHttpHeaderSize: 8192
>>>>> maxKeepAliveRequests: 256
>>>>> keepAliveTimeoutInSeconds: 30
>>>>> Static File Cache enabled: true
>>>>> Stream Algorithm :
>>>>> com.sun.grizzly.http.algorithms.NoParsingAlgorithm
>>>>> Pipeline : com.sun.grizzly.http.LinkedListPipeline
>>>>> Round Robin Selector Algorithm enabled: false
>>>>> Round Robin Selector pool size: 0
>>>>> recycleTasks: true
>>>>> Asynchronous Request Processing enabled: true
>>>>> Mar 12, 2008 7:51:00 PM com.sun.grizzly.DefaultProtocolChain
>>>>> executeProtocolFilter
>>>>> SEVERE: ProtocolChain exception
>>>>> java.lang.NullPointerException
>>>>> at
>>>>> com.sun.grizzly.arp.AsyncProtocolFilter.execute(AsyncProtocolFilter.java:136)
>>>>>
>>>>> at
>>>>> com.sun.grizzly.DefaultProtocolChain.executeProtocolFilter(DefaultProtocolChain.java:101)
>>>>>
>>>>> at
>>>>> com.sun.grizzly.DefaultProtocolChain.execute(DefaultProtocolChain.java:78)
>>>>>
>>>>> at
>>>>> com.sun.grizzly.http.SelectorThread$1.execute(SelectorThread.java:669)
>>>>> at
>>>>> com.sun.grizzly.ProtocolChainContextTask.doCall(ProtocolChainContextTask.java:54)
>>>>>
>>>>> at
>>>>> com.sun.grizzly.SelectionKeyContextTask.call(SelectionKeyContextTask.java:57)
>>>>>
>>>>> at
>>>>> com.sun.grizzly.util.WorkerThreadImpl.run(WorkerThreadImpl.java:179)
>>>>>
>>>>>
>>>>>
>>>>> import java.io.IOException;
>>>>> import java.util.HashMap;
>>>>> import java.util.concurrent.ArrayBlockingQueue;
>>>>>
>>>>> import com.sun.grizzly.SSLConfig;
>>>>> import com.sun.grizzly.arp.DefaultAsyncHandler;
>>>>> import com.sun.grizzly.http.AsyncExecutor;
>>>>> import com.sun.grizzly.http.AsyncFilter;
>>>>> import com.sun.grizzly.http.AsyncHandler;
>>>>> import com.sun.grizzly.http.AsyncTask;
>>>>> import com.sun.grizzly.http.DefaultProcessorTask;
>>>>> import com.sun.grizzly.http.SelectorThread;
>>>>> import com.sun.grizzly.ssl.SSLSelectorThread;
>>>>> import com.sun.grizzly.util.buf.ByteChunk;
>>>>> import com.sun.grizzly.util.net.jsse.JSSEImplementation;
>>>>>
>>>>> public class SSLApp {
>>>>> public static ArrayBlockingQueue<NameValue> msgs = new
>>>>> ArrayBlockingQueue<NameValue>( 100 );
>>>>> public static HashMap<String, TransactionHandler> map = new
>>>>> HashMap<String,
>>>>> TransactionHandler>();
>>>>> public static String TRAN_ID = "ID";
>>>>> static long count = 0;
>>>>> public static void main( String[] args ) {
>>>>> SSLApp app = new SSLApp();
>>>>> ServerStarter ss = app.new ServerStarter();
>>>>> ss.start();
>>>>> ResumerThread resThread = new ResumerThread();
>>>>> resThread.start();
>>>>> }
>>>>>
>>>>> public class ServerStarter extends Thread {
>>>>> private SSLConfig sslConfig;
>>>>>
>>>>> private void setUp() {
>>>>> sslConfig = new SSLConfig();
>>>>> // override system properties
>>>>> sslConfig.setTrustStoreFile("c:/temp/key/ssltest-cacerts.jks");
>>>>> sslConfig.setKeyStoreFile("c:/temp/key/ssltest-keystore.jks");
>>>>> }
>>>>> private SelectorThread createSelectorThread(int port) {
>>>>> SSLSelectorThread selectorThread = new SSLSelectorThread();
>>>>> selectorThread.setPort(port);
>>>>> SSLSelectorThread.setWebAppRootPath( "/dev/null" );
>>>>> selectorThread.setSSLConfig(sslConfig);
>>>>> try {
>>>>> selectorThread.setSSLImplementation( new
>>>>> JSSEImplementation() );
>>>>> } catch ( ClassNotFoundException e ) {
>>>>> // TODO Auto-generated catch block
>>>>> e.printStackTrace();
>>>>> }
>>>>> AsyncHandler handler = new DefaultAsyncHandler();
>>>>> handler.addAsyncFilter( new MyAsyncFilter() );
>>>>> selectorThread.setAsyncHandler( handler );
>>>>> selectorThread.setEnableAsyncExecution( true );
>>>>> selectorThread.setAdapter( new MyAdapter() );
>>>>> return selectorThread;
>>>>> }
>>>>> @Override
>>>>> public void run() {
>>>>> setUp();
>>>>> SelectorThread sel = createSelectorThread( 8282 );
>>>>> sel.setDisplayConfiguration( true );
>>>>> try {
>>>>> sel.initEndpoint();
>>>>> sel.startEndpoint();
>>>>> } catch ( IOException e ) {
>>>>> e.printStackTrace();
>>>>> } catch ( InstantiationException e ) {
>>>>> e.printStackTrace();
>>>>> }
>>>>> }
>>>>> }
>>>>> private class MyAsyncFilter implements AsyncFilter {
>>>>> public boolean doFilter( AsyncExecutor executor ) {
>>>>> System.out.println("DO_FILTER");
>>>>> AsyncTask asyncTask = executor.getAsyncTask();
>>>>> AsyncHandler asyncHandler = executor.getAsyncHandler();
>>>>> DefaultProcessorTask processorTask =
>>>>> (DefaultProcessorTask)
>>>>> executor.getAsyncTask().getProcessorTask();
>>>>> int contentLenght =
>>>>> processorTask.getRequest().getContentLength();
>>>>> ByteChunk byteChunk = new ByteChunk();
>>>>> byteChunk.setLimit( contentLenght );
>>>>> try {
>>>>> processorTask.getRequest().doRead( byteChunk );
>>>>> } catch ( IOException e ) {
>>>>> e.printStackTrace();
>>>>> }
>>>>> String requestURI =
>>>>> processorTask.getRequest().requestURI().toString();
>>>>> System.out.println("New incoming to service: " +
>>>>> getService(
>>>>> requestURI
>>>>> ));
>>>>> String inStr = byteChunk.toString();
>>>>> TransactionHandler transHandler = new
>>>>> TransactionHandler();
>>>>> transHandler.setMsg( inStr );
>>>>> transHandler.setRunnable( new MyRunnable( asyncHandler,
>>>>> asyncTask ) );
>>>>> map.put( Long.toString( count), transHandler );
>>>>> processorTask.getRequest().setAttribute( TRAN_ID,
>>>>> Long.toString(
>>>>> count)
>>>>> );
>>>>> processorTask.invokeAdapter();
>>>>> return false;
>>>>> }
>>>>> }
>>>>>
>>>>> /**
>>>>> * Get the service that is mapped to the specified request.
>>>>> */
>>>>> private String getService( String uri ) {
>>>>> if ( uri == null )
>>>>> return "";
>>>>> String serviceName="";
>>>>> if ( uri.startsWith( "/" ) ) {
>>>>> serviceName = uri.substring( 1 );
>>>>> } else {
>>>>> serviceName = uri;
>>>>> }
>>>>> return serviceName;
>>>>> }
>>>>> }
>>>>>
>>>>> -----
>>>>> --
>>>>> Danijel
>>>> ---------------------------------------------------------------------
>>>> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
>>>> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>>>>
>>>>
>>>>
>>>
>>>
>>> -----
>>> --
>>> Danijel
>>
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
>> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>
>
>
-----
--
Danijel
--
View this message in context: http://www.nabble.com/SEVERE%3A-ProtocolChain-exception---ARP-over-HTTPS-problem-tp16012530p16048623.html
Sent from the Grizzly - Users mailing list archive at Nabble.com.