oysteikt/mpd
0
0
Fork 0
Code Issues Pull Requests Releases Activity

utils: add new unforgiving utility functions

Browse Source 
We'll be using pipes when waiting for I/O, and condition
variables at other times.

git-svn-id: https://svn.musicpd.org/mpd/trunk@7391 09075e82-0dd4-0310-85a5-a0d7c8717e4f
This commit is contained in:
Eric Wong 2008-06-30 02:43:04 +00:00
parent c593152967
commit 8426740f44
2 changed files with 30 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/utils.c
View File

@ -230,3 +230,27 @@ int set_nonblocking(int fd)
while ((ret = fcntl(fd, F_SETFL, flags)) < 0 && errno == EINTR) ;
return ret;
}
void init_async_pipe(int file_des[2])
{
if (pipe(file_des) < 0)
FATAL("Couldn't open pipe: %s", strerror(errno));
if (set_nonblocking(file_des[0]) < 0)
FATAL("Couldn't set non-blocking I/O: %s\n", strerror(errno));
if (set_nonblocking(file_des[1]) < 0)
FATAL("Couldn't set non-blocking I/O: %s\n", strerror(errno));
}
void xpthread_mutex_destroy(pthread_mutex_t *mutex)
{
int err;
if ((err = pthread_mutex_destroy(mutex)))
FATAL("failed to destroy mutex: %s\n", strerror(err));
}
void xpthread_cond_destroy(pthread_cond_t *cond)
{
int err;
if ((err = pthread_cond_destroy(cond)))
FATAL("failed to destroy cond: %s\n", strerror(err));
}

6
src/utils.h
View File

@ -80,4 +80,10 @@ char *parsePath(char *path);
int set_nonblocking(int fd);
void init_async_pipe(int file_des[2]);
void xpthread_mutex_destroy(pthread_mutex_t *mutex);
void xpthread_cond_destroy(pthread_cond_t *cond);
#endif