Function bthread_rwlock_init

src/bthread/rwlock.cpp:295–329

} // namespace bthread

__BEGIN_DECLS

int bthread_rwlock_init(bthread_rwlock_t* __restrict rwlock,
                        const bthread_rwlockattr_t* __restrict) {
    int rc = bthread_sem_init(&rwlock->reader_sema, 0);
    if (BAIDU_UNLIKELY(0 != rc)) {
        return rc;
    }
    bthread_sem_disable_csite(&rwlock->reader_sema);
    rc = bthread_sem_init(&rwlock->writer_sema, 0);
    if (BAIDU_UNLIKELY(0 != rc)) {
        bthread_sem_destroy(&rwlock->reader_sema);
        return rc;
    }
    bthread_sem_disable_csite(&rwlock->writer_sema);

    rwlock->reader_count = 0;
    rwlock->reader_wait = 0;
    rwlock->wlock_flag = false;

    bthread_mutexattr_t attr;
    bthread_mutexattr_init(&attr);
    bthread_mutexattr_disable_csite(&attr);
    rc = bthread_mutex_init(&rwlock->write_queue_mutex, &attr);
    if (BAIDU_UNLIKELY(0 != rc)) {
        bthread_sem_destroy(&rwlock->reader_sema);
        bthread_sem_destroy(&rwlock->writer_sema);
        return rc;
    }
    bthread_mutexattr_destroy(&attr);

    bthread::make_contention_site_invalid(&rwlock->writer_csite);

    return 0;
}

int bthread_rwlock_destroy(bthread_rwlock_t* rwlock) {
    bthread_sem_destroy(&rwlock->reader_sema);