ETCP 5.0一处神秘代码

已注销41434

在ETCP c++中源码有一处 永远无法执行的代码块 位于tcp.cpp,385行 难道这个地方有什么特别之处吗？

accet

可能是以前的版本 哪里复制来的一块代码.
然后ctrl+v就不管了...

FanLi

可能是程序员们秉承着代码能跑就别动的优良传统保留下来的吧。

已注销41434

〞剑舞长空 发表于 2024-7-9 21:56
都m_is了，总不能线程抢占变量吧

这段代码在没有调用其他函数的时候 在m_is 判断内做了2次m_Is判断 其实没必要直接跳过就好了 应该只是代码没做优化删减

已注销41434

hxznhf 发表于 2024-7-9 23:16
要么写错了，要么此处的m_is一定还有其它地方会同时修改它（比如其它线程），你后面代码也没截图完整。 ...

这个方法很长的 处理了不同方式的数据

已注销41434

hxznhf 发表于 2024-7-9 23:16
要么写错了，要么此处的m_is一定还有其它地方会同时修改它（比如其它线程），你后面代码也没截图完整。 ...

这是ETCP 完整的代码

[C++] 纯文本查看 复制代码

void tcp::RecvData(bool error, P_tcpstruct nop)
{
        if (error)
        {
                EnterCriticalSection(&m_cs);
                m_cnum--;
                LeaveCriticalSection(&m_cs);

                g_fun(this, nop->c_so, tcp_close, NULL, NULL, m_cnum);

                //closesockets(nop->c_so);
                //nop->c_so = INVALID_SOCKET;

                delete[]nop->buf;
                nop->buf = NULL;

                delete nop;
                nop = NULL;
                return;
        }

        if (m_Is)
        {
                nop->bufOffset += nop->cb;
                if (nop->bufOffset < nop->bufSize)
                {
                        nop->state = tcp_recv;
                        WSABUF wsabuf;
                        if (m_Is)
                        {
                                wsabuf.buf = nop->buf + nop->bufOffset;
                                wsabuf.len = nop->bufSize - nop->bufOffset;
                        }
                        else
                        {
                                wsabuf.buf = nop->buf;
                                wsabuf.len = buf_len;
                        }
                        DWORD Cb = 0;
                        DWORD Flg = 0;
                        if (WSARecv(nop->c_so, &wsabuf, 1, &Cb, &Flg, (LPWSAOVERLAPPED)nop, NULL))
                        {
                                int ercode = WSAGetLastError();
                                if (ercode == WSAEFAULT)
                                {
                                        return;
                                }
                                else if (ercode != WSA_IO_PENDING)
                                {
                                        EnterCriticalSection(&m_cs);
                                        m_cnum--;
                                        LeaveCriticalSection(&m_cs);

                                        g_fun(this, nop->c_so, tcp_close, NULL, NULL, m_cnum);

                                        delete[]nop->buf;
                                        nop->buf = NULL;

                                        delete nop;
                                        nop = NULL;
                                        return;
                                }
                        }
                        return;
                }
                DWORD size = *((DWORD*)(nop->buf));
                if (size > 65536000)
                {
                        EnterCriticalSection(&m_cs);
                        m_cnum--;
                        LeaveCriticalSection(&m_cs);

                        g_fun(this, nop->c_so, tcp_close, NULL, NULL, m_cnum);
                        //closesockets(nop->c_so);
                        //nop->c_so = INVALID_SOCKET;

                        delete[]nop->buf;
                        nop->buf = NULL;
                
                        delete nop;
                        nop = NULL;
                        return;
                }


                if (nop->bufOffset < DWORD(sizeof(DWORD)) + size)  //ÍêÕûÐÔ¼ì²â
                {
                        delete[] nop->buf;

                        nop->buf = new char[sizeof(DWORD)+size];
                        nop->bufSize = sizeof(DWORD)+size;
                        nop->bufOffset = sizeof(DWORD);
                        memcpy(nop->buf, &size, sizeof(DWORD));

                        nop->state = tcp_recv;
                        WSABUF wsabuf;
                        if (m_Is)
                        {
                                wsabuf.buf = nop->buf + nop->bufOffset;
                                wsabuf.len = nop->bufSize - nop->bufOffset;
                        }
                        else
                        {
                                wsabuf.buf = nop->buf;
                                wsabuf.len = buf_len;
                        }
                        DWORD Cb = 0;
                        DWORD Flg = 0;
                        if (WSARecv(nop->c_so, &wsabuf, 1, &Cb, &Flg, (LPWSAOVERLAPPED)nop, NULL))
                        {
                                int ercode = WSAGetLastError();
                                if (ercode == WSAEFAULT)
                                {
                                        return;
                                }
                                else if (ercode != WSA_IO_PENDING)
                                {
                                        EnterCriticalSection(&m_cs);
                                        m_cnum--;
                                        LeaveCriticalSection(&m_cs);

                                        g_fun(this, nop->c_so, tcp_close, NULL, NULL, m_cnum);

                                        delete[]nop->buf;
                                        nop->buf = NULL;

                                        delete nop;
                                        nop = NULL;
                                        return;
                                }
                        }
                        return;
                }
                if (nop->bufSize - sizeof(DWORD) > 0)
                {
                        g_fun(this, nop->c_so, tcp_recv, nop->buf + sizeof(DWORD), nop->bufSize - sizeof(DWORD), m_cnum);
                }
                delete[]nop->buf;
                nop->buf = new char[sizeof(DWORD)];
                nop->bufSize = sizeof(DWORD);
        }
        else
        {
                g_fun(this, nop->c_so, tcp_recv, nop->buf, nop->cb, m_cnum);
        }

        nop->bufOffset = 0;
        nop->state = tcp_recv;
        WSABUF wsabuf;
        if (m_Is)
        {
                wsabuf.buf = nop->buf + nop->bufOffset;
                wsabuf.len = nop->bufSize - nop->bufOffset;
        }
        else
        {
                wsabuf.buf = nop->buf;
                wsabuf.len = buf_len;
        }
        DWORD Cb = 0;
        DWORD Flg = 0;
        if (WSARecv(nop->c_so, &wsabuf, 1, &Cb, &Flg, (LPWSAOVERLAPPED)nop, NULL))
        {
                int ercode = WSAGetLastError();
                if (ercode == WSAEFAULT)
                {
                        return;
                }
                else if (ercode != WSA_IO_PENDING)
                {
                        EnterCriticalSection(&m_cs);
                        m_cnum--;
                        LeaveCriticalSection(&m_cs);

                        g_fun(this, nop->c_so, tcp_close, NULL, NULL, m_cnum);

                        //closesocket(nop->c_so);
                        //nop->c_so = INVALID_SOCKET;

                        
                        //PostQueuedCompletionStatus(g_iocp, 0, NULL, (LPOVERLAPPED)nop);

                        delete[]nop->buf;
                        nop->buf = NULL;

                        delete nop;
                        nop = NULL;
                }
        }
}

hxznhf

要么写错了，要么此处的m_is一定还有其它地方会同时修改它（比如其它线程），你后面代码也没截图完整。

承易

不明觉厉

〞剑舞长空

都m_is了，总不能线程抢占变量吧

7ian

不知这里，下面还有，这是处理沾包的代码，应该外面的if是后来加的