发表新帖

WARNING swWorker_discard_data (ERRNO 1007): [2] received the wrong data[89 bytes] from socket#5

发布于3年前 · 21 次浏览 · 来自提问

Caption

2020-07-22

鲁飞

2020-07-24

Caption 回复鲁飞

2020-07-22

marionjson

可以看下
reactor_thread.cc的源码：
```
static int swReactorThread_onPipeWrite(swReactor *reactor, swEvent *ev)
{
 int ret;

swBuffer_chunk *chunk = NULL;
    swEventData *send_data;
    swConnection *conn;
    swServer *serv = (swServer *) reactor->ptr;
    swBuffer *buffer = ev->socket->out_buffer;

while (!swBuffer_empty(buffer))
    {
        chunk = swBuffer_get_chunk(buffer);
        send_data = (swEventData *) chunk->store.ptr;

//server active close, discard data.
        if (swEventData_is_stream(send_data->info.type))
        {
            //send_data->info.fd is session_id
            conn = swServer_connection_verify(serv, send_data->info.fd);
            if (conn)
            {
                if (conn->closed)
                {
                    swoole_error_log(SW_LOG_NOTICE, SW_ERROR_SESSION_CLOSED_BY_SERVER, "Session#%d is closed by server", send_data->info.fd);
                    _discard:
                    swBuffer_pop_chunk(buffer, chunk);
                    continue;
                }
            }
            else if (serv->discard_timeout_request)
            {
                swoole_error_log(
                    SW_LOG_WARNING, SW_ERROR_SESSION_DISCARD_TIMEOUT_DATA,
                    "[1] received the wrong data[%d bytes] from socket#%d",
                    send_data->info.len, send_data->info.fd
                );
                goto _discard;
            }
        }

ret = swSocket_send(ev->socket, chunk->store.ptr, chunk->length, 0);
        if (ret < 0)
        {
            return (swConnection_error(errno) == SW_WAIT) ? SW_OK : SW_ERR;
        }
        else
        {
            swBuffer_pop_chunk(buffer, chunk);
        }
    }

if (swBuffer_empty(buffer))
    {
        if (swReactor_remove_write_event(reactor, ev->socket) < 0)
        {
            swSysWarn("reactor->set(%d) failed", ev->fd);
        }
    }

return SW_OK;
}
```

从源码可以看出 当sw服务器轮询检查连接，如果不能获取到连接信息，且线程标记为discard_timeout_request（放弃超时请求）时，就会提示超时错误请求，