Fork us on GitHub Follow us on Facebook Follow us on Twitter

Changeset d6ff08a0 in mainline


Ignore:
Timestamp:
2015-05-14T06:19:23Z (6 years ago)
Author:
Jiri Svoboda <jiri@…>
Branches:
lfn, master
Children:
683e584
Parents:
b99f6e2
Message:

Fix remcons and rfb.

Location:
uspace/srv/hid
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • uspace/srv/hid/remcons/remcons.c

    rb99f6e2 rd6ff08a0  
    282282}
    283283
    284 /** Fibril for each accepted socket.
    285  *
    286  * @param arg Corresponding @c telnet_user_t structure.
    287  */
    288 static int network_user_fibril(void *arg)
    289 {
    290         telnet_user_t *user = arg;
     284/** Handle network connection.
     285 *
     286 * @param lst  Listener
     287 * @param conn Connection
     288 */
     289static void remcons_new_conn(tcp_listener_t *lst, tcp_conn_t *conn)
     290{
     291        telnet_user_t *user = telnet_user_create(conn);
     292        assert(user);
     293
     294        con_srvs_init(&user->srvs);
     295        user->srvs.ops = &con_ops;
     296        user->srvs.sarg = user;
     297        user->srvs.abort_timeout = 1000;
     298
     299        telnet_user_add(user);
    291300
    292301        int rc = loc_service_register(user->service_name, &user->service_id);
     
    294303                telnet_user_error(user, "Unable to register %s with loc: %s.",
    295304                    user->service_name, str_error(rc));
    296                 return EOK;
     305                return;
    297306        }
    298307
    299308        telnet_user_log(user, "Service %s registerd with id %" PRIun ".",
    300309            user->service_name, user->service_id);
    301        
     310
    302311        fid_t spawn_fibril = fibril_create(spawn_task_fibril, user);
    303312        assert(spawn_fibril);
    304313        fibril_add_ready(spawn_fibril);
    305        
     314
    306315        /* Wait for all clients to exit. */
    307316        fibril_mutex_lock(&user->guard);
     
    321330        }
    322331        fibril_mutex_unlock(&user->guard);
    323        
     332
    324333        rc = loc_service_unregister(user->service_id);
    325334        if (rc != EOK) {
     
    331340        telnet_user_log(user, "Destroying...");
    332341        telnet_user_destroy(user);
    333 
    334         return EOK;
    335 }
    336 
    337 static void remcons_new_conn(tcp_listener_t *lst, tcp_conn_t *conn)
    338 {
    339         telnet_user_t *user = telnet_user_create(conn);
    340         assert(user);
    341 
    342         con_srvs_init(&user->srvs);
    343         user->srvs.ops = &con_ops;
    344         user->srvs.sarg = user;
    345         user->srvs.abort_timeout = 1000;
    346 
    347         telnet_user_add(user);
    348 
    349         fid_t fid = fibril_create(network_user_fibril, user);
    350         assert(fid);
    351         fibril_add_ready(fid);
    352342}
    353343
     
    367357
    368358        rc = tcp_create(&tcp);
    369         if (tcp != EOK) {
    370                 fprintf(stderr, "%s: Error initialzing TCP.\n", NAME);
     359        if (rc != EOK) {
     360                fprintf(stderr, "%s: Error initializing TCP.\n", NAME);
    371361                return rc;
    372362        }
    373363
    374364        inet_ep_init(&ep);
    375         ep.port = 2223;
     365        ep.port = 8080;
    376366
    377367        rc = tcp_listener_create(tcp, &ep, &listen_cb, NULL, &conn_cb, NULL,
  • uspace/srv/hid/rfb/rfb.c

    rb99f6e2 rd6ff08a0  
    757757        int rc;
    758758       
     759        rc = tcp_create(&tcp);
     760        if (rc != EOK) {
     761                log_msg(LOG_DEFAULT, LVL_ERROR, "Error initializing TCP.");
     762                goto error;
     763        }
     764       
    759765        inet_ep_init(&ep);
    760766        ep.port = port;
     
    763769            &lst);
    764770        if (rc != EOK) {
    765                 log_msg(LOG_DEFAULT, LVL_ERROR, "Error creating listener.\n");
     771                log_msg(LOG_DEFAULT, LVL_ERROR, "Error creating listener.");
    766772                goto error;
    767773        }
Note: See TracChangeset for help on using the changeset viewer.