Changeset 8080262 in mainline for uspace/lib/c/generic/fibril_synch.c


Ignore:
Timestamp:
2018-07-30T18:55:22Z (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:
2965d18
Parents:
b4c8a7b
git-author:
Jiří Zárevúcky <jiri.zarevucky@…> (2018-07-30 18:07:46)
git-committer:
Jiří Zárevúcky <jiri.zarevucky@…> (2018-07-30 18:55:22)
Message:

Replace remaining explicit uses of futex_t outside fibril implementation, and get rid of async_futex.

File:
1 edited

Legend:

Unmodified
Added
Removed

  • uspace/lib/c/generic/fibril_synch.c

    rb4c8a7b r8080262  
    5353static fibril_local bool deadlocked = false;
    5454
     55static futex_t fibril_synch_futex = FUTEX_INITIALIZER;
     56
    5557typedef struct {
    5658        link_t link;
    … …  
    9698static void check_fibril_for_deadlock(fibril_owner_info_t *oi, fibril_t *fib)
    9799{
    98         futex_assert_is_locked(&async_futex);
     100        futex_assert_is_locked(&fibril_synch_futex);
    99101
    100102        while (oi && oi->owned_by) {
    101103                if (oi->owned_by == fib) {
    102                         futex_unlock(&async_futex);
     104                        futex_unlock(&fibril_synch_futex);
    103105                        print_deadlock(oi);
    104106                        abort();
    … …  
    124126        fibril_t *f = (fibril_t *) fibril_get_id();
    125127
    126         futex_lock(&async_futex);
     128        futex_lock(&fibril_synch_futex);
    127129
    128130        if (fm->counter-- > 0) {
    129131                fm->oi.owned_by = f;
    130                 futex_unlock(&async_futex);
     132                futex_unlock(&fibril_synch_futex);
    131133                return;
    132134        }
    … …  
    137139        f->waits_for = &fm->oi;
    138140
    139         futex_unlock(&async_futex);
     141        futex_unlock(&fibril_synch_futex);
    140142
    141143        fibril_wait_for(&wdata.event);
    … …  
    146148        bool locked = false;
    147149
    148         futex_lock(&async_futex);
     150        futex_lock(&fibril_synch_futex);
    149151        if (fm->counter > 0) {
    150152                fm->counter--;
    … …  
    152154                locked = true;
    153155        }
    154         futex_unlock(&async_futex);
     156        futex_unlock(&fibril_synch_futex);
    155157
    156158        return locked;
    … …  
    177179void fibril_mutex_unlock(fibril_mutex_t *fm)
    178180{
    179         futex_lock(&async_futex);
     181        futex_lock(&fibril_synch_futex);
    180182        _fibril_mutex_unlock_unsafe(fm);
    181         futex_unlock(&async_futex);
     183        futex_unlock(&fibril_synch_futex);
    182184}
    183185
    184186bool fibril_mutex_is_locked(fibril_mutex_t *fm)
    185187{
    186         futex_lock(&async_futex);
     188        futex_lock(&fibril_synch_futex);
    187189        bool locked = (fm->oi.owned_by == (fibril_t *) fibril_get_id());
    188         futex_unlock(&async_futex);
     190        futex_unlock(&fibril_synch_futex);
    189191        return locked;
    190192}
    … …  
    202204        fibril_t *f = (fibril_t *) fibril_get_id();
    203205
    204         futex_lock(&async_futex);
     206        futex_lock(&fibril_synch_futex);
    205207
    206208        if (!frw->writers) {
    … …  
    208210                if (frw->readers++ == 0)
    209211                        frw->oi.owned_by = f;
    210                 futex_unlock(&async_futex);
     212                futex_unlock(&fibril_synch_futex);
    211213                return;
    212214        }
    … …  
    219221        f->waits_for = &frw->oi;
    220222
    221         futex_unlock(&async_futex);
     223        futex_unlock(&fibril_synch_futex);
    222224
    223225        fibril_wait_for(&wdata.event);
    … …  
    228230        fibril_t *f = (fibril_t *) fibril_get_id();
    229231
    230         futex_lock(&async_futex);
     232        futex_lock(&fibril_synch_futex);
    231233
    232234        if (!frw->writers && !frw->readers) {
    233235                frw->oi.owned_by = f;
    234236                frw->writers++;
    235                 futex_unlock(&async_futex);
     237                futex_unlock(&fibril_synch_futex);
    236238                return;
    237239        }
    … …  
    244246        f->waits_for = &frw->oi;
    245247
    246         futex_unlock(&async_futex);
     248        futex_unlock(&fibril_synch_futex);
    247249
    248250        fibril_wait_for(&wdata.event);
    … …  
    306308void fibril_rwlock_read_unlock(fibril_rwlock_t *frw)
    307309{
    308         futex_lock(&async_futex);
     310        futex_lock(&fibril_synch_futex);
    309311        assert(frw->readers > 0);
    310312        _fibril_rwlock_common_unlock(frw);
    311         futex_unlock(&async_futex);
     313        futex_unlock(&fibril_synch_futex);
    312314}
    313315
    314316void fibril_rwlock_write_unlock(fibril_rwlock_t *frw)
    315317{
    316         futex_lock(&async_futex);
     318        futex_lock(&fibril_synch_futex);
    317319        assert(frw->writers == 1);
    318320        assert(frw->oi.owned_by == fibril_self());
    319321        _fibril_rwlock_common_unlock(frw);
    320         futex_unlock(&async_futex);
     322        futex_unlock(&fibril_synch_futex);
    321323}
    322324
    323325bool fibril_rwlock_is_read_locked(fibril_rwlock_t *frw)
    324326{
    325         futex_lock(&async_futex);
     327        futex_lock(&fibril_synch_futex);
    326328        bool locked = (frw->readers > 0);
    327         futex_unlock(&async_futex);
     329        futex_unlock(&fibril_synch_futex);
    328330        return locked;
    329331}
    … …  
    331333bool fibril_rwlock_is_write_locked(fibril_rwlock_t *frw)
    332334{
    333         futex_lock(&async_futex);
     335        futex_lock(&fibril_synch_futex);
    334336        assert(frw->writers <= 1);
    335337        bool locked = (frw->writers > 0) && (frw->oi.owned_by == fibril_self());
    336         futex_unlock(&async_futex);
     338        futex_unlock(&fibril_synch_futex);
    337339        return locked;
    338340}
    … …  
    374376        }
    375377
    376         futex_lock(&async_futex);
     378        futex_lock(&fibril_synch_futex);
    377379        _fibril_mutex_unlock_unsafe(fm);
    378380        list_append(&wdata.link, &fcv->waiters);
    379         futex_unlock(&async_futex);
     381        futex_unlock(&fibril_synch_futex);
    380382
    381383        (void) fibril_wait_timeout(&wdata.event, expires);
    382384
    383         futex_lock(&async_futex);
     385        futex_lock(&fibril_synch_futex);
    384386        bool timed_out = link_in_use(&wdata.link);
    385387        list_remove(&wdata.link);
    386         futex_unlock(&async_futex);
     388        futex_unlock(&fibril_synch_futex);
    387389
    388390        fibril_mutex_lock(fm);
    … …  
    398400void fibril_condvar_signal(fibril_condvar_t *fcv)
    399401{
    400         futex_lock(&async_futex);
     402        futex_lock(&fibril_synch_futex);
    401403
    402404        awaiter_t *w = list_pop(&fcv->waiters, awaiter_t, link);
    … …  
    404406                fibril_notify(&w->event);
    405407
    406         futex_unlock(&async_futex);
     408        futex_unlock(&fibril_synch_futex);
    407409}
    408410
    409411void fibril_condvar_broadcast(fibril_condvar_t *fcv)
    410412{
    411         futex_lock(&async_futex);
     413        futex_lock(&fibril_synch_futex);
    412414
    413415        awaiter_t *w;
    … …  
    415417                fibril_notify(&w->event);
    416418
    417         futex_unlock(&async_futex);
     419        futex_unlock(&fibril_synch_futex);
    418420}
    419421
    … …  
    644646void fibril_semaphore_up(fibril_semaphore_t *sem)
    645647{
    646         futex_lock(&async_futex);
     648        futex_lock(&fibril_synch_futex);
    647649        sem->count++;
    648650
    … …  
    653655        }
    654656
    655         futex_unlock(&async_futex);
     657        futex_unlock(&fibril_synch_futex);
    656658}
    657659
    … …  
    665667void fibril_semaphore_down(fibril_semaphore_t *sem)
    666668{
    667         futex_lock(&async_futex);
     669        futex_lock(&fibril_synch_futex);
    668670        sem->count--;
    669671
    670672        if (sem->count >= 0) {
    671                 futex_unlock(&async_futex);
     673                futex_unlock(&fibril_synch_futex);
    672674                return;
    673675        }
    … …  
    676678        list_append(&wdata.link, &sem->waiters);
    677679
    678         futex_unlock(&async_futex);
     680        futex_unlock(&fibril_synch_futex);
    679681
    680682        fibril_wait_for(&wdata.event);
Note: See TracChangeset for help on using the changeset viewer.