[Asterisk-cvs] asterisk asterisk.c,1.71,1.72 channel.c,1.98,1.99 manager.c,1.43,1.44
markster at lists.digium.com
markster at lists.digium.com
Sat Apr 24 19:05:57 CDT 2004
Update of /usr/cvsroot/asterisk
In directory mongoose.digium.com:/tmp/cvs-serv6597
Modified Files:
asterisk.c channel.c manager.c
Log Message:
Temporarily revert poll changes
Index: asterisk.c
===================================================================
RCS file: /usr/cvsroot/asterisk/asterisk.c,v
retrieving revision 1.71
retrieving revision 1.72
diff -u -d -r1.71 -r1.72
--- asterisk.c 24 Apr 2004 23:02:21 -0000 1.71
+++ asterisk.c 24 Apr 2004 23:11:28 -0000 1.72
@@ -13,7 +13,6 @@
#include <unistd.h>
#include <stdlib.h>
-#include <sys/poll.h>
#include <asterisk/logger.h>
#include <asterisk/options.h>
#include <asterisk/cli.h>
@@ -230,24 +229,26 @@
char hostname[256];
char tmp[512];
int res;
- struct pollfd fds[2];
+ int max;
+ fd_set rfds;
if (gethostname(hostname, sizeof(hostname)))
strncpy(hostname, "<Unknown>", sizeof(hostname)-1);
snprintf(tmp, sizeof(tmp), "%s/%d/%s\n", hostname, ast_mainpid, ASTERISK_VERSION);
fdprint(con->fd, tmp);
for(;;) {
- fds[0].fd = con->fd;
- fds[0].events = POLLIN;
- fds[1].fd = con->p[0];
- fds[1].events = POLLIN;
-
- res = poll(fds, 2, -1);
+ FD_ZERO(&rfds);
+ FD_SET(con->fd, &rfds);
+ FD_SET(con->p[0], &rfds);
+ max = con->fd;
+ if (con->p[0] > max)
+ max = con->p[0];
+ res = ast_select(max + 1, &rfds, NULL, NULL, NULL);
if (res < 0) {
- ast_log(LOG_WARNING, "poll returned < 0: %s\n", strerror(errno));
+ ast_log(LOG_WARNING, "select returned < 0: %s\n", strerror(errno));
continue;
}
- if (fds[0].revents) {
+ if (FD_ISSET(con->fd, &rfds)) {
res = read(con->fd, tmp, sizeof(tmp));
if (res < 1) {
break;
@@ -255,7 +256,7 @@
tmp[res] = 0;
ast_cli_command(con->fd, tmp);
}
- if (fds[1].revents) {
+ if (FD_ISSET(con->p[0], &rfds)) {
res = read(con->p[0], tmp, sizeof(tmp));
if (res < 1) {
ast_log(LOG_ERROR, "read returned %d\n", res);
@@ -279,23 +280,23 @@
static void *listener(void *unused)
{
struct sockaddr_un sun;
+ fd_set fds;
int s;
int len;
int x;
int flags;
- struct pollfd fds[1];
pthread_attr_t attr;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
for(;;) {
if (ast_socket < 0)
return NULL;
- fds[0].fd = ast_socket;
- fds[0].events= POLLIN;
- s = poll(fds, 1, -1);
+ FD_ZERO(&fds);
+ FD_SET(ast_socket, &fds);
+ s = ast_select(ast_socket + 1, &fds, NULL, NULL, NULL);
if (s < 0) {
if (errno != EINTR)
- ast_log(LOG_WARNING, "poll returned error: %s\n", strerror(errno));
+ ast_log(LOG_WARNING, "Select returned error: %s\n", strerror(errno));
continue;
}
len = sizeof(sun);
@@ -396,7 +397,7 @@
static void urg_handler(int num)
{
- /* Called by soft_hangup to interrupt the poll, read, or other
+ /* Called by soft_hangup to interrupt the select, read, or other
system call. We don't actually need to do anything though. */
/* Cannot EVER ast_log from within a signal handler */
if (option_debug)
@@ -627,7 +628,7 @@
fputs(s + pos,stdout);
fflush(stdout);
if (complete)
- /* Wake up a poll()ing console */
+ /* Wake up a select()ing console */
if (option_console && consolethread != AST_PTHREADT_NULL)
pthread_kill(consolethread, SIGURG);
}
@@ -820,38 +821,38 @@
static int ast_el_read_char(EditLine *el, char *cp)
{
- int num_read=0;
+ int num_read=0;
int lastpos=0;
- struct pollfd fds[2];
+ fd_set rfds;
int res;
int max;
char buf[512];
for (;;) {
- max = 1;
- fds[0].fd = ast_consock;
- fds[0].events = POLLIN;
+ FD_ZERO(&rfds);
+ FD_SET(ast_consock, &rfds);
+ max = ast_consock;
if (!option_exec) {
- fds[1].fd = STDIN_FILENO;
- fds[1].events = POLLIN;
- max++;
+ FD_SET(STDIN_FILENO, &rfds);
+ if (STDIN_FILENO > max)
+ max = STDIN_FILENO;
}
- res = poll(fds, max, -1);
+ res = ast_select(max+1, &rfds, NULL, NULL, NULL);
if (res < 0) {
if (errno == EINTR)
continue;
- ast_log(LOG_ERROR, "poll failed: %s\n", strerror(errno));
+ ast_log(LOG_ERROR, "select failed: %s\n", strerror(errno));
break;
}
- if (!option_exec && fds[1].revents) {
+ if (FD_ISSET(STDIN_FILENO, &rfds)) {
num_read = read(STDIN_FILENO, cp, 1);
if (num_read < 1) {
break;
} else
return (num_read);
}
- if (fds[0].revents) {
+ if (FD_ISSET(ast_consock, &rfds)) {
res = read(ast_consock, buf, sizeof(buf) - 1);
/* if the remote side disappears exit */
if (res < 1) {
@@ -1671,7 +1672,7 @@
} else {
/* Do nothing */
- poll(NULL,0, -1);
+ ast_select(0,NULL,NULL,NULL,NULL);
}
return 0;
}
Index: channel.c
===================================================================
RCS file: /usr/cvsroot/asterisk/channel.c,v
retrieving revision 1.98
retrieving revision 1.99
diff -u -d -r1.98 -r1.99
--- channel.c 24 Apr 2004 23:02:21 -0000 1.98
+++ channel.c 24 Apr 2004 23:11:28 -0000 1.99
@@ -20,7 +20,6 @@
#include <errno.h>
#include <unistd.h>
#include <math.h> /* For PI */
-#include <sys/poll.h>
#include <asterisk/pbx.h>
#include <asterisk/frame.h>
#include <asterisk/sched.h>
@@ -774,40 +773,32 @@
return 0;
}
-static inline int ast_fdisset(struct pollfd *pfds, int fd, int max)
-{
- int x;
- for (x=0;x<max;x++)
- if (pfds[x].fd == fd)
- return pfds[x].revents;
- return 0;
-}
-
int ast_waitfor_n_fd(int *fds, int n, int *ms, int *exception)
{
/* Wait for x amount of time on a file descriptor to have input. */
- struct timeval start, now;
+ struct timeval tv;
+ fd_set rfds, efds;
int res;
- int x, y;
+ int x, max=-1;
int winner = -1;
- struct pollfd *pfds;
- pfds = alloca(sizeof(struct pollfd) * n);
- if (!pfds) {
- ast_log(LOG_WARNING, "alloca failed! bad things will happen.\n");
- return -1;
- }
- if (*ms > 0)
- gettimeofday(&start, NULL);
- y = 0;
+ tv.tv_sec = *ms / 1000;
+ tv.tv_usec = (*ms % 1000) * 1000;
+ FD_ZERO(&rfds);
+ FD_ZERO(&efds);
for (x=0;x<n;x++) {
if (fds[x] > -1) {
- pfds[y].fd = fds[x];
- pfds[y].events = POLLIN | POLLPRI;
- y++;
+ FD_SET(fds[x], &rfds);
+ FD_SET(fds[x], &efds);
+ if (fds[x] > max)
+ max = fds[x];
}
}
- res = poll(pfds, y, *ms);
+ if (*ms >= 0)
+ res = ast_select(max + 1, &rfds, NULL, &efds, &tv);
+ else
+ res = ast_select(max + 1, &rfds, NULL, &efds, NULL);
+
if (res < 0) {
/* Simulate a timeout if we were interrupted */
if (errno != EINTR)
@@ -816,29 +807,15 @@
*ms = 0;
return -1;
}
+
for (x=0;x<n;x++) {
- if (fds[x] > -1) {
- if ((res = ast_fdisset(pfds, fds[x], y))) {
- winner = fds[x];
- if (exception) {
- if (res & POLLPRI)
- *exception = -1;
- else
- *exception = 0;
- }
- }
+ if ((fds[x] > -1) && (FD_ISSET(fds[x], &rfds) || FD_ISSET(fds[x], &efds)) && (winner < 0)) {
+ if (exception)
+ *exception = FD_ISSET(fds[x], &efds);
+ winner = fds[x];
}
}
- if (*ms > 0) {
- long passed;
- gettimeofday(&now, NULL);
- passed = (now.tv_sec - start.tv_sec) * 1000;
- passed += (now.tv_usec - start.tv_usec) / 1000;
- if (passed <= *ms)
- *ms -= passed;
- else
- *ms = 0;
- }
+ *ms = tv.tv_sec * 1000 + tv.tv_usec / 1000;
return winner;
}
@@ -846,21 +823,13 @@
int *exception, int *outfd, int *ms)
{
/* Wait for x amount of time on a file descriptor to have input. */
- struct timeval start, end;
- struct pollfd *pfds;
+ struct timeval tv;
+ fd_set rfds, efds;
int res;
- long rms;
- int x, y, max;
+ int x, y, max=-1;
time_t now = 0;
long whentohangup = 0, havewhen = 0, diff;
struct ast_channel *winner = NULL;
-
- pfds = alloca(sizeof(struct pollfd) * (n * AST_MAX_FDS + nfds));
- if (!pfds) {
- ast_log(LOG_WARNING, "alloca failed! bad things will happen.\n");
- *outfd = -1;
- return NULL;
- }
if (outfd)
*outfd = -99999;
if (exception)
@@ -888,35 +857,41 @@
}
ast_mutex_unlock(&c[x]->lock);
}
-
- rms = *ms;
+
+ tv.tv_sec = *ms / 1000;
+ tv.tv_usec = (*ms % 1000) * 1000;
if (havewhen) {
if ((*ms < 0) || (whentohangup * 1000 < *ms)) {
- rms = whentohangup * 1000;
+ tv.tv_sec = whentohangup;
+ tv.tv_usec = 0;
}
}
- max = 0;
+ FD_ZERO(&rfds);
+ FD_ZERO(&efds);
+
for (x=0;x<n;x++) {
for (y=0;y<AST_MAX_FDS;y++) {
if (c[x]->fds[y] > -1) {
- pfds[max].fd = c[x]->fds[y];
- pfds[max].events = POLLIN | POLLPRI;
- max++;
+ FD_SET(c[x]->fds[y], &rfds);
+ FD_SET(c[x]->fds[y], &efds);
+ if (c[x]->fds[y] > max)
+ max = c[x]->fds[y];
}
}
CHECK_BLOCKING(c[x]);
}
for (x=0;x<nfds; x++) {
- if (fds[x] > -1) {
- pfds[max].fd = fds[x];
- pfds[max].events = POLLIN | POLLPRI;
- max++;
- }
+ FD_SET(fds[x], &rfds);
+ FD_SET(fds[x], &efds);
+ if (fds[x] > max)
+ max = fds[x];
}
- if (*ms > 0)
- gettimeofday(&start, NULL);
- res = poll(pfds, max, rms);
+ if ((*ms >= 0) || (havewhen))
+ res = ast_select(max + 1, &rfds, NULL, &efds, &tv);
+ else
+ res = ast_select(max + 1, &rfds, NULL, &efds, NULL);
+
if (res < 0) {
for (x=0;x<n;x++)
c[x]->blocking = 0;
@@ -943,41 +918,26 @@
}
for (y=0;y<AST_MAX_FDS;y++) {
if (c[x]->fds[y] > -1) {
- if ((res = ast_fdisset(pfds, c[x]->fds[y], max))) {
- if (res & POLLPRI)
+ if ((FD_ISSET(c[x]->fds[y], &rfds) || FD_ISSET(c[x]->fds[y], &efds)) && !winner) {
+ /* Set exception flag if appropriate */
+ if (FD_ISSET(c[x]->fds[y], &efds))
c[x]->exception = 1;
- else
- c[x]->exception = 0;
+ c[x]->fdno = y;
winner = c[x];
}
}
}
}
for (x=0;x<nfds;x++) {
- if (fds[x] > -1) {
- if ((res = ast_fdisset(pfds, fds[x], max))) {
- if (outfd)
- *outfd = fds[x];
- if (exception) {
- if (res & POLLPRI)
- *exception = -1;
- else
- *exception = 1;
- }
- winner = NULL;
- }
- }
- }
- if (*ms > 0) {
- long diff;
- gettimeofday(&end, NULL);
- diff = (end.tv_sec - start.tv_sec) * 1000;
- diff += (end.tv_usec - start.tv_usec) * 1000;
- if (diff < *ms)
- *ms -= diff;
- else
- *ms = 0;
+ if ((FD_ISSET(fds[x], &rfds) || FD_ISSET(fds[x], &efds)) && !winner) {
+ if (outfd)
+ *outfd = fds[x];
+ if (FD_ISSET(fds[x], &efds) && exception)
+ *exception = 1;
+ winner = NULL;
+ }
}
+ *ms = tv.tv_sec * 1000 + tv.tv_usec / 1000;
return winner;
}
Index: manager.c
===================================================================
RCS file: /usr/cvsroot/asterisk/manager.c,v
retrieving revision 1.43
retrieving revision 1.44
diff -u -d -r1.43 -r1.44
--- manager.c 24 Apr 2004 23:02:21 -0000 1.43
+++ manager.c 24 Apr 2004 23:11:28 -0000 1.44
@@ -25,7 +25,6 @@
#include <signal.h>
#include <errno.h>
#include <unistd.h>
-#include <sys/poll.h>
#include <asterisk/channel.h>
#include <asterisk/file.h>
#include <asterisk/manager.h>
@@ -69,7 +68,8 @@
/* Try to write string, but wait no more than ms milliseconds
before timing out */
int res=0;
- struct pollfd fds[1];
+ struct timeval tv;
+ fd_set fds;
while(len) {
res = write(fd, s, len);
if ((res < 0) && (errno != EAGAIN)) {
@@ -78,10 +78,12 @@
if (res < 0) res = 0;
len -= res;
s += res;
- fds[0].fd = fd;
- fds[0].events = POLLOUT;
+ tv.tv_sec = timeoutms / 1000;
+ tv.tv_usec = timeoutms % 1000;
+ FD_ZERO(&fds);
+ FD_SET(fd, &fds);
/* Wait until writable again */
- res = poll(fds, 1, timeoutms);
+ res = select(fd + 1, NULL, &fds, NULL, &tv);
if (res < 1)
return -1;
}
@@ -713,7 +715,7 @@
/* output must have at least sizeof(s->inbuf) space */
int res;
int x;
- struct pollfd fds[1];
+ fd_set fds;
for (x=1;x<s->inlen;x++) {
if ((s->inbuf[x] == '\n') && (s->inbuf[x-1] == '\r')) {
/* Copy output data up to and including \r\n */
@@ -730,9 +732,9 @@
ast_log(LOG_WARNING, "Dumping long line with no return from %s: %s\n", inet_ntoa(s->sin.sin_addr), s->inbuf);
s->inlen = 0;
}
- fds[0].fd = s->fd;
- fds[0].events = POLLIN;
- res = poll(fds, 1, -1);
+ FD_ZERO(&fds);
+ FD_SET(s->fd, &fds);
+ res = ast_select(s->fd + 1, &fds, NULL, NULL, NULL);
if (res < 0) {
ast_log(LOG_WARNING, "Select returned error: %s\n", strerror(errno));
} else if (res > 0) {
More information about the svn-commits
mailing list