X-Git-Url: http://git.silcnet.org/gitweb/?a=blobdiff_plain;f=lib%2Fsilcutil%2Ftests%2Ftest_silcnet.c;h=246d56bf3b7a04ce9cd5d35963a1e76e9bef52e8;hb=aa427d8e98d1b24952f869062536ca6c49670479;hp=9158585809677f3193cdc0bccf6b40c28e6077eb;hpb=bdf83e1e0e5c65a888075986a452c6e431047a6d;p=silc.git diff --git a/lib/silcutil/tests/test_silcnet.c b/lib/silcutil/tests/test_silcnet.c index 91585858..246d56bf 100644 --- a/lib/silcutil/tests/test_silcnet.c +++ b/lib/silcutil/tests/test_silcnet.c @@ -6,7 +6,7 @@ SilcSchedule schedule; typedef struct { SilcFSM fsm; - SilcFSMSemaStruct sema; + SilcFSMEventStruct sema; SilcFSMThreadStruct thread; SilcNetListener server; SilcStream client_stream; @@ -30,7 +30,7 @@ static void test_accept_connection(SilcNetStatus status, SilcStream stream, SILC_LOG_DEBUG(("Accepted new connection")); f->client_status = status; f->client_stream = stream; - SILC_FSM_SEMA_POST(&f->sema); + SILC_FSM_EVENT_SIGNAL(&f->sema); } static void test_connected(SilcNetStatus status, SilcStream stream, @@ -66,13 +66,13 @@ SILC_FSM_STATE(test_st_connected) if (f->server_status != SILC_NET_OK) { SILC_LOG_DEBUG(("Creating connection failed")); - return SILC_FSM_FINISH; + SILC_FSM_FINISH; } silc_socket_stream_get_info(f->server_stream, NULL, &host, &ip, &port); SILC_LOG_DEBUG(("Connected to server %s, %s:%d", host, ip, port)); - return SILC_FSM_FINISH; + SILC_FSM_FINISH; } SILC_FSM_STATE(test_st_start) @@ -89,7 +89,7 @@ SILC_FSM_STATE(test_st_start) /** Creating network listener failed */ SILC_LOG_DEBUG(("Listener creation failed")); silc_fsm_next(fsm, test_st_finish); - return SILC_FSM_CONTINUE; + SILC_FSM_CONTINUE; } /* Create thread to connect to the listener */ @@ -98,9 +98,9 @@ SILC_FSM_STATE(test_st_start) /** Start waiting connection */ SILC_LOG_DEBUG(("Start waiting for incoming connections")); - silc_fsm_sema_init(&f->sema, fsm, 0); + silc_fsm_event_init(&f->sema, fsm); silc_fsm_next(fsm, test_st_second); - return SILC_FSM_CONTINUE; + SILC_FSM_CONTINUE; } SILC_FSM_STATE(test_st_second) @@ -111,13 +111,13 @@ SILC_FSM_STATE(test_st_second) SILC_LOG_DEBUG(("test_st_second")); - SILC_FSM_SEMA_WAIT(&f->sema); + SILC_FSM_EVENT_WAIT(&f->sema); if (f->client_status != SILC_NET_OK) { /** Accepting new connection failed */ SILC_LOG_DEBUG(("Accepting failed %d", f->client_status)); silc_fsm_next(fsm, test_st_finish); - return SILC_FSM_CONTINUE; + SILC_FSM_CONTINUE; } silc_socket_stream_get_info(f->client_stream, NULL, &host, &ip, &port); @@ -148,7 +148,7 @@ SILC_FSM_STATE(test_st_finish) silc_net_close_listener(f->server); SILC_LOG_DEBUG(("Finish machine")); - return SILC_FSM_FINISH; + SILC_FSM_FINISH; } static void destructor(SilcFSM fsm, void *fsm_context,