Changeset 339dfc5 in mainline

Timestamp:

2011-01-08T21:36:15Z (14 years ago)

Author:

Jakub Jermar <jakub@…>

Branches:

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

Children:

fa581b3

Parents:

e08a733

git-author:

Vojtech Horky <> (2011-01-08 21:36:15)

git-committer:

Jakub Jermar <jakub@…> (2011-01-08 21:36:15)

Message:

Provide means to specify ARG1 to IPC_M_CONNECT_ME_TO sent by async sessions.

Location:

uspace/lib/c

Files:

• generic/async_sess.c (modified) (3 diffs)
• include/async_sess.h (modified) (2 diffs)

uspace/lib/c/generic/async_sess.c

@@ -154 +154 @@
 {
         sess->sess_phone = phone;
+        sess->connect_arg1 = 0;
         list_initialize(&sess->conn_head);
         
@@ -159 +160 @@
         fibril_mutex_lock(&async_sess_mutex);
         list_append(&sess->sess_link, &session_list_head);
+        fibril_mutex_unlock(&async_sess_mutex);
+}
+
+void async_session_set_connect_args(async_sess_t *sess, sysarg_t arg1)
+{
+        fibril_mutex_lock(&async_sess_mutex);
+        sess->connect_arg1 = arg1;
         fibril_mutex_unlock(&async_sess_mutex);
 }
@@ -231 +239 @@
                  */
 retry:
-                data_phone = async_connect_me_to(sess->sess_phone, 0, 0, 0);
+                data_phone = async_connect_me_to(sess->sess_phone,
+                    sess->connect_arg1, 0, 0);
                 if (data_phone >= 0) {
                         /* success, do nothing */

uspace/lib/c/include/async_sess.h

@@ -40 +40 @@
 typedef struct {
         int sess_phone;         /**< Phone for cloning off the connections. */
+        sysarg_t connect_arg1;  /**< Argument for CONNECT_ME_TO. */
         link_t conn_head;       /**< List of open data connections. */
         link_t sess_link;       /**< Link in global list of open sessions. */
@@ -46 +47 @@
 extern void _async_sess_init(void);
 extern void async_session_create(async_sess_t *, int);
+extern void async_session_set_connect_args(async_sess_t *, sysarg_t);
 extern void async_session_destroy(async_sess_t *);
 extern int async_exchange_begin(async_sess_t *);