1 /** 2 * @file mqueue.h Thread Safe Message Queue -- Internal API 3 * 4 * Copyright (C) 2010 Creytiv.com 5 */ 6 7 8 #ifdef WIN32 9 int pipe(int fds[2]); 10 ssize_t pipe_read(int s, void *buf, size_t len); 11 ssize_t pipe_write(int s, const void *buf, size_t len); 12 #else 13 static inline ssize_t pipe_read(int s, void *buf, size_t len) 14 { 15 return read(s, buf, len); 16 } 17 18 19 static inline ssize_t pipe_write(int s, const void *buf, size_t len) 20 { 21 return write(s, buf, len); 22 } 23 #endif 24