mirrors/byedpi
1
0
Fork 0
mirror of https://github.com/hufrea/byedpi.git synced 2024-11-20 04:22:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

set POLLRDHUP flag

Browse Source
This commit is contained in:
ruti 2024-05-10 02:30:17 +03:00
parent 47aad58e7c
commit e3be71ea46
2 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
conev.c
View File

@ -65,7 +65,7 @@ struct eval *add_event(struct poolhd *pool, enum eid type,
struct pollfd *pfd = &(pool->pevents[pool->count]);
pfd->fd = fd;
pfd->events = e;
pfd->events = POLLRDHUP | e;
pfd->revents = 0;
#endif
@ -76,12 +76,13 @@ struct eval *add_event(struct poolhd *pool, enum eid type,
void del_event(struct poolhd *pool, struct eval *val)
{
assert(val && ((val->fd > 0 && val->mod_iter < pool->iters) ||
val->mod_iter == pool->iters));
assert(val->fd >= -1 && val->mod_iter <= pool->iters);
if (val->fd == -1) {
return;
}
#ifdef NOEPOLL
assert(val->fd == pool->pevents[val->index].fd);
#endif
if (val->buff.data) {
assert(val->buff.size);
free(val->buff.data);
@ -211,7 +212,7 @@ struct eval *next_event(struct poolhd *pool, int *offs, int *typel)
int mod_etype(struct poolhd *pool, struct eval *val, int type)
{
assert(val->index >= 0 && val->index < pool->count);
pool->pevents[val->index].events = type;
pool->pevents[val->index].events = POLLRDHUP | type;
return 0;
}
#endif

2
proxy.c
View File

@ -540,7 +540,7 @@ int on_tunnel(struct poolhd *pool, struct eval *val,
ssize_t n = 0;
struct eval *pair = val->pair;
if (pair->buff.size && out) {
if (pair->buff.data && out) {
pair = val;
val = val->pair;