Changeset 3781092 in mainline for uspace/lib/c/generic/async.c

Timestamp:

2011-09-09T18:22:33Z (13 years ago)

Author:

Maurizio Lombardi <m.lombardi85@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

40a2af3

Parents:

980671e7 (diff), 5da7199 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

merge mainline changes

File:

• uspace/lib/c/generic/async.c (modified) (2 diffs)

uspace/lib/c/generic/async.c

@@ -118 +118 @@
 #define CONN_HASH_TABLE_BUCKETS    32
 
+/** Session data */
+struct async_sess {
+        /** List of inactive exchanges */
+        list_t exch_list;
+        
+        /** Exchange management style */
+        exch_mgmt_t mgmt;
+        
+        /** Session identification */
+        int phone;
+        
+        /** First clone connection argument */
+        sysarg_t arg1;
+        
+        /** Second clone connection argument */
+        sysarg_t arg2;
+        
+        /** Third clone connection argument */
+        sysarg_t arg3;
+        
+        /** Exchange mutex */
+        fibril_mutex_t mutex;
+        
+        /** Number of opened exchanges */
+        atomic_t refcnt;
+        
+        /** Mutex for stateful connections */
+        fibril_mutex_t remote_state_mtx;
+        
+        /** Data for stateful connections */
+        void *remote_state_data;
+};
+
+/** Exchange data */
+struct async_exch {
+        /** Link into list of inactive exchanges */
+        link_t sess_link;
+        
+        /** Link into global list of inactive exchanges */
+        link_t global_link;
+        
+        /** Session pointer */
+        async_sess_t *sess;
+        
+        /** Exchange identification */
+        int phone;
+};
+
 /** Async framework global futex */
 atomic_t async_futex = FUTEX_INITIALIZER;
@@ -134 +182 @@
         ipc_call_t call;
 } msg_t;
+
+/** Message data */
+typedef struct {
+        awaiter_t wdata;
+        
+        /** If reply was received. */
+        bool done;
+        
+        /** Pointer to where the answer data is stored. */
+        ipc_call_t *dataptr;
+        
+        sysarg_t retval;
+} amsg_t;
 
 /* Client connection data */