DE4 simple socket server

Hello all,

I implemented a data acquisition system on the DE4. In general, I grab a fixed number of samples (called A-line), store them on a RAM and then my SOPC reads the RAM contents (through PIO's) and then Nios sends data through ethernet to the PC (Matlab, with pnet http://www.mathworks.com/matlabcentral/fileexchange/345-tcpudpip-toolbox-2-0-6)

I modified the example provided by Terasic, having 2 transfer modes:

1. Slow transfer: I send a command (ASCII 65) to the socket server and it sends one A-line to PC. Works fine, but terribly slow (~4.85 lines/sec).

2. Continuous transfer: I send another command (ASCII 67) and the socket server continuously sends A-lines (~1093 lines/sec), but they overlap each other. See attached picture.

I wonder if anyone has an idea how to avoid data from overlapping :confused:

I basically modified the function sss_exec_command in the code simple_socket_server.c:

.
.
.
/*sss_exec_command()*/
void sss_exec_command(SSSConn* conn)
{
    int bytes_to_process = conn->rx_wr_pos - conn->rx_rd_pos;
    INT8U tx_buf;
    INT8U *tx_wr_pos = tx_buf;
    int pos_ini = tx_wr_pos;
    INT8U error_code;
    /*
    * "SSSCommand" is declared static so that the data will reside
    * in the BSS segment. This is done because a pointer to the data in
    * SSSCommand
    * will be passed via SSSLedCommandQ to the LEDManagementTask. 
    * Therefore SSSCommand cannot be placed on the stack of the
    * SSSSimpleSocketServerTask, since the LEDManagementTask does not
    * have access to the stack of the SSSSimpleSocketServerTask.
    */
    static INT32U SSSCommand;
    SSSCommand = CMD_LEDS_BIT_0_TOGGLE;
    while(bytes_to_process--)
    {
        SSSCommand = toupper(*(conn->rx_rd_pos++));
        if(SSSCommand >= ' ' && SSSCommand <= '~')
        {
            tx_wr_pos += sprintf(tx_wr_pos,
                "--> Simple Socket Server Command %c.\n\r",
                (char)SSSCommand);
            if (SSSCommand == CMD_QUIT)
            {
                tx_wr_pos += sprintf(tx_wr_pos,"Terminating connection.\n\n\r");
                conn->close = 1;
            } // END if (SSSCommand == CMD_QUIT)
            else
            {
                if (SSSCommand == 65)
                {// Read command A (ASCII code = 65)
                    //printf("--> Acquiring single %c-line...\n",(char)SSSCommand);
                    // Wait to finish writing acquired data to the RAM
                    do
                    {
                        acq_busy_signal = IORD_ALTERA_AVALON_PIO_DATA(ACQ_BUSY_PIO_BASE);
                        // look definitions in ..software\simple_socket_server\simple_socket_server_syslib\Debug\system_description\system.h
                    }
                    while (acq_busy_signal == 1);
                    // Indicate that we are busy reading RAM contents
                    read_RAM_busy = 1;
                    IOWR_ALTERA_AVALON_PIO_DATA(READ_RAM_BUSY_PIO_BASE, read_RAM_busy);
                    // Do the transfer
                    buffer_position = 0;
                    *tx_wr_pos = 0;
                    tx_wr_pos = pos_ini;             
                    if (acq_busy_signal == 0)//acq_busy_signal == 0
                    {
                        for (RAM_address = 1; RAM_address <= NSAMPLES; RAM_address++)
                        {
                            // Read data port (from RAM)
                            ADC_data = IORD_ALTERA_AVALON_PIO_DATA(ADC_DATA_PIO_BASE);
                            // Write address port (to RAM)
                            IOWR_ALTERA_AVALON_PIO_DATA(READ_RAM_ADDRESS_BASE, RAM_address + 1);
                            dataPointer = &ADC_data;
                            // Send 16-bit data
                            tx_buf = dataPointer;
                            tx_buf = dataPointer;
                            /*                If ADC_data == 32bits
                            tx_buf = dataPointer;
                            tx_buf = dataPointer;
                            tx_buf = dataPointer;
                            tx_buf = dataPointer;
                            tx_wr_pos += 4;                     // 4 bytes*/
                            tx_wr_pos += 2;                     // 2 bytes increment
                            buffer_position += 2;
                            // Send data every 500*2 bytes               
                            /*                if (RAM_address % 500 == 0 && RAM_address != 0)
                            {
                            send(conn->fd, tx_buf, tx_wr_pos - tx_buf, 0);
                            buffer_position = 0;
                            *tx_wr_pos = 0;
                            tx_wr_pos = pos_ini;   
                            }
                            else
                            {
                            buffer_position = (RAM_address  % 500) * 2; //2 bytes
                            }*/
                        } // END for (RAM_address = 0; RAM_address <= NSAMPLES; RAM_address++)
                        send(conn->fd, tx_buf, tx_wr_pos - tx_buf, 0);
                        buffer_position = 0;
                        *tx_wr_pos = 0;
                        tx_wr_pos = pos_ini; 
                        //printf("--> A-line sent!\n");
                    } // END if (acq_busy_signal == 0)
                    // Indicate that we are done reading RAM contents
                    read_RAM_busy = 0;
                    IOWR_ALTERA_AVALON_PIO_DATA(READ_RAM_BUSY_PIO_BASE, read_RAM_busy);
                } // END if (SSSCommand == 65)
               
                else
                {
                    if (SSSCommand == 67)
                    {
                        printf("Continuous acquisition! \n");
                        while (SSSCommand != CMD_QUIT)
                        {
                            // Wait to finish writing acquired data to the RAM
                    do
                    {
                        acq_busy_signal = IORD_ALTERA_AVALON_PIO_DATA(ACQ_BUSY_PIO_BASE);
                        // look definitions in ..software\simple_socket_server\simple_socket_server_syslib\Debug\system_description\system.h
                    }
                    while (acq_busy_signal == 1);
                    // Indicate that we are busy reading RAM contents
                    read_RAM_busy = 1;
                    IOWR_ALTERA_AVALON_PIO_DATA(READ_RAM_BUSY_PIO_BASE, read_RAM_busy);
                    // Do the transfer
                    buffer_position = 0;
                    *tx_wr_pos = 0;
                    tx_wr_pos = pos_ini;             
                    if (acq_busy_signal == 0)//acq_busy_signal == 0
                    {
                        for (RAM_address = 1; RAM_address <= NSAMPLES; RAM_address++)
                        {
                            // Read data port (from RAM)
                            ADC_data = IORD_ALTERA_AVALON_PIO_DATA(ADC_DATA_PIO_BASE);
                            // Write address port (to RAM)
                            IOWR_ALTERA_AVALON_PIO_DATA(READ_RAM_ADDRESS_BASE, RAM_address + 1);
                            dataPointer = &ADC_data;
                            // Send 16-bit data
                            tx_buf = dataPointer;
                            tx_buf = dataPointer;
                            tx_wr_pos += 2;                     // 2 bytes increment
                            buffer_position += 2;
                        } // END for (RAM_address = 0; RAM_address <= NSAMPLES; RAM_address++)
                        send(conn->fd, tx_buf, tx_wr_pos - tx_buf, 0);
                        buffer_position = 0;
                        *tx_wr_pos = 0;
                        tx_wr_pos = pos_ini; 
                    } // END if (acq_busy_signal == 0)
                    // Indicate that we are done reading RAM contents
                    read_RAM_busy = 0;
                    IOWR_ALTERA_AVALON_PIO_DATA(READ_RAM_BUSY_PIO_BASE, read_RAM_busy);
                        } // END while (SSSCommand != CMD_QUIT)
                    } // END if (SSSCommand == 67)
                    else
                    {
                    error_code = OSQPost(SSSLEDCommandQ, (void *)SSSCommand);   
                    alt_SSSErrorHandler(error_code, 0);
                    } // END else if (SSSCommand == 67)
                } // END else if (SSSCommand == 65)
            } // END else if(SSSCommand == CMD_QUIT)
        } // END if(SSSCommand >= ' ' && SSSCommand <= '~')
    } // END while(bytes_to_process--)
    // ORIGINAL POSITION OF SEND COMMAND!!!
    return;
} // END void sss_exec_command(SSSConn* conn)
.
.
.

p.s. change .zip extension to .rar