Changes in uspace/srv/devman/devman.c [463e734:7e752b2] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/devman/devman.c
r463e734 r7e752b2 508 508 /** Notify driver about the devices to which it was assigned. 509 509 * 510 * The driver's mutex must be locked. 511 * 510 512 * @param driver The driver to which the devices are passed. 511 513 */ … … 516 518 int phone; 517 519 518 printf(NAME ": pass_devices_to_driver(`%s')\n", driver->name); 519 520 fibril_mutex_lock(&driver->driver_mutex); 521 522 phone = async_connect_me_to(driver->phone, DRIVER_DEVMAN, 0, 0); 523 524 if (phone < 0) { 525 fibril_mutex_unlock(&driver->driver_mutex); 526 return; 527 } 528 529 /* 530 * Go through devices list as long as there is some device 531 * that has not been passed to the driver. 532 */ 533 link = driver->devices.next; 534 while (link != &driver->devices) { 535 dev = list_get_instance(link, node_t, driver_devices); 536 if (dev->passed_to_driver) { 520 printf(NAME ": pass_devices_to_driver\n"); 521 522 phone = ipc_connect_me_to(driver->phone, DRIVER_DEVMAN, 0, 0); 523 if (phone > 0) { 524 525 link = driver->devices.next; 526 while (link != &driver->devices) { 527 dev = list_get_instance(link, node_t, driver_devices); 528 add_device(phone, driver, dev, tree); 537 529 link = link->next; 538 continue;539 530 } 540 541 /* 542 * We remove the device from the list to allow safe adding 543 * of new devices (no one will touch our item this way). 544 */ 545 list_remove(link); 546 547 /* 548 * Unlock to avoid deadlock when adding device 549 * handled by itself. 550 */ 551 fibril_mutex_unlock(&driver->driver_mutex); 552 553 add_device(phone, driver, dev, tree); 554 555 /* 556 * Lock again as we will work with driver's 557 * structure. 558 */ 559 fibril_mutex_lock(&driver->driver_mutex); 560 561 /* 562 * Insert the device back. 563 * The order is not relevant here so no harm is done 564 * (actually, the order would be preserved in most cases). 565 */ 566 list_append(link, &driver->devices); 567 568 /* 569 * Restart the cycle to go through all devices again. 570 */ 571 link = driver->devices.next; 572 } 573 574 ipc_hangup(phone); 575 576 /* 577 * Once we passed all devices to the driver, we need to mark the 578 * driver as running. 579 * It is vital to do it here and inside critical section. 580 * 581 * If we would change the state earlier, other devices added to 582 * the driver would be added to the device list and started 583 * immediately and possibly started here as well. 584 */ 585 printf(NAME ": driver %s goes into running state.\n", driver->name); 586 driver->state = DRIVER_RUNNING; 587 588 fibril_mutex_unlock(&driver->driver_mutex); 531 532 ipc_hangup(phone); 533 } 589 534 } 590 535 … … 600 545 void initialize_running_driver(driver_t *driver, dev_tree_t *tree) 601 546 { 602 printf(NAME ": initialize_running_driver (`%s')\n", driver->name); 547 printf(NAME ": initialize_running_driver\n"); 548 fibril_mutex_lock(&driver->driver_mutex); 603 549 604 550 /* … … 607 553 */ 608 554 pass_devices_to_driver(driver, tree); 555 556 /* Change driver's state to running. */ 557 driver->state = DRIVER_RUNNING; 558 559 fibril_mutex_unlock(&driver->driver_mutex); 609 560 } 610 561 … … 678 629 } 679 630 680 static FIBRIL_MUTEX_INITIALIZE(add_device_guard);681 631 682 632 /** Pass a device to running driver. … … 687 637 void add_device(int phone, driver_t *drv, node_t *node, dev_tree_t *tree) 688 638 { 689 fibril_mutex_lock(&add_device_guard); 690 691 /* 692 * We do not expect to have driver's mutex locked as we do not 693 * access any structures that would affect driver_t. 694 */ 695 printf(NAME ": add_device (driver `%s', device `%s')\n", drv->name, 696 node->name); 639 printf(NAME ": add_device\n"); 697 640 698 641 ipcarg_t rc; … … 700 643 701 644 /* Send the device to the driver. */ 702 devman_handle_t parent_handle; 703 if (node->parent) { 704 parent_handle = node->parent->handle; 705 } else { 706 parent_handle = 0; 707 } 708 709 aid_t req = async_send_2(phone, DRIVER_ADD_DEVICE, node->handle, 710 parent_handle, &answer); 645 aid_t req = async_send_1(phone, DRIVER_ADD_DEVICE, node->handle, 646 &answer); 711 647 712 648 /* Send the device's name to the driver. */ … … 716 652 /* TODO handle error */ 717 653 } 718 654 719 655 /* Wait for answer from the driver. */ 720 656 async_wait_for(req, &rc); 721 722 fibril_mutex_unlock(&add_device_guard);723 724 657 switch(rc) { 725 658 case EOK: … … 734 667 } 735 668 736 node->passed_to_driver = true;737 738 669 return; 739 670 } … … 761 692 attach_driver(node, drv); 762 693 763 fibril_mutex_lock(&drv->driver_mutex);764 694 if (drv->state == DRIVER_NOT_STARTED) { 765 695 /* Start the driver. */ 766 696 start_driver(drv); 767 697 } 768 fibril_mutex_unlock(&drv->driver_mutex); 769 770 fibril_mutex_lock(&drv->driver_mutex); 771 bool is_running = drv->state == DRIVER_RUNNING; 772 fibril_mutex_unlock(&drv->driver_mutex); 773 774 if (is_running) { 698 699 if (drv->state == DRIVER_RUNNING) { 775 700 /* Notify the driver about the new device. */ 776 int phone = async_connect_me_to(drv->phone, DRIVER_DEVMAN, 0, 0);701 int phone = ipc_connect_me_to(drv->phone, DRIVER_DEVMAN, 0, 0); 777 702 if (phone > 0) { 778 703 add_device(phone, drv, node, tree); … … 936 861 node->name = dev_name; 937 862 if (!set_dev_path(node, parent)) { 863 fibril_rwlock_write_unlock(&tree->rwlock); 938 864 return false; 939 865 } … … 1157 1083 while (link != &class_list->classes) { 1158 1084 cl = list_get_instance(link, dev_class_t, link); 1159 if (str_cmp(cl->name, class_name) == 0) {1085 if (str_cmp(cl->name, class_name) == 0) 1160 1086 return cl; 1161 }1162 link = link->next;1163 1087 } 1164 1088
Note:
See TracChangeset
for help on using the changeset viewer.