Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • uspace/srv/net/tcp/test.c

    r69a93df7 ra2e3ee6  
    3838#include <errno.h>
    3939#include <stdio.h>
    40 #include <thread.h>
     40#include <fibril.h>
    4141#include <str.h>
    4242#include "tcp_type.h"
     
    4747#define RCV_BUF_SIZE 64
    4848
    49 static void test_srv(void *arg)
     49static int test_srv(void *arg)
    5050{
    5151        tcp_conn_t *conn;
     
    5757
    5858        printf("test_srv()\n");
     59       
     60        inet_addr(&lsock.addr, 127, 0, 0, 1);
    5961        lsock.port = 80;
    60         lsock.addr.ipv4 = 0x7f000001;
     62       
     63        inet_addr(&fsock.addr, 127, 0, 0, 1);
    6164        fsock.port = 1024;
    62         fsock.addr.ipv4 = 0x7f000001;
     65       
    6366        printf("S: User open...\n");
    6467        tcp_uc_open(&lsock, &fsock, ap_passive, 0, &conn);
     
    8487
    8588        printf("test_srv() terminating\n");
     89        return 0;
    8690}
    8791
    88 static void test_cli(void *arg)
     92static int test_cli(void *arg)
    8993{
    9094        tcp_conn_t *conn;
     
    9498
    9599        printf("test_cli()\n");
    96 
     100       
     101        inet_addr(&lsock.addr, 127, 0, 0, 1);
    97102        lsock.port = 1024;
    98         lsock.addr.ipv4 = 0x7f000001;
     103       
     104        inet_addr(&fsock.addr, 127, 0, 0, 1);
    99105        fsock.port = 80;
    100         fsock.addr.ipv4 = 0x7f000001;
    101106
    102107        async_usleep(1000*1000*3);
     
    112117        printf("C: User close...\n");
    113118        tcp_uc_close(conn);
     119
     120        return 0;
    114121}
    115122
    116123void tcp_test(void)
    117124{
    118         thread_id_t srv_tid;
    119         thread_id_t cli_tid;
    120         int rc;
     125        fid_t srv_fid;
     126        fid_t cli_fid;
    121127
    122128        printf("tcp_test()\n");
     
    125131
    126132        if (0) {
    127                 rc = thread_create(test_srv, NULL, "test_srv", &srv_tid);
    128                 if (rc != EOK) {
    129                         printf("Failed to create server thread.\n");
     133                srv_fid = fibril_create(test_srv, NULL);
     134                if (srv_fid == 0) {
     135                        printf("Failed to create server fibril.\n");
    130136                        return;
    131137                }
     138
     139                fibril_add_ready(srv_fid);
    132140        }
    133141
    134142        if (0) {
    135                 rc = thread_create(test_cli, NULL, "test_cli", &cli_tid);
    136                 if (rc != EOK) {
    137                         printf("Failed to create client thread.\n");
     143                cli_fid = fibril_create(test_cli, NULL);
     144                if (cli_fid == 0) {
     145                        printf("Failed to create client fibril.\n");
    138146                        return;
    139147                }
     148
     149                fibril_add_ready(cli_fid);
    140150        }
    141151}
Note: See TracChangeset for help on using the changeset viewer.