Changes in uspace/srv/devman/main.c [3e6a98c5:33fc3ae] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/devman/main.c
r3e6a98c5 r33fc3ae 44 44 #include <errno.h> 45 45 #include <str_error.h> 46 #include < stdbool.h>46 #include <bool.h> 47 47 #include <fibril_synch.h> 48 48 #include <stdlib.h> … … 73 73 char *drv_name = NULL; 74 74 75 log_msg(L OG_DEFAULT, LVL_DEBUG, "devman_driver_register");75 log_msg(LVL_DEBUG, "devman_driver_register"); 76 76 77 77 /* Get driver name. */ … … 82 82 } 83 83 84 log_msg(L OG_DEFAULT, LVL_DEBUG, "The `%s' driver is trying to register.",84 log_msg(LVL_DEBUG, "The `%s' driver is trying to register.", 85 85 drv_name); 86 86 … … 88 88 driver = find_driver(&drivers_list, drv_name); 89 89 if (driver == NULL) { 90 log_msg(L OG_DEFAULT, LVL_ERROR, "No driver named `%s' was found.", drv_name);90 log_msg(LVL_ERROR, "No driver named `%s' was found.", drv_name); 91 91 free(drv_name); 92 92 drv_name = NULL; … … 102 102 if (driver->sess) { 103 103 /* We already have a connection to the driver. */ 104 log_msg(L OG_DEFAULT, LVL_ERROR, "Driver '%s' already started.\n",104 log_msg(LVL_ERROR, "Driver '%s' already started.\n", 105 105 driver->name); 106 106 fibril_mutex_unlock(&driver->driver_mutex); … … 112 112 case DRIVER_NOT_STARTED: 113 113 /* Somebody started the driver manually. */ 114 log_msg(L OG_DEFAULT, LVL_NOTE, "Driver '%s' started manually.\n",114 log_msg(LVL_NOTE, "Driver '%s' started manually.\n", 115 115 driver->name); 116 116 driver->state = DRIVER_STARTING; … … 125 125 126 126 /* Create connection to the driver. */ 127 log_msg(L OG_DEFAULT, LVL_DEBUG, "Creating connection to the `%s' driver.",127 log_msg(LVL_DEBUG, "Creating connection to the `%s' driver.", 128 128 driver->name); 129 129 driver->sess = async_callback_receive(EXCHANGE_PARALLEL); … … 136 136 async_sess_args_set(driver->sess, DRIVER_DEVMAN, 0, 0); 137 137 138 log_msg(L OG_DEFAULT, LVL_NOTE,138 log_msg(LVL_NOTE, 139 139 "The `%s' driver was successfully registered as running.", 140 140 driver->name); … … 147 147 fid_t fid = fibril_create(init_running_drv, driver); 148 148 if (fid == 0) { 149 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed to create initialization fibril " \149 log_msg(LVL_ERROR, "Failed to create initialization fibril " \ 150 150 "for driver `%s'.", driver->name); 151 151 fibril_mutex_unlock(&driver->driver_mutex); … … 176 176 callid = async_get_call(&call); 177 177 if (DEVMAN_ADD_MATCH_ID != IPC_GET_IMETHOD(call)) { 178 log_msg(L OG_DEFAULT, LVL_ERROR,178 log_msg(LVL_ERROR, 179 179 "Invalid protocol when trying to receive match id."); 180 180 async_answer_0(callid, EINVAL); … … 184 184 185 185 if (match_id == NULL) { 186 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed to allocate match id.");186 log_msg(LVL_ERROR, "Failed to allocate match id."); 187 187 async_answer_0(callid, ENOMEM); 188 188 return ENOMEM; … … 198 198 if (rc != EOK) { 199 199 delete_match_id(match_id); 200 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed to receive match id string: %s.",200 log_msg(LVL_ERROR, "Failed to receive match id string: %s.", 201 201 str_error(rc)); 202 202 return rc; … … 205 205 list_append(&match_id->link, &match_ids->ids); 206 206 207 log_msg(L OG_DEFAULT, LVL_DEBUG, "Received match id `%s', score %d.",207 log_msg(LVL_DEBUG, "Received match id `%s', score %d.", 208 208 match_id->id, match_id->score); 209 209 return rc; … … 248 248 if (fun->state == FUN_ON_LINE) { 249 249 fibril_rwlock_write_unlock(&device_tree.rwlock); 250 log_msg(L OG_DEFAULT, LVL_WARN, "Function %s is already on line.",250 log_msg(LVL_WARN, "Function %s is already on line.", 251 251 fun->pathname); 252 252 return EOK; … … 264 264 } 265 265 266 log_msg(L OG_DEFAULT, LVL_DEBUG, "devman_add_function(fun=\"%s\")", fun->pathname);266 log_msg(LVL_DEBUG, "devman_add_function(fun=\"%s\")", fun->pathname); 267 267 268 268 if (fun->ftype == fun_inner) { … … 282 282 fid_t assign_fibril = fibril_create(assign_driver_fibril, dev); 283 283 if (assign_fibril == 0) { 284 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed to create fibril for "284 log_msg(LVL_ERROR, "Failed to create fibril for " 285 285 "assigning driver."); 286 286 /* XXX Cleanup */ … … 305 305 if (fun->state == FUN_OFF_LINE) { 306 306 fibril_rwlock_write_unlock(&device_tree.rwlock); 307 log_msg(L OG_DEFAULT, LVL_WARN, "Function %s is already off line.",307 log_msg(LVL_WARN, "Function %s is already off line.", 308 308 fun->pathname); 309 309 return EOK; … … 311 311 312 312 if (fun->ftype == fun_inner) { 313 log_msg(L OG_DEFAULT, LVL_DEBUG, "Offlining inner function %s.",313 log_msg(LVL_DEBUG, "Offlining inner function %s.", 314 314 fun->pathname); 315 315 … … 359 359 if (rc != EOK) { 360 360 fibril_rwlock_write_unlock(&device_tree.rwlock); 361 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed unregistering tree service.");361 log_msg(LVL_ERROR, "Failed unregistering tree service."); 362 362 return EIO; 363 363 } … … 391 391 if (ftype != fun_inner && ftype != fun_exposed) { 392 392 /* Unknown function type */ 393 log_msg(L OG_DEFAULT, LVL_ERROR,393 log_msg(LVL_ERROR, 394 394 "Unknown function type %d provided by driver.", 395 395 (int) ftype); … … 432 432 433 433 fun_node_t *fun = create_fun_node(); 434 /* One reference for creation, one for us */435 fun_add_ref(fun);436 434 fun_add_ref(fun); 437 435 fun->ftype = ftype; 438 439 /*440 * We can lock the function here even when holding the tree because441 * we know it cannot be held by anyone else yet.442 */443 fun_busy_lock(fun);444 436 445 437 if (!insert_fun_node(&device_tree, fun, fun_name, pdev)) { 446 438 fibril_rwlock_write_unlock(&tree->rwlock); 447 439 dev_del_ref(pdev); 448 fun_busy_unlock(fun);449 fun_del_ref(fun);450 440 delete_fun_node(fun); 451 441 async_answer_0(callid, ENOMEM); … … 460 450 rc = online_function(fun); 461 451 if (rc != EOK) { 462 /* XXX Set some failed state? */ 463 fun_busy_unlock(fun); 464 fun_del_ref(fun); 452 /* XXX clean up */ 465 453 async_answer_0(callid, rc); 466 454 return; 467 455 } 468 469 fun_busy_unlock(fun);470 fun_del_ref(fun);471 456 472 457 /* Return device handle to parent's driver. */ … … 507 492 if (rc == EOK) { 508 493 loc_service_add_to_cat(fun->service_id, cat_id); 509 log_msg(L OG_DEFAULT, LVL_NOTE, "Function `%s' added to category `%s'.",494 log_msg(LVL_NOTE, "Function `%s' added to category `%s'.", 510 495 fun->pathname, cat_name); 511 496 } else { 512 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed adding function `%s' to category "497 log_msg(LVL_ERROR, "Failed adding function `%s' to category " 513 498 "`%s'.", fun->pathname, cat_name); 514 499 } … … 529 514 int rc; 530 515 531 log_msg(L OG_DEFAULT, LVL_DEBUG, "devman_drv_fun_online()");516 log_msg(LVL_DEBUG, "devman_drv_fun_online()"); 532 517 533 518 fun = find_fun_node(&device_tree, IPC_GET_ARG1(*icall)); … … 536 521 return; 537 522 } 538 539 fun_busy_lock(fun);540 523 541 524 fibril_rwlock_read_lock(&device_tree.rwlock); 542 525 if (fun->dev == NULL || fun->dev->drv != drv) { 543 526 fibril_rwlock_read_unlock(&device_tree.rwlock); 544 fun_busy_unlock(fun);545 527 fun_del_ref(fun); 546 528 async_answer_0(iid, ENOENT); … … 551 533 rc = online_function(fun); 552 534 if (rc != EOK) { 553 fun_busy_unlock(fun);554 535 fun_del_ref(fun); 555 536 async_answer_0(iid, (sysarg_t) rc); … … 557 538 } 558 539 559 fun_busy_unlock(fun);560 540 fun_del_ref(fun); 561 541 … … 579 559 } 580 560 581 fun_busy_lock(fun);582 583 561 fibril_rwlock_write_lock(&device_tree.rwlock); 584 562 if (fun->dev == NULL || fun->dev->drv != drv) { 585 fun_busy_unlock(fun);586 563 fun_del_ref(fun); 587 564 async_answer_0(iid, ENOENT); … … 592 569 rc = offline_function(fun); 593 570 if (rc != EOK) { 594 fun_busy_unlock(fun);595 571 fun_del_ref(fun); 596 572 async_answer_0(iid, (sysarg_t) rc); … … 598 574 } 599 575 600 fun_busy_unlock(fun);601 576 fun_del_ref(fun); 602 577 async_answer_0(iid, (sysarg_t) EOK); … … 616 591 } 617 592 618 fun_busy_lock(fun);619 620 593 fibril_rwlock_write_lock(&tree->rwlock); 621 594 622 log_msg(L OG_DEFAULT, LVL_DEBUG, "devman_remove_function(fun='%s')", fun->pathname);595 log_msg(LVL_DEBUG, "devman_remove_function(fun='%s')", fun->pathname); 623 596 624 597 /* Check function state */ 625 598 if (fun->state == FUN_REMOVED) { 626 599 fibril_rwlock_write_unlock(&tree->rwlock); 627 fun_busy_unlock(fun);628 fun_del_ref(fun);629 600 async_answer_0(callid, ENOENT); 630 601 return; … … 653 624 /* Verify that driver succeeded and removed all functions */ 654 625 if (gone_rc != EOK || !list_empty(&dev->functions)) { 655 log_msg(L OG_DEFAULT, LVL_ERROR, "Driver did not remove "626 log_msg(LVL_ERROR, "Driver did not remove " 656 627 "functions for device that is gone. " 657 628 "Device node is now defunct."); … … 667 638 if (gone_rc == EOK) 668 639 gone_rc = ENOTSUP; 669 fun_busy_unlock(fun);670 fun_del_ref(fun);671 640 async_answer_0(callid, gone_rc); 672 641 return; … … 692 661 rc = loc_service_unregister(fun->service_id); 693 662 if (rc != EOK) { 694 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed unregistering tree "663 log_msg(LVL_ERROR, "Failed unregistering tree " 695 664 "service."); 696 665 fibril_rwlock_write_unlock(&tree->rwlock); 697 fun_busy_unlock(fun);698 666 fun_del_ref(fun); 699 667 async_answer_0(callid, EIO); … … 705 673 remove_fun_node(&device_tree, fun); 706 674 fibril_rwlock_write_unlock(&tree->rwlock); 707 fun_busy_unlock(fun);708 675 709 676 /* Delete ref added when inserting function into tree */ … … 712 679 fun_del_ref(fun); 713 680 714 log_msg(L OG_DEFAULT, LVL_DEBUG, "devman_remove_function() succeeded.");681 log_msg(LVL_DEBUG, "devman_remove_function() succeeded."); 715 682 async_answer_0(callid, EOK); 716 683 } … … 726 693 727 694 initialize_running_driver(driver, &device_tree); 728 log_msg(L OG_DEFAULT, LVL_DEBUG, "The `%s` driver was successfully initialized.",695 log_msg(LVL_DEBUG, "The `%s` driver was successfully initialized.", 729 696 driver->name); 730 697 return 0; … … 742 709 client = async_get_client_data(); 743 710 if (client == NULL) { 744 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed to allocate client data.");711 log_msg(LVL_ERROR, "Failed to allocate client data."); 745 712 return; 746 713 } … … 1229 1196 */ 1230 1197 if (dev == NULL) { 1231 log_msg(L OG_DEFAULT, LVL_ERROR, "IPC forwarding failed - no device or "1198 log_msg(LVL_ERROR, "IPC forwarding failed - no device or " 1232 1199 "function with handle %" PRIun " was found.", handle); 1233 1200 async_answer_0(iid, ENOENT); … … 1236 1203 1237 1204 if (fun == NULL && !drv_to_parent) { 1238 log_msg(L OG_DEFAULT, LVL_ERROR, NAME ": devman_forward error - cannot "1205 log_msg(LVL_ERROR, NAME ": devman_forward error - cannot " 1239 1206 "connect to handle %" PRIun ", refers to a device.", 1240 1207 handle); … … 1264 1231 1265 1232 if (driver == NULL) { 1266 log_msg(L OG_DEFAULT, LVL_ERROR, "IPC forwarding refused - " \1233 log_msg(LVL_ERROR, "IPC forwarding refused - " \ 1267 1234 "the device %" PRIun " is not in usable state.", handle); 1268 1235 async_answer_0(iid, ENOENT); … … 1277 1244 1278 1245 if (!driver->sess) { 1279 log_msg(L OG_DEFAULT, LVL_ERROR,1246 log_msg(LVL_ERROR, 1280 1247 "Could not forward to driver `%s'.", driver->name); 1281 1248 async_answer_0(iid, EINVAL); … … 1284 1251 1285 1252 if (fun != NULL) { 1286 log_msg(L OG_DEFAULT, LVL_DEBUG,1253 log_msg(LVL_DEBUG, 1287 1254 "Forwarding request for `%s' function to driver `%s'.", 1288 1255 fun->pathname, driver->name); 1289 1256 } else { 1290 log_msg(L OG_DEFAULT, LVL_DEBUG,1257 log_msg(LVL_DEBUG, 1291 1258 "Forwarding request for `%s' device to driver `%s'.", 1292 1259 dev->pfun->pathname, driver->name); … … 1320 1287 1321 1288 if (fun == NULL || fun->dev == NULL || fun->dev->drv == NULL) { 1322 log_msg(L OG_DEFAULT, LVL_WARN, "devman_connection_loc(): function "1289 log_msg(LVL_WARN, "devman_connection_loc(): function " 1323 1290 "not found.\n"); 1324 1291 fibril_rwlock_read_unlock(&device_tree.rwlock); … … 1338 1305 async_exchange_end(exch); 1339 1306 1340 log_msg(L OG_DEFAULT, LVL_DEBUG,1307 log_msg(LVL_DEBUG, 1341 1308 "Forwarding loc service request for `%s' function to driver `%s'.", 1342 1309 fun->pathname, driver->name); … … 1394 1361 static bool devman_init(void) 1395 1362 { 1396 log_msg(L OG_DEFAULT, LVL_DEBUG, "devman_init - looking for available drivers.");1363 log_msg(LVL_DEBUG, "devman_init - looking for available drivers."); 1397 1364 1398 1365 /* Initialize list of available drivers. */ … … 1400 1367 if (lookup_available_drivers(&drivers_list, 1401 1368 DRIVER_DEFAULT_STORE) == 0) { 1402 log_msg(L OG_DEFAULT, LVL_FATAL, "No drivers found.");1369 log_msg(LVL_FATAL, "No drivers found."); 1403 1370 return false; 1404 1371 } 1405 1372 1406 log_msg(L OG_DEFAULT, LVL_DEBUG, "devman_init - list of drivers has been initialized.");1373 log_msg(LVL_DEBUG, "devman_init - list of drivers has been initialized."); 1407 1374 1408 1375 /* Create root device node. */ 1409 1376 if (!init_device_tree(&device_tree, &drivers_list)) { 1410 log_msg(L OG_DEFAULT, LVL_FATAL, "Failed to initialize device tree.");1377 log_msg(LVL_FATAL, "Failed to initialize device tree."); 1411 1378 return false; 1412 1379 } … … 1428 1395 printf("%s: HelenOS Device Manager\n", NAME); 1429 1396 1430 int rc = log_init(NAME );1397 int rc = log_init(NAME, LVL_WARN); 1431 1398 if (rc != EOK) { 1432 1399 printf("%s: Error initializing logging subsystem.\n", NAME); … … 1440 1407 1441 1408 if (!devman_init()) { 1442 log_msg(L OG_DEFAULT, LVL_ERROR, "Error while initializing service.");1409 log_msg(LVL_ERROR, "Error while initializing service."); 1443 1410 return -1; 1444 1411 } … … 1447 1414 rc = service_register(SERVICE_DEVMAN); 1448 1415 if (rc != EOK) { 1449 log_msg(L OG_DEFAULT, LVL_ERROR, "Failed registering as a service.");1416 log_msg(LVL_ERROR, "Failed registering as a service."); 1450 1417 return rc; 1451 1418 }
Note:
See TracChangeset
for help on using the changeset viewer.