Subversion Repositories openrisc

//==========================================================================

//

//      tests/nc_test_slave.c

//

//      Network characterizations test (slave portion)

//

//==========================================================================

// ####BSDALTCOPYRIGHTBEGIN####                                             

// -------------------------------------------                              

// Portions of this software may have been derived from FreeBSD, OpenBSD,   

// or other sources, and if so are covered by the appropriate copyright     

// and license included herein.                                             

// -------------------------------------------                              

// ####BSDALTCOPYRIGHTEND####                                               

//==========================================================================

//#####DESCRIPTIONBEGIN####

//

// Author(s):    gthomas

// Contributors: gthomas

// Date:         2000-01-10

// Purpose:      

// Description:  

//              

//

//####DESCRIPTIONEND####

//

//==========================================================================

// Network characterization test code - slave portion

#include "nc_test_framework.h"

#include <math.h>

#ifdef __ECOS

#ifndef CYGPKG_LIBC_STDIO

#define perror(s) diag_printf(#s ": %s\n", strerror(errno))

#endif

#define STACK_SIZE               (CYGNUM_HAL_STACK_SIZE_TYPICAL + 0x1000)

#define MAX_LOAD_THREAD_LEVEL    20

#define MIN_LOAD_THREAD_LEVEL    0

#define NUM_LOAD_THREADS         10

#define IDLE_THREAD_PRIORITY     CYGPKG_NET_THREAD_PRIORITY+3

#define LOAD_THREAD_PRIORITY     CYGPKG_NET_THREAD_PRIORITY-1

#define MAIN_THREAD_PRIORITY     CYGPKG_NET_THREAD_PRIORITY-2

#define DESIRED_BACKGROUND_LOAD  20

static char         main_thread_stack[CYGHWR_NET_DRIVERS][STACK_SIZE];

static cyg_thread   main_thread_data[CYGHWR_NET_DRIVERS];

static cyg_handle_t main_thread_handle[CYGHWR_NET_DRIVERS];

static char         idle_thread_stack[STACK_SIZE];

static cyg_thread   idle_thread_data;

static cyg_handle_t idle_thread_handle;

static cyg_sem_t    idle_thread_sem;

volatile static long long    idle_thread_count;

static cyg_tick_count_t idle_thread_start_time;

static cyg_tick_count_t idle_thread_stop_time;

static char         load_thread_stack[NUM_LOAD_THREADS][STACK_SIZE];

static cyg_thread   load_thread_data[NUM_LOAD_THREADS];

static cyg_handle_t load_thread_handle[NUM_LOAD_THREADS];

static cyg_sem_t    load_thread_sem[NUM_LOAD_THREADS];

static long         load_thread_level;

static void calibrate_load(int load);

static void start_load(int load);

static void do_some_random_computation(int p);

#define abs(n) ((n) < 0 ? -(n) : (n))

#endif

#ifdef __ECOS

#define test_param_t cyg_addrword_t

#ifdef CYGDBG_NET_TIMING_STATS

extern void show_net_times(void);

#endif

#else

#define test_param_t int

#endif

#define MAX_BUF 8192

static unsigned char in_buf[MAX_BUF], out_buf[MAX_BUF];

#ifdef __ECOS

extern void

cyg_test_exit(void);

#else

void

cyg_test_exit(void)

{

    test_printf("... Done\n");

    exit(1);

}

static void

show_net_times(void)

{

}

#endif

#ifdef __ECOS

static void

test_delay(int ticks)

{

    cyg_thread_delay(ticks);

}

#else

static void

test_delay(int ticks)

{

    usleep(ticks * 10000);

}

#endif

void

pexit(char *s)

{

    perror(s);

#ifdef CYGDBG_NET_TIMING_STATS

    show_net_times();

#endif

    cyg_test_exit();

}

//

// Generic UDP test

//

static void

do_udp_test(int s1, struct nc_request *req, struct sockaddr_in *master)

{

    int i, s, td_len, seq, seq_errors, lost;

    struct sockaddr_in test_chan_slave, test_chan_master;

    fd_set fds;

    struct timeval timeout;

    struct nc_test_results results;

    struct nc_test_data *tdp;

    int nsent, nrecvd;

    int need_recv, need_send;

    need_recv = true;  need_send = true;

    switch (ntohl(req->type)) {

    case NC_REQUEST_UDP_SEND:

        need_recv = false;

        need_send = true;

        break;

    case NC_REQUEST_UDP_RECV:

        need_recv = true;

        need_send = false;

        break;

    case NC_REQUEST_UDP_ECHO:

        break;

    }

    s = socket(AF_INET, SOCK_DGRAM, 0);

    if (s < 0) {

        pexit("datagram socket");

    }

    memset((char *) &test_chan_slave, 0, sizeof(test_chan_slave));

    test_chan_slave.sin_family = AF_INET;

#ifdef __ECOS

    test_chan_slave.sin_len = sizeof(test_chan_slave);

#endif

    test_chan_slave.sin_addr.s_addr = htonl(INADDR_ANY);

    test_chan_slave.sin_port = htons(ntohl(req->slave_port));

    if (bind(s, (struct sockaddr *) &test_chan_slave, sizeof(test_chan_slave)) < 0) {

        perror("bind");

        close(s);

    }

    memcpy(&test_chan_master, master, sizeof(*master));

    test_chan_master.sin_port = htons(ntohl(req->master_port));

    nsent = 0;  nrecvd = 0;  seq = 0;  seq_errors = 0;  lost = 0;

    for (i = 0;  i < ntohl(req->nbufs);  i++) {

        if (need_recv) {

            FD_ZERO(&fds);

            FD_SET(s, &fds);

            timeout.tv_sec = NC_TEST_TIMEOUT;

            timeout.tv_usec = 0;

            if (select(s+1, &fds, 0, 0, &timeout) <= 0) {

                test_printf("recvfrom timeout, expecting seq #%d\n", seq);

                if (++lost > MAX_ERRORS) {

                    test_printf("... giving up\n");

                    break;

                }

            } else {

                nrecvd++;

                tdp = (struct nc_test_data *)in_buf;

                td_len = ntohl(req->buflen) + sizeof(struct nc_test_data);

                if (recvfrom(s, tdp, td_len, 0, 0, 0) < 0) {

                    perror("recvfrom");

                    close(s);

                    return;

                }

                if ((ntohl(tdp->key1) == NC_TEST_DATA_KEY1) &&

                    (ntohl(tdp->key2) == NC_TEST_DATA_KEY2)) {

                    if (ntohl(tdp->seq) != seq) {

                        test_printf("Packets out of sequence - recvd: %d, expected: %d\n",

                                    ntohl(tdp->seq), seq);

                        seq = ntohl(tdp->seq);

                        seq_errors++;

                    }

                } else {

                    test_printf("Bad data packet - key: %x/%x, seq: %d\n",

                                ntohl(tdp->key1), ntohl(tdp->key2),

                                ntohl(tdp->seq));

                }

            }

        }

        if (need_send) {

            int retries = 10;

            int sent = false;

            int res;

            tdp = (struct nc_test_data *)out_buf;

            tdp->key1 = htonl(NC_TEST_DATA_KEY1);

            tdp->key2 = htonl(NC_TEST_DATA_KEY2);

            tdp->seq = htonl(seq);

            td_len = ntohl(req->buflen) + sizeof(struct nc_test_data);

            tdp->len = htonl(td_len);

            while (!sent && (--retries >= 0)) {

                res = sendto(s, tdp, td_len, 0,

                             (struct sockaddr *)&test_chan_master, sizeof(test_chan_master));

                if (res > 0) {

                    sent = true;

                    break;

                }

                if (errno == ENOBUFS) {

                    // Saturated the system

                    test_delay(1);   // Time for 200 500 byte 10-baseT packets 

                } else {

                    // What else to do?

                    close(s);

                    return;

                }

            }

            if (sent) {

                nsent++;

            } else {

                perror("sendto");

            }

        }

        seq++;

    }

    results.key1 = htonl(NC_TEST_RESULT_KEY1);

    results.key2 = htonl(NC_TEST_RESULT_KEY2);

    results.seq = req->seq;

    results.nsent = htonl(nsent);

    results.nrecvd = htonl(nrecvd);

    if (sendto(s, &results, sizeof(results), 0,

               (struct sockaddr *)&test_chan_master, sizeof(test_chan_master)) < 0) {

        perror("sendto results");

    }

    close(s);

}

//

// Read data from a stream, accounting for the fact that packet 'boundaries'

// are not preserved.  This can also timeout (which would probably wreck the

// data boundaries).

//

int

do_read(int fd, void *buf, int buflen)

{

    char *p = (char *)buf;

    int len = buflen;

    int res;

    while (len) {

        res = read(fd, p, len);

        if (res < 0) {

            perror("read");

        } else {

            len -= res;

            p += res;

            if (res == 0) {

                break;

            }

        }

    }

    return (buflen - len);

}

//

// Generic TCP test

//

static void

do_tcp_test(int s1, struct nc_request *req, struct sockaddr_in *master)

{

    int i, s, td_len, seq, seq_errors, lost, test_chan, res;

    socklen_t len;

    struct sockaddr_in test_chan_slave, test_chan_master;

    struct nc_test_results results;

    struct nc_test_data *tdp;

    int nsent, nrecvd;

    int need_recv, need_send;

    int one = 1;

    static int slave_tcp_port = -1;

    need_recv = true;  need_send = true;

    switch (ntohl(req->type)) {

    case NC_REQUEST_TCP_SEND:

        need_recv = false;

        need_send = true;

        break;

    case NC_REQUEST_TCP_RECV:

        need_recv = true;

        need_send = false;

        break;

    case NC_REQUEST_TCP_ECHO:

        break;

    }

    if (slave_tcp_port < 0) {

        s = socket(AF_INET, SOCK_STREAM, 0);

        if (s < 0) {

            pexit("datagram socket");

        }

        if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one))) {

            perror("setsockopt SO_REUSEADDR");

            return;

        }

#ifdef SO_REUSEPORT

        if (setsockopt(s, SOL_SOCKET, SO_REUSEPORT, &one, sizeof(one))) {

            perror("setsockopt SO_REUSEPORT");

            return;

        }

#endif

        memset((char *) &test_chan_slave, 0, sizeof(test_chan_slave));

        test_chan_slave.sin_family = AF_INET;

#ifdef __ECOS

        test_chan_slave.sin_len = sizeof(test_chan_slave);

#endif

        test_chan_slave.sin_addr.s_addr = htonl(INADDR_ANY);

        test_chan_slave.sin_port = htons(ntohl(req->slave_port));

        if (bind(s, (struct sockaddr *) &test_chan_slave, sizeof(test_chan_slave)) < 0) {

            perror("bind");

            close(s);

        }

        listen(s, SOMAXCONN);

        slave_tcp_port = s;

    }

    s = slave_tcp_port;

    len = sizeof(test_chan_master);

    if ((test_chan = accept(s, (struct sockaddr *)&test_chan_master, &len)) < 0) {

        pexit("accept");

    }

    len = sizeof(test_chan_master);

    getpeername(test_chan, (struct sockaddr *)&test_chan_master, &len);

    test_printf("connection from %s.%d\n", inet_ntoa(test_chan_master.sin_addr),

                ntohs(test_chan_master.sin_port));

    nsent = 0;  nrecvd = 0;  seq = 0;  seq_errors = 0;  lost = 0;

    for (i = 0;  i < ntohl(req->nbufs);  i++) {

        if (need_recv) {

            tdp = (struct nc_test_data *)in_buf;

            td_len = ntohl(req->buflen) + sizeof(struct nc_test_data);

            res = do_read(test_chan, tdp, td_len);

            if (res != td_len) {

                test_printf("recvfrom timeout, expecting seq #%d\n", seq);

                if (++lost > MAX_ERRORS) {

                    test_printf("... giving up\n");

                    break;

                }

            } else {

                nrecvd++;

                if ((ntohl(tdp->key1) == NC_TEST_DATA_KEY1) &&

                    (ntohl(tdp->key2) == NC_TEST_DATA_KEY2)) {

                    if (ntohl(tdp->seq) != seq) {

                        test_printf("Packets out of sequence - recvd: %d, expected: %d\n",

                                    ntohl(tdp->seq), seq);

                        seq = ntohl(tdp->seq);

                        seq_errors++;

                    }

                } else {

                    test_printf("Bad data packet - key: %x/%x, seq: %d\n",

                                ntohl(tdp->key1), ntohl(tdp->key2),

                                ntohl(tdp->seq));

                }

            }

        }

        if (need_send) {

            tdp = (struct nc_test_data *)out_buf;

            tdp->key1 = htonl(NC_TEST_DATA_KEY1);

            tdp->key2 = htonl(NC_TEST_DATA_KEY2);

            tdp->seq = htonl(seq);

            td_len = ntohl(req->buflen) + sizeof(struct nc_test_data);

            tdp->len = htonl(td_len);

            if (write(test_chan, tdp, td_len) != td_len) {

                perror("write");

                if (errno == ENOBUFS) {

                    // Saturated the system

                    test_delay(25);

                } else {

                    // What else to do?

                    close(test_chan);

                    return;

                }

            } else {

                nsent++;

            }

        }

        seq++;

    }

    results.key1 = htonl(NC_TEST_RESULT_KEY1);

    results.key2 = htonl(NC_TEST_RESULT_KEY2);

    results.seq = req->seq;

    results.nsent = htonl(nsent);

    results.nrecvd = htonl(nrecvd);

    if (write(test_chan, &results, sizeof(results)) != sizeof(results)) {

        perror("write");

    }

    close(test_chan);

}

//

// Protocol driver for testing slave.

//

// This function is the main routine running here, handling requests sent from

// the master and providing various responses.

//

static void

nc_slave(test_param_t param)

{

    int s;

    socklen_t masterlen;

    struct sockaddr_in my_addr, master;

    struct nc_request req;

    struct nc_reply reply;

    int done = false;

    test_printf("Start test for eth%d\n", param);

    s = socket(AF_INET, SOCK_DGRAM, 0);

    if (s < 0) {

        pexit("datagram socket");

    }

    memset((char *) &my_addr, 0, sizeof(my_addr));

    my_addr.sin_family = AF_INET;

#ifdef __ECOS

    my_addr.sin_len = sizeof(my_addr);

#endif

    my_addr.sin_addr.s_addr = htonl(INADDR_ANY);

    my_addr.sin_port = htons(NC_SLAVE_PORT);

    if (bind(s, (struct sockaddr *) &my_addr, sizeof(my_addr)) < 0) {

        pexit("bind");

    }

    while (!done) {

        masterlen = sizeof(master);

        if (recvfrom(s, &req, sizeof(req), 0, (struct sockaddr *)&master, &masterlen) < 0) {

            pexit("recvfrom");

        }

#if 0

        test_printf("Request %d from %s:%d\n", ntohl(req.type),

                    inet_ntoa(master.sin_addr), ntohs(master.sin_port));

#endif

        reply.response = htonl(NC_REPLY_ACK);

        reply.seq = req.seq;

        switch (ntohl(req.type)) {

        case NC_REQUEST_DISCONNECT:

            done = true;

            break;

        case NC_REQUEST_UDP_SEND:

            test_printf("UDP send - %d buffers, %d bytes\n", ntohl(req.nbufs), ntohl(req.buflen));

            break;

        case NC_REQUEST_UDP_RECV:

            test_printf("UDP recv - %d buffers, %d bytes\n", ntohl(req.nbufs), ntohl(req.buflen));

            break;

        case NC_REQUEST_UDP_ECHO:

            test_printf("UDP echo - %d buffers, %d bytes\n", ntohl(req.nbufs), ntohl(req.buflen));

            break;

        case NC_REQUEST_TCP_SEND:

            test_printf("TCP send - %d buffers, %d bytes\n", ntohl(req.nbufs), ntohl(req.buflen));

            break;

        case NC_REQUEST_TCP_RECV:

            test_printf("TCP recv - %d buffers, %d bytes\n", ntohl(req.nbufs), ntohl(req.buflen));

            break;

        case NC_REQUEST_TCP_ECHO:

            test_printf("TCP echo - %d buffers, %d bytes\n", ntohl(req.nbufs), ntohl(req.buflen));

            break;

#ifdef __ECOS

        case NC_REQUEST_SET_LOAD:

            start_load(ntohl(req.nbufs));

            break;

        case NC_REQUEST_START_IDLE:

            test_printf("Start IDLE thread\n");

            idle_thread_count = 0;

            idle_thread_start_time = cyg_current_time();

            cyg_semaphore_post(&idle_thread_sem);

            break;

        case NC_REQUEST_STOP_IDLE:

            cyg_semaphore_wait(&idle_thread_sem);

            idle_thread_stop_time = cyg_current_time();

            test_printf("Stop IDLE thread\n");

            reply.misc.idle_results.elapsed_time = htonl(idle_thread_stop_time - idle_thread_start_time);

            reply.misc.idle_results.count[0] = htonl(idle_thread_count >> 32);

            reply.misc.idle_results.count[1] = htonl((long)idle_thread_count);

            break;

#endif

        default:

            test_printf("Unrecognized request: %d\n", ntohl(req.type));

            reply.response = htonl(NC_REPLY_NAK);

            reply.reason = htonl(NC_REPLY_NAK_UNKNOWN_REQUEST);

            break;

        }

        if (sendto(s, &reply, sizeof(reply), 0, (struct sockaddr *)&master, masterlen) < 0) {

            pexit("sendto");

        }

        if (reply.response == ntohl(NC_REPLY_NAK)) {

            continue;

        }

        switch (ntohl(req.type)) {

        case NC_REQUEST_UDP_SEND:

        case NC_REQUEST_UDP_RECV:

        case NC_REQUEST_UDP_ECHO:

            do_udp_test(s, &req, &master);

            break;

        case NC_REQUEST_TCP_SEND:

        case NC_REQUEST_TCP_RECV:

        case NC_REQUEST_TCP_ECHO:

            do_tcp_test(s, &req, &master);

            break;

        case NC_REQUEST_START_IDLE:

        case NC_REQUEST_STOP_IDLE:

        case NC_REQUEST_SET_LOAD:

        default:

            break;

        }

    }

    close(s);

}

void

net_test(test_param_t param)

{

//    int i;

    if (param == 0) {

        test_printf("Start Network Characterization - SLAVE\n");

#ifdef __ECOS

        init_all_network_interfaces();

        calibrate_load(DESIRED_BACKGROUND_LOAD);

#if 0

// I can see what this is trying to do, but I get "bind: Address already in

// use" errors from the 2nd interface - and the parameter is not used

// anyway, so one thread does quite well enough (but only tests one i/f at

// once).

// Comment in the 'int i' above too.

        for (i = 1;  i < CYGHWR_NET_DRIVERS;  i++) {

            cyg_thread_resume(main_thread_handle[i]);   // Start other threads

        }

#endif

#endif

    }

    nc_slave(param);

#ifdef CYGDBG_NET_TIMING_STATS

    show_net_times();

#endif

    cyg_test_exit();

}

#ifdef __ECOS

//

// This function is called to calibrate the "background load" which can be

// applied during testing.  It will be called before any commands from the

// host are managed.

//

static void

calibrate_load(int desired_load)

{

    long long no_load_idle, load_idle;

    int percent_load;

    int high, low;

    // Set limits

    high = MAX_LOAD_THREAD_LEVEL;

    low = MIN_LOAD_THREAD_LEVEL;

    // Compute the "no load" idle value

    idle_thread_count = 0;

    cyg_semaphore_post(&idle_thread_sem);  // Start idle thread

    cyg_thread_delay(1*100);               // Pause for one second

    cyg_semaphore_wait(&idle_thread_sem);  // Stop idle thread

    no_load_idle = idle_thread_count;

    diag_printf("No load = %d\n", (int)idle_thread_count);

    // First ensure that the HIGH level is indeed higher

    while (true) {

        load_thread_level = high;

        start_load(desired_load);              // Start up a given load

        idle_thread_count = 0;

        cyg_semaphore_post(&idle_thread_sem);  // Start idle thread

        cyg_thread_delay(1*100);               // Pause for one second

        cyg_semaphore_wait(&idle_thread_sem);  // Stop idle thread

        load_idle = idle_thread_count;

        start_load(0);                         // Shut down background load

        percent_load = 100 - ((load_idle * 100) / no_load_idle);

        diag_printf("High Load[%ld] = %d => %d%%\n", load_thread_level,

                    (int)idle_thread_count, percent_load);

        if ( percent_load > desired_load )

            break; // HIGH level is indeed higher

        low = load_thread_level; // known to be lower

        high *= 2; // else double it and try again

    }

    // Now chop down to the level required

    while (true) {

        load_thread_level = (high + low) / 2;

        start_load(desired_load);              // Start up a given load

        idle_thread_count = 0;

        cyg_semaphore_post(&idle_thread_sem);  // Start idle thread

        cyg_thread_delay(1*100);               // Pause for one second

        cyg_semaphore_wait(&idle_thread_sem);  // Stop idle thread

        load_idle = idle_thread_count;

        start_load(0);                         // Shut down background load

        percent_load = 100 - ((load_idle * 100) / no_load_idle);

        diag_printf("Load[%ld] = %d => %d%%\n", load_thread_level,

                    (int)idle_thread_count, percent_load);

        if (((high-low) <= 1) || (abs(desired_load-percent_load) <= 2)) break;