diff --git a/src/utils/channel.c b/src/utils/channel.c
index afce6f5d9cc9aa883afb9569aef9a384c433eb01..a45247a71060503b55589655e2cd6711dd1bcd7f 100644 (file)
--- a/src/utils/channel.c
+++ b/src/utils/channel.c
size_t head;
size_t tail;
_Bool full;
+
+ _Bool shutdown;
};
/*
{
assert(chan);
- if (chan->full)
+ if (chan->full || chan->shutdown)
return -1;
else if (! data)
return 0;
sdb_channel_select(sdb_channel_t *chan, int *wantread, void *read_data,
int *wantwrite, void *write_data, const struct timespec *timeout)
{
- struct timespec abstime;
int status = 0;
if (! chan) {
return -1;
}
- if (timeout) {
- if (clock_gettime(CLOCK_REALTIME, &abstime))
- return -1;
-
- abstime.tv_sec += timeout->tv_sec;
- abstime.tv_nsec += timeout->tv_nsec;
- }
-
pthread_mutex_lock(&chan->lock);
while (! status) {
int read_status, write_status;
break;
}
- if (timeout)
+ if (chan->shutdown) {
+ if (read_status)
+ status = EBADF;
+ break;
+ }
+
+ if (timeout) {
+ struct timespec abstime;
+
+ if (clock_gettime(CLOCK_REALTIME, &abstime)) {
+ pthread_mutex_unlock(&chan->lock);
+ return -1;
+ }
+
+ abstime.tv_sec += timeout->tv_sec;
+ abstime.tv_nsec += timeout->tv_nsec;
+
+ if (abstime.tv_nsec > 1000000000) {
+ abstime.tv_nsec -= 1000000000;
+ abstime.tv_sec += 1;
+ }
+
status = pthread_cond_timedwait(&chan->cond, &chan->lock,
&abstime);
+ }
else
status = pthread_cond_wait(&chan->cond, &chan->lock);
}
-
pthread_mutex_unlock(&chan->lock);
+
if (status) {
errno = status;
return -1;
return status;
} /* sdb_channel_read */
+int
+sdb_channel_shutdown(sdb_channel_t *chan)
+{
+ if (! chan)
+ return -1;
+ chan->shutdown = 1;
+ return 0;
+} /* sdb_channel_shutdown */
+
/* vim: set tw=78 sw=4 ts=4 noexpandtab : */