WebSVN – HelenOS-historic – Diff – /uspace/trunk/libc/generic/ipc.c

     return call;
+}
 /** Epilogue of ipc_async_send functions */
-static inline void ipc_finish_async(ipc_callid_t callid, int phoneid, async_call_t *call)
+static inline void ipc_finish_async(ipc_callid_t callid, int phoneid,
+                    async_call_t *call, int can_preempt)
+{
     if (callid == IPC_CALLRET_FATAL) {
         futex_up(&ipc_futex);
         /* Call asynchronous handler with error code */
         if (call->callback)
     if (callid == IPC_CALLRET_TEMPORARY) {
         futex_up(&ipc_futex);
         call->u.msg.phoneid = phoneid;
-        call->ptid = psthread_get_id();
         futex_down(&async_futex);
         list_append(&call->list, &queued_calls);
+        if (can_preempt) {
+            call->ptid = psthread_get_id();
-        psthread_schedule_next_adv(PS_TO_MANAGER);
+            psthread_schedule_next_adv(PS_TO_MANAGER);
-        /* Async futex unlocked by previous call */
+            /* Async futex unlocked by previous call */
+        } else {
+            call->ptid = 0;
+            futex_up(&async_futex);
+        }
         return;
+    }
     call->u.callid = callid;
     /* Add call to list of dispatched calls */
     list_append(&call->list, &dispatched_calls);
  * - if fatal error, call callback handler with proper error code
  * - if message cannot be temporarily sent, add to queue
  */
 void ipc_call_async_2(int phoneid, ipcarg_t method, ipcarg_t arg1,
               ipcarg_t arg2, void *private,
-              ipc_async_callback_t callback)
+              ipc_async_callback_t callback, int can_preempt)
+{
     async_call_t *call;
     ipc_callid_t callid;
     call = ipc_prepare_async(private, callback);
     if (callid == IPC_CALLRET_TEMPORARY) {
         IPC_SET_METHOD(call->u.msg.data, method);
         IPC_SET_ARG1(call->u.msg.data, arg1);
         IPC_SET_ARG2(call->u.msg.data, arg2);
+    }
-    ipc_finish_async(callid, phoneid, call);
+    ipc_finish_async(callid, phoneid, call, can_preempt);
+}
 /** Send asynchronous message
+ *
  * - if fatal error, call callback handler with proper error code
  * - if message cannot be temporarily sent, add to queue
  */
 void ipc_call_async_3(int phoneid, ipcarg_t method, ipcarg_t arg1,
               ipcarg_t arg2, ipcarg_t arg3, void *private,
-              ipc_async_callback_t callback)
+              ipc_async_callback_t callback, int can_preempt)
+{
     async_call_t *call;
     ipc_callid_t callid;
     call = ipc_prepare_async(private, callback);
     /* We need to make sure that we get callid before
      * another thread accesses the queue again */
     futex_down(&ipc_futex);
     callid = _ipc_call_async(phoneid, &call->u.msg.data);
-    ipc_finish_async(callid, phoneid, call);
+    ipc_finish_async(callid, phoneid, call, can_preempt);
+}
 /** Send a fast answer to a received call.
+ *
             break;
+        }
         list_remove(&call->list);
         futex_up(&async_futex);
+        if (call->ptid)
-        psthread_add_ready(call->ptid);
+            psthread_add_ready(call->ptid);
         if (callid == IPC_CALLRET_FATAL) {
             if (call->callback)
                 call->callback(call->private, ENOENT, NULL);
             free(call);
 int ipc_forward_fast(ipc_callid_t callid, int phoneid, int method, ipcarg_t arg1)
+{
     return __SYSCALL4(SYS_IPC_FORWARD_FAST, callid, phoneid, method, arg1);
+}
-/** Open shared memory connection over specified phoneid
- *
- *
- * Allocate as_area, notify the other side about our intention
- * to open the connection
- *
- * @return Connection id identifying this connection
+/* Primitive functions for simple communication */
- */
-//int ipc_dgr_open(int pohoneid, size_t bufsize)
+void send_call_3(int phoneid, ipcarg_t method, ipcarg_t arg1,
-//{
-    /* Find new file descriptor in local descriptor table */
-    /* Create AS_area, initialize structures */
-    /* Send AS to other side, handle error states */
-//}
-/*
-void ipc_dgr_close(int cid)
-{
-}
-void * ipc_dgr_alloc(int cid, size_t size)
+         ipcarg_t arg2, ipcarg_t arg3)
+{
+    ipc_call_async_3(phoneid, method, arg1, arg2, arg3, NULL, NULL, 1);
+}
-void ipc_dgr_free(int cid, void *area)
+void send_call_2(int phoneid, ipcarg_t method, ipcarg_t arg1, ipcarg_t arg2)
+{
+    ipc_call_async_2(phoneid, method, arg1, arg2, NULL, NULL, 1);
+}
+void nsend_call_3(int phoneid, ipcarg_t method, ipcarg_t arg1,
-int ipc_dgr_send(int cid, void *area)
+          ipcarg_t arg2, ipcarg_t arg3)
+{
+    ipc_call_async_3(phoneid, method, arg1, arg2, arg3, NULL, NULL, 0);
+}
-int ipc_dgr_send_data(int cid, void *data, size_t size)
+void nsend_call_2(int phoneid, ipcarg_t method, ipcarg_t arg1, ipcarg_t arg2)
+{
+    ipc_call_async_2(phoneid, method, arg1, arg2, NULL, NULL, 0);
+}
-*/

Subversion Repositories HelenOS-historic

(root)/uspace/trunk/libc/generic/ipc.c – Rev 1503 → 1518