Changeset 58cbf8d5 in mainline for uspace/lib/c/generic/async.c

Timestamp:

2011-08-19T18:51:05Z (13 years ago)

Author:

Martin Decky <martin@…>

Branches:

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

Children:

e3e4a2c

Parents:

7b2a7ad

Message:

basic support for tracking a client replica of the remote state in stateful protocols

File:

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

uspace/lib/c/generic/async.c

@@ -996 +996 @@
         session_ns->arg3 = 0;
         
+        fibril_mutex_initialize(&session_ns->remote_state_mtx);
+        session_ns->remote_state_data = NULL;
+        
         list_initialize(&session_ns->exch_list);
         fibril_mutex_initialize(&session_ns->mutex);
@@ -1561 +1564 @@
         sess->arg3 = 0;
         
+        fibril_mutex_initialize(&sess->remote_state_mtx);
+        sess->remote_state_data = NULL;
+        
         list_initialize(&sess->exch_list);
         fibril_mutex_initialize(&sess->mutex);
@@ -1642 +1648 @@
         sess->arg3 = arg3;
         
+        fibril_mutex_initialize(&sess->remote_state_mtx);
+        sess->remote_state_data = NULL;
+        
         list_initialize(&sess->exch_list);
         fibril_mutex_initialize(&sess->mutex);
@@ -1692 +1701 @@
         sess->arg3 = arg3;
         
+        fibril_mutex_initialize(&sess->remote_state_mtx);
+        sess->remote_state_data = NULL;
+        
         list_initialize(&sess->exch_list);
         fibril_mutex_initialize(&sess->mutex);
@@ -1722 +1734 @@
         sess->arg2 = 0;
         sess->arg3 = 0;
+        
+        fibril_mutex_initialize(&sess->remote_state_mtx);
+        sess->remote_state_data = NULL;
         
         list_initialize(&sess->exch_list);
@@ -2386 +2401 @@
         sess->arg3 = 0;
         
+        fibril_mutex_initialize(&sess->remote_state_mtx);
+        sess->remote_state_data = NULL;
+        
         list_initialize(&sess->exch_list);
         fibril_mutex_initialize(&sess->mutex);
@@ -2432 +2450 @@
         sess->arg3 = 0;
         
+        fibril_mutex_initialize(&sess->remote_state_mtx);
+        sess->remote_state_data = NULL;
+        
         list_initialize(&sess->exch_list);
         fibril_mutex_initialize(&sess->mutex);
@@ -2473 +2494 @@
         sess->arg2 = 0;
         sess->arg3 = 0;
+        
+        fibril_mutex_initialize(&sess->remote_state_mtx);
+        sess->remote_state_data = NULL;
         
         list_initialize(&sess->exch_list);
@@ -2514 +2538 @@
 }
 
+/** Lock and get session remote state
+ *
+ * Lock and get the local replica of the remote state
+ * in stateful sessions. The call should be paired
+ * with async_remote_state_release*().
+ *
+ * @param[in] sess Stateful session.
+ *
+ * @return Local replica of the remote state.
+ *
+ */
+void *async_remote_state_acquire(async_sess_t *sess)
+{
+        fibril_mutex_lock(&sess->remote_state_mtx);
+        return sess->remote_state_data;
+}
+
+/** Update the session remote state
+ *
+ * Update the local replica of the remote state
+ * in stateful sessions. The remote state must
+ * be already locked.
+ *
+ * @param[in] sess  Stateful session.
+ * @param[in] state New local replica of the remote state.
+ *
+ */
+void async_remote_state_update(async_sess_t *sess, void *state)
+{
+        assert(fibril_mutex_is_locked(&sess->remote_state_mtx));
+        sess->remote_state_data = state;
+}
+
+/** Release the session remote state
+ *
+ * Unlock the local replica of the remote state
+ * in stateful sessions.
+ *
+ * @param[in] sess Stateful session.
+ *
+ */
+void async_remote_state_release(async_sess_t *sess)
+{
+        assert(fibril_mutex_is_locked(&sess->remote_state_mtx));
+        
+        fibril_mutex_unlock(&sess->remote_state_mtx);
+}
+
+/** Release the session remote state and end an exchange
+ *
+ * Unlock the local replica of the remote state
+ * in stateful sessions. This is convenience function
+ * which gets the session pointer from the exchange
+ * and also ends the exchange.
+ *
+ * @param[in] exch Stateful session's exchange.
+ *
+ */
+void async_remote_state_release_exchange(async_exch_t *exch)
+{
+        if (exch == NULL)
+                return;
+        
+        async_sess_t *sess = exch->sess;
+        assert(fibril_mutex_is_locked(&sess->remote_state_mtx));
+        
+        async_exchange_end(exch);
+        fibril_mutex_unlock(&sess->remote_state_mtx);
+}
+
 /** @}
  */