projects
/
silc.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
77ae225
)
updates.
author
Pekka Riikonen
<priikone@silcnet.org>
Tue, 24 Jul 2001 09:47:53 +0000
(09:47 +0000)
committer
Pekka Riikonen
<priikone@silcnet.org>
Tue, 24 Jul 2001 09:47:53 +0000
(09:47 +0000)
lib/silcutil/silcschedule.c
patch
|
blob
|
history
diff --git
a/lib/silcutil/silcschedule.c
b/lib/silcutil/silcschedule.c
index 1d727c6b900605ef9a8276fa27bd3e832c1605aa..d3833af1aaf23f006586418dc436937f4390845b 100644
(file)
--- a/
lib/silcutil/silcschedule.c
+++ b/
lib/silcutil/silcschedule.c
@@
-269,14
+269,17
@@
static void silc_schedule_dispatch_nontimeout(SilcSchedule schedule)
{
SilcTask task;
int i, last_fd = schedule->last_fd;
{
SilcTask task;
int i, last_fd = schedule->last_fd;
+ uint32 fd;
for (i = 0; i <= last_fd; i++) {
if (schedule->fd_list[i].events == 0)
continue;
for (i = 0; i <= last_fd; i++) {
if (schedule->fd_list[i].events == 0)
continue;
+ fd = schedule->fd_list[i].fd;
+
/* First check whether this fd has task in the fd queue */
silc_mutex_lock(schedule->fd_queue->lock);
/* First check whether this fd has task in the fd queue */
silc_mutex_lock(schedule->fd_queue->lock);
- task = silc_task_find(schedule->fd_queue,
schedule->fd_list[i].
fd);
+ task = silc_task_find(schedule->fd_queue, fd);
/* If the task was found then execute its callbacks. If not then
execute all generic tasks for that fd. */
/* If the task was found then execute its callbacks. If not then
execute all generic tasks for that fd. */
@@
-328,8
+331,7
@@
static void silc_schedule_dispatch_nontimeout(SilcSchedule schedule)
if (task->valid && schedule->fd_list[i].revents & SILC_TASK_READ) {
silc_mutex_unlock(schedule->generic_queue->lock);
silc_mutex_unlock(schedule->lock);
if (task->valid && schedule->fd_list[i].revents & SILC_TASK_READ) {
silc_mutex_unlock(schedule->generic_queue->lock);
silc_mutex_unlock(schedule->lock);
- task->callback(schedule, SILC_TASK_READ, schedule->fd_list[i].fd,
- task->context);
+ task->callback(schedule, SILC_TASK_READ, fd, task->context);
silc_mutex_lock(schedule->lock);
silc_mutex_lock(schedule->generic_queue->lock);
}
silc_mutex_lock(schedule->lock);
silc_mutex_lock(schedule->generic_queue->lock);
}
@@
-338,8
+340,7
@@
static void silc_schedule_dispatch_nontimeout(SilcSchedule schedule)
if (task->valid && schedule->fd_list[i].revents & SILC_TASK_WRITE) {
silc_mutex_unlock(schedule->generic_queue->lock);
silc_mutex_unlock(schedule->lock);
if (task->valid && schedule->fd_list[i].revents & SILC_TASK_WRITE) {
silc_mutex_unlock(schedule->generic_queue->lock);
silc_mutex_unlock(schedule->lock);
- task->callback(schedule, SILC_TASK_WRITE, schedule->fd_list[i].fd,
- task->context);
+ task->callback(schedule, SILC_TASK_WRITE, fd, task->context);
silc_mutex_lock(schedule->lock);
silc_mutex_lock(schedule->generic_queue->lock);
}
silc_mutex_lock(schedule->lock);
silc_mutex_lock(schedule->generic_queue->lock);
}