Changes in uspace/srv/devman/main.c [aa7dc64:ffa2c8ef] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/devman/main.c
raa7dc64 rffa2c8ef 199 199 static int assign_driver_fibril(void *arg) 200 200 { 201 dev_node_t *dev_node = (dev_node_t *) arg;202 assign_driver( dev_node, &drivers_list, &device_tree);201 node_t *node = (node_t *) arg; 202 assign_driver(node, &drivers_list, &device_tree); 203 203 return EOK; 204 204 } 205 205 206 /** Handle functionregistration.206 /** Handle child device registration. 207 207 * 208 208 * Child devices are registered by their parent's device driver. 209 209 */ 210 static void devman_add_function(ipc_callid_t callid, ipc_call_t *call) 211 { 212 fun_type_t ftype = (fun_type_t) IPC_GET_ARG1(*call); 213 devman_handle_t dev_handle = IPC_GET_ARG2(*call); 214 sysarg_t match_count = IPC_GET_ARG3(*call); 210 static void devman_add_child(ipc_callid_t callid, ipc_call_t *call) 211 { 212 devman_handle_t parent_handle = IPC_GET_ARG1(*call); 213 sysarg_t match_count = IPC_GET_ARG2(*call); 215 214 dev_tree_t *tree = &device_tree; 216 215 217 216 fibril_rwlock_write_lock(&tree->rwlock); 218 219 dev_node_t *dev = NULL; 220 dev_node_t *pdev = find_dev_node_no_lock(&device_tree, dev_handle); 221 222 if (pdev == NULL) { 217 node_t *parent = find_dev_node_no_lock(&device_tree, parent_handle); 218 219 if (parent == NULL) { 223 220 fibril_rwlock_write_unlock(&tree->rwlock); 224 221 async_answer_0(callid, ENOENT); … … 226 223 } 227 224 228 if (ftype != fun_inner && ftype != fun_exposed) { 229 /* Unknown function type */ 230 printf(NAME ": Error, unknown function type provided by driver!\n"); 231 232 fibril_rwlock_write_unlock(&tree->rwlock); 233 async_answer_0(callid, EINVAL); 234 return; 235 } 236 237 char *fun_name = NULL; 238 int rc = async_data_write_accept((void **)&fun_name, true, 0, 0, 0, 0); 225 char *dev_name = NULL; 226 int rc = async_data_write_accept((void **)&dev_name, true, 0, 0, 0, 0); 239 227 if (rc != EOK) { 240 228 fibril_rwlock_write_unlock(&tree->rwlock); … … 243 231 } 244 232 245 fun_node_t *fun = create_fun_node();246 if (!insert_ fun_node(&device_tree, fun, fun_name, pdev)) {233 node_t *node = create_dev_node(); 234 if (!insert_dev_node(&device_tree, node, dev_name, parent)) { 247 235 fibril_rwlock_write_unlock(&tree->rwlock); 248 delete_ fun_node(fun);236 delete_dev_node(node); 249 237 async_answer_0(callid, ENOMEM); 250 238 return; 251 239 } 252 240 253 if (ftype == fun_inner) {254 dev = create_dev_node();255 if (dev == NULL) {256 fibril_rwlock_write_unlock(&tree->rwlock);257 delete_fun_node(fun);258 async_answer_0(callid, ENOMEM);259 return;260 }261 262 insert_dev_node(tree, dev, fun);263 }264 265 241 fibril_rwlock_write_unlock(&tree->rwlock); 266 242 267 printf(NAME ": devman_add_function %s\n", fun->pathname); 268 269 devman_receive_match_ids(match_count, &fun->match_ids); 270 271 if (ftype == fun_inner) { 272 assert(dev != NULL); 243 printf(NAME ": devman_add_child %s\n", node->pathname); 244 245 devman_receive_match_ids(match_count, &node->match_ids); 246 247 /* 248 * Try to find a suitable driver and assign it to the device. We do 249 * not want to block the current fibril that is used for processing 250 * incoming calls: we will launch a separate fibril to handle the 251 * driver assigning. That is because assign_driver can actually include 252 * task spawning which could take some time. 253 */ 254 fid_t assign_fibril = fibril_create(assign_driver_fibril, node); 255 if (assign_fibril == 0) { 273 256 /* 274 * Try to find a suitable driver and assign it to the device. We do 275 * not want to block the current fibril that is used for processing 276 * incoming calls: we will launch a separate fibril to handle the 277 * driver assigning. That is because assign_driver can actually include 278 * task spawning which could take some time. 257 * Fallback in case we are out of memory. 258 * Probably not needed as we will die soon anyway ;-). 279 259 */ 280 fid_t assign_fibril = fibril_create(assign_driver_fibril, dev); 281 if (assign_fibril == 0) { 282 /* 283 * Fallback in case we are out of memory. 284 * Probably not needed as we will die soon anyway ;-). 285 */ 286 (void) assign_driver_fibril(fun); 287 } else { 288 fibril_add_ready(assign_fibril); 289 } 260 (void) assign_driver_fibril(node); 290 261 } else { 291 devmap_register_tree_function(fun, tree);292 } 293 262 fibril_add_ready(assign_fibril); 263 } 264 294 265 /* Return device handle to parent's driver. */ 295 async_answer_1(callid, EOK, fun->handle);266 async_answer_1(callid, EOK, node->handle); 296 267 } 297 268 … … 317 288 * mapper. 318 289 */ 319 class_add_devmap_ function(&class_list, cli);290 class_add_devmap_device(&class_list, cli); 320 291 321 292 free(devmap_pathname); 322 293 } 323 294 324 static void devman_add_ function_to_class(ipc_callid_t callid, ipc_call_t *call)295 static void devman_add_device_to_class(ipc_callid_t callid, ipc_call_t *call) 325 296 { 326 297 devman_handle_t handle = IPC_GET_ARG1(*call); … … 335 306 } 336 307 337 fun_node_t *fun = find_fun_node(&device_tree, handle);338 if ( fun== NULL) {308 node_t *dev = find_dev_node(&device_tree, handle); 309 if (dev == NULL) { 339 310 async_answer_0(callid, ENOENT); 340 311 return; … … 342 313 343 314 dev_class_t *cl = get_dev_class(&class_list, class_name); 344 dev_class_info_t *class_info = add_ function_to_class(fun, cl, NULL);315 dev_class_info_t *class_info = add_device_to_class(dev, cl, NULL); 345 316 346 317 /* Register the device's class alias by devmapper. */ 347 318 devmap_register_class_dev(class_info); 348 319 349 printf(NAME ": function'%s' added to class '%s', class name '%s' was "350 "asigned to it\n", fun->pathname, class_name, class_info->dev_name);320 printf(NAME ": device '%s' added to class '%s', class name '%s' was " 321 "asigned to it\n", dev->pathname, class_name, class_info->dev_name); 351 322 352 323 async_answer_0(callid, EOK); … … 401 372 cont = false; 402 373 continue; 403 case DEVMAN_ADD_ FUNCTION:404 devman_add_ function(callid, &call);374 case DEVMAN_ADD_CHILD_DEVICE: 375 devman_add_child(callid, &call); 405 376 break; 406 377 case DEVMAN_ADD_DEVICE_TO_CLASS: 407 devman_add_ function_to_class(callid, &call);378 devman_add_device_to_class(callid, &call); 408 379 break; 409 380 default: … … 416 387 /** Find handle for the device instance identified by the device's path in the 417 388 * device tree. */ 418 static void devman_ function_get_handle(ipc_callid_t iid, ipc_call_t *icall)389 static void devman_device_get_handle(ipc_callid_t iid, ipc_call_t *icall) 419 390 { 420 391 char *pathname; … … 426 397 } 427 398 428 fun_node_t *fun = find_fun_node_by_path(&device_tree, pathname);399 node_t * dev = find_dev_node_by_path(&device_tree, pathname); 429 400 430 401 free(pathname); 431 402 432 if ( fun== NULL) {403 if (dev == NULL) { 433 404 async_answer_0(iid, ENOENT); 434 405 return; 435 406 } 436 437 async_answer_1(iid, EOK, fun->handle);407 408 async_answer_1(iid, EOK, dev->handle); 438 409 } 439 410 … … 455 426 continue; 456 427 case DEVMAN_DEVICE_GET_HANDLE: 457 devman_ function_get_handle(callid, &call);428 devman_device_get_handle(callid, &call); 458 429 break; 459 430 default: … … 467 438 { 468 439 devman_handle_t handle = IPC_GET_ARG2(*icall); 469 devman_handle_t fwd_h; 470 fun_node_t *fun = NULL; 471 dev_node_t *dev = NULL; 472 473 fun = find_fun_node(&device_tree, handle); 474 if (fun == NULL) 475 dev = find_dev_node(&device_tree, handle); 476 else 477 dev = fun->dev; 478 479 if (fun == NULL && dev == NULL) { 480 printf(NAME ": devman_forward error - no device or function with " 481 "handle %" PRIun " was found.\n", handle); 440 441 node_t *dev = find_dev_node(&device_tree, handle); 442 if (dev == NULL) { 443 printf(NAME ": devman_forward error - no device with handle %" PRIun 444 " was found.\n", handle); 482 445 async_answer_0(iid, ENOENT); 483 446 return; 484 447 } 485 486 if (fun == NULL && !drv_to_parent) {487 printf(NAME ": devman_forward error - cannot connect to "488 "handle %" PRIun ", refers to a device.\n", handle);489 async_answer_0(iid, ENOENT);490 return;491 }492 448 493 449 driver_t *driver = NULL; 494 450 495 451 if (drv_to_parent) { 496 /* Connect to parent function of a device (or device function). */ 497 if (dev->pfun->dev != NULL) 498 driver = dev->pfun->dev->drv; 499 fwd_h = dev->pfun->handle; 452 if (dev->parent != NULL) 453 driver = dev->parent->drv; 500 454 } else if (dev->state == DEVICE_USABLE) { 501 /* Connect to the specified function */502 455 driver = dev->drv; 503 456 assert(driver != NULL); 504 505 fwd_h = handle;506 457 } 507 458 … … 527 478 } 528 479 529 if (fun != NULL) { 530 printf(NAME ": devman_forward: forward connection to function %s to " 531 "driver %s.\n", fun->pathname, driver->name); 532 } else { 533 printf(NAME ": devman_forward: forward connection to device %s to " 534 "driver %s.\n", dev->pfun->pathname, driver->name); 535 } 536 537 async_forward_fast(iid, driver->phone, method, fwd_h, 0, IPC_FF_NONE); 480 printf(NAME ": devman_forward: forward connection to device %s to " 481 "driver %s.\n", dev->pathname, driver->name); 482 async_forward_fast(iid, driver->phone, method, dev->handle, 0, IPC_FF_NONE); 538 483 } 539 484 … … 543 488 { 544 489 devmap_handle_t devmap_handle = IPC_GET_ARG2(*icall); 545 fun_node_t *fun; 546 dev_node_t *dev; 547 548 fun = find_devmap_tree_function(&device_tree, devmap_handle); 549 if (fun == NULL) 550 fun = find_devmap_class_function(&class_list, devmap_handle); 551 552 if (fun == NULL || fun->dev->drv == NULL) { 490 node_t *dev; 491 492 dev = find_devmap_tree_device(&device_tree, devmap_handle); 493 if (dev == NULL) 494 dev = find_devmap_class_device(&class_list, devmap_handle); 495 496 if (dev == NULL || dev->drv == NULL) { 553 497 async_answer_0(iid, ENOENT); 554 498 return; 555 499 } 556 557 dev = fun->dev;558 500 559 501 if (dev->state != DEVICE_USABLE || dev->drv->phone <= 0) { … … 565 507 IPC_FF_NONE); 566 508 printf(NAME ": devman_connection_devmapper: forwarded connection to " 567 "device %s to driver %s.\n", fun->pathname, dev->drv->name);509 "device %s to driver %s.\n", dev->pathname, dev->drv->name); 568 510 } 569 511
Note:
See TracChangeset
for help on using the changeset viewer.