goahead webserver 奇怪问题

wb_sxck

static int socketDoEvent(socket_t *sp)
{
        ringq_t                *rq;
        int                 sid;

        a_assert(sp);

        sid = sp->sid;
        if (sp->currentEvents & SOCKET_READABLE) {
                if (sp->flags & SOCKET_LISTENING) {
                        socketAccept(sp);
                        sp->currentEvents = 0;
                        return 1;
                }

        } else {
/*
*                If there is still read data in the buffers, trigger the read handler
*                NOTE: this may busy spin if the read handler doesn't read the data
*/
                if (sp->handlerMask & SOCKET_READABLE && socketInputBuffered(sid) > 0) {
                        sp->currentEvents |= SOCKET_READABLE;
                }
        }


/*
*        If now writable and flushing in the background, continue flushing
*/
        if (sp->currentEvents & SOCKET_WRITABLE) {
                if (sp->flags & SOCKET_FLUSHING) {
                        rq = &sp->outBuf;
                        if (ringqLen(rq) > 0) {
                                socketFlush(sp->sid);
                        } else {
                                sp->flags &= ~SOCKET_FLUSHING;
                        }
                }
        }

/*
*        Now invoke the users socket handler. NOTE: the handler may delete the
*        socket, so we must be very careful after calling the handler.
*/
        if (sp->handler && (sp->handlerMask & sp->currentEvents)) {
                (sp->handler)(sid, sp->handlerMask & sp->currentEvents,
                        sp->handler_data);
/*
*                Make sure socket pointer is still valid, then reset the currentEvents.
*/
                if (socketList && sid < socketMax && socketList[sid] == sp) {
                        sp->currentEvents = 0;
                }
        }
        return 1;
}

为什么我请求一个web界面，它只执行下面这些
        if (sp->currentEvents & SOCKET_READABLE) {
                if (sp->flags & SOCKET_LISTENING) {
                        socketAccept(sp);
                        sp->currentEvents = 0;
                        return 1;
                }

        }

weihby

关注