async.c

Go to the documentation of this file.

/*
 * Copyright (c) 2006 Ondrej Palkovsky
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * - Redistributions of source code must retain the above copyright
 *   notice, this list of conditions and the following disclaimer.
 * - Redistributions in binary form must reproduce the above copyright
 *   notice, this list of conditions and the following disclaimer in the
 *   documentation and/or other materials provided with the distribution.
 * - The name of the author may not be used to endorse or promote products
 *   derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

#define LIBC_ASYNC_C_
#include <ipc/ipc.h>
#include <async.h>
#undef LIBC_ASYNC_C_

#include <futex.h>
#include <fibril.h>
#include <stdio.h>
#include <adt/hash_table.h>
#include <adt/list.h>
#include <assert.h>
#include <errno.h>
#include <sys/time.h>
#include <arch/barrier.h>
#include <bool.h>
#include <stdlib.h>
#include <malloc.h>
#include "private/async.h"

atomic_t async_futex = FUTEX_INITIALIZER;

atomic_t threads_in_ipc_wait = { 0 };

typedef struct {
        awaiter_t wdata;
        
        bool done;
        
        ipc_call_t *dataptr;
        
        sysarg_t retval;
} amsg_t;

typedef struct {
        link_t link;
        ipc_callid_t callid;
        ipc_call_t call;
} msg_t;

typedef struct {
        sysarg_t in_task_hash;
        link_t link;
        int refcnt;
        void *data;
} client_t;

typedef struct {
        awaiter_t wdata;
        
        link_t link;
        
        sysarg_t in_task_hash;
        sysarg_t in_phone_hash;
        
        client_t *client;
        
        link_t msg_queue;
        
        ipc_callid_t callid;
        ipc_call_t call;
        
        ipc_callid_t close_callid;
        
        void (*cfibril)(ipc_callid_t, ipc_call_t *);
} connection_t;

static fibril_local connection_t *FIBRIL_connection;

static void *default_client_data_constructor(void)
{
        return NULL;
}

static void default_client_data_destructor(void *data)
{
}

static async_client_data_ctor_t async_client_data_create =
    default_client_data_constructor;
static async_client_data_dtor_t async_client_data_destroy =
    default_client_data_destructor;

void async_set_client_data_constructor(async_client_data_ctor_t ctor)
{
        async_client_data_create = ctor;
}

void async_set_client_data_destructor(async_client_data_dtor_t dtor)
{
        async_client_data_destroy = dtor;
}

void *async_client_data_get(void)
{
        assert(FIBRIL_connection);
        return FIBRIL_connection->client->data;
}

static void default_client_connection(ipc_callid_t callid, ipc_call_t *call)
{
        ipc_answer_0(callid, ENOENT);
}

static async_client_conn_t client_connection = default_client_connection;

static void default_interrupt_received(ipc_callid_t callid, ipc_call_t *call)
{
}

static async_client_conn_t interrupt_received = default_interrupt_received;

static hash_table_t client_hash_table;
static hash_table_t conn_hash_table;
static LIST_INITIALIZE(timeout_list);

#define CLIENT_HASH_TABLE_BUCKETS  32
#define CONN_HASH_TABLE_BUCKETS    32

static hash_index_t client_hash(unsigned long key[])
{
        assert(key);
        return (((key[0]) >> 4) % CLIENT_HASH_TABLE_BUCKETS);
}

static int client_compare(unsigned long key[], hash_count_t keys, link_t *item)
{
        client_t *client = hash_table_get_instance(item, client_t, link);
        return (key[0] == client->in_task_hash);
}

static void client_remove(link_t *item)
{
}

static hash_table_operations_t client_hash_table_ops = {
        .hash = client_hash,
        .compare = client_compare,
        .remove_callback = client_remove
};

static hash_index_t conn_hash(unsigned long key[])
{
        assert(key);
        return (((key[0]) >> 4) % CONN_HASH_TABLE_BUCKETS);
}

static int conn_compare(unsigned long key[], hash_count_t keys, link_t *item)
{
        connection_t *conn = hash_table_get_instance(item, connection_t, link);
        return (key[0] == conn->in_phone_hash);
}

static void conn_remove(link_t *item)
{
}

static hash_table_operations_t conn_hash_table_ops = {
        .hash = conn_hash,
        .compare = conn_compare,
        .remove_callback = conn_remove
};

void async_insert_timeout(awaiter_t *wd)
{
        wd->to_event.occurred = false;
        wd->to_event.inlist = true;
        
        link_t *tmp = timeout_list.next;
        while (tmp != &timeout_list) {
                awaiter_t *cur
                    = list_get_instance(tmp, awaiter_t, to_event.link);
                
                if (tv_gteq(&cur->to_event.expires, &wd->to_event.expires))
                        break;
                
                tmp = tmp->next;
        }
        
        list_append(&wd->to_event.link, tmp);
}

static bool route_call(ipc_callid_t callid, ipc_call_t *call)
{
        futex_down(&async_futex);
        
        unsigned long key = call->in_phone_hash;
        link_t *hlp = hash_table_find(&conn_hash_table, &key);
        
        if (!hlp) {
                futex_up(&async_futex);
                return false;
        }
        
        connection_t *conn = hash_table_get_instance(hlp, connection_t, link);
        
        msg_t *msg = malloc(sizeof(*msg));
        if (!msg) {
                futex_up(&async_futex);
                return false;
        }
        
        msg->callid = callid;
        msg->call = *call;
        list_append(&msg->link, &conn->msg_queue);
        
        if (IPC_GET_IMETHOD(*call) == IPC_M_PHONE_HUNGUP)
                conn->close_callid = callid;
        
        /* If the connection fibril is waiting for an event, activate it */
        if (!conn->wdata.active) {
                
                /* If in timeout list, remove it */
                if (conn->wdata.to_event.inlist) {
                        conn->wdata.to_event.inlist = false;
                        list_remove(&conn->wdata.to_event.link);
                }
                
                conn->wdata.active = true;
                fibril_add_ready(conn->wdata.fid);
        }
        
        futex_up(&async_futex);
        return true;
}

static int notification_fibril(void *arg)
{
        msg_t *msg = (msg_t *) arg;
        interrupt_received(msg->callid, &msg->call);
        
        free(msg);
        return 0;
}

static bool process_notification(ipc_callid_t callid, ipc_call_t *call)
{
        futex_down(&async_futex);
        
        msg_t *msg = malloc(sizeof(*msg));
        if (!msg) {
                futex_up(&async_futex);
                return false;
        }
        
        msg->callid = callid;
        msg->call = *call;
        
        fid_t fid = fibril_create(notification_fibril, msg);
        if (fid == 0) {
                free(msg);
                futex_up(&async_futex);
                return false;
        }
        
        fibril_add_ready(fid);
        
        futex_up(&async_futex);
        return true;
}

ipc_callid_t async_get_call_timeout(ipc_call_t *call, suseconds_t usecs)
{
        assert(FIBRIL_connection);
        
        /* Why doing this?
         * GCC 4.1.0 coughs on FIBRIL_connection-> dereference.
         * GCC 4.1.1 happilly puts the rdhwr instruction in delay slot.
         *           I would never expect to find so many errors in
         *           a compiler.
         */
        connection_t *conn = FIBRIL_connection;
        
        futex_down(&async_futex);
        
        if (usecs) {
                gettimeofday(&conn->wdata.to_event.expires, NULL);
                tv_add(&conn->wdata.to_event.expires, usecs);
        } else
                conn->wdata.to_event.inlist = false;
        
        /* If nothing in queue, wait until something arrives */
        while (list_empty(&conn->msg_queue)) {
                if (conn->close_callid) {
                        /*
                         * Handle the case when the connection was already
                         * closed by the client but the server did not notice
                         * the first IPC_M_PHONE_HUNGUP call and continues to
                         * call async_get_call_timeout(). Repeat
                         * IPC_M_PHONE_HUNGUP until the caller notices.
                         */
                        memset(call, 0, sizeof(ipc_call_t));
                        IPC_SET_IMETHOD(*call, IPC_M_PHONE_HUNGUP);
                        futex_up(&async_futex);
                        return conn->close_callid;
                }
                
                if (usecs)
                        async_insert_timeout(&conn->wdata);
                
                conn->wdata.active = false;
                
                /*
                 * Note: the current fibril will be rescheduled either due to a
                 * timeout or due to an arriving message destined to it. In the
                 * former case, handle_expired_timeouts() and, in the latter
                 * case, route_call() will perform the wakeup.
                 */
                fibril_switch(FIBRIL_TO_MANAGER);
                
                /*
                 * Futex is up after getting back from async_manager.
                 * Get it again.
                 */
                futex_down(&async_futex);
                if ((usecs) && (conn->wdata.to_event.occurred)
                    && (list_empty(&conn->msg_queue))) {
                        /* If we timed out -> exit */
                        futex_up(&async_futex);
                        return 0;
                }
        }
        
        msg_t *msg = list_get_instance(conn->msg_queue.next, msg_t, link);
        list_remove(&msg->link);
        
        ipc_callid_t callid = msg->callid;
        *call = msg->call;
        free(msg);
        
        futex_up(&async_futex);
        return callid;
}

static int connection_fibril(void *arg)
{
        /*
         * Setup fibril-local connection pointer.
         */
        FIBRIL_connection = (connection_t *) arg;
        
        futex_down(&async_futex);
        
        /*
         * Add our reference for the current connection in the client task
         * tracking structure. If this is the first reference, create and
         * hash in a new tracking structure.
         */
        
        unsigned long key = FIBRIL_connection->in_task_hash;
        link_t *lnk = hash_table_find(&client_hash_table, &key);
        
        client_t *client;
        
        if (lnk) {
                client = hash_table_get_instance(lnk, client_t, link);
                client->refcnt++;
        } else {
                client = malloc(sizeof(client_t));
                if (!client) {
                        ipc_answer_0(FIBRIL_connection->callid, ENOMEM);
                        futex_up(&async_futex);
                        return 0;
                }
                
                client->in_task_hash = FIBRIL_connection->in_task_hash;
                
                async_serialize_start();
                client->data = async_client_data_create();
                async_serialize_end();
                
                client->refcnt = 1;
                hash_table_insert(&client_hash_table, &key, &client->link);
        }
        
        futex_up(&async_futex);
        
        FIBRIL_connection->client = client;
        
        /*
         * Call the connection handler function.
         */
        FIBRIL_connection->cfibril(FIBRIL_connection->callid,
            &FIBRIL_connection->call);
        
        /*
         * Remove the reference for this client task connection.
         */
        bool destroy;
        
        futex_down(&async_futex);
        
        if (--client->refcnt == 0) {
                hash_table_remove(&client_hash_table, &key, 1);
                destroy = true;
        } else
                destroy = false;
        
        futex_up(&async_futex);
        
        if (destroy) {
                if (client->data)
                        async_client_data_destroy(client->data);
                
                free(client);
        }
        
        /*
         * Remove myself from the connection hash table.
         */
        futex_down(&async_futex);
        key = FIBRIL_connection->in_phone_hash;
        hash_table_remove(&conn_hash_table, &key, 1);
        futex_up(&async_futex);
        
        /*
         * Answer all remaining messages with EHANGUP.
         */
        while (!list_empty(&FIBRIL_connection->msg_queue)) {
                msg_t *msg =
                    list_get_instance(FIBRIL_connection->msg_queue.next, msg_t,
                    link);
                
                list_remove(&msg->link);
                ipc_answer_0(msg->callid, EHANGUP);
                free(msg);
        }
        
        /*
         * If the connection was hung-up, answer the last call,
         * i.e. IPC_M_PHONE_HUNGUP.
         */
        if (FIBRIL_connection->close_callid)
                ipc_answer_0(FIBRIL_connection->close_callid, EOK);
        
        free(FIBRIL_connection);
        return 0;
}

fid_t async_new_connection(sysarg_t in_task_hash, sysarg_t in_phone_hash,
    ipc_callid_t callid, ipc_call_t *call,
    void (*cfibril)(ipc_callid_t, ipc_call_t *))
{
        connection_t *conn = malloc(sizeof(*conn));
        if (!conn) {
                if (callid)
                        ipc_answer_0(callid, ENOMEM);
                
                return (uintptr_t) NULL;
        }
        
        conn->in_task_hash = in_task_hash;
        conn->in_phone_hash = in_phone_hash;
        list_initialize(&conn->msg_queue);
        conn->callid = callid;
        conn->close_callid = 0;
        
        if (call)
                conn->call = *call;
        
        /* We will activate the fibril ASAP */
        conn->wdata.active = true;
        conn->cfibril = cfibril;
        conn->wdata.fid = fibril_create(connection_fibril, conn);
        
        if (conn->wdata.fid == 0) {
                free(conn);
                
                if (callid)
                        ipc_answer_0(callid, ENOMEM);
                
                return (uintptr_t) NULL;
        }
        
        /* Add connection to the connection hash table */
        unsigned long key = conn->in_phone_hash;
        
        futex_down(&async_futex);
        hash_table_insert(&conn_hash_table, &key, &conn->link);
        futex_up(&async_futex);
        
        fibril_add_ready(conn->wdata.fid);
        
        return conn->wdata.fid;
}

static void handle_call(ipc_callid_t callid, ipc_call_t *call)
{
        /* Unrouted call - take some default action */
        if ((callid & IPC_CALLID_NOTIFICATION)) {
                process_notification(callid, call);
                return;
        }
        
        switch (IPC_GET_IMETHOD(*call)) {
        case IPC_M_CONNECT_ME:
        case IPC_M_CONNECT_ME_TO:
                /* Open new connection with fibril, etc. */
                async_new_connection(call->in_task_hash, IPC_GET_ARG5(*call),
                    callid, call, client_connection);
                return;
        }
        
        /* Try to route the call through the connection hash table */
        if (route_call(callid, call))
                return;
        
        /* Unknown call from unknown phone - hang it up */
        ipc_answer_0(callid, EHANGUP);
}

static void handle_expired_timeouts(void)
{
        struct timeval tv;
        gettimeofday(&tv, NULL);
        
        futex_down(&async_futex);
        
        link_t *cur = timeout_list.next;
        while (cur != &timeout_list) {
                awaiter_t *waiter =
                    list_get_instance(cur, awaiter_t, to_event.link);
                
                if (tv_gt(&waiter->to_event.expires, &tv))
                        break;
                
                cur = cur->next;
                
                list_remove(&waiter->to_event.link);
                waiter->to_event.inlist = false;
                waiter->to_event.occurred = true;
                
                /*
                 * Redundant condition?
                 * The fibril should not be active when it gets here.
                 */
                if (!waiter->active) {
                        waiter->active = true;
                        fibril_add_ready(waiter->fid);
                }
        }
        
        futex_up(&async_futex);
}

static int async_manager_worker(void)
{
        while (true) {
                if (fibril_switch(FIBRIL_FROM_MANAGER)) {
                        futex_up(&async_futex);
                        /*
                         * async_futex is always held when entering a manager
                         * fibril.
                         */
                        continue;
                }
                
                futex_down(&async_futex);
                
                suseconds_t timeout;
                if (!list_empty(&timeout_list)) {
                        awaiter_t *waiter = list_get_instance(timeout_list.next,
                            awaiter_t, to_event.link);
                        
                        struct timeval tv;
                        gettimeofday(&tv, NULL);
                        
                        if (tv_gteq(&tv, &waiter->to_event.expires)) {
                                futex_up(&async_futex);
                                handle_expired_timeouts();
                                continue;
                        } else
                                timeout = tv_sub(&waiter->to_event.expires, &tv);
                } else
                        timeout = SYNCH_NO_TIMEOUT;
                
                futex_up(&async_futex);
                
                atomic_inc(&threads_in_ipc_wait);
                
                ipc_call_t call;
                ipc_callid_t callid = ipc_wait_cycle(&call, timeout,
                    SYNCH_FLAGS_NONE);
                
                atomic_dec(&threads_in_ipc_wait);
                
                if (!callid) {
                        handle_expired_timeouts();
                        continue;
                }
                
                if (callid & IPC_CALLID_ANSWERED)
                        continue;
                
                handle_call(callid, &call);
        }
        
        return 0;
}

static int async_manager_fibril(void *arg)
{
        futex_up(&async_futex);
        
        /*
         * async_futex is always locked when entering manager
         */
        async_manager_worker();
        
        return 0;
}

void async_create_manager(void)
{
        fid_t fid = fibril_create(async_manager_fibril, NULL);
        if (fid != 0)
                fibril_add_manager(fid);
}

void async_destroy_manager(void)
{
        fibril_remove_manager();
}

void __async_init(void)
{
        if (!hash_table_create(&client_hash_table, CLIENT_HASH_TABLE_BUCKETS, 1,
            &client_hash_table_ops))
                abort();
        
        if (!hash_table_create(&conn_hash_table, CONN_HASH_TABLE_BUCKETS, 1,
            &conn_hash_table_ops))
                abort();
}

static void reply_received(void *arg, int retval, ipc_call_t *data)
{
        futex_down(&async_futex);
        
        amsg_t *msg = (amsg_t *) arg;
        msg->retval = retval;
        
        /* Copy data after futex_down, just in case the call was detached */
        if ((msg->dataptr) && (data))
                *msg->dataptr = *data;
        
        write_barrier();
        
        /* Remove message from timeout list */
        if (msg->wdata.to_event.inlist)
                list_remove(&msg->wdata.to_event.link);
        
        msg->done = true;
        if (!msg->wdata.active) {
                msg->wdata.active = true;
                fibril_add_ready(msg->wdata.fid);
        }
        
        futex_up(&async_futex);
}

aid_t async_send_fast(int phoneid, sysarg_t method, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3, sysarg_t arg4, ipc_call_t *dataptr)
{
        amsg_t *msg = malloc(sizeof(amsg_t));
        
        if (!msg)
                return 0;
        
        msg->done = false;
        msg->dataptr = dataptr;
        
        msg->wdata.to_event.inlist = false;
        
        /*
         * We may sleep in the next method,
         * but it will use its own means
         */
        msg->wdata.active = true;
        
        ipc_call_async_4(phoneid, method, arg1, arg2, arg3, arg4, msg,
            reply_received, true);
        
        return (aid_t) msg;
}

aid_t async_send_slow(int phoneid, sysarg_t method, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3, sysarg_t arg4, sysarg_t arg5,
    ipc_call_t *dataptr)
{
        amsg_t *msg = malloc(sizeof(amsg_t));
        
        if (!msg)
                return 0;
        
        msg->done = false;
        msg->dataptr = dataptr;
        
        msg->wdata.to_event.inlist = false;
        
        /*
         * We may sleep in the next method,
         * but it will use its own means
         */
        msg->wdata.active = true;
        
        ipc_call_async_5(phoneid, method, arg1, arg2, arg3, arg4, arg5, msg,
            reply_received, true);
        
        return (aid_t) msg;
}

void async_wait_for(aid_t amsgid, sysarg_t *retval)
{
        amsg_t *msg = (amsg_t *) amsgid;
        
        futex_down(&async_futex);
        if (msg->done) {
                futex_up(&async_futex);
                goto done;
        }
        
        msg->wdata.fid = fibril_get_id();
        msg->wdata.active = false;
        msg->wdata.to_event.inlist = false;
        
        /* Leave the async_futex locked when entering this function */
        fibril_switch(FIBRIL_TO_MANAGER);
        
        /* Futex is up automatically after fibril_switch */
        
done:
        if (retval)
                *retval = msg->retval;
        
        free(msg);
}

int async_wait_timeout(aid_t amsgid, sysarg_t *retval, suseconds_t timeout)
{
        amsg_t *msg = (amsg_t *) amsgid;
        
        /* TODO: Let it go through the event read at least once */
        if (timeout < 0)
                return ETIMEOUT;
        
        futex_down(&async_futex);
        if (msg->done) {
                futex_up(&async_futex);
                goto done;
        }
        
        gettimeofday(&msg->wdata.to_event.expires, NULL);
        tv_add(&msg->wdata.to_event.expires, timeout);
        
        msg->wdata.fid = fibril_get_id();
        msg->wdata.active = false;
        async_insert_timeout(&msg->wdata);
        
        /* Leave the async_futex locked when entering this function */
        fibril_switch(FIBRIL_TO_MANAGER);
        
        /* Futex is up automatically after fibril_switch */
        
        if (!msg->done)
                return ETIMEOUT;
        
done:
        if (retval)
                *retval = msg->retval;
        
        free(msg);
        
        return 0;
}

void async_usleep(suseconds_t timeout)
{
        amsg_t *msg = malloc(sizeof(amsg_t));
        
        if (!msg)
                return;
        
        msg->wdata.fid = fibril_get_id();
        msg->wdata.active = false;
        
        gettimeofday(&msg->wdata.to_event.expires, NULL);
        tv_add(&msg->wdata.to_event.expires, timeout);
        
        futex_down(&async_futex);
        
        async_insert_timeout(&msg->wdata);
        
        /* Leave the async_futex locked when entering this function */
        fibril_switch(FIBRIL_TO_MANAGER);
        
        /* Futex is up automatically after fibril_switch() */
        
        free(msg);
}

void async_set_client_connection(async_client_conn_t conn)
{
        client_connection = conn;
}

void async_set_interrupt_received(async_client_conn_t intr)
{
        interrupt_received = intr;
}

sysarg_t async_req_fast(int phoneid, sysarg_t method, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3, sysarg_t arg4, sysarg_t *r1, sysarg_t *r2,
    sysarg_t *r3, sysarg_t *r4, sysarg_t *r5)
{
        ipc_call_t result;
        aid_t eid = async_send_4(phoneid, method, arg1, arg2, arg3, arg4,
            &result);
        
        sysarg_t rc;
        async_wait_for(eid, &rc);
        
        if (r1)
                *r1 = IPC_GET_ARG1(result);
        
        if (r2)
                *r2 = IPC_GET_ARG2(result);
        
        if (r3)
                *r3 = IPC_GET_ARG3(result);
        
        if (r4)
                *r4 = IPC_GET_ARG4(result);
        
        if (r5)
                *r5 = IPC_GET_ARG5(result);
        
        return rc;
}

sysarg_t async_req_slow(int phoneid, sysarg_t method, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3, sysarg_t arg4, sysarg_t arg5, sysarg_t *r1,
    sysarg_t *r2, sysarg_t *r3, sysarg_t *r4, sysarg_t *r5)
{
        ipc_call_t result;
        aid_t eid = async_send_5(phoneid, method, arg1, arg2, arg3, arg4, arg5,
            &result);
        
        sysarg_t rc;
        async_wait_for(eid, &rc);
        
        if (r1)
                *r1 = IPC_GET_ARG1(result);
        
        if (r2)
                *r2 = IPC_GET_ARG2(result);
        
        if (r3)
                *r3 = IPC_GET_ARG3(result);
        
        if (r4)
                *r4 = IPC_GET_ARG4(result);
        
        if (r5)
                *r5 = IPC_GET_ARG5(result);
        
        return rc;
}

void async_msg_0(int phone, sysarg_t imethod)
{
        ipc_call_async_0(phone, imethod, NULL, NULL, true);
}

void async_msg_1(int phone, sysarg_t imethod, sysarg_t arg1)
{
        ipc_call_async_1(phone, imethod, arg1, NULL, NULL, true);
}

void async_msg_2(int phone, sysarg_t imethod, sysarg_t arg1, sysarg_t arg2)
{
        ipc_call_async_2(phone, imethod, arg1, arg2, NULL, NULL, true);
}

void async_msg_3(int phone, sysarg_t imethod, sysarg_t arg1, sysarg_t arg2,
    sysarg_t arg3)
{
        ipc_call_async_3(phone, imethod, arg1, arg2, arg3, NULL, NULL, true);
}

void async_msg_4(int phone, sysarg_t imethod, sysarg_t arg1, sysarg_t arg2,
    sysarg_t arg3, sysarg_t arg4)
{
        ipc_call_async_4(phone, imethod, arg1, arg2, arg3, arg4, NULL, NULL,
            true);
}

void async_msg_5(int phone, sysarg_t imethod, sysarg_t arg1, sysarg_t arg2,
    sysarg_t arg3, sysarg_t arg4, sysarg_t arg5)
{
        ipc_call_async_5(phone, imethod, arg1, arg2, arg3, arg4, arg5, NULL,
            NULL, true);
}

sysarg_t async_answer_0(ipc_callid_t callid, sysarg_t retval)
{
        return ipc_answer_0(callid, retval);
}

sysarg_t async_answer_1(ipc_callid_t callid, sysarg_t retval, sysarg_t arg1)
{
        return ipc_answer_1(callid, retval, arg1);
}

sysarg_t async_answer_2(ipc_callid_t callid, sysarg_t retval, sysarg_t arg1,
    sysarg_t arg2)
{
        return ipc_answer_2(callid, retval, arg1, arg2);
}

sysarg_t async_answer_3(ipc_callid_t callid, sysarg_t retval, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3)
{
        return ipc_answer_3(callid, retval, arg1, arg2, arg3);
}

sysarg_t async_answer_4(ipc_callid_t callid, sysarg_t retval, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3, sysarg_t arg4)
{
        return ipc_answer_4(callid, retval, arg1, arg2, arg3, arg4);
}

sysarg_t async_answer_5(ipc_callid_t callid, sysarg_t retval, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3, sysarg_t arg4, sysarg_t arg5)
{
        return ipc_answer_5(callid, retval, arg1, arg2, arg3, arg4, arg5);
}

int async_forward_fast(ipc_callid_t callid, int phoneid, sysarg_t imethod,
    sysarg_t arg1, sysarg_t arg2, unsigned int mode)
{
        return ipc_forward_fast(callid, phoneid, imethod, arg1, arg2, mode);
}

int async_forward_slow(ipc_callid_t callid, int phoneid, sysarg_t imethod,
    sysarg_t arg1, sysarg_t arg2, sysarg_t arg3, sysarg_t arg4, sysarg_t arg5,
    unsigned int mode)
{
        return ipc_forward_slow(callid, phoneid, imethod, arg1, arg2, arg3, arg4,
            arg5, mode);
}

int async_connect_to_me(int phone, sysarg_t arg1, sysarg_t arg2,
    sysarg_t arg3, async_client_conn_t client_receiver)
{
        sysarg_t task_hash;
        sysarg_t phone_hash;
        int rc = async_req_3_5(phone, IPC_M_CONNECT_TO_ME, arg1, arg2, arg3,
            NULL, NULL, NULL, &task_hash, &phone_hash);
        if (rc != EOK)
                return rc;
        
        if (client_receiver != NULL)
                async_new_connection(task_hash, phone_hash, 0, NULL,
                    client_receiver);
        
        return EOK;
}

int async_connect_me_to(int phone, sysarg_t arg1, sysarg_t arg2,
    sysarg_t arg3)
{
        sysarg_t newphid;
        int rc = async_req_3_5(phone, IPC_M_CONNECT_ME_TO, arg1, arg2, arg3,
            NULL, NULL, NULL, NULL, &newphid);
        
        if (rc != EOK)
                return rc;
        
        return newphid;
}

int async_connect_me_to_blocking(int phoneid, sysarg_t arg1, sysarg_t arg2,
    sysarg_t arg3)
{
        sysarg_t newphid;
        int rc = async_req_4_5(phoneid, IPC_M_CONNECT_ME_TO, arg1, arg2, arg3,
            IPC_FLAG_BLOCKING, NULL, NULL, NULL, NULL, &newphid);
        
        if (rc != EOK)
                return rc;
        
        return newphid;
}

int async_connect_kbox(task_id_t id)
{
        return ipc_connect_kbox(id);
}

int async_hangup(int phone)
{
        return ipc_hangup(phone);
}

void async_poke(void)
{
        ipc_poke();
}

int async_share_in_start(int phoneid, void *dst, size_t size, sysarg_t arg,
    unsigned int *flags)
{
        sysarg_t tmp_flags;
        int res = async_req_3_2(phoneid, IPC_M_SHARE_IN, (sysarg_t) dst,
            (sysarg_t) size, arg, NULL, &tmp_flags);
        
        if (flags)
                *flags = (unsigned int) tmp_flags;
        
        return res;
}

bool async_share_in_receive(ipc_callid_t *callid, size_t *size)
{
        assert(callid);
        assert(size);
        
        ipc_call_t data;
        *callid = async_get_call(&data);
        
        if (IPC_GET_IMETHOD(data) != IPC_M_SHARE_IN)
                return false;
        
        *size = (size_t) IPC_GET_ARG2(data);
        return true;
}

int async_share_in_finalize(ipc_callid_t callid, void *src, unsigned int flags)
{
        return ipc_share_in_finalize(callid, src, flags);
}

int async_share_out_start(int phoneid, void *src, unsigned int flags)
{
        return async_req_3_0(phoneid, IPC_M_SHARE_OUT, (sysarg_t) src, 0,
            (sysarg_t) flags);
}

bool async_share_out_receive(ipc_callid_t *callid, size_t *size, unsigned int *flags)
{
        assert(callid);
        assert(size);
        assert(flags);
        
        ipc_call_t data;
        *callid = async_get_call(&data);
        
        if (IPC_GET_IMETHOD(data) != IPC_M_SHARE_OUT)
                return false;
        
        *size = (size_t) IPC_GET_ARG2(data);
        *flags = (unsigned int) IPC_GET_ARG3(data);
        return true;
}

int async_share_out_finalize(ipc_callid_t callid, void *dst)
{
        return ipc_share_out_finalize(callid, dst);
}

aid_t async_data_read(int phoneid, void *dst, size_t size, ipc_call_t *dataptr)
{
        return async_send_2(phoneid, IPC_M_DATA_READ, (sysarg_t) dst,
            (sysarg_t) size, dataptr);
}

int
async_data_read_start_generic(int phoneid, void *dst, size_t size, int flags)
{
        return async_req_3_0(phoneid, IPC_M_DATA_READ, (sysarg_t) dst,
            (sysarg_t) size, (sysarg_t) flags);
}

bool async_data_read_receive(ipc_callid_t *callid, size_t *size)
{
        assert(callid);
        
        ipc_call_t data;
        *callid = async_get_call(&data);
        
        if (IPC_GET_IMETHOD(data) != IPC_M_DATA_READ)
                return false;
        
        if (size)
                *size = (size_t) IPC_GET_ARG2(data);
        
        return true;
}

int async_data_read_finalize(ipc_callid_t callid, const void *src, size_t size)
{
        return ipc_data_read_finalize(callid, src, size);
}

int async_data_read_forward_fast(int phoneid, sysarg_t method, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3, sysarg_t arg4, ipc_call_t *dataptr)
{
        ipc_callid_t callid;
        if (!async_data_read_receive(&callid, NULL)) {
                ipc_answer_0(callid, EINVAL);
                return EINVAL;
        }
        
        aid_t msg = async_send_fast(phoneid, method, arg1, arg2, arg3, arg4,
            dataptr);
        if (msg == 0) {
                ipc_answer_0(callid, EINVAL);
                return EINVAL;
        }
        
        int retval = ipc_forward_fast(callid, phoneid, 0, 0, 0,
            IPC_FF_ROUTE_FROM_ME);
        if (retval != EOK) {
                async_wait_for(msg, NULL);
                ipc_answer_0(callid, retval);
                return retval;
        }
        
        sysarg_t rc;
        async_wait_for(msg, &rc);
        
        return (int) rc;
}

int
async_data_write_start_generic(int phoneid, const void *src, size_t size,
    int flags)
{
        return async_req_3_0(phoneid, IPC_M_DATA_WRITE, (sysarg_t) src,
            (sysarg_t) size, (sysarg_t) flags);
}

bool async_data_write_receive(ipc_callid_t *callid, size_t *size)
{
        assert(callid);
        
        ipc_call_t data;
        *callid = async_get_call(&data);
        
        if (IPC_GET_IMETHOD(data) != IPC_M_DATA_WRITE)
                return false;
        
        if (size)
                *size = (size_t) IPC_GET_ARG2(data);
        
        return true;
}

int async_data_write_finalize(ipc_callid_t callid, void *dst, size_t size)
{
        return ipc_data_write_finalize(callid, dst, size);
}

int async_data_write_accept(void **data, const bool nullterm,
    const size_t min_size, const size_t max_size, const size_t granularity,
    size_t *received)
{
        ipc_callid_t callid;
        size_t size;
        if (!async_data_write_receive(&callid, &size)) {
                ipc_answer_0(callid, EINVAL);
                return EINVAL;
        }
        
        if (size < min_size) {
                ipc_answer_0(callid, EINVAL);
                return EINVAL;
        }
        
        if ((max_size > 0) && (size > max_size)) {
                ipc_answer_0(callid, EINVAL);
                return EINVAL;
        }
        
        if ((granularity > 0) && ((size % granularity) != 0)) {
                ipc_answer_0(callid, EINVAL);
                return EINVAL;
        }
        
        void *_data;
        
        if (nullterm)
                _data = malloc(size + 1);
        else
                _data = malloc(size);
        
        if (_data == NULL) {
                ipc_answer_0(callid, ENOMEM);
                return ENOMEM;
        }
        
        int rc = async_data_write_finalize(callid, _data, size);
        if (rc != EOK) {
                free(_data);
                return rc;
        }
        
        if (nullterm)
                ((char *) _data)[size] = 0;
        
        *data = _data;
        if (received != NULL)
                *received = size;
        
        return EOK;
}

void async_data_write_void(sysarg_t retval)
{
        ipc_callid_t callid;
        async_data_write_receive(&callid, NULL);
        ipc_answer_0(callid, retval);
}

int async_data_write_forward_fast(int phoneid, sysarg_t method, sysarg_t arg1,
    sysarg_t arg2, sysarg_t arg3, sysarg_t arg4, ipc_call_t *dataptr)
{
        ipc_callid_t callid;
        if (!async_data_write_receive(&callid, NULL)) {
                ipc_answer_0(callid, EINVAL);
                return EINVAL;
        }
        
        aid_t msg = async_send_fast(phoneid, method, arg1, arg2, arg3, arg4,
            dataptr);
        if (msg == 0) {
                ipc_answer_0(callid, EINVAL);
                return EINVAL;
        }
        
        int retval = ipc_forward_fast(callid, phoneid, 0, 0, 0,
            IPC_FF_ROUTE_FROM_ME);
        if (retval != EOK) {
                async_wait_for(msg, NULL);
                ipc_answer_0(callid, retval);
                return retval;
        }
        
        sysarg_t rc;
        async_wait_for(msg, &rc);
        
        return (int) rc;
}

---