1 files changed, 73 insertions, 0 deletions
diff --git a/src/lib/polling.c b/src/lib/polling.c
new file mode 100644
index 0000000..42e9fef
--- /dev/null
+++ b/src/lib/polling.c
@@ -0,0 +1,73 @@
+// $Id: polling.c,v 1.1.1.1 2013/12/11 20:49:20 bcbrock Exp $
+// $Source: /afs/awd/projects/eclipz/KnowledgeBase/.cvsroot/eclipz/chips/p8/working/procedures/lib/polling.c,v $
+//-----------------------------------------------------------------------------
+// *! (C) Copyright International Business Machines Corp. 2013
+// *! All Rights Reserved -- Property of IBM
+// *! *** IBM Confidential ***
+//-----------------------------------------------------------------------------
+
+/// \file polling.c
+/// \brief Library APIs for polling
+
+#include "polling.h"
+
+int
+polling(int* o_rc,
+        int (*i_condition)(void* io_arg, int* o_satisfied),
+        void* io_arg,
+        SsxInterval i_timeout,
+        SsxInterval i_sleep)
+{
+    SsxTimebase start;
+    int rc, pollRc, timed_out, done;
+
+    if (SSX_ERROR_CHECK_API) {
+        SSX_ERROR_IF((i_condition == 0), POLLING_ERROR);
+    }
+    
+    start = ssx_timebase_get();
+    timed_out = 0;
+
+    do {
+        pollRc = i_condition(io_arg, &done);
+        if (pollRc) {
+            rc = POLLING_CONDITION;
+            break;
+        }
+        if (done) {
+            rc = 0;
+            break;
+        }
+        if (timed_out) {
+            rc = POLLING_TIMEOUT;
+            break;
+        }
+        if (i_sleep != 0) {
+            rc = ssx_sleep(i_sleep);
+            if (rc) {
+                break;
+            }
+        }
+        timed_out = 
+            ((i_timeout != SSX_WAIT_FOREVER) &&
+             ((ssx_timebase_get() - start) >= i_timeout));
+
+    } while (1);
+
+    if (o_rc) {
+        *o_rc = pollRc;
+    }
+
+    return rc;
+}
+
+
+void
+busy_wait(SsxInterval i_interval)
+{
+    SsxTimebase start;
+
+    start = ssx_timebase_get();
+    while ((ssx_timebase_get() - start) < i_interval);
+}
+