From 7c49f715593ad7bbe0a4fb86284e2023f7b65bc1 Mon Sep 17 00:00:00 2001 From: Ondrej Filip Date: Mon, 14 Feb 2005 21:28:51 +0000 Subject: Added s->err_hook wrapper that empties socket. --- sysdep/unix/io.c | 21 ++++++++++++++------- 1 file changed, 14 insertions(+), 7 deletions(-) (limited to 'sysdep/unix/io.c') diff --git a/sysdep/unix/io.c b/sysdep/unix/io.c index 5ecc8ae..d34ff2f 100644 --- a/sysdep/unix/io.c +++ b/sysdep/unix/io.c @@ -75,6 +75,13 @@ tracked_fopen(pool *p, char *name, char *mode) return f; } +void +c_err_hook(struct birdsock *s, int err) +{ + s->ttx = s->tpos; /* empty tx buffer */ + s->err_hook(s, err); +} + /** * DOC: Timers * @@ -680,7 +687,7 @@ sk_passive_connected(sock *s, struct sockaddr *sa, int al, int type) else if (errno != EINTR && errno != EAGAIN) { log(L_ERR "accept: %m"); - s->err_hook(s, errno); + c_err_hook(s, errno); } return 0; } @@ -898,7 +905,7 @@ sk_maybe_write(sock *s) { if (errno != EINTR && errno != EAGAIN) { - s->err_hook(s, errno); + c_err_hook(s, errno); return -1; } return 0; @@ -923,7 +930,7 @@ sk_maybe_write(sock *s) { if (errno != EINTR && errno != EAGAIN) { - s->err_hook(s, errno); + c_err_hook(s, errno); return -1; } return 0; @@ -1001,10 +1008,10 @@ sk_read(sock *s) if (c < 0) { if (errno != EINTR && errno != EAGAIN) - s->err_hook(s, errno); + c_err_hook(s, errno); } else if (!c) - s->err_hook(s, 0); + c_err_hook(s, 0); else { s->rpos += c; @@ -1029,7 +1036,7 @@ sk_read(sock *s) if (e < 0) { if (errno != EINTR && errno != EAGAIN) - s->err_hook(s, errno); + c_err_hook(s, errno); return 0; } s->rpos = s->rbuf + e; @@ -1052,7 +1059,7 @@ sk_write(sock *s) if (connect(s->fd, (struct sockaddr *) &sa, sizeof(sa)) >= 0 || errno == EISCONN) sk_tcp_connected(s); else if (errno != EINTR && errno != EAGAIN && errno != EINPROGRESS) - s->err_hook(s, errno); + c_err_hook(s, errno); return 0; } default: -- cgit v1.2.3