summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorNiels Provos <provos@gmail.com>2006-11-05 17:26:21 +0000
committerNiels Provos <provos@gmail.com>2006-11-05 17:26:21 +0000
commit4ad1da38724df2e30382a7048f32e2f0650f78fc (patch)
tree7e5066498e4a6645f7e0db2189617204abb408a2
parent362e59897ee4f1ac25f2d785e002b120deef1126 (diff)
downloadlibevent-4ad1da38724df2e30382a7048f32e2f0650f78fc.tar.gz
merge from trunk
svn:r250
-rw-r--r--poll.c48
1 files changed, 34 insertions, 14 deletions
diff --git a/poll.c b/poll.c
index f05819e0..7c1593f6 100644
--- a/poll.c
+++ b/poll.c
@@ -234,29 +234,48 @@ poll_add(void *arg, struct event *ev)
poll_check_ok(pop);
if (pop->nfds + 1 >= pop->event_count) {
+ struct pollfd *tmp_event_set;
+ struct event **tmp_event_r_back;
+ struct event **tmp_event_w_back;
+ int tmp_event_count;
+
if (pop->event_count < 32)
- pop->event_count = 32;
+ tmp_event_count = 32;
else
- pop->event_count *= 2;
+ tmp_event_count = pop->event_count * 2;
/* We need more file descriptors */
- pop->event_set = realloc(pop->event_set,
- pop->event_count * sizeof(struct pollfd));
- if (pop->event_set == NULL) {
+ tmp_event_set = realloc(pop->event_set,
+ tmp_event_count * sizeof(struct pollfd));
+ if (tmp_event_set == NULL) {
event_warn("realloc");
return (-1);
}
- pop->event_r_back = realloc(pop->event_r_back,
- pop->event_count * sizeof(struct event *));
- pop->event_w_back = realloc(pop->event_w_back,
- pop->event_count * sizeof(struct event *));
- if (pop->event_r_back == NULL ||
- pop->event_w_back == NULL) {
+ pop->event_set = tmp_event_set;
+
+ tmp_event_r_back = realloc(pop->event_r_back,
+ tmp_event_count * sizeof(struct event *));
+ if (tmp_event_r_back == NULL) {
+ /* event_set overallocated; that's okay. */
event_warn("realloc");
return (-1);
}
+ pop->event_r_back = tmp_event_r_back;
+
+ tmp_event_w_back = realloc(pop->event_w_back,
+ tmp_event_count * sizeof(struct event *));
+ if (tmp_event_w_back == NULL) {
+ /* event_set and event_r_back overallocated; that's
+ * okay. */
+ event_warn("realloc");
+ return (-1);
+ }
+ pop->event_w_back = tmp_event_w_back;
+
+ pop->event_count = tmp_event_count;
}
if (ev->ev_fd >= pop->fd_count) {
+ int *tmp_idxplus1_by_fd;
int new_count;
if (pop->fd_count < 32)
new_count = 32;
@@ -264,12 +283,13 @@ poll_add(void *arg, struct event *ev)
new_count = pop->fd_count * 2;
while (new_count <= ev->ev_fd)
new_count *= 2;
- pop->idxplus1_by_fd =
- realloc(pop->idxplus1_by_fd, new_count*sizeof(int));
- if (pop->idxplus1_by_fd == NULL) {
+ tmp_idxplus1_by_fd =
+ realloc(pop->idxplus1_by_fd, new_count * sizeof(int));
+ if (tmp_idxplus1_by_fd == NULL) {
event_warn("realloc");
return (-1);
}
+ pop->idxplus1_by_fd = tmp_idxplus1_by_fd;
memset(pop->idxplus1_by_fd + pop->fd_count,
0, sizeof(int)*(new_count - pop->fd_count));
pop->fd_count = new_count;