Changeset 241f1985 in mainline for uspace/lib/c/generic/async/client.c

Timestamp:

2019-08-31T10:45:17Z (6 years ago)

Author:

Matthieu Riolo <matthieu.riolo@…>

Children:

102f641

Parents:

f92b315

git-author:

Matthieu Riolo <matthieu.riolo@…> (2019-08-23 22:04:34)

git-committer:

Matthieu Riolo <matthieu.riolo@…> (2019-08-31 10:45:17)

Message:

Correcting failure from previous merge

The commits from Michal Koutný from the branch system-daemon
where built on a old version of Helenos. Because of this
many types and API functions have changed. This commit
upgrades the merge code

File:

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

uspace/lib/c/generic/async/client.c

@@ -99 +99 @@
 #include <async.h>
 #include "../private/async.h"
-#include "../private/ns.h"
 #undef _LIBC_ASYNC_C_
 
@@ -114 +113 @@
 #include <stdbool.h>
 #include <stdlib.h>
+#include <stdatomic.h>
 #include <mem.h>
-#include <stdlib.h>
 #include <macros.h>
 #include <as.h>
@@ -174 +173 @@
     sysarg_t arg1, sysarg_t arg2, sysarg_t arg3)
 {
-        async_sess_t *session = (async_sess_t *) malloc(sizeof(async_sess_t));
+        async_sess_t *session = (async_sess_t *) calloc(1, sizeof(async_sess_t));
 
         if (session != NULL) {
-                session->iface = 0;
                 session->mgmt = mgmt;
                 session->phone = phone;
@@ -189 +187 @@
                 list_initialize(&session->exch_list);
                 fibril_mutex_initialize(&session->mutex);
-                atomic_set(&session->refcnt, 0);
-                &session.exchanges = 0;
         } else {
                 errno = ENOMEM;
@@ -198 +194 @@
 }
 
-int async_session_phone(async_sess_t *sess)
+cap_phone_handle_t async_session_phone(async_sess_t *sess)
 {
         return sess->phone;
@@ -859 +855 @@
         }
 
-        async_sess_t *sess = create_session(phone, mgmt, iface, arg2, arg3);
+        async_sess_t *sess = create_session(phone, iface & IFACE_EXCHANGE_MASK, iface, arg2, arg3);
         if (sess == NULL) {
                 ipc_hangup(phone);
         }
+        sess->iface = iface;
 
         return sess;
@@ -912 +909 @@
         if (rc != EOK) {
                 errno = rc;
-                free(sess);
                 return NULL;
         }
 
-        async_sess_t *sess = create_session(phone, mgmt, iface, arg2, arg3);
+        async_sess_t *sess = create_session(phone, iface & IFACE_EXCHANGE_MASK, iface, arg2, arg3);
         if (sess == NULL) {
                 ipc_hangup(phone);
         }
+        sess->iface = iface;
 
         return sess;