sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-24 21:34:56 +03:00
Code

tsocket/bsd: also ask for TEVENT_FD_READ when we want to write into a stream socket

Browse Source 
Otherwise we would not notice a broken connection.

metze
This commit is contained in:
Stefan Metzmacher 2009-06-29 13:13:05 +02:00
parent b1d5e515b2
commit 857ed9ca5a
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/tsocket/tsocket_bsd.c
View File

@ -1292,6 +1292,10 @@ static void tstream_bsd_fde_handler(struct tevent_context *ev,
}
if (flags & TEVENT_FD_READ) {
if (!bsds->readable_handler) {
if (bsds->writeable_handler) {
bsds->writeable_handler(bsds->writeable_private);
return;
}
TEVENT_FD_NOT_READABLE(bsds->fde);
return;
}
@ -1387,7 +1391,8 @@ static int tstream_bsd_set_writeable_handler(struct tstream_bsd *bsds,
TALLOC_FREE(bsds->fde);
bsds->fde = tevent_add_fd(ev, bsds,
bsds->fd, TEVENT_FD_WRITE,
bsds->fd,
TEVENT_FD_READ | TEVENT_FD_WRITE,
tstream_bsd_fde_handler,
bsds);
if (!bsds->fde) {
@ -1398,7 +1403,9 @@ static int tstream_bsd_set_writeable_handler(struct tstream_bsd *bsds,
/* cache the event context we're running on */
bsds->event_ptr = ev;
} else if (!bsds->writeable_handler) {
TEVENT_FD_WRITEABLE(bsds->fde);
uint16_t flags = tevent_fd_get_flags(bsds->fde);
flags |= TEVENT_FD_READ | TEVENT_FD_WRITE;
tevent_fd_set_flags(bsds->fde, flags);
}
bsds->writeable_handler = handler;