Function aeProcessCmd

src/ae.cpp:139–197

#endif

void aeProcessCmd(aeEventLoop *eventLoop, int fd, void *, int )
{
    std::unique_lock<decltype(g_lock)> ulock(g_lock, std::defer_lock);
    aeCommand cmd;
    for (;;)
    {
        auto cb = read(fd, &cmd, sizeof(aeCommand));
        if (cb != sizeof(cmd))
        {
            serverAssert(errno == EAGAIN);
            break;
        }
        switch (cmd.op)
        {
        case AE_ASYNC_OP::DeleteFileEvent:
            aeDeleteFileEvent(eventLoop, cmd.fd, cmd.mask);
            break;

        case AE_ASYNC_OP::CreateFileEvent:
            aeCreateFileEvent(eventLoop, cmd.fd, cmd.mask, cmd.fproc, cmd.clientData);
            break;

        case AE_ASYNC_OP::PostFunction:
            {
            if (cmd.fLock && !ulock.owns_lock()) {
                g_forkLock.releaseRead();
                ulock.lock();
                g_forkLock.acquireRead();
            }
            ((aePostFunctionProc*)cmd.proc)(cmd.clientData);
            break;
            }

        case AE_ASYNC_OP::PostCppFunction:
        {
            if (cmd.fLock && !ulock.owns_lock()) {
                g_forkLock.releaseRead();
                ulock.lock();
                g_forkLock.acquireRead();
            }
            (*cmd.pfn)();

            delete cmd.pfn;
            break;
        }
        case AE_ASYNC_OP::PostAsynDBFunction:
        {   //added to support async api IStorage
           if (cmd.fLock && !ulock.owns_lock()) {
                g_forkLock.releaseRead();
                ulock.lock();
                g_forkLock.acquireRead();
            }  
            ((aePostFunctionTokenProc*)cmd.tproc)(eventLoop,(StorageToken*)cmd.clientData);
            break; 
        }
            break;
        }
    }