Method KqueueAddObj

adapter/micro_thread/kqueue_proxy.cpp:313–338

}

bool KqueueProxy::KqueueAddObj(KqueuerObj* obj)
{
    if (obj == NULL)
    {
        MTLOG_ERROR("kqobj input invalid, %p", obj);
        return false;
    }

    KqFdRef* item = KqFdRefGet(obj->GetOsfd());
    if (item == NULL)
    {
        MT_ATTR_API(320851, 1); // fd error
        MTLOG_ERROR("kqfd ref not find, failed, fd: %d", obj->GetOsfd());
        kqueue_assert(0);
        return false;
    }

    int ret = obj->KqueueCtlAdd(item);
    if (ret < 0) {
        MTLOG_ERROR("kqueue ctrl callback failed, fd: %d, obj: %p", obj->GetOsfd(), obj);
        kqueue_assert(0);
        return false;
    }

    return true;
}

bool KqueueProxy::KqueueDelObj(KqueuerObj* obj)
{