Changeset e1e4192 in mainline for uspace/srv


Ignore:
Timestamp:
2012-06-03T20:45:58Z (14 years ago)
Author:
Maurizio Lombardi <m.lombardi85@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
90478727
Parents:
f7e69f5 (diff), 3123d2a (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.
Message:

Merge mainline changes

Location:
uspace/srv
Files:
30 edited

Legend:

Unmodified
Added
Removed
  • uspace/srv/bd/ata_bd/ata_bd.c

    rf7e69f5 re1e4192  
    191191        }
    192192
    193         printf(NAME ": Accepting connections\n");
     193        printf("%s: Accepting connections\n", NAME);
    194194        task_retval(0);
    195195        async_manager();
     
    243243static int ata_bd_init(void)
    244244{
     245        async_set_client_connection(ata_bd_connection);
     246        int rc = loc_server_register(NAME);
     247        if (rc != EOK) {
     248                printf("%s: Unable to register driver.\n", NAME);
     249                return rc;
     250        }
     251       
    245252        void *vaddr;
    246         int rc;
    247        
    248         async_set_client_connection(ata_bd_connection);
    249         rc = loc_server_register(NAME);
    250         if (rc < 0) {
    251                 printf(NAME ": Unable to register driver.\n");
    252                 return rc;
    253         }
    254 
    255253        rc = pio_enable((void *) cmd_physical, sizeof(ata_cmd_t), &vaddr);
    256254        if (rc != EOK) {
    257                 printf(NAME ": Could not initialize device I/O space.\n");
     255                printf("%s: Could not initialize device I/O space.\n", NAME);
    258256                return rc;
    259257        }
    260 
     258       
    261259        cmd = vaddr;
    262 
     260       
    263261        rc = pio_enable((void *) ctl_physical, sizeof(ata_ctl_t), &vaddr);
    264262        if (rc != EOK) {
    265                 printf(NAME ": Could not initialize device I/O space.\n");
     263                printf("%s: Could not initialize device I/O space.\n", NAME);
    266264                return rc;
    267265        }
    268 
     266       
    269267        ctl = vaddr;
    270 
    271 
     268       
    272269        return EOK;
    273270}
  • uspace/srv/bd/file_bd/file_bd.c

    rf7e69f5 re1e4192  
    119119        rc = loc_service_register(device_name, &service_id);
    120120        if (rc != EOK) {
    121                 printf(NAME ": Unable to register device '%s'.\n",
    122                         device_name);
     121                printf("%s: Unable to register device '%s'.\n",
     122                    NAME, device_name);
    123123                return rc;
    124124        }
    125 
    126         printf(NAME ": Accepting connections\n");
     125       
     126        printf("%s: Accepting connections\n", NAME);
    127127        task_retval(0);
    128128        async_manager();
    129 
     129       
    130130        /* Not reached */
    131131        return 0;
     
    139139static int file_bd_init(const char *fname)
    140140{
    141         int rc;
    142         long img_size;
    143        
    144141        async_set_client_connection(file_bd_connection);
    145         rc = loc_server_register(NAME);
    146         if (rc < 0) {
    147                 printf(NAME ": Unable to register driver.\n");
     142        int rc = loc_server_register(NAME);
     143        if (rc != EOK) {
     144                printf("%s: Unable to register driver.\n", NAME);
    148145                return rc;
    149146        }
    150 
     147       
    151148        img = fopen(fname, "rb+");
    152149        if (img == NULL)
    153150                return EINVAL;
    154 
     151       
    155152        if (fseek(img, 0, SEEK_END) != 0) {
    156153                fclose(img);
    157154                return EIO;
    158155        }
    159 
    160         img_size = ftell(img);
     156       
     157        off64_t img_size = ftell(img);
    161158        if (img_size < 0) {
    162159                fclose(img);
    163160                return EIO;
    164161        }
    165 
     162       
    166163        num_blocks = img_size / block_size;
    167 
     164       
    168165        fibril_mutex_initialize(&dev_lock);
    169 
     166       
    170167        return EOK;
    171168}
  • uspace/srv/bd/gxe_bd/gxe_bd.c

    rf7e69f5 re1e4192  
    122122static int gxe_bd_init(void)
    123123{
     124        async_set_client_connection(gxe_bd_connection);
     125        int rc = loc_server_register(NAME);
     126        if (rc != EOK) {
     127                printf("%s: Unable to register driver.\n", NAME);
     128                return rc;
     129        }
     130       
    124131        void *vaddr;
    125         int rc, i;
    126         char name[16];
    127        
    128         async_set_client_connection(gxe_bd_connection);
    129         rc = loc_server_register(NAME);
    130         if (rc < 0) {
    131                 printf(NAME ": Unable to register driver.\n");
    132                 return rc;
    133         }
    134 
    135132        rc = pio_enable((void *) dev_physical, sizeof(gxe_bd_t), &vaddr);
    136133        if (rc != EOK) {
    137                 printf(NAME ": Could not initialize device I/O space.\n");
     134                printf("%s: Could not initialize device I/O space.\n", NAME);
    138135                return rc;
    139136        }
    140 
     137       
    141138        dev = vaddr;
    142 
    143         for (i = 0; i < MAX_DISKS; i++) {
    144                 snprintf(name, 16, "%s/disk%d", NAMESPACE, i);
     139       
     140        for (unsigned int i = 0; i < MAX_DISKS; i++) {
     141                char name[16];
     142               
     143                snprintf(name, 16, "%s/disk%u", NAMESPACE, i);
    145144                rc = loc_service_register(name, &service_id[i]);
    146145                if (rc != EOK) {
    147                         printf(NAME ": Unable to register device %s.\n", name);
     146                        printf("%s: Unable to register device %s.\n", NAME,
     147                            name);
    148148                        return rc;
    149149                }
     150               
    150151                fibril_mutex_initialize(&dev_lock[i]);
    151152        }
    152 
     153       
    153154        return EOK;
    154155}
  • uspace/srv/bd/part/guid_part/guid_part.c

    rf7e69f5 re1e4192  
    170170                return rc;
    171171        }
    172 
     172       
    173173        /*
    174174         * Create partition devices.
  • uspace/srv/bd/rd/rd.c

    rf7e69f5 re1e4192  
    237237        async_set_client_connection(rd_connection);
    238238        ret = loc_server_register(NAME);
    239         if (ret < 0) {
     239        if (ret != EOK) {
    240240                printf("%s: Unable to register driver (%d)\n", NAME, ret);
    241241                return false;
  • uspace/srv/clipboard/clipboard.c

    rf7e69f5 re1e4192  
    181181       
    182182        async_set_client_connection(clip_connection);
    183        
    184         if (service_register(SERVICE_CLIPBOARD) != EOK)
    185                 return -1;
     183        int rc = service_register(SERVICE_CLIPBOARD);
     184        if (rc != EOK)
     185                return rc;
    186186       
    187187        printf("%s: Accepting connections\n", NAME);
  • uspace/srv/devman/devman.h

    rf7e69f5 re1e4192  
    210210};
    211211
    212 
    213212/** Represents device tree. */
    214213typedef struct dev_tree {
  • uspace/srv/devman/main.c

    rf7e69f5 re1e4192  
    245245       
    246246        fibril_rwlock_write_lock(&device_tree.rwlock);
    247 
     247       
    248248        if (fun->state == FUN_ON_LINE) {
    249249                fibril_rwlock_write_unlock(&device_tree.rwlock);
     
    259259                        return ENOMEM;
    260260                }
    261 
     261               
    262262                insert_dev_node(&device_tree, dev, fun);
    263263                dev_add_ref(dev);
     
    272272                /* Give one reference over to assign_driver_fibril(). */
    273273                dev_add_ref(dev);
     274               
    274275                /*
    275276                 * Try to find a suitable driver and assign it to the device.  We do
     
    288289                }
    289290                fibril_add_ready(assign_fibril);
    290         } else {
     291        } else
    291292                loc_register_tree_function(fun, &device_tree);
    292         }
    293293       
    294294        fibril_rwlock_write_unlock(&device_tree.rwlock);
     
    11491149                if (dev->pfun->dev != NULL)
    11501150                        driver = dev->pfun->dev->drv;
     1151               
    11511152                fwd_h = dev->pfun->handle;
    11521153        } else if (dev->state == DEVICE_USABLE) {
     
    11541155                driver = dev->drv;
    11551156                assert(driver != NULL);
    1156 
     1157               
    11571158                fwd_h = handle;
    11581159        }
     
    11811182
    11821183        if (fun != NULL) {
    1183                 log_msg(LVL_DEBUG, 
     1184                log_msg(LVL_DEBUG,
    11841185                    "Forwarding request for `%s' function to driver `%s'.",
    11851186                    fun->pathname, driver->name);
    11861187        } else {
    1187                 log_msg(LVL_DEBUG, 
     1188                log_msg(LVL_DEBUG,
    11881189                    "Forwarding request for `%s' device to driver `%s'.",
    11891190                    dev->pfun->pathname, driver->name);
     
    11931194        async_forward_fast(iid, exch, method, fwd_h, 0, IPC_FF_NONE);
    11941195        async_exchange_end(exch);
    1195 
     1196       
    11961197cleanup:
    11971198        if (dev != NULL)
    11981199                dev_del_ref(dev);
     1200       
    11991201        if (fun != NULL)
    12001202                fun_del_ref(fun);
     
    12991301                return false;
    13001302        }
    1301 
     1303       
    13021304        log_msg(LVL_DEBUG, "devman_init - list of drivers has been initialized.");
    1303 
     1305       
    13041306        /* Create root device node. */
    13051307        if (!init_device_tree(&device_tree, &drivers_list)) {
     
    13071309                return false;
    13081310        }
    1309 
     1311       
    13101312        /*
    13111313         * Caution: As the device manager is not a real loc
     
    13221324int main(int argc, char *argv[])
    13231325{
    1324         printf(NAME ": HelenOS Device Manager\n");
    1325 
    1326         if (log_init(NAME, LVL_WARN) != EOK) {
    1327                 printf(NAME ": Error initializing logging subsystem.\n");
    1328                 return -1;
     1326        printf("%s: HelenOS Device Manager\n", NAME);
     1327       
     1328        int rc = log_init(NAME, LVL_WARN);
     1329        if (rc != EOK) {
     1330                printf("%s: Error initializing logging subsystem.\n", NAME);
     1331                return rc;
    13291332        }
    13301333       
     
    13331336        async_set_client_data_destructor(devman_client_data_destroy);
    13341337        async_set_client_connection(devman_connection);
    1335 
     1338       
    13361339        if (!devman_init()) {
    13371340                log_msg(LVL_ERROR, "Error while initializing service.");
    13381341                return -1;
    13391342        }
    1340 
     1343       
    13411344        /* Register device manager at naming service. */
    1342         if (service_register(SERVICE_DEVMAN) != EOK) {
     1345        rc = service_register(SERVICE_DEVMAN);
     1346        if (rc != EOK) {
    13431347                log_msg(LVL_ERROR, "Failed registering as a service.");
    1344                 return -1;
    1345         }
    1346 
    1347         printf(NAME ": Accepting connections.\n");
     1348                return rc;
     1349        }
     1350       
     1351        printf("%s: Accepting connections.\n", NAME);
    13481352        task_retval(0);
    13491353        async_manager();
    1350 
     1354       
    13511355        /* Never reached. */
    13521356        return 0;
  • uspace/srv/hid/console/console.c

    rf7e69f5 re1e4192  
    827827        async_set_client_connection(client_connection);
    828828        int rc = loc_server_register(NAME);
    829         if (rc < 0) {
     829        if (rc != EOK) {
    830830                printf("%s: Unable to register server (%s)\n", NAME,
    831831                    str_error(rc));
  • uspace/srv/hid/fb/fb.c

    rf7e69f5 re1e4192  
    990990        int rc = loc_server_register(NAME);
    991991        if (rc != EOK) {
    992                 printf("%s: Unable to register driver (%d)\n", NAME, rc);
    993                 return 1;
     992                printf("%s: Unable to register driver\n", NAME);
     993                return rc;
    994994        }
    995995       
  • uspace/srv/hid/input/ctl/kbdev.c

    rf7e69f5 re1e4192  
    6868        /** Link to generic keyboard device */
    6969        kbd_dev_t *kbd_dev;
    70 
     70       
    7171        /** Session with kbdev device */
    7272        async_sess_t *sess;
     
    7575static kbdev_t *kbdev_new(kbd_dev_t *kdev)
    7676{
    77         kbdev_t *kbdev;
    78 
    79         kbdev = calloc(1, sizeof(kbdev_t));
     77        kbdev_t *kbdev = calloc(1, sizeof(kbdev_t));
    8078        if (kbdev == NULL)
    8179                return NULL;
    82 
     80       
    8381        kbdev->kbd_dev = kdev;
    8482
     
    9088        if (kbdev->sess != NULL)
    9189                async_hangup(kbdev->sess);
     90       
    9291        free(kbdev);
    9392}
     
    9594static int kbdev_ctl_init(kbd_dev_t *kdev)
    9695{
    97         async_sess_t *sess;
    98         async_exch_t *exch;
    99         kbdev_t *kbdev;
    100         int rc;
    101 
    102         sess = loc_service_connect(EXCHANGE_SERIALIZE, kdev->svc_id, 0);
     96        async_sess_t *sess = loc_service_connect(EXCHANGE_SERIALIZE,
     97            kdev->svc_id, 0);
    10398        if (sess == NULL) {
    10499                printf("%s: Failed starting session with '%s.'\n", NAME,
    105100                    kdev->svc_name);
    106                 return -1;
     101                return ENOENT;
    107102        }
    108 
    109         kbdev = kbdev_new(kdev);
     103       
     104        kbdev_t *kbdev = kbdev_new(kdev);
    110105        if (kbdev == NULL) {
    111106                printf("%s: Failed allocating device structure for '%s'.\n",
    112107                    NAME, kdev->svc_name);
    113108                async_hangup(sess);
    114                 return -1;
     109                return ENOMEM;
    115110        }
    116 
     111       
    117112        kbdev->sess = sess;
    118 
    119         exch = async_exchange_begin(sess);
     113       
     114        async_exch_t *exch = async_exchange_begin(sess);
    120115        if (exch == NULL) {
    121116                printf("%s: Failed starting exchange with '%s'.\n", NAME,
    122117                    kdev->svc_name);
    123118                kbdev_destroy(kbdev);
    124                 return -1;
     119                return ENOENT;
    125120        }
    126 
    127         rc = async_connect_to_me(exch, 0, 0, 0, kbdev_callback_conn, kbdev);
     121       
     122        int rc = async_connect_to_me(exch, 0, 0, 0, kbdev_callback_conn, kbdev);
    128123        if (rc != EOK) {
    129124                printf("%s: Failed creating callback connection from '%s'.\n",
     
    131126                async_exchange_end(exch);
    132127                kbdev_destroy(kbdev);
    133                 return -1;
     128                return rc;
    134129        }
    135 
     130       
    136131        async_exchange_end(exch);
    137 
     132       
    138133        kdev->ctl_private = (void *) kbdev;
    139134        return 0;
     
    142137static void kbdev_ctl_set_ind(kbd_dev_t *kdev, unsigned mods)
    143138{
    144         async_sess_t *sess;
    145         async_exch_t *exch;
    146 
    147         sess = ((kbdev_t *) kdev->ctl_private)->sess;
    148 
    149         exch = async_exchange_begin(sess);
     139        async_sess_t *sess = ((kbdev_t *) kdev->ctl_private)->sess;
     140        async_exch_t *exch = async_exchange_begin(sess);
    150141        if (!exch)
    151142                return;
    152 
     143       
    153144        async_msg_1(exch, KBDEV_SET_IND, mods);
    154145        async_exchange_end(exch);
  • uspace/srv/hid/input/generic/input.c

    rf7e69f5 re1e4192  
    662662        async_set_client_connection(client_connection);
    663663        int rc = loc_server_register(NAME);
    664         if (rc < 0) {
    665                 printf("%s: Unable to register server (%d)\n", NAME, rc);
    666                 return -1;
     664        if (rc != EOK) {
     665                printf("%s: Unable to register server\n", NAME);
     666                return rc;
    667667        }
    668668       
     
    671671       
    672672        service_id_t service_id;
    673         if (loc_service_register(kbd, &service_id) != EOK) {
     673        rc = loc_service_register(kbd, &service_id);
     674        if (rc != EOK) {
    674675                printf("%s: Unable to register service %s\n", NAME, kbd);
    675                 return -1;
     676                return rc;
    676677        }
    677678       
  • uspace/srv/hid/input/port/adb.c

    rf7e69f5 re1e4192  
    6565static int adb_port_init(kbd_dev_t *kdev)
    6666{
     67        kbd_dev = kdev;
     68       
    6769        const char *dev = "adb/kbd";
    6870        service_id_t service_id;
    69         async_exch_t *exch;
    70         int rc;
    71        
    72         kbd_dev = kdev;
    73        
    74         rc = loc_service_get_id(dev, &service_id, 0);
     71        int rc = loc_service_get_id(dev, &service_id, 0);
    7572        if (rc != EOK)
    7673                return rc;
     
    8279        }
    8380       
    84         exch = async_exchange_begin(dev_sess);
     81        async_exch_t *exch = async_exchange_begin(dev_sess);
    8582        if (exch == NULL) {
    8683                printf("%s: Failed starting exchange with device\n", NAME);
     
    8986        }
    9087       
    91         /* NB: The callback connection is slotted for removal */
    9288        rc = async_connect_to_me(exch, 0, 0, 0, kbd_port_events, NULL);
    9389        async_exchange_end(exch);
  • uspace/srv/hid/input/proto/mousedev.c

    rf7e69f5 re1e4192  
    117117                printf("%s: Failed starting session with '%s'\n", NAME,
    118118                    mdev->svc_name);
    119                 return -1;
     119                return ENOENT;
    120120        }
    121121       
     
    125125                    NAME, mdev->svc_name);
    126126                async_hangup(sess);
    127                 return -1;
     127                return ENOMEM;
    128128        }
    129129       
     
    134134                mousedev_destroy(mousedev);
    135135                async_hangup(sess);
    136                 return -1;
     136                return ENOENT;
    137137        }
    138138       
     
    145145                    NAME, mdev->svc_name);
    146146                mousedev_destroy(mousedev);
    147                 return -1;
     147                return rc;
    148148        }
    149149       
    150         return 0;
     150        return EOK;
    151151}
    152152
  • uspace/srv/hid/remcons/remcons.c

    rf7e69f5 re1e4192  
    7171        TELNET_IAC, TELNET_WONT, TELNET_LINEMODE
    7272};
     73
    7374static const size_t telnet_force_character_mode_command_count =
    7475    sizeof(telnet_force_character_mode_command) / sizeof(telnet_cmd_t);
     
    272273static int network_user_fibril(void *arg)
    273274{
    274         int rc;
    275275        telnet_user_t *user = arg;
    276276
    277         rc = loc_service_register(user->service_name, &user->service_id);
     277        int rc = loc_service_register(user->service_name, &user->service_id);
    278278        if (rc != EOK) {
    279279                telnet_user_error(user, "Unable to register %s with loc: %s.",
     
    284284        telnet_user_log(user, "Service %s registerd with id %" PRIun ".",
    285285            user->service_name, user->service_id);
    286 
     286       
    287287        fid_t spawn_fibril = fibril_create(spawn_task_fibril, user);
    288288        assert(spawn_fibril);
    289289        fibril_add_ready(spawn_fibril);
    290 
     290       
    291291        /* Wait for all clients to exit. */
    292292        fibril_mutex_lock(&user->guard);
     
    304304        }
    305305        fibril_mutex_unlock(&user->guard);
    306 
     306       
    307307        rc = loc_service_unregister(user->service_id);
    308308        if (rc != EOK) {
     
    324324        async_set_client_connection(client_connection);
    325325        int rc = loc_server_register(NAME);
    326         if (rc < 0) {
    327                 fprintf(stderr, NAME ": Unable to register server: %s.\n",
    328                     str_error(rc));
    329                 return 1;
    330         }
    331 
     326        if (rc != EOK) {
     327                fprintf(stderr, "%s: Unable to register server\n", NAME);
     328                return rc;
     329        }
     330       
    332331        struct sockaddr_in addr;
    333 
     332       
    334333        addr.sin_family = AF_INET;
    335334        addr.sin_port = htons(port);
    336 
     335       
    337336        rc = inet_pton(AF_INET, "127.0.0.1", (void *)
    338337            &addr.sin_addr.s_addr);
  • uspace/srv/hid/remcons/telnet.h

    rf7e69f5 re1e4192  
    5757#define TELNET_LINEMODE 34
    5858
    59 
    6059#endif
    6160
  • uspace/srv/hid/remcons/user.h

    rf7e69f5 re1e4192  
    7676} telnet_user_t;
    7777
    78 telnet_user_t *telnet_user_create(int socket);
    79 void telnet_user_destroy(telnet_user_t *user);
    80 telnet_user_t *telnet_user_get_for_client_connection(service_id_t id);
    81 bool telnet_user_is_zombie(telnet_user_t *user);
    82 void telnet_user_notify_client_disconnected(telnet_user_t *user);
    83 int telnet_user_get_next_keyboard_event(telnet_user_t *user, kbd_event_t *event);
    84 int telnet_user_send_data(telnet_user_t *user, uint8_t *data, size_t size);
    85 void telnet_user_update_cursor_x(telnet_user_t *user, int new_x);
     78extern telnet_user_t *telnet_user_create(int);
     79extern void telnet_user_destroy(telnet_user_t *);
     80extern telnet_user_t *telnet_user_get_for_client_connection(service_id_t);
     81extern bool telnet_user_is_zombie(telnet_user_t *);
     82extern void telnet_user_notify_client_disconnected(telnet_user_t *);
     83extern int telnet_user_get_next_keyboard_event(telnet_user_t *, kbd_event_t *);
     84extern int telnet_user_send_data(telnet_user_t *, uint8_t *, size_t);
     85extern void telnet_user_update_cursor_x(telnet_user_t *, int);
    8686
    8787/** Print informational message about connected user. */
    8888#ifdef CONFIG_DEBUG
    8989#define telnet_user_log(user, fmt, ...) \
    90         printf(NAME " [console %d (%d)]: " fmt "\n", user->id, (int) user->service_id, ##__VA_ARGS__)
     90        printf(NAME " [console %d (%d)]: " fmt "\n", \
     91            user->id, (int) user->service_id, ##__VA_ARGS__)
    9192#else
    92 #define telnet_user_log(user, fmt, ...) (void)0
     93#define telnet_user_log(user, fmt, ...) ((void) 0)
    9394#endif
    9495
    9596/** Print error message associated with connected user. */
    9697#define telnet_user_error(user, fmt, ...) \
    97         fprintf(stderr, NAME " [console %d (%d)]: ERROR: " fmt "\n", user->id, (int) user->service_id, ##__VA_ARGS__)
     98        fprintf(stderr, NAME " [console %d (%d)]: ERROR: " fmt "\n", \
     99            user->id, (int) user->service_id, ##__VA_ARGS__)
    98100
    99101#endif
  • uspace/srv/hid/s3c24xx_ts/s3c24xx_ts.c

    rf7e69f5 re1e4192  
    8484int main(int argc, char *argv[])
    8585{
    86         int rc;
    87 
    88         printf(NAME ": S3C24xx touchscreen driver\n");
     86        printf("%s: S3C24xx touchscreen driver\n", NAME);
    8987       
    9088        async_set_client_connection(s3c24xx_ts_connection);
    91         rc = loc_server_register(NAME);
    92         if (rc < 0) {
    93                 printf(NAME ": Unable to register driver.\n");
    94                 return -1;
     89        int rc = loc_server_register(NAME);
     90        if (rc != EOK) {
     91                printf("%s: Unable to register driver.\n", NAME);
     92                return rc;
    9593        }
    9694
  • uspace/srv/hw/char/s3c24xx_uart/s3c24xx_uart.c

    rf7e69f5 re1e4192  
    7777int main(int argc, char *argv[])
    7878{
    79         int rc;
    80 
    81         printf(NAME ": S3C24xx on-chip UART driver\n");
    82 
     79        printf("%s: S3C24xx on-chip UART driver\n", NAME);
     80       
    8381        async_set_client_connection(s3c24xx_uart_connection);
    84         rc = loc_server_register(NAME);
    85         if (rc < 0) {
    86                 printf(NAME ": Unable to register server.\n");
    87                 return -1;
     82        int rc = loc_server_register(NAME);
     83        if (rc != EOK) {
     84                printf("%s: Unable to register server.\n", NAME);
     85                return rc;
    8886        }
    8987
  • uspace/srv/loader/main.c

    rf7e69f5 re1e4192  
    450450        int rc = ns_intro(id);
    451451        if (rc != EOK)
    452                 return -1;
     452                return rc;
    453453       
    454454        /* Register at naming service. */
    455         if (service_register(SERVICE_LOAD) != EOK)
    456                 return -2;
     455        rc = service_register(SERVICE_LOAD);
     456        if (rc != EOK)
     457                return rc;
    457458       
    458459        async_manager();
  • uspace/srv/locsrv/locsrv.c

    rf7e69f5 re1e4192  
    390390         */
    391391        list_initialize(&server->services);
    392 
    393392        link_initialize(&server->servers);
    394393       
     
    14931492       
    14941493        /* Register location service at naming service */
    1495         if (service_register(SERVICE_LOC) != EOK)
    1496                 return -1;
     1494        int rc = service_register(SERVICE_LOC);
     1495        if (rc != EOK)
     1496                return rc;
    14971497       
    14981498        printf("%s: Accepting connections\n", NAME);
  • uspace/srv/locsrv/locsrv.h

    rf7e69f5 re1e4192  
    8686        /** Link to global list of services (services_list) */
    8787        link_t services;
     88       
    8889        /** Link to server list of services (loc_server_t.services) */
    8990        link_t server_services;
     91       
    9092        /** Link to list of services in category (category_t.services) */
    9193        link_t cat_services;
     94       
    9295        /** List of category memberships (svc_categ_t) */
    9396        list_t cat_memb;
     97       
    9498        /** Unique service identifier */
    9599        service_id_t id;
     100       
    96101        /** Service namespace */
    97102        loc_namespace_t *namespace;
     103       
    98104        /** Service name */
    99105        char *name;
     106       
    100107        /** Supplier of this service */
    101108        loc_server_t *server;
     109       
    102110        /** Use this interface when forwarding to server. */
    103111        sysarg_t forward_interface;
  • uspace/srv/net/ethip/ethip.c

    rf7e69f5 re1e4192  
    7373static int ethip_init(void)
    7474{
    75         int rc;
    76 
    7775        async_set_client_connection(ethip_client_conn);
    78 
    79         rc = loc_server_register(NAME);
     76       
     77        int rc = loc_server_register(NAME);
    8078        if (rc != EOK) {
    8179                log_msg(LVL_ERROR, "Failed registering server.");
    8280                return rc;
    8381        }
    84 
     82       
    8583        rc = ethip_nic_discovery_start();
    8684        if (rc != EOK)
    8785                return rc;
    88 
     86       
    8987        return EOK;
    9088}
  • uspace/srv/net/ethip/ethip_nic.c

    rf7e69f5 re1e4192  
    150150static int ethip_nic_open(service_id_t sid)
    151151{
    152         ethip_nic_t *nic;
    153         int rc;
    154152        bool in_list = false;
    155153        nic_address_t nic_address;
    156 
     154       
    157155        log_msg(LVL_DEBUG, "ethip_nic_open()");
    158         nic = ethip_nic_new();
     156        ethip_nic_t *nic = ethip_nic_new();
    159157        if (nic == NULL)
    160158                return ENOMEM;
    161 
    162         rc = loc_service_get_name(sid, &nic->svc_name);
     159       
     160        int rc = loc_service_get_name(sid, &nic->svc_name);
    163161        if (rc != EOK) {
    164162                log_msg(LVL_ERROR, "Failed getting service name.");
    165163                goto error;
    166164        }
    167 
     165       
    168166        nic->sess = loc_service_connect(EXCHANGE_SERIALIZE, sid, 0);
    169167        if (nic->sess == NULL) {
     
    171169                goto error;
    172170        }
    173 
     171       
    174172        nic->svc_id = sid;
    175 
     173       
    176174        rc = nic_callback_create(nic->sess, ethip_nic_cb_conn, nic);
    177175        if (rc != EOK) {
     
    298296int ethip_nic_discovery_start(void)
    299297{
    300         int rc;
    301 
    302         rc = loc_register_cat_change_cb(ethip_nic_cat_change_cb);
     298        int rc = loc_register_cat_change_cb(ethip_nic_cat_change_cb);
    303299        if (rc != EOK) {
    304300                log_msg(LVL_ERROR, "Failed registering callback for NIC "
     
    306302                return rc;
    307303        }
    308 
     304       
    309305        return ethip_nic_check_new();
    310306}
  • uspace/srv/net/inetsrv/inetsrv.c

    rf7e69f5 re1e4192  
    6666static int inet_init(void)
    6767{
    68         service_id_t sid;
    69         int rc;
    70 
    7168        log_msg(LVL_DEBUG, "inet_init()");
    72 
     69       
    7370        async_set_client_connection(inet_client_conn);
    74 
    75         rc = loc_server_register(NAME);
     71       
     72        int rc = loc_server_register(NAME);
    7673        if (rc != EOK) {
    7774                log_msg(LVL_ERROR, "Failed registering server (%d).", rc);
    7875                return EEXIST;
    7976        }
    80 
     77       
     78        service_id_t sid;
    8179        rc = loc_service_register_with_iface(SERVICE_NAME_INET, &sid,
    8280            INET_PORT_DEFAULT);
     
    8583                return EEXIST;
    8684        }
    87 
     85       
    8886        rc = loc_service_register_with_iface(SERVICE_NAME_INETCFG, &sid,
    8987            INET_PORT_CFG);
     
    9290                return EEXIST;
    9391        }
    94 
     92       
    9593        rc = loc_service_register_with_iface(SERVICE_NAME_INETPING, &sid,
    9694            INET_PORT_PING);
     
    9997                return EEXIST;
    10098        }
    101 
     99       
    102100        rc = inet_link_discovery_start();
    103101        if (rc != EOK)
    104102                return EEXIST;
    105 
     103       
    106104        return EOK;
    107105}
  • uspace/srv/net/loopip/loopip.c

    rf7e69f5 re1e4192  
    9191        category_id_t iplink_cat;
    9292        const char *svc_name = "net/loopback";
    93 
     93       
    9494        async_set_client_connection(loopip_client_conn);
    95 
     95       
    9696        rc = loc_server_register(NAME);
    9797        if (rc != EOK) {
  • uspace/srv/net/tcp/sock.c

    rf7e69f5 re1e4192  
    6868int tcp_sock_init(void)
    6969{
    70         int rc;
    71 
    7270        socket_ports_initialize(&gsock);
    73 
     71       
    7472        async_set_client_connection(tcp_sock_connection);
    75 
    76         rc = service_register(SERVICE_TCP);
     73       
     74        int rc = service_register(SERVICE_TCP);
    7775        if (rc != EOK)
    7876                return EEXIST;
    79 
     77       
    8078        return EOK;
    8179}
  • uspace/srv/net/udp/sock.c

    rf7e69f5 re1e4192  
    6666int udp_sock_init(void)
    6767{
    68         int rc;
    69 
    7068        socket_ports_initialize(&gsock);
    71 
     69       
    7270        async_set_client_connection(udp_sock_connection);
    73 
    74         rc = service_register(SERVICE_UDP);
     71       
     72        int rc = service_register(SERVICE_UDP);
    7573        if (rc != EOK)
    7674                return EEXIST;
    77 
     75       
    7876        return EOK;
    7977}
  • uspace/srv/ns/ns.c

    rf7e69f5 re1e4192  
    4848int main(int argc, char **argv)
    4949{
    50         printf(NAME ": HelenOS IPC Naming Service\n");
     50        printf("%s: HelenOS IPC Naming Service\n", NAME);
    5151       
    5252        int rc = service_init();
  • uspace/srv/vfs/vfs.c

    rf7e69f5 re1e4192  
    159159int main(int argc, char **argv)
    160160{
    161         printf(NAME ": HelenOS VFS server\n");
     161        printf("%s: HelenOS VFS server\n", NAME);
    162162       
    163163        /*
     
    165165         */
    166166        if (!vfs_nodes_init()) {
    167                 printf(NAME ": Failed to initialize VFS node hash table\n");
     167                printf("%s: Failed to initialize VFS node hash table\n",
     168                    NAME);
    168169                return ENOMEM;
    169170        }
     
    175176            AS_AREA_READ | AS_AREA_WRITE | AS_AREA_CACHEABLE);
    176177        if (plb == (void *) -1) {
    177                 printf(NAME ": Cannot create address space area\n");
     178                printf("%s: Cannot create address space area\n", NAME);
    178179                return ENOMEM;
    179180        }
     
    196197        async_set_interrupt_received(notification_received);
    197198        event_task_subscribe(EVENT_TASK_STATE_CHANGE, VFS_TASK_STATE_CHANGE);
    198 
     199       
    199200        /*
    200201         * Register at the naming service.
    201202         */
    202         if (service_register(SERVICE_VFS) != EOK) {
     203        int rc = service_register(SERVICE_VFS);
     204        if (rc != EOK) {
    203205                printf("%s: Cannot register VFS service\n", NAME);
    204                 return EINVAL;
     206                return rc;
    205207        }
    206208       
     
    208210         * Start accepting connections.
    209211         */
    210         printf(NAME ": Accepting connections\n");
     212        printf("%s: Accepting connections\n", NAME);
    211213        async_manager();
    212214        return 0;
Note: See TracChangeset for help on using the changeset viewer.