Changeset 1118:62d16667d373 in roaraudio for libroar/vio.c

Timestamp:

01/16/09 17:32:49 (15 years ago)

Author:

phi

Branch:

default

Phase:

public

Message:

add vio support for nonblock() and (f)sync()

File:

• libroar/vio.c (modified) (4 diffs)

libroar/vio.c

@@ -36 +36 @@
 
 int roar_vio_init_calls (struct roar_vio_calls * calls) {
- if ( !calls )
+ if ( calls == NULL )
   return -1;
 
@@ -47 +47 @@
 */
 
- calls->read  = roar_vio_basic_read;
- calls->write = roar_vio_basic_write;
- calls->lseek = roar_vio_basic_lseek;
+ calls->read     = roar_vio_basic_read;
+ calls->write    = roar_vio_basic_write;
+ calls->lseek    = roar_vio_basic_lseek;
+ calls->nonblock = roar_vio_basic_nonblock;
+ calls->sync     = roar_vio_basic_sync;
 
  return 0;
@@ -103 +105 @@
 
  return vio->lseek(vio, offset, whence);
+}
+
+int     roar_vio_nonblock(struct roar_vio_calls * vio, int state) {
+ if ( vio == NULL )
+  return -1;
+
+ if ( vio->nonblock == NULL )
+  return -1;
+
+ return vio->nonblock(vio, state);
+}
+
+int     roar_vio_sync    (struct roar_vio_calls * vio) {
+ if ( vio == NULL )
+  return -1;
+
+ if ( vio->sync == NULL )
+  return -1;
+
+ return vio->sync(vio);
 }
 
@@ -118 +140 @@
 off_t   roar_vio_basic_lseek(struct roar_vio_calls * vio, off_t offset, int whence) {
  return lseek(roar_vio_get_fh(vio), offset, whence);
+}
+
+int     roar_vio_basic_nonblock(struct roar_vio_calls * vio, int state) {
+ if ( roar_socket_nonblock(roar_vio_get_fh(vio), state) == -1 )
+  return -1;
+
+ if ( state == ROAR_SOCKET_NONBLOCK )
+  return 0;
+
+ return roar_vio_sync(vio);
+}
+
+int     roar_vio_basic_sync    (struct roar_vio_calls * vio) {
+ return fdatasync(roar_vio_get_fh(vio));
 }