|
|
@ -366,8 +366,6 @@ void *sender(void *arg) |
|
|
|
while (sender_send->len) { |
|
|
|
while (sender_send->len) { |
|
|
|
ret = send(fd, sender_send->buf + ofs, sender_send->len , 0); |
|
|
|
ret = send(fd, sender_send->buf + ofs, sender_send->len , 0); |
|
|
|
if (unlikely(ret < 0)) { |
|
|
|
if (unlikely(ret < 0)) { |
|
|
|
if (interrupted()) |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
LOGWARNING("Client id %d disconnected", client->id); |
|
|
|
LOGWARNING("Client id %d disconnected", client->id); |
|
|
|
invalidate_client(ckp, ci, client); |
|
|
|
invalidate_client(ckp, ci, client); |
|
|
|
break; |
|
|
|
break; |
|
|
|