aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2008-06-30 02:43:04 +0000
committerEric Wong <normalperson@yhbt.net>2008-06-30 02:43:04 +0000
commit8426740f44e6584e291f23ac9858754111221395 (patch)
treeb0459e117615e3a492deee60f93236254d405853 /src
parentc5931529675a863e7173635c5f8779f78b3940e2 (diff)
downloadmpd-8426740f44e6584e291f23ac9858754111221395.tar.gz
mpd-8426740f44e6584e291f23ac9858754111221395.tar.xz
mpd-8426740f44e6584e291f23ac9858754111221395.zip
utils: add new unforgiving utility functions
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
Diffstat (limited to 'src')
-rw-r--r--src/utils.c24
-rw-r--r--src/utils.h6
2 files changed, 30 insertions, 0 deletions
diff --git a/src/utils.c b/src/utils.c
index a311796c8..eedae22de 100644
--- a/src/utils.c
+++ b/src/utils.c
@@ -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));
+}
diff --git a/src/utils.h b/src/utils.h
index 0b6763a05..eb16e87bc 100644
--- a/src/utils.h
+++ b/src/utils.h
@@ -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