95 lines
2.0 KiB
C
95 lines
2.0 KiB
C
/****************************************************************
|
|
* *
|
|
* Copyright 2001 Sanchez Computer Associates, Inc. *
|
|
* *
|
|
* This source code contains the intellectual property *
|
|
* of its copyright holder(s), and is made available *
|
|
* under a license. If you do not know the terms of *
|
|
* the license, please stop and do not read further. *
|
|
* *
|
|
****************************************************************/
|
|
#include "mdef.h"
|
|
#include "cmidef.h"
|
|
#include "gtm_time.h"
|
|
#include <sys/time.h>
|
|
#include <errno.h>
|
|
|
|
GBLREF struct NTD *ntd_root;
|
|
|
|
void cmj_select(int signo)
|
|
{
|
|
int count, local_errno;
|
|
int rsfd;
|
|
int wsfd;
|
|
int esfd;
|
|
struct timeval t;
|
|
int n = ntd_root->max_fd + 1;
|
|
struct CLB *lnk;
|
|
|
|
fd_set myrs = ntd_root->rs;
|
|
fd_set myws = ntd_root->ws;
|
|
fd_set myes = ntd_root->es;
|
|
|
|
t.tv_usec = 0;
|
|
t.tv_sec = 0;
|
|
do
|
|
{
|
|
count = select(n, &myrs, &myws, &myes, &t);
|
|
} while (0 > count && (EINTR == errno || EAGAIN == errno));
|
|
if (0 > count)
|
|
{
|
|
local_errno = errno;
|
|
}
|
|
|
|
while (0 < count) {
|
|
/* decode */
|
|
esfd = cmj_firstone(&myes, n);
|
|
while (0 < esfd)
|
|
{
|
|
lnk = cmj_unit2clb(ntd_root, esfd);
|
|
if (lnk)
|
|
cmj_exception_interrupt(lnk, signo);
|
|
esfd = cmj_firstone(&myes, n);
|
|
}
|
|
|
|
rsfd = cmj_firstone(&myrs, n);
|
|
while (0 < rsfd)
|
|
{
|
|
if (rsfd == ntd_root->listen_fd)
|
|
cmj_incoming_call(ntd_root);
|
|
else
|
|
{
|
|
lnk = cmj_unit2clb(ntd_root, rsfd);
|
|
if (lnk)
|
|
cmj_read_interrupt(lnk, signo);
|
|
}
|
|
rsfd = cmj_firstone(&myrs, n);
|
|
}
|
|
|
|
wsfd = cmj_firstone(&myws, n);
|
|
while (0 < wsfd)
|
|
{
|
|
lnk = cmj_unit2clb(ntd_root, wsfd);
|
|
if (lnk)
|
|
cmj_write_interrupt(lnk, signo);
|
|
wsfd = cmj_firstone(&myws, n);
|
|
}
|
|
myrs = ntd_root->rs;
|
|
myws = ntd_root->ws;
|
|
t.tv_usec = 0;
|
|
t.tv_sec = 0;
|
|
/*
|
|
* don't look at exceptions again since urgent exception
|
|
* is not cleared until the first byte of non-urgent data
|
|
*/
|
|
do
|
|
{
|
|
count = select(n, &myrs, &myws, NULL, &t);
|
|
} while (0 > count && (EINTR == errno || EAGAIN == errno));
|
|
if (0 > count)
|
|
{
|
|
local_errno = errno;
|
|
}
|
|
}
|
|
}
|