Changeset 4697 for trunk/Ohana/src/opihi/lib.data/IOBufferOps.c

Timestamp:

Aug 2, 2005, 9:40:50 AM (21 years ago)

Author:

eugene

Message:

psched bugfixes, moved IOBuffers and queues

File:

• trunk/Ohana/src/opihi/lib.data/IOBufferOps.c (modified) (2 diffs)

trunk/Ohana/src/opihi/lib.data/IOBufferOps.c

@@ -1 @@
-# include "pclient.h"
+# include "data.h"
 
 int InitIOBuffer (IOBuffer *buffer, int Nalloc) {
@@ -61 +61 @@
 }
 
+/* read until buffer is empty (Nmax retries) */
+int EmptyIOBuffer (IOBuffer *buffer, int Nmax, int fd) {
+
+  int i, status;
+
+  status = -1;
+  for (i = 0; (status != 0) && (i < Nmax); i++) {
+    status = ReadtoIOBuffer (buffer, fd);
+    if (status == -1) usleep (10000);
+    if (status > 0) i = 0;
+  }
+  if (status == -1) return (FALSE);
+  return (TRUE);
+}
+
 void FreeIOBuffer (IOBuffer *buffer) {