if (c[x]->fds[y] > -1) {
pfds[max].fd = c[x]->fds[y];
pfds[max].events = POLLIN | POLLPRI;
+ pfds[max].revents = 0;
max++;
}
}
if (fds[x] > -1) {
pfds[max].fd = fds[x];
pfds[max].events = POLLIN | POLLPRI;
+ pfds[max].revents = 0;
max++;
}
}
size = READ_SIZE;
fds[0].fd = fd;
fds[0].events = POLLPRI | POLLOUT;
+ fds[0].revents = 0;
res = poll(fds, 1, -1);
if (!res) {
ast_log(LOG_DEBUG, "poll (for write) ret. 0 on channel %d\n", p->channel);
/* This needs to be watched, as it lacks an owner */
pfds[count].fd = i->subs[SUB_REAL].zfd;
pfds[count].events = POLLPRI;
+ pfds[count].revents = 0;
/* Message waiting or r2 channels also get watched for reading */
#ifdef ZAPATA_R2
if (i->cidspill || i->r2)
break;
fds[i].fd = pri->fds[i];
fds[i].events = POLLIN | POLLPRI;
+ fds[i].revents = 0;
}
numdchans = i;
time(&t);
size = READ_SIZE;
fds[0].fd = fd;
fds[0].events = POLLOUT | POLLPRI;
+ fds[0].revents = 0;
res = poll(fds, 1, -1);
if (!res) {
ast_log(LOG_DEBUG, "poll (for write) ret. 0 on channel %d\n", p->channel);
*/
ioc->fds[ioc->fdcnt].fd = fd;
ioc->fds[ioc->fdcnt].events = events;
+ ioc->fds[ioc->fdcnt].revents = 0;
ioc->ior[ioc->fdcnt].callback = callback;
ioc->ior[ioc->fdcnt].data = data;
ioc->ior[ioc->fdcnt].id = (int *)malloc(sizeof(int));