csp->http->hostport);
}
else if (((csp->flags & CSP_FLAG_PIPELINED_REQUEST_WAITING) == 0)
- && (flush_socket(csp->server_connection.sfd, csp->client_iob, 0) < 0))
+ && (flush_iob(csp->server_connection.sfd, csp->client_iob, 0) < 0))
{
write_failure = 1;
log_error(LOG_LEVEL_CONNECT, "Failed sending request body to: %s: %E",
hdrlen = strlen(hdr);
if (write_socket_delayed(csp->cfd, hdr, hdrlen, write_delay)
- || ((flushed = flush_socket(csp->cfd, csp->iob,
- write_delay) < 0)
+ || ((flushed = flush_iob(csp->cfd, csp->iob, write_delay) < 0)
|| (write_socket_delayed(csp->cfd, csp->receive_buffer,
(size_t)len, write_delay))))
{
*/
if (write_socket_delayed(csp->cfd, hdr, strlen(hdr), write_delay)
- || ((len = flush_socket(csp->cfd, csp->iob, write_delay)) < 0))
+ || ((len = flush_iob(csp->cfd, csp->iob, write_delay)) < 0))
{
log_error(LOG_LEVEL_CONNECT, "write header to client failed: %E");
/*********************************************************************
*
- * Function : flush_socket
+ * Function : flush_iob
*
* Description : Write any pending "buffered" content.
*
* file, the results are not portable.
*
*********************************************************************/
-long flush_socket(jb_socket fd, struct iob *iob, unsigned int delay)
+long flush_iob(jb_socket fd, struct iob *iob, unsigned int delay)
{
long len = iob->eod - iob->cur;
#define FILTER_CLIENT_HEADERS 0
#define FILTER_SERVER_HEADERS 1
-extern long flush_socket(jb_socket fd, struct iob *iob, unsigned int delay);
+extern long flush_iob(jb_socket fd, struct iob *iob, unsigned int delay);
extern jb_err add_to_iob(struct iob *iob, const size_t buffer_limit, char *src, long n);
extern void clear_iob(struct iob *iob);
extern jb_err decompress_iob(struct client_state *csp);