spieleprogrammierer.de - Forum und Wiki zur Spieleprogrammierung und Spieleentwicklung

C-/C++-Quelltext

void BasicClient::ThreadUpdate(unsigned acttime)
{
    if(state == CONNECTING && !tryconnect())
        return;

    TIMEVAL     time;
    fd_set      readset;

    time.tv_sec = 0;
    time.tv_usec = 1000;
    
    FD_ZERO(&readset);
    FD_SET(Socket, &readset);

    if(-1 == select(static_cast<int>(Socket + 1), &readset, NULL, NULL, &time))
    {
        geterror();//EDIT: has to be logged
        state = FAILED;
    }

    if(FD_ISSET(Socket, &readset))
        ClientCallback();
}

C-/C++-Quelltext

void Clientclass::ClientCallback(void)
{
    int rl = recv(Socket, const_cast<char*>(RecvBuffer.GetDataFromWOffset()), (int)RecvBuffer.GetUnusedSize(), 0);
    if(rl == -1 || rl == 0)// occur an error?
    {
        state = FAILED;
        geterror();
        return;
    }

    RecvBuffer.SetWriteOffset(rl + RecvBuffer.GetWriteOffset());

    while(RecvBuffer.GetWriteOffset() >= PAKETSIZE)
    {
        if(!ParsedHeader)
        {
            ParsedHeader = true;

            //parse data into header
            RecvPacket.ReadHeader(RecvBuffer);

            //is the packet correct?
            if(!IsHeaderOkay(RecvPacket))
            {
                HandleErrorMessage("Message from syncsys: Header is corrupted");
                state = FAILED;
                return;
            }

            unsigned CompleteSize = RecvPacket.ZippedSize + PAKETSIZE;
            if(CompleteSize < RecvBuffer.GetWriteOffset())  CompleteSize = RecvBuffer.GetWriteOffset();
            CheckAndDoResize(RecvBuffer, CompleteSize, true);
            
            if(RecvPacket.MSG == CloseMsg)
            {
                Send(RecvPacket);
                if(0 != closesocket(Socket))
                    geterror();
                Socket = (SOCKET)-1;
                state = CLOSED;
                break;
            }
        }
        unsigned int CompleteSize = RecvPacket.ZippedSize + PAKETSIZE;
        //are there enough buffered data?
        if(RecvBuffer.GetWriteOffset() >= CompleteSize)
        {
                    [... ein wenig dekompressionskrams später...]
            
            if(!AsyncCallbackFunc(RecvPacket))
                SyncList.push_back(RecvPacket, true);

            //reset RecvLen + Buffer, cleaning up etc.
            NumRecvPackets++;
            SizeRecvPackets += CompleteSize;

            RecvBuffer.ShiftBuffer(true, CompleteSize);
            ParsedHeader    = false;
        }
        else
            break;//lets go away
    }
}