X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=queue.c;fp=queue.c;h=29c2b65ca7b5fed55f9f8a507a49a29f918d2a5f;hb=5139a081952de0c231f53bc4876655e0fcecd994;hp=0000000000000000000000000000000000000000;hpb=c35c5cc9a0456642119e21bfa63eeaf14cbf0415;p=ir-tcl-moved-to-github.git

diff --git a/queue.c b/queue.c
new file mode 100644
index 0000000..29c2b65
--- /dev/null
+++ b/queue.c
@@ -0,0 +1,78 @@
+
+/*
+ * IR toolkit for tcl/tk
+ * (c) Index Data 1995
+ * See the file LICENSE for details.
+ * Sebastian Hammer, Adam Dickmeiss
+ *
+ * $Log: queue.c,v $
+ * Revision 1.1  1995-07-28 10:28:39  adam
+ * First work on request queue.
+ *
+ */
+
+#include <stdlib.h>
+#include <stdio.h>
+#include <ctype.h>
+#include <assert.h>
+
+#include "ir-tclp.h"
+
+void *ir_tcl_malloc (size_t size)
+{
+    void *p = malloc (size);
+    if (!p)
+    {
+        logf (LOG_FATAL, "Out of memory. %d bytes requested", size);
+        exit (1);
+    }
+    return p;
+}
+
+int ir_tcl_send (Tcl_Interp *interp, IrTcl_Obj *p, Z_APDU *apdu,
+                 const char *msg)
+{
+    IrTcl_Request **rp;
+    int empty;
+
+    if (!z_APDU (p->odr_out, &apdu, 0))
+    {
+        Tcl_AppendResult (interp, odr_errlist [odr_geterror (p->odr_out)],
+                          NULL);
+        odr_reset (p->odr_out);
+        return TCL_ERROR;
+    }
+    rp = &p->request_queue;
+    empty = *rp ? 0 : 1;
+    while (*rp)
+        rp = &(*rp)->next;
+    *rp = ir_tcl_malloc (sizeof(**rp));
+    (*rp)->next = NULL;
+    (*rp)->state = IR_TCL_R_Queue;
+    (*rp)->buf_out = odr_getbuf (p->odr_out, &(*rp)->len_out, NULL);
+    odr_reset (p->odr_out);
+    if (empty)
+    {
+        int r;
+
+        r = cs_put (p->cs_link, (*rp)->buf_out, (*rp)->len_out);
+        if (r < 0)
+        {
+            sprintf (interp->result, "cs_put failed in %s", msg);
+            return TCL_ERROR;
+        } 
+        else if (r == 1)
+        {
+            ir_select_add_write (cs_fileno (p->cs_link), p);
+            logf (LOG_DEBUG, "Send part of %s", msg);
+            (*rp)->state = IR_TCL_R_Writing;
+        }
+        else
+        {
+            logf (LOG_DEBUG, "Send %s (%d bytes)", msg, (*rp)->len_out);
+            (*rp)->state = IR_TCL_R_Waiting;
+        }
+    }
+    return TCL_OK;
+}
+