void ConsumerAckInner::Ack()

in src/consumer_ack_inner.cpp [34:51]

• 14 lines of code
• 2 McCabe index (conditional complexity)

void ConsumerAckInner::Ack(CConsumeStatus _status)
{
    uv_mutex_lock(&mutex);
    bool _acked = acked;

    if(_acked)
    {
        uv_mutex_unlock(&mutex);
        return;
    }

    status = _status;
    acked = true;

    // tell `this->WaitResult()` to continue
    uv_cond_signal(&cond);
    uv_mutex_unlock(&mutex);
}