[jira] [Closed] (GEODE-1776) ExecuteRegionFunctionOp fails to read all data off the wire when an exception is sent with sendResult

["Swapnil Bawaskar (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/GEODE-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Swapnil Bawaskar closed GEODE-1776.
-----------------------------------

> ExecuteRegionFunctionOp fails to read all data off the wire when an exception is sent with sendResult
> -----------------------------------------------------------------------------------------------------
>
>                 Key: GEODE-1776
>                 URL: https://issues.apache.org/jira/browse/GEODE-1776
>             Project: Geode
>          Issue Type: Bug
>          Components: functions
>            Reporter: Dan Smith
>            Assignee: Dan Smith
>             Fix For: 1.0.0-incubating
>
>
> Executing the below code on a client will result in the function service not reading all of the data off the wire. The next message sent will receive serialization errors.
> {code}
>     ResultCollector rc = getExecution().execute((context) -> {
>         context.getResultSender().sendResult(new FunctionException());
>         context.getResultSender().lastResult("done");
>     });
>     final Object result = rc.getResult();
> {code}
> It looks like what is happening is that inside ExecuteRegionFunctionOp.processResponse, there is special handling to read multiple chunks until all of the results are received. Unfortunately, certain code paths like the one above with multiple results end up throwing an exception instead of reading all of the chunks. 
> Here's the relevant bits of code:
> {code}
> // Read the chunk
> do {
>   //...
>   if (result instanceof FunctionException) {
>     //...
>     //This will end the loop without reading the remaining data
>     throw ex;
>   }
>   //...
> } while (!executeFunctionResponseMsg.isLastChunk());
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)