微芯片，通用tcp服务器

Question

我非常新的微芯片线，我目前使用的Pic32以太网起动器工具包2。我一直在播放和测试该产品的所有方面，我目前正在与通用的TCPIP伺服演示来自和谐。我可以在芯片上加载应用程序，并使用Telnet登录到它。我还可以看到，如果我输入"h“，它就会像它应该的那样回显"hH”。因为在这个演示中，它在上面运行一个ToUpper行。我想尝试的是在telnet中键入"hello“，然后让它将"World”发回，这只是一些简单的东西，让我用它来滚动。下面是读取传入数据的当前代码部分，将其转换为Upper并将其发回。

case APP_TCPIP_SERVING_CONNECTION:
    {
        if (!TCPIP_TCP_IsConnected(appData.socket))
        {
            appData.state = APP_TCPIP_CLOSING_CONNECTION;
            SYS_CONSOLE_MESSAGE("Connection was closed\r\n");
            break;
        }
        int16_t wMaxGet, wMaxPut, wCurrentChunk;
        uint16_t w, w2;
        uint8_t AppBuffer[32];

        //uint8_t AppBuffer2[] = "This is a Test";
        // Figure out how many bytes have been received and how many we can transmit.
        wMaxGet = TCPIP_TCP_GetIsReady(appData.socket); // Get TCP RX FIFO byte count
        wMaxPut = TCPIP_TCP_PutIsReady(appData.socket); // Get TCP TX FIFO free space

        // Make sure we don't take more bytes out of the RX FIFO than we can put into the TX FIFO
        if(wMaxPut < wMaxGet)
                wMaxGet = wMaxPut;

        // Process all bytes that we can
        // This is implemented as a loop, processing up to sizeof(AppBuffer) bytes at a time.
        // This limits memory usage while maximizing performance.  Single byte Gets and Puts are a lot slower than multibyte GetArrays and PutArrays.
        wCurrentChunk = sizeof(AppBuffer);
        for(w = 0; w < wMaxGet; w += sizeof(AppBuffer))
        {
            // Make sure the last chunk, which will likely be smaller than sizeof(AppBuffer), is treated correctly.
            if(w + sizeof(AppBuffer) > wMaxGet)
                wCurrentChunk = wMaxGet - w;

            // Transfer the data out of the TCP RX FIFO and into our local processing buffer.
            TCPIP_TCP_ArrayGet(appData.socket, AppBuffer, wCurrentChunk);

            // Perform the "ToUpper" operation on each data byte
            for(w2 = 0; w2 < wCurrentChunk; w2++)
            {
                i = AppBuffer[w2];
                if(i >= 'a' && i <= 'z')
                {
                        i -= ('a' - 'A');
                        AppBuffer[w2] = i;
                }
                else if(i == '\e')   //escape
                {
                    appData.state = APP_TCPIP_CLOSING_CONNECTION;
                    SYS_CONSOLE_MESSAGE("Connection was closed\r\n");
                }

            }

            // Transfer the data out of our local processing buffer and into the TCP TX FIFO.
            SYS_CONSOLE_PRINT("Server Sending %s\r\n", AppBuffer);
            TCPIP_TCP_ArrayPut(appData.socket, AppBuffer, wCurrentChunk);



            // No need to perform any flush.  TCP data in TX FIFO will automatically transmit itself after it accumulates for a while.  If you want to decrease latency (at the expense of wasting network bandwidth on TCP overhead), perform and explicit flush via the TCPFlush() API.
        }
    }
    break;

提前谢谢。PBSnake

Answer 1

case APP_TCPIP_SERVING_CONNECTION:
{
    static uint8_t message[] = "Hello";
    static uint16_t pos = 0;

    if (!TCPIP_TCP_IsConnected(appData.socket))
    {
        pos = 0;
        appData.state = APP_TCPIP_CLOSING_CONNECTION;
        SYS_CONSOLE_MESSAGE("Connection was closed\r\n");
        break;
    }
    int16_t wMaxGet, wMaxPut, wCurrentChunk;
    uint16_t w, w2;
    uint8_t AppBuffer[32];

    //uint8_t AppBuffer2[] = "This is a Test";
    // Figure out how many bytes have been received and how many we can transmit.
    wMaxGet = TCPIP_TCP_GetIsReady(appData.socket); // Get TCP RX FIFO byte count
    wMaxPut = TCPIP_TCP_PutIsReady(appData.socket); // Get TCP TX FIFO free space

    // Make sure we don't take more bytes out of the RX FIFO than we can put into the TX FIFO
    if(wMaxPut < wMaxGet)
            wMaxGet = wMaxPut;

    // Process all bytes that we can
    // This is implemented as a loop, processing up to sizeof(AppBuffer) bytes at a time.
    // This limits memory usage while maximizing performance.  Single byte Gets and Puts are a lot slower than multibyte GetArrays and PutArrays.
    wCurrentChunk = sizeof(AppBuffer);
    for(w2 = 0; w2 < wCurrentChunk; w2++)
    {

        i = AppBuffer[w2];

        if (i == message[pos]) 
        {
            pos++;

            if (pos == strlen(message))
            {
                pos = 0;
                strcpy(AppBuffer, "World");
                SYS_CONSOLE_PRINT("Server Sending %s\r\n", AppBuffer);
                TCPPutArray(MySocket, AppBuffer, strlen(AppBuffer));
            }
        } 
        else 
        {
            pos = 0;
        }

        if(i == '\e')   //escape
        {
            TCPServerState = SM_CLOSING;
        }

    }
}

break;