Changeset 5071:a550bcffdb13 in roaraudio

Timestamp:

06/19/11 13:44:49 (13 years ago)

Author:

phi

Branch:

default

Phase:

public

Message:

added a function to handle async stuff, still need to integerate it with roar_vs_iterate()

File:

• libroar/vs.c (modified) (12 diffs)

libroar/vs.c

@@ -57 +57 @@
 #define _seterrse() do { roar_err_from_errno(); _seterr(roar_error); } while(0)
 #define _ckvss(ret) do { if ( vss == NULL ) { _seterr(ROAR_ERROR_INVAL); return (ret); } } while(0)
+#define _ckasync(ret) do { if ( _handle_async(vss, error) == -1 ) { return (ret); } } while(0);
 
 struct roar_vs {
@@ -85 +86 @@
   struct roar_time last_time;
  } latmes;
+ struct {
+  size_t qlen;
+ } async;
 };
 
 static int _roar_vs_find_first_prim(roar_vs_t * vss);
+
+static int _handle_async_req(roar_vs_t * vss, int * error) {
+ _seterr(ROAR_ERROR_NOSYS);
+ return -1;
+}
+
+static inline int _handle_async(roar_vs_t * vss, int * error) {
+ while (vss->async.qlen) {
+  if ( _handle_async_req(vss, error) == -1 ) {
+   return -1;
+  }
+ }
+
+ return 0;
+}
 
 const char * roar_vs_strerr(int error) {
@@ -383 +402 @@
 
  _ckvss(-1);
+ _ckasync(-1);
 
  if ( vss->readbuffer != NULL )
@@ -510 +530 @@
 
  if ( wait == ROAR_VS_WAIT ) {
+  _ckasync(-1);
+
   memset(&waits, 0, sizeof(waits));
   waits.event       = ROAR_OE_STREAM_XRUN;
@@ -579 +601 @@
  int num;
  int i;
+ int * error = NULL; // needed for _ckasync() macro
+
+ _ckasync(-1);
 
  if ( vss->first_primid != -1 )
@@ -616 +641 @@
 
  _ckvss(-1);
+ _ckasync(-1);
 
  if ( !(vss->flags & FLAG_STREAM) ) {
@@ -716 +742 @@
 
  _ckvss(0);
+ _ckasync(-1);
 
  if (pos == -1) {
@@ -849 +876 @@
 
  _ckvss(-1);
+ _ckasync(-1);
 
  if ( !(vss->flags & FLAG_STREAM) ) {
@@ -902 +930 @@
 
  _ckvss(-1);
+ _ckasync(-1);
 
  if ( !(vss->flags & FLAG_STREAM) ) {
@@ -1010 +1039 @@
  }
 
+ _ckasync(-1);
+
  _initerr();
 
@@ -1033 +1064 @@
 
  _ckvss(-1);
+ _ckasync(-1);
 
  if ( !(vss->flags & FLAG_STREAM) ) {
@@ -1074 +1106 @@
 int     roar_vs_role          (roar_vs_t * vss, int role, int * error) {
  _ckvss(-1);
+ _ckasync(-1);
 
  if ( !(vss->flags & FLAG_STREAM) ) {