Changeset 95838f1 in mainline for uspace/lib/c/generic/async


Ignore:
Timestamp:
2018-06-25T21:45:15Z (7 years ago)
Author:
Jiří Zárevúcky <jiri.zarevucky@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
38e34273
Parents:
3679f51a
git-author:
Jiří Zárevúcky <jiri.zarevucky@…> (2018-06-25 20:58:01)
git-committer:
Jiří Zárevúcky <jiri.zarevucky@…> (2018-06-25 21:45:15)
Message:

Switch async_futex to using futex_lock/unlock.

Location:
uspace/lib/c/generic/async
Files:
2 edited

Legend:

Unmodified
Added
Removed

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

    r3679f51a r95838f1  
    243243        assert(arg);
    244244
    245         futex_down(&async_futex);
     245        futex_lock(&async_futex);
    246246
    247247        amsg_t *msg = (amsg_t *) arg;
    … …  
    268268        }
    269269
    270         futex_up(&async_futex);
     270        futex_unlock(&async_futex);
    271271}
    272272
    … …  
    357357        amsg_t *msg = (amsg_t *) amsgid;
    358358
    359         futex_down(&async_futex);
     359        futex_lock(&async_futex);
    360360
    361361        assert(!msg->forget);
    … …  
    363363
    364364        if (msg->done) {
    365                 futex_up(&async_futex);
     365                futex_unlock(&async_futex);
    366366                goto done;
    367367        }
    … …  
    403403        amsg_t *msg = (amsg_t *) amsgid;
    404404
    405         futex_down(&async_futex);
     405        futex_lock(&async_futex);
    406406
    407407        assert(!msg->forget);
    … …  
    409409
    410410        if (msg->done) {
    411                 futex_up(&async_futex);
     411                futex_unlock(&async_futex);
    412412                goto done;
    413413        }
    … …  
    477477        assert(!msg->destroyed);
    478478
    479         futex_down(&async_futex);
     479        futex_lock(&async_futex);
    480480
    481481        if (msg->done) {
    … …  
    486486        }
    487487
    488         futex_up(&async_futex);
     488        futex_unlock(&async_futex);
    489489}
    490490
    … …  
    506506        tv_add_diff(&awaiter.to_event.expires, timeout);
    507507
    508         futex_down(&async_futex);
     508        futex_lock(&async_futex);
    509509
    510510        async_insert_timeout(&awaiter);

  • uspace/lib/c/generic/async/server.c

    r3679f51a r95838f1  
    432432         * Remove myself from the connection hash table.
    433433         */
    434         futex_down(&async_futex);
     434        futex_lock(&async_futex);
    435435        hash_table_remove(&conn_hash_table, &(conn_key_t){
    436436                .task_id = fibril_connection->in_task_id,
    437437                .phone_hash = fibril_connection->in_phone_hash
    438438        });
    439         futex_up(&async_futex);
     439        futex_unlock(&async_futex);
    440440
    441441        /*
    … …  
    520520        /* Add connection to the connection hash table */
    521521
    522         futex_down(&async_futex);
     522        futex_lock(&async_futex);
    523523        hash_table_insert(&conn_hash_table, &conn->link);
    524         futex_up(&async_futex);
     524        futex_unlock(&async_futex);
    525525
    526526        fibril_add_ready(conn->wdata.fid);
    … …  
    648648        assert(call);
    649649
    650         futex_down(&async_futex);
     650        futex_lock(&async_futex);
    651651
    652652        ht_link_t *link = hash_table_find(&conn_hash_table, &(conn_key_t){
    … …  
    655655        });
    656656        if (!link) {
    657                 futex_up(&async_futex);
     657                futex_unlock(&async_futex);
    658658                return false;
    659659        }
    … …  
    663663        msg_t *msg = malloc(sizeof(*msg));
    664664        if (!msg) {
    665                 futex_up(&async_futex);
     665                futex_unlock(&async_futex);
    666666                return false;
    667667        }
    … …  
    687687        }
    688688
    689         futex_up(&async_futex);
     689        futex_unlock(&async_futex);
    690690        return true;
    691691}
    … …  
    962962        connection_t *conn = fibril_connection;
    963963
    964         futex_down(&async_futex);
     964        futex_lock(&async_futex);
    965965
    966966        if (usecs) {
    … …  
    982982                        memset(call, 0, sizeof(ipc_call_t));
    983983                        IPC_SET_IMETHOD(*call, IPC_M_PHONE_HUNGUP);
    984                         futex_up(&async_futex);
     984                        futex_unlock(&async_futex);
    985985                        return conn->close_chandle;
    986986                }
    … …  
    10031003                 * Get it again.
    10041004                 */
    1005                 futex_down(&async_futex);
     1005                futex_lock(&async_futex);
    10061006                if ((usecs) && (conn->wdata.to_event.occurred) &&
    10071007                    (list_empty(&conn->msg_queue))) {
    10081008                        /* If we timed out -> exit */
    1009                         futex_up(&async_futex);
     1009                        futex_unlock(&async_futex);
    10101010                        return CAP_NIL;
    10111011                }
    … …  
    10201020        free(msg);
    10211021
    1022         futex_up(&async_futex);
     1022        futex_unlock(&async_futex);
    10231023        return chandle;
    10241024}
    … …  
    11061106        getuptime(&tv);
    11071107
    1108         futex_down(&async_futex);
     1108        futex_lock(&async_futex);
    11091109
    11101110        link_t *cur = list_first(&timeout_list);
    … …  
    11321132        }
    11331133
    1134         futex_up(&async_futex);
     1134        futex_unlock(&async_futex);
    11351135}
    11361136
    … …  
    11441144        while (true) {
    11451145                if (fibril_switch(FIBRIL_FROM_MANAGER)) {
    1146                         futex_up(&async_futex);
     1146                        futex_unlock(&async_futex);
    11471147                        /*
    11481148                         * async_futex is always held when entering a manager
    … …  
    11521152                }
    11531153
    1154                 futex_down(&async_futex);
     1154                futex_lock(&async_futex);
    11551155
    11561156                suseconds_t timeout;
    … …  
    11641164
    11651165                        if (tv_gteq(&tv, &waiter->to_event.expires)) {
    1166                                 futex_up(&async_futex);
     1166                                futex_unlock(&async_futex);
    11671167                                handle_expired_timeouts();
    11681168                                /*
    … …  
    11821182                                timeout = tv_sub_diff(&waiter->to_event.expires,
    11831183                                    &tv);
    1184                                 futex_up(&async_futex);
     1184                                futex_unlock(&async_futex);
    11851185                        }
    11861186                } else {
    1187                         futex_up(&async_futex);
     1187                        futex_unlock(&async_futex);
    11881188                        timeout = SYNCH_NO_TIMEOUT;
    11891189                }
    … …  
    12261226static errno_t async_manager_fibril(void *arg)
    12271227{
    1228         futex_up(&async_futex);
     1228        futex_unlock(&async_futex);
    12291229
    12301230        /*
    … …  
    18871887_Noreturn void async_manager(void)
    18881888{
    1889         futex_down(&async_futex);
     1889        futex_lock(&async_futex);
    18901890        fibril_switch(FIBRIL_FROM_DEAD);
    18911891        __builtin_unreachable();
Note: See TracChangeset for help on using the changeset viewer.