Salut,
fixed. Can you try it and let us know? We can cut 1.9.2 just for that :-)
A+
-- Jeanfrabcois
Oleksiy Stashok wrote:
> Hi,
>
> The problem is that connection is getting expired on server side and it
> closes it.
> As workaround we can add this to the server side, when initializing
> SelectorThread:
> sel.setKeepAliveTimeoutInSeconds(Integer.MAX_VALUE);
>
> We've create issue [1].
> And Jeanfrancois will fix that ASAP.
>
> Thanks.
>
> WBR,
> Alexey.
>
> [1] https://grizzly.dev.java.net/issues/show_bug.cgi?id=355
>
>>
>> Hello,
>>
>> In order to help finding what's going wrong with my implementation I
>> simplified as much as I can.
>> So I obtained a unique class that contain 2 static classes.
>> My server part is a 198 lines long class that contain 2 static classes.
>> With this simple testcase I also reproduce the problems that I encounter.
>>
>> Here is the code of my simple server class. I also put in attachment my
>> complete project that contain a client part.
>> http://www.nabble.com/file/p20837112/arp-tries2.zip arp-tries2.zip
>> ------------------------------------------------------------------------------------------------
>> package com.grizzly.test.arp.server;
>>
>> import java.io.IOException;
>> import java.util.concurrent.ExecutorService;
>> import java.util.concurrent.Executors;
>>
>> import com.sun.grizzly.arp.AsyncExecutor;
>> import com.sun.grizzly.arp.AsyncFilter;
>> import com.sun.grizzly.arp.AsyncHandler;
>> import com.sun.grizzly.arp.AsyncTask;
>> import com.sun.grizzly.arp.DefaultAsyncHandler;
>> import com.sun.grizzly.http.DefaultProcessorTask;
>> import com.sun.grizzly.http.SelectorThread;
>> import com.sun.grizzly.tcp.ActionCode;
>> import com.sun.grizzly.tcp.Adapter;
>> import com.sun.grizzly.tcp.OutputBuffer;
>> import com.sun.grizzly.tcp.Request;
>> import com.sun.grizzly.tcp.Response;
>> import com.sun.grizzly.util.buf.ByteChunk;
>>
>> /**
>> * Original code comes from
>> http://kasparov.skife.org/blog/src/java/grizzly-arp-basic.html
>> *
>> * @author Brian McCallister
>> * @author evrignaud
>> */
>> public class SimpleArpServer
>> {
>> public static final String CALLBACK_KEY =
>> "com.grizzly.test.arp.server.FINISH_REQUEST";
>>
>> public static void main(String[] args) throws IOException,
>> InstantiationException
>> {
>> System.out.println("Starting arp-tries2 testcase");
>>
>> SelectorThread sel = new SelectorThread();
>> sel.setPort(8080);
>>
>> sel.setAdapter(new ViewAdapter());
>>
>> final AsyncHandler handler = new DefaultAsyncHandler();
>> handler.addAsyncFilter(new AsyncFilter()
>> {
>> public boolean doFilter(final AsyncExecutor executor)
>> {
>> final AsyncTask asyncTask = executor.getAsyncTask();
>> final AsyncHandler asyncHandler =
>> executor.getAsyncHandler();
>>
>> final DefaultProcessorTask processorTask =
>> (DefaultProcessorTask) executor.getProcessorTask();
>> Request req = processorTask.getRequest();
>> if (req.requestURI().toString().equals("/refreshView"))
>> {
>> req.setAttribute(CALLBACK_KEY, new Runnable()
>> {
>> public void run()
>> {
>> asyncHandler.handle(asyncTask);
>> }
>> });
>> processorTask.invokeAdapter();
>> return false;
>> }
>> return true;
>> }
>> });
>> sel.setAsyncHandler(handler);
>> sel.setEnableAsyncExecution(true);
>> sel.setDisplayConfiguration(true);
>> sel.initEndpoint();
>> sel.startEndpoint();
>> }
>>
>> private static final ExecutorService exec =
>> Executors.newFixedThreadPool(30);
>>
>> static class ViewAdapter implements Adapter
>> {
>> public void service(Request req, Response res) throws Exception
>> {
>> if (req.requestURI().toString().equals("/refreshView") ==
>> false)
>> {
>> res.setStatus(400);
>>
>> byte[] bytes = ByteChunk.convertToBytes("Bad request !\n");
>> ByteChunk chunk = new ByteChunk();
>> res.setContentLength(bytes.length);
>> res.setContentType("text/plain");
>> chunk.append(bytes, 0, bytes.length);
>> res.doWrite(chunk);
>> return;
>> }
>>
>> exec.execute(new Refresher(req));
>> }
>>
>> public void afterService(Request req, Response res) throws
>> Exception
>> {
>> req.action(ActionCode.ACTION_POST_REQUEST, null);
>> }
>> }
>>
>> static class Refresher implements Runnable
>> {
>> private Request req;
>>
>> private Refresher(Request req)
>> {
>> this.req = req;
>> }
>>
>> @Override
>> public void run()
>> {
>> try
>> {
>> Response res = req.getResponse();
>> res.setContentType("text/xml");
>>
>> res.addHeader("Cache-Control", "private");
>> res.addHeader("Pragma", "no-cache");
>> res.setCharacterEncoding("UTF-8");
>>
>> String viewId = req.getParameters().getParameter("viewId");
>> System.out.println("Refresh for view: " + viewId);
>>
>> for (int resultNumber = 0; resultNumber < 30;
>> resultNumber++)
>> {
>> Thread.sleep(3000);
>>
>> String result = "";
>> result += "<?xml version=\"1.0\"
>> encoding=\"windows-1252\"?>\n";
>> result += "<QueryResult>\n";
>> result += "\t<name>result" + resultNumber +
>> "</name>\n";
>> result += "\t<viewId>" + viewId + "</viewId>\n";
>> result += "</QueryResult>\n";
>>
>> sendData(req, result);
>> }
>>
>> terminateResponse(req);
>> }
>> catch (Exception ex)
>> {
>> System.out.println(ex);
>> }
>> }
>>
>> public void terminateResponse(Request request) throws IOException
>> {
>> // Terminate the response.
>> streamChunk(null, request.getResponse().getOutputBuffer(),
>> request.getResponse());
>>
>> request.getResponse().setStatus(200);
>>
>> // Really terminate the request
>> Runnable completion = (Runnable)
>> request.getAttribute(SimpleArpServer.CALLBACK_KEY);
>> completion.run();
>> }
>>
>> public void sendData(Request request, String data) throws
>> IOException
>> {
>> try
>> {
>> Response response = request.getResponse();
>> streamChunk(data.getBytes(), response.getOutputBuffer(),
>> response);
>> }
>> catch (IOException e)
>> {
>> throw e;
>> }
>> catch (Exception e)
>> {
>> throw new IOException(e);
>> }
>> }
>>
>> private static final byte[] CRLF_BYTES = { (byte) 13, (byte) 10 };
>> private static final byte ZERO_BYTE = (byte) 48;
>>
>> private void streamChunk(byte[] bytes, OutputBuffer output,
>> Response
>> response) throws IOException
>> {
>> ByteChunk chunk = new ByteChunk();
>> if ((bytes != null) && (bytes.length > 0))
>> {
>> byte[] chunkLength =
>> Integer.toHexString(bytes.length).getBytes("ASCII");
>> chunk.append(chunkLength, 0, chunkLength.length);
>> chunk.append(CRLF_BYTES, 0, CRLF_BYTES.length);
>> chunk.append(bytes, 0, bytes.length);
>> chunk.append(CRLF_BYTES, 0, CRLF_BYTES.length);
>> }
>> else
>> { // Send final 'EOF' chunk for the response.
>> chunk.append(ZERO_BYTE);
>> chunk.append(CRLF_BYTES, 0, CRLF_BYTES.length);
>> }
>> output.doWrite(chunk, response);
>> response.flush();
>> }
>> }
>> }
>> ------------------------------------------------------------------------------------------------
>>
>> Thanks for your help,
>> Regards,
>> Etienne VRIGNAUD
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Need-help-on-ARP-usage-tp20789925p20837112.html
>> Sent from the Grizzly - Users mailing list archive at Nabble.com.
>>
>>
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
>> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>>
>