"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "src/stream_interface.c" between
haproxy-2.2.1.tar.gz and haproxy-2.2.2.tar.gz

About: HAProxy is a TCP/HTTP reverse proxy which is particularly suited for high availability environments.

stream_interface.c  (haproxy-2.2.1):stream_interface.c  (haproxy-2.2.2)
skipping to change at line 659 skipping to change at line 659
} }
/* We're already waiting to be able to send, give up */ /* We're already waiting to be able to send, give up */
if (si->wait_event.events & SUB_RETRY_SEND) if (si->wait_event.events & SUB_RETRY_SEND)
return 0; return 0;
/* we might have been called just after an asynchronous shutw */ /* we might have been called just after an asynchronous shutw */
if (oc->flags & CF_SHUTW) if (oc->flags & CF_SHUTW)
return 1; return 1;
/* we must wait because the mux is not installed yet */
if (!conn->mux)
return 0;
if (oc->pipe && conn->xprt->snd_pipe && conn->mux->snd_pipe) { if (oc->pipe && conn->xprt->snd_pipe && conn->mux->snd_pipe) {
ret = conn->mux->snd_pipe(cs, oc->pipe); ret = conn->mux->snd_pipe(cs, oc->pipe);
if (ret > 0) if (ret > 0)
did_send = 1; did_send = 1;
if (!oc->pipe->data) { if (!oc->pipe->data) {
put_pipe(oc->pipe); put_pipe(oc->pipe);
oc->pipe = NULL; oc->pipe = NULL;
} }
skipping to change at line 1217 skipping to change at line 1221
/* If another call to si_cs_recv() failed, and we subscribed to /* If another call to si_cs_recv() failed, and we subscribed to
* recv events already, give up now. * recv events already, give up now.
*/ */
if (si->wait_event.events & SUB_RETRY_RECV) if (si->wait_event.events & SUB_RETRY_RECV)
return 0; return 0;
/* maybe we were called immediately after an asynchronous shutr */ /* maybe we were called immediately after an asynchronous shutr */
if (ic->flags & CF_SHUTR) if (ic->flags & CF_SHUTR)
return 1; return 1;
/* we must wait because the mux is not installed yet */
if (!conn->mux)
return 0;
/* stop here if we reached the end of data */ /* stop here if we reached the end of data */
if (cs->flags & CS_FL_EOS) if (cs->flags & CS_FL_EOS)
goto end_recv; goto end_recv;
/* stop immediately on errors. Note that we DON'T want to stop on /* stop immediately on errors. Note that we DON'T want to stop on
* POLL_ERR, as the poller might report a write error while there * POLL_ERR, as the poller might report a write error while there
* are still data available in the recv buffer. This typically * are still data available in the recv buffer. This typically
* happens when we send too large a request to a backend server * happens when we send too large a request to a backend server
* which rejects it before reading it all. * which rejects it before reading it all.
*/ */
 End of changes. 2 change blocks. 
0 lines changed or deleted 8 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)