Changeset 6edc69a in mainline
- Timestamp:
- 2011-02-19T20:02:18Z (14 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- b9d910f
- Parents:
- 7e7f0f5 (diff), 374552ef (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. - Location:
- uspace
- Files:
-
- 15 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/drv/uhci-hcd/iface.c
r7e7f0f5 r6edc69a 54 54 } 55 55 /*----------------------------------------------------------------------------*/ 56 static int reserve_default_address(device_t *dev )56 static int reserve_default_address(device_t *dev, usb_speed_t speed) 57 57 { 58 58 assert(dev); … … 72 72 } 73 73 /*----------------------------------------------------------------------------*/ 74 static int request_address(device_t *dev, usb_address_t *address) 74 static int request_address(device_t *dev, usb_speed_t speed, 75 usb_address_t *address) 75 76 { 76 77 assert(dev); … … 163 164 return EOK; 164 165 } 165 /*----------------------------------------------------------------------------*/166 static int control_write_setup(device_t *dev, usb_target_t target,167 size_t max_packet_size,168 void *data, size_t size,169 usbhc_iface_transfer_out_callback_t callback, void *arg)170 {171 dev_speed_t speed = FULL_SPEED;172 166 173 usb_log_warning("Using deprecated API %s.\n", __FUNCTION__);174 batch_t *batch = batch_get(dev, target, USB_TRANSFER_CONTROL,175 max_packet_size, speed, NULL, 0, data, size, NULL, callback, arg);176 if (!batch)177 return ENOMEM;178 batch_control_setup_old(batch);179 return EOK;180 }181 /*----------------------------------------------------------------------------*/182 static int control_write_data(device_t *dev, usb_target_t target,183 size_t max_packet_size,184 void *data, size_t size,185 usbhc_iface_transfer_out_callback_t callback, void *arg)186 {187 dev_speed_t speed = FULL_SPEED;188 167 189 usb_log_warning("Using deprecated API %s.\n", __FUNCTION__);190 batch_t *batch = batch_get(dev, target, USB_TRANSFER_CONTROL,191 max_packet_size, speed, data, size, NULL, 0, NULL, callback, arg);192 if (!batch)193 return ENOMEM;194 batch_control_write_data_old(batch);195 return EOK;196 }197 /*----------------------------------------------------------------------------*/198 static int control_write_status(device_t *dev, usb_target_t target,199 usbhc_iface_transfer_in_callback_t callback, void *arg)200 {201 size_t max_packet_size = 8;202 dev_speed_t speed = FULL_SPEED;203 204 usb_log_warning("Using deprecated API %s.\n", __FUNCTION__);205 batch_t *batch = batch_get(dev, target, USB_TRANSFER_CONTROL,206 max_packet_size, speed, NULL, 0, NULL, 0, callback, NULL, arg);207 if (!batch)208 return ENOMEM;209 batch_control_write_status_old(batch);210 return EOK;211 }212 /*----------------------------------------------------------------------------*/213 static int control_read_setup(device_t *dev, usb_target_t target,214 size_t max_packet_size,215 void *data, size_t size,216 usbhc_iface_transfer_out_callback_t callback, void *arg)217 {218 dev_speed_t speed = FULL_SPEED;219 220 usb_log_warning("Using deprecated API %s.\n", __FUNCTION__);221 batch_t *batch = batch_get(dev, target, USB_TRANSFER_CONTROL,222 max_packet_size, speed, NULL, 0, data, size, NULL, callback, arg);223 if (!batch)224 return ENOMEM;225 batch_control_setup_old(batch);226 return EOK;227 }228 /*----------------------------------------------------------------------------*/229 static int control_read_data(device_t *dev, usb_target_t target,230 size_t max_packet_size,231 void *data, size_t size,232 usbhc_iface_transfer_in_callback_t callback, void *arg)233 {234 dev_speed_t speed = FULL_SPEED;235 236 usb_log_warning("Using deprecated API %s.\n", __FUNCTION__);237 batch_t *batch = batch_get(dev, target, USB_TRANSFER_CONTROL,238 max_packet_size, speed, data, size, NULL, 0, callback, NULL, arg);239 if (!batch)240 return ENOMEM;241 batch_control_read_data_old(batch);242 return EOK;243 }244 /*----------------------------------------------------------------------------*/245 static int control_read_status(device_t *dev, usb_target_t target,246 usbhc_iface_transfer_out_callback_t callback, void *arg)247 {248 size_t max_packet_size = 8;249 dev_speed_t speed = FULL_SPEED;250 251 usb_log_warning("Using deprecated API %s.\n", __FUNCTION__);252 batch_t *batch = batch_get(dev, target, USB_TRANSFER_CONTROL,253 max_packet_size, speed, NULL, 0, NULL, 0, NULL, callback, arg);254 if (!batch)255 return ENOMEM;256 batch_control_read_status_old(batch);257 return EOK;258 }259 168 /*----------------------------------------------------------------------------*/ 260 169 usbhc_iface_t uhci_iface = { … … 272 181 .control_read = control_read, 273 182 .control_write = control_write, 274 275 .control_write_setup = control_write_setup,276 .control_write_data = control_write_data,277 .control_write_status = control_write_status,278 279 .control_read_setup = control_read_setup,280 .control_read_data = control_read_data,281 .control_read_status = control_read_status282 183 }; 283 184 /** -
uspace/drv/uhci-rhd/port.c
r7e7f0f5 r6edc69a 131 131 return EOK; 132 132 } 133 /*----------------------------------------------------------------------------*/ 134 static int uhci_port_new_device(uhci_port_t *port) 135 { 136 assert(port); 137 assert(usb_hc_connection_is_opened(&port->hc_connection)); 138 139 usb_log_info("Adding new device on port %d.\n", port->number); 140 141 /* get address of the future device */ 142 const usb_address_t usb_address = usb_hc_request_address(&port->hc_connection); 143 144 if (usb_address <= 0) { 145 usb_log_error("Recieved invalid address(%d).\n", usb_address); 146 return usb_address; 147 } 148 usb_log_debug("Sucessfully obtained address %d for port %d.\n", 149 usb_address, port->number); 150 151 /* get default address */ 152 int ret = usb_hc_reserve_default_address(&port->hc_connection); 153 if (ret != EOK) { 154 usb_log_error("Failed to reserve default address on port %d.\n", 155 port->number); 156 int ret2 = usb_hc_unregister_device(&port->hc_connection, 157 usb_address); 158 if (ret2 != EOK) { 159 usb_log_fatal("Failed to return requested address on port %d.\n", 160 port->number); 161 return ret2; 162 } 163 usb_log_debug("Successfully returned reserved address on port %d.\n", 164 port->number); 165 return ret; 166 } 167 usb_log_debug("Sucessfully obtained default address for port %d.\n", 168 port->number); 133 134 /** Callback for enabling port during adding a new device. 135 * 136 * @param portno Port number (unused). 137 * @param arg Pointer to uhci_port_t of port with the new device. 138 * @return Error code. 139 */ 140 static int new_device_enable_port(int portno, void *arg) 141 { 142 uhci_port_t *port = (uhci_port_t *) arg; 143 144 usb_log_debug("new_device_enable_port(%d)\n", port->number); 169 145 170 146 /* 171 * the host then waits for at least 100 ms to allow completion of147 * The host then waits for at least 100 ms to allow completion of 172 148 * an insertion process and for power at the device to become stable. 173 149 */ 174 150 async_usleep(100000); 175 151 176 /* enable port*/152 /* Enable the port. */ 177 153 uhci_port_set_enabled(port, true); 178 154 … … 196 172 } 197 173 198 /* 199 * Initialize connection to the device. 200 */ 201 /* FIXME: check for errors. */ 202 usb_device_connection_t new_dev_connection; 203 usb_endpoint_pipe_t new_dev_ctrl_pipe; 204 usb_device_connection_initialize_on_default_address( 205 &new_dev_connection, &port->hc_connection); 206 usb_endpoint_pipe_initialize_default_control(&new_dev_ctrl_pipe, 207 &new_dev_connection); 208 209 /* 210 * Assign new address to the device. This function updates 211 * the backing connection to still point to the same device. 212 */ 213 /* FIXME: check for errors. */ 214 usb_endpoint_pipe_start_session(&new_dev_ctrl_pipe); 215 ret = usb_request_set_address(&new_dev_ctrl_pipe, usb_address); 216 usb_endpoint_pipe_end_session(&new_dev_ctrl_pipe); 217 218 if (ret != EOK) { /* address assigning went wrong */ 219 usb_log_error("Failed(%d) to assign address to the device.\n", ret); 174 return EOK; 175 } 176 177 /*----------------------------------------------------------------------------*/ 178 static int uhci_port_new_device(uhci_port_t *port) 179 { 180 assert(port); 181 assert(usb_hc_connection_is_opened(&port->hc_connection)); 182 183 usb_log_info("Detected new device on port %u.\n", port->number); 184 185 usb_address_t dev_addr; 186 int rc = usb_hc_new_device_wrapper(port->rh, &port->hc_connection, 187 USB_SPEED_FULL, 188 new_device_enable_port, port->number, port, 189 &dev_addr, &port->attached_device); 190 if (rc != EOK) { 191 usb_log_error("Failed adding new device on port %u: %s.\n", 192 port->number, str_error(rc)); 220 193 uhci_port_set_enabled(port, false); 221 int release = usb_hc_release_default_address(&port->hc_connection); 222 if (release != EOK) { 223 usb_log_error("Failed to release default address on port %d.\n", 224 port->number); 225 return release; 226 } 227 usb_log_debug("Sucessfully released default address on port %d.\n", 228 port->number); 229 return ret; 230 } 231 usb_log_debug("Sucessfully assigned address %d for port %d.\n", 232 usb_address, port->number); 233 234 /* release default address */ 235 ret = usb_hc_release_default_address(&port->hc_connection); 236 if (ret != EOK) { 237 usb_log_error("Failed to release default address on port %d.\n", 238 port->number); 239 return ret; 240 } 241 usb_log_debug("Sucessfully released default address on port %d.\n", 242 port->number); 243 244 /* communicate and possibly report to devman */ 245 assert(port->attached_device == 0); 246 247 ret = usb_device_register_child_in_devman(new_dev_connection.address, 248 new_dev_connection.hc_handle, port->rh, &port->attached_device); 249 250 if (ret != EOK) { /* something went wrong */ 251 usb_log_error("Failed(%d) in usb_drv_register_child.\n", ret); 252 uhci_port_set_enabled(port, false); 253 return ENOMEM; 254 } 255 usb_log_info("Sucessfully added device on port(%d) address(%d) handle %d.\n", 256 port->number, usb_address, port->attached_device); 257 258 /* 259 * Register the device in the host controller. 260 */ 261 usb_hc_attached_device_t new_device = { 262 .address = new_dev_connection.address, 263 .handle = port->attached_device 264 }; 265 266 ret = usb_hc_register_device(&port->hc_connection, &new_device); 267 // TODO: proper error check here 268 assert(ret == EOK); 269 270 return EOK; 271 } 194 return rc; 195 } 196 197 usb_log_info("New device on port %u has address %d (handle %zu).\n", 198 port->number, dev_addr, port->attached_device); 199 200 return EOK; 201 } 202 272 203 /*----------------------------------------------------------------------------*/ 273 204 static int uhci_port_remove_device(uhci_port_t *port) -
uspace/drv/uhci-rhd/root_hub.c
r7e7f0f5 r6edc69a 47 47 assert(rh); 48 48 int ret; 49 ret = usb_ drv_find_hc(rh, &instance->hc_handle);49 ret = usb_hc_find(rh->handle, &instance->hc_handle); 50 50 usb_log_info("rh found(%d) hc handle: %d.\n", ret, instance->hc_handle); 51 51 if (ret != EOK) { -
uspace/drv/usbhub/usbhub.c
r7e7f0f5 r6edc69a 50 50 #include "usb/usb.h" 51 51 52 static int iface_get_hc_handle(device_t *device, devman_handle_t *handle) 53 { 54 return usb_hc_find(device->handle, handle); 55 } 56 52 57 static usb_iface_t hub_usb_iface = { 53 .get_hc_handle = usb_drv_find_hc58 .get_hc_handle = iface_get_hc_handle 54 59 }; 55 60 -
uspace/drv/vhc/connhost.c
r7e7f0f5 r6edc69a 234 234 } 235 235 236 static int enqueue_transfer_setup(device_t *dev,237 usb_target_t target, usb_transfer_type_t transfer_type,238 void *buffer, size_t size,239 usbhc_iface_transfer_out_callback_t callback, void *arg)240 {241 usb_log_debug2("Transfer SETUP [%d.%d (%s); %zu].\n",242 target.address, target.endpoint,243 usb_str_transfer_type(transfer_type),244 size);245 246 transfer_info_t *transfer247 = create_transfer_info(dev, USB_DIRECTION_OUT, arg);248 transfer->out_callback = callback;249 250 hc_add_transaction_to_device(true, target, transfer_type, buffer, size,251 universal_callback, transfer);252 253 return EOK;254 }255 256 236 static int enqueue_transfer_in(device_t *dev, 257 237 usb_target_t target, usb_transfer_type_t transfer_type, … … 292 272 return enqueue_transfer_in(dev, target, USB_TRANSFER_INTERRUPT, 293 273 data, size, 294 callback, arg);295 }296 297 static int control_write_setup(device_t *dev, usb_target_t target,298 size_t max_packet_size,299 void *data, size_t size,300 usbhc_iface_transfer_out_callback_t callback, void *arg)301 {302 return enqueue_transfer_setup(dev, target, USB_TRANSFER_CONTROL,303 data, size,304 callback, arg);305 }306 307 static int control_write_data(device_t *dev, usb_target_t target,308 size_t max_packet_size,309 void *data, size_t size,310 usbhc_iface_transfer_out_callback_t callback, void *arg)311 {312 return enqueue_transfer_out(dev, target, USB_TRANSFER_CONTROL,313 data, size,314 callback, arg);315 }316 317 static int control_write_status(device_t *dev, usb_target_t target,318 usbhc_iface_transfer_in_callback_t callback, void *arg)319 {320 return enqueue_transfer_in(dev, target, USB_TRANSFER_CONTROL,321 NULL, 0,322 274 callback, arg); 323 275 } … … 341 293 } 342 294 343 static int control_read_setup(device_t *dev, usb_target_t target,344 size_t max_packet_size,345 void *data, size_t size,346 usbhc_iface_transfer_out_callback_t callback, void *arg)347 {348 return enqueue_transfer_setup(dev, target, USB_TRANSFER_CONTROL,349 data, size,350 callback, arg);351 }352 353 static int control_read_data(device_t *dev, usb_target_t target,354 size_t max_packet_size,355 void *data, size_t size,356 usbhc_iface_transfer_in_callback_t callback, void *arg)357 {358 return enqueue_transfer_in(dev, target, USB_TRANSFER_CONTROL,359 data, size,360 callback, arg);361 }362 363 static int control_read_status(device_t *dev, usb_target_t target,364 usbhc_iface_transfer_out_callback_t callback, void *arg)365 {366 return enqueue_transfer_out(dev, target, USB_TRANSFER_CONTROL,367 NULL, 0,368 callback, arg);369 }370 371 295 static int control_read(device_t *dev, usb_target_t target, 372 296 size_t max_packet_size, … … 390 314 391 315 392 static int reserve_default_address(device_t *dev )316 static int reserve_default_address(device_t *dev, usb_speed_t ignored) 393 317 { 394 318 usb_address_keeping_reserve_default(&addresses); … … 402 326 } 403 327 404 static int request_address(device_t *dev, usb_address_t *address) 328 static int request_address(device_t *dev, usb_speed_t ignored, 329 usb_address_t *address) 405 330 { 406 331 usb_address_t addr = usb_address_keeping_request(&addresses); … … 454 379 .interrupt_in = interrupt_in, 455 380 456 .control_write_setup = control_write_setup,457 .control_write_data = control_write_data,458 .control_write_status = control_write_status,459 460 381 .control_write = control_write, 461 462 .control_read_setup = control_read_setup,463 .control_read_data = control_read_data,464 .control_read_status = control_read_status,465 466 382 .control_read = control_read 467 383 }; -
uspace/lib/c/generic/str_error.c
r7e7f0f5 r6edc69a 73 73 case EBADCHECKSUM: 74 74 return "Bad checksum"; 75 case ESTALL: 76 return "Operation stalled"; 75 77 case EAGAIN: 76 78 return "Resource temporarily unavailable"; -
uspace/lib/c/include/errno.h
r7e7f0f5 r6edc69a 59 59 #define EBADCHECKSUM (-300) 60 60 61 /** USB: stalled operation. */ 62 #define ESTALL (-301) 63 61 64 /** An API function is called while another blocking function is in progress. */ 62 65 #define EINPROGRESS (-10036) -
uspace/lib/drv/generic/remote_usbhc.c
r7e7f0f5 r6edc69a 46 46 static void remote_usbhc_interrupt_out(device_t *, void *, ipc_callid_t, ipc_call_t *); 47 47 static void remote_usbhc_interrupt_in(device_t *, void *, ipc_callid_t, ipc_call_t *); 48 static void remote_usbhc_control_write_setup(device_t *, void *, ipc_callid_t, ipc_call_t *);49 static void remote_usbhc_control_write_data(device_t *, void *, ipc_callid_t, ipc_call_t *);50 static void remote_usbhc_control_write_status(device_t *, void *, ipc_callid_t, ipc_call_t *);51 static void remote_usbhc_control_read_setup(device_t *, void *, ipc_callid_t, ipc_call_t *);52 static void remote_usbhc_control_read_data(device_t *, void *, ipc_callid_t, ipc_call_t *);53 static void remote_usbhc_control_read_status(device_t *, void *, ipc_callid_t, ipc_call_t *);54 48 static void remote_usbhc_control_write(device_t *, void *, ipc_callid_t, ipc_call_t *); 55 49 static void remote_usbhc_control_read(device_t *, void *, ipc_callid_t, ipc_call_t *); … … 75 69 remote_usbhc_interrupt_in, 76 70 77 remote_usbhc_control_write_setup,78 remote_usbhc_control_write_data,79 remote_usbhc_control_write_status,80 81 remote_usbhc_control_read_setup,82 remote_usbhc_control_read_data,83 remote_usbhc_control_read_status,84 85 71 remote_usbhc_control_write, 86 72 remote_usbhc_control_read … … 165 151 return; 166 152 } 167 168 int rc = usb_iface->reserve_default_address(device); 153 154 usb_speed_t speed = DEV_IPC_GET_ARG1(*call); 155 156 int rc = usb_iface->reserve_default_address(device, speed); 169 157 170 158 async_answer_0(callid, rc); … … 195 183 return; 196 184 } 185 186 usb_speed_t speed = DEV_IPC_GET_ARG1(*call); 197 187 198 188 usb_address_t address; 199 int rc = usb_iface->request_address(device, &address);189 int rc = usb_iface->request_address(device, speed, &address); 200 190 if (rc != EOK) { 201 191 async_answer_0(callid, rc); … … 293 283 } 294 284 295 size_t expected_len= DEV_IPC_GET_ARG3(*call);285 size_t max_packet_size = DEV_IPC_GET_ARG3(*call); 296 286 usb_target_t target = { 297 287 .address = DEV_IPC_GET_ARG1(*call), … … 301 291 size_t len = 0; 302 292 void *buffer = NULL; 303 if (expected_len > 0) { 304 int rc = async_data_write_accept(&buffer, false, 305 1, USB_MAX_PAYLOAD_SIZE, 306 0, &len); 307 308 if (rc != EOK) { 309 async_answer_0(callid, rc); 310 return; 311 } 293 294 int rc = async_data_write_accept(&buffer, false, 295 1, USB_MAX_PAYLOAD_SIZE, 296 0, &len); 297 298 if (rc != EOK) { 299 async_answer_0(callid, rc); 300 return; 312 301 } 313 302 … … 324 313 trans->size = len; 325 314 326 int rc = transfer_func(device, target, HACK_MAX_PACKET_SIZE,315 rc = transfer_func(device, target, max_packet_size, 327 316 buffer, len, 328 317 callback_out, trans); … … 350 339 } 351 340 352 size_t len= DEV_IPC_GET_ARG3(*call);341 size_t max_packet_size = DEV_IPC_GET_ARG3(*call); 353 342 usb_target_t target = { 354 343 .address = DEV_IPC_GET_ARG1(*call), … … 356 345 }; 357 346 347 size_t len; 358 348 ipc_callid_t data_callid; 359 349 if (!async_data_read_receive(&data_callid, &len)) { … … 371 361 trans->size = len; 372 362 373 int rc = transfer_func(device, target, HACK_MAX_PACKET_SIZE_INTERRUPT_IN,363 int rc = transfer_func(device, target, max_packet_size, 374 364 trans->buffer, len, 375 365 callback_in, trans); … … 381 371 } 382 372 383 /** Process status part of control transfer.384 *385 * @param device Target device.386 * @param callid Initiating caller.387 * @param call Initiating call.388 * @param direction Transfer direction (read ~ in, write ~ out).389 * @param transfer_in_func Transfer function for control read (might be NULL).390 * @param transfer_out_func Transfer function for control write (might be NULL).391 */392 static void remote_usbhc_status_transfer(device_t *device,393 ipc_callid_t callid, ipc_call_t *call,394 usb_direction_t direction,395 int (*transfer_in_func)(device_t *, usb_target_t,396 usbhc_iface_transfer_in_callback_t, void *),397 int (*transfer_out_func)(device_t *, usb_target_t,398 usbhc_iface_transfer_out_callback_t, void *))399 {400 switch (direction) {401 case USB_DIRECTION_IN:402 if (!transfer_in_func) {403 async_answer_0(callid, ENOTSUP);404 return;405 }406 break;407 case USB_DIRECTION_OUT:408 if (!transfer_out_func) {409 async_answer_0(callid, ENOTSUP);410 return;411 }412 break;413 default:414 assert(false && "unreachable code");415 break;416 }417 418 usb_target_t target = {419 .address = DEV_IPC_GET_ARG1(*call),420 .endpoint = DEV_IPC_GET_ARG2(*call)421 };422 423 async_transaction_t *trans = async_transaction_create(callid);424 if (trans == NULL) {425 async_answer_0(callid, ENOMEM);426 return;427 }428 429 int rc;430 switch (direction) {431 case USB_DIRECTION_IN:432 rc = transfer_in_func(device, target,433 callback_in, trans);434 break;435 case USB_DIRECTION_OUT:436 rc = transfer_out_func(device, target,437 callback_out, trans);438 break;439 default:440 assert(false && "unreachable code");441 break;442 }443 444 if (rc != EOK) {445 async_answer_0(callid, rc);446 async_transaction_destroy(trans);447 }448 }449 450 451 373 void remote_usbhc_interrupt_out(device_t *device, void *iface, 452 374 ipc_callid_t callid, ipc_call_t *call) … … 467 389 return remote_usbhc_in_transfer(device, callid, call, 468 390 usb_iface->interrupt_in); 469 }470 471 void remote_usbhc_control_write_setup(device_t *device, void *iface,472 ipc_callid_t callid, ipc_call_t *call)473 {474 usbhc_iface_t *usb_iface = (usbhc_iface_t *) iface;475 assert(usb_iface != NULL);476 477 return remote_usbhc_out_transfer(device, callid, call,478 usb_iface->control_write_setup);479 }480 481 void remote_usbhc_control_write_data(device_t *device, void *iface,482 ipc_callid_t callid, ipc_call_t *call)483 {484 usbhc_iface_t *usb_iface = (usbhc_iface_t *) iface;485 assert(usb_iface != NULL);486 487 return remote_usbhc_out_transfer(device, callid, call,488 usb_iface->control_write_data);489 }490 491 void remote_usbhc_control_write_status(device_t *device, void *iface,492 ipc_callid_t callid, ipc_call_t *call)493 {494 usbhc_iface_t *usb_iface = (usbhc_iface_t *) iface;495 assert(usb_iface != NULL);496 497 return remote_usbhc_status_transfer(device, callid, call,498 USB_DIRECTION_IN, usb_iface->control_write_status, NULL);499 }500 501 void remote_usbhc_control_read_setup(device_t *device, void *iface,502 ipc_callid_t callid, ipc_call_t *call)503 {504 usbhc_iface_t *usb_iface = (usbhc_iface_t *) iface;505 assert(usb_iface != NULL);506 507 return remote_usbhc_out_transfer(device, callid, call,508 usb_iface->control_read_setup);509 }510 511 void remote_usbhc_control_read_data(device_t *device, void *iface,512 ipc_callid_t callid, ipc_call_t *call)513 {514 usbhc_iface_t *usb_iface = (usbhc_iface_t *) iface;515 assert(usb_iface != NULL);516 517 return remote_usbhc_in_transfer(device, callid, call,518 usb_iface->control_read_data);519 }520 521 void remote_usbhc_control_read_status(device_t *device, void *iface,522 ipc_callid_t callid, ipc_call_t *call)523 {524 usbhc_iface_t *usb_iface = (usbhc_iface_t *) iface;525 assert(usb_iface != NULL);526 527 return remote_usbhc_status_transfer(device, callid, call,528 USB_DIRECTION_OUT, NULL, usb_iface->control_read_status);529 391 } 530 392 … … 545 407 }; 546 408 size_t data_buffer_len = DEV_IPC_GET_ARG3(*call); 409 size_t max_packet_size = DEV_IPC_GET_ARG4(*call); 547 410 548 411 int rc; … … 580 443 trans->size = data_buffer_len; 581 444 582 rc = usb_iface->control_write(device, target, HACK_MAX_PACKET_SIZE,445 rc = usb_iface->control_write(device, target, max_packet_size, 583 446 setup_packet, setup_packet_len, 584 447 data_buffer, data_buffer_len, … … 607 470 .endpoint = DEV_IPC_GET_ARG2(*call) 608 471 }; 472 size_t max_packet_size = DEV_IPC_GET_ARG3(*call); 609 473 610 474 int rc; … … 644 508 } 645 509 646 rc = usb_iface->control_read(device, target, HACK_MAX_PACKET_SIZE,510 rc = usb_iface->control_read(device, target, max_packet_size, 647 511 setup_packet, setup_packet_len, 648 512 trans->buffer, trans->size, -
uspace/lib/drv/include/usbhc_iface.h
r7e7f0f5 r6edc69a 40 40 #include "driver.h" 41 41 #include <usb/usb.h> 42 #include <bool.h> 42 43 43 44 … … 52 53 * - argument #1 is target address 53 54 * - argument #2 is target endpoint 54 * - argument #3 is buffer size55 * - argument #3 is max packet size of the endpoint 55 56 * - this call is immediately followed by IPC data write (from caller) 56 57 * - the initial call (and the whole transaction) is answer after the … … 65 66 * - argument #1 is target address 66 67 * - argument #2 is target endpoint 67 * - argument #3 is buffer size68 * - argument #3 is max packet size of the endpoint 68 69 * - this call is immediately followed by IPC data read (async version) 69 70 * - the call is not answered until the device returns some data (or until … … 152 153 IPC_M_USBHC_INTERRUPT_IN, 153 154 154 155 /** Start WRITE control transfer.156 * See explanation at usb_iface_funcs_t (OUT transaction).157 */158 IPC_M_USBHC_CONTROL_WRITE_SETUP,159 160 /** Send control-transfer data to device.161 * See explanation at usb_iface_funcs_t (OUT transaction).162 */163 IPC_M_USBHC_CONTROL_WRITE_DATA,164 165 /** Terminate WRITE control transfer.166 * See explanation at usb_iface_funcs_t (NO-DATA transaction).167 */168 IPC_M_USBHC_CONTROL_WRITE_STATUS,169 170 171 172 /** Start READ control transfer.173 * See explanation at usb_iface_funcs_t (OUT transaction).174 */175 IPC_M_USBHC_CONTROL_READ_SETUP,176 177 /** Get control-transfer data from device.178 * See explanation at usb_iface_funcs_t (IN transaction).179 */180 IPC_M_USBHC_CONTROL_READ_DATA,181 182 /** Terminate READ control transfer.183 * See explanation at usb_iface_funcs_t (NO-DATA transaction).184 */185 IPC_M_USBHC_CONTROL_READ_STATUS,186 187 155 /** Issue control WRITE transfer. 188 156 * See explanation at usb_iface_funcs_t (OUT transaction) for … … 193 161 IPC_M_USBHC_CONTROL_WRITE, 194 162 195 /** Issue control WRITEtransfer.163 /** Issue control READ transfer. 196 164 * See explanation at usb_iface_funcs_t (IN transaction) for 197 165 * call parameters. 198 * This call is immediately followed by IPC data read from the caller 199 * (setup packet). 200 * Actual data are retrieved through IPC_M_USBHC_GET_BUFFER. 166 * This call is immediately followed by IPC data write from the caller 167 * (setup packet) and IPC data read (buffer that was read). 201 168 */ 202 169 IPC_M_USBHC_CONTROL_READ, … … 231 198 int (*tell_address)(device_t *, devman_handle_t, usb_address_t *); 232 199 233 int (*reserve_default_address)(device_t * );200 int (*reserve_default_address)(device_t *, usb_speed_t); 234 201 int (*release_default_address)(device_t *); 235 int (*request_address)(device_t *, usb_ address_t *);202 int (*request_address)(device_t *, usb_speed_t, usb_address_t *); 236 203 int (*bind_address)(device_t *, usb_address_t, devman_handle_t); 237 204 int (*release_address)(device_t *, usb_address_t); … … 239 206 usbhc_iface_transfer_out_t interrupt_out; 240 207 usbhc_iface_transfer_in_t interrupt_in; 241 242 usbhc_iface_transfer_setup_t control_write_setup;243 usbhc_iface_transfer_out_t control_write_data;244 int (*control_write_status)(device_t *, usb_target_t,245 usbhc_iface_transfer_in_callback_t, void *);246 247 usbhc_iface_transfer_setup_t control_read_setup;248 usbhc_iface_transfer_in_t control_read_data;249 int (*control_read_status)(device_t *, usb_target_t,250 usbhc_iface_transfer_out_callback_t, void *);251 208 252 209 int (*control_write)(device_t *, usb_target_t, -
uspace/lib/usb/include/usb/hub.h
r7e7f0f5 r6edc69a 39 39 #include <usb/usbdevice.h> 40 40 41 int usb_hc_new_device_wrapper(device_t *, usb_hc_connection_t *, usb_speed_t, 42 int (*)(int, void *), int, void *, usb_address_t *, devman_handle_t *); 43 41 44 /** Info about device attached to host controller. 42 45 * … … 52 55 } usb_hc_attached_device_t; 53 56 54 int usb_hc_reserve_default_address(usb_hc_connection_t * );57 int usb_hc_reserve_default_address(usb_hc_connection_t *, usb_speed_t); 55 58 int usb_hc_release_default_address(usb_hc_connection_t *); 56 59 57 usb_address_t usb_hc_request_address(usb_hc_connection_t * );60 usb_address_t usb_hc_request_address(usb_hc_connection_t *, usb_speed_t); 58 61 int usb_hc_register_device(usb_hc_connection_t *, 59 62 const usb_hc_attached_device_t *); -
uspace/lib/usb/include/usb/usb.h
r7e7f0f5 r6edc69a 68 68 USB_DIRECTION_BOTH 69 69 } usb_direction_t; 70 71 /** USB speeds. */ 72 typedef enum { 73 /** USB 1.1 low speed (1.5Mbits/s). */ 74 USB_SPEED_LOW, 75 /** USB 1.1 full speed (12Mbits/s). */ 76 USB_SPEED_FULL, 77 /** USB 2.0 high speed (480Mbits/s). */ 78 USB_SPEED_HIGH 79 } usb_speed_t; 70 80 71 81 /** USB request type target. */ -
uspace/lib/usb/src/hub.c
r7e7f0f5 r6edc69a 34 34 */ 35 35 #include <usb/hub.h> 36 #include <usb/pipes.h> 37 #include <usb/request.h> 38 #include <usb/recognise.h> 36 39 #include <usbhc_iface.h> 37 40 #include <errno.h> … … 55 58 * @return Error code. 56 59 */ 57 int usb_hc_reserve_default_address(usb_hc_connection_t *connection) 60 int usb_hc_reserve_default_address(usb_hc_connection_t *connection, 61 usb_speed_t speed) 62 { 63 CHECK_CONNECTION(connection); 64 65 return async_req_2_0(connection->hc_phone, 66 DEV_IFACE_ID(USBHC_DEV_IFACE), 67 IPC_M_USBHC_RESERVE_DEFAULT_ADDRESS, speed); 68 } 69 70 /** Tell host controller to release default address. 71 * 72 * @param connection Opened connection to host controller. 73 * @return Error code. 74 */ 75 int usb_hc_release_default_address(usb_hc_connection_t *connection) 58 76 { 59 77 CHECK_CONNECTION(connection); … … 61 79 return async_req_1_0(connection->hc_phone, 62 80 DEV_IFACE_ID(USBHC_DEV_IFACE), 63 IPC_M_USBHC_RESERVE_DEFAULT_ADDRESS);64 }65 66 /** Tell host controller to release default address.67 *68 * @param connection Opened connection to host controller.69 * @return Error code.70 */71 int usb_hc_release_default_address(usb_hc_connection_t *connection)72 {73 CHECK_CONNECTION(connection);74 75 return async_req_1_0(connection->hc_phone,76 DEV_IFACE_ID(USBHC_DEV_IFACE),77 81 IPC_M_USBHC_RELEASE_DEFAULT_ADDRESS); 78 82 } … … 83 87 * @return Assigned USB address or negative error code. 84 88 */ 85 usb_address_t usb_hc_request_address(usb_hc_connection_t *connection) 89 usb_address_t usb_hc_request_address(usb_hc_connection_t *connection, 90 usb_speed_t speed) 86 91 { 87 92 CHECK_CONNECTION(connection); 88 93 89 94 sysarg_t address; 90 int rc = async_req_1_1(connection->hc_phone, 91 DEV_IFACE_ID(USBHC_DEV_IFACE), 92 IPC_M_USBHC_REQUEST_ADDRESS, &address); 95 int rc = async_req_2_1(connection->hc_phone, 96 DEV_IFACE_ID(USBHC_DEV_IFACE), 97 IPC_M_USBHC_REQUEST_ADDRESS, speed, 98 &address); 93 99 if (rc != EOK) { 94 100 return (usb_address_t) rc; … … 135 141 136 142 143 /** Wrapper for registering attached device to the hub. 144 * 145 * The @p enable_port function is expected to enable singalling on given 146 * port. 147 * The two arguments to it can have arbitrary meaning 148 * (the @p port_no is only a suggestion) 149 * and are not touched at all by this function 150 * (they are passed as is to the @p enable_port function). 151 * 152 * If the @p enable_port fails (i.e. does not return EOK), the device 153 * addition is cancelled. 154 * The return value is then returned (it is good idea to use different 155 * error codes than those listed as return codes by this function itself). 156 * 157 * @param parent Parent device (i.e. the hub device). 158 * @param connection Opened connection to host controller. 159 * @param dev_speed New device speed. 160 * @param enable_port Function for enabling signalling through the port the 161 * device is attached to. 162 * @param port_no Port number (passed through to @p enable_port). 163 * @param arg Any data argument to @p enable_port. 164 * @param[out] assigned_address USB address of the device. 165 * @param[out] assigned_handle Devman handle of the new device. 166 * @return Error code. 167 * @retval ENOENT Connection to HC not opened. 168 * @retval EADDRNOTAVAIL Failed retrieving free address from host controller. 169 * @retval EBUSY Failed reserving default USB address. 170 * @retval ENOTCONN Problem connecting to the host controller via USB pipe. 171 * @retval ESTALL Problem communication with device (either SET_ADDRESS 172 * request or requests for descriptors when creating match ids). 173 */ 174 int usb_hc_new_device_wrapper(device_t *parent, usb_hc_connection_t *connection, 175 usb_speed_t dev_speed, 176 int (*enable_port)(int port_no, void *arg), int port_no, void *arg, 177 usb_address_t *assigned_address, devman_handle_t *assigned_handle) 178 { 179 CHECK_CONNECTION(connection); 180 181 /* 182 * Request new address. 183 */ 184 usb_address_t dev_addr = usb_hc_request_address(connection, dev_speed); 185 if (dev_addr < 0) { 186 return EADDRNOTAVAIL; 187 } 188 189 int rc; 190 191 /* 192 * Reserve the default address. 193 */ 194 rc = usb_hc_reserve_default_address(connection, dev_speed); 195 if (rc != EOK) { 196 rc = EBUSY; 197 goto leave_release_free_address; 198 } 199 200 /* 201 * Enable the port (i.e. allow signalling through this port). 202 */ 203 rc = enable_port(port_no, arg); 204 if (rc != EOK) { 205 goto leave_release_default_address; 206 } 207 208 /* 209 * Change the address from default to the free one. 210 * We need to create a new control pipe for that. 211 */ 212 usb_device_connection_t dev_conn; 213 rc = usb_device_connection_initialize_on_default_address(&dev_conn, 214 connection); 215 if (rc != EOK) { 216 rc = ENOTCONN; 217 goto leave_release_default_address; 218 } 219 220 usb_endpoint_pipe_t ctrl_pipe; 221 rc = usb_endpoint_pipe_initialize_default_control(&ctrl_pipe, 222 &dev_conn); 223 if (rc != EOK) { 224 rc = ENOTCONN; 225 goto leave_release_default_address; 226 } 227 228 rc = usb_endpoint_pipe_start_session(&ctrl_pipe); 229 if (rc != EOK) { 230 rc = ENOTCONN; 231 goto leave_release_default_address; 232 } 233 234 rc = usb_request_set_address(&ctrl_pipe, dev_addr); 235 if (rc != EOK) { 236 rc = ESTALL; 237 goto leave_stop_session; 238 } 239 240 usb_endpoint_pipe_end_session(&ctrl_pipe); 241 242 /* 243 * Once the address is changed, we can return the default address. 244 */ 245 usb_hc_release_default_address(connection); 246 247 /* 248 * It is time to register the device with devman. 249 */ 250 /* FIXME: create device_register that will get opened ctrl pipe. */ 251 devman_handle_t child_handle; 252 rc = usb_device_register_child_in_devman(dev_addr, dev_conn.hc_handle, 253 parent, &child_handle); 254 if (rc != EOK) { 255 rc = ESTALL; 256 goto leave_release_free_address; 257 } 258 259 /* 260 * And now inform the host controller about the handle. 261 */ 262 usb_hc_attached_device_t new_device = { 263 .address = dev_addr, 264 .handle = child_handle 265 }; 266 rc = usb_hc_register_device(connection, &new_device); 267 if (rc != EOK) { 268 rc = EDESTADDRREQ; 269 goto leave_release_free_address; 270 } 271 272 /* 273 * And we are done. 274 */ 275 if (assigned_address != NULL) { 276 *assigned_address = dev_addr; 277 } 278 if (assigned_handle != NULL) { 279 *assigned_handle = child_handle; 280 } 281 282 return EOK; 283 284 285 286 /* 287 * Error handling (like nested exceptions) starts here. 288 * Completely ignoring errors here. 289 */ 290 291 leave_stop_session: 292 usb_endpoint_pipe_end_session(&ctrl_pipe); 293 294 leave_release_default_address: 295 usb_hc_release_default_address(connection); 296 297 leave_release_free_address: 298 usb_hc_unregister_device(connection, dev_addr); 299 300 return rc; 301 } 302 303 137 304 /** 138 305 * @} -
uspace/lib/usb/src/pipes.c
r7e7f0f5 r6edc69a 35 35 #include <usb/usb.h> 36 36 #include <usb/pipes.h> 37 #include <usbhc_iface.h> 37 38 #include <errno.h> 38 39 #include <assert.h> 39 #include <usb/usbdrv.h> 40 41 /** Tell USB address assigned to given device. 42 * 43 * @param phone Phone to my HC. 44 * @param dev Device in question. 45 * @return USB address or error code. 46 */ 47 static usb_address_t get_my_address(int phone, device_t *dev) 48 { 49 sysarg_t address; 50 int rc = async_req_2_1(phone, DEV_IFACE_ID(USBHC_DEV_IFACE), 51 IPC_M_USBHC_GET_ADDRESS, 52 dev->handle, &address); 53 54 if (rc != EOK) { 55 return rc; 56 } 57 58 return (usb_address_t) address; 59 } 40 60 41 61 /** Initialize connection to USB device. … … 55 75 usb_address_t my_address; 56 76 57 rc = usb_ drv_find_hc(device, &hc_handle);77 rc = usb_hc_find(device->handle, &hc_handle); 58 78 if (rc != EOK) { 59 79 return rc; … … 65 85 } 66 86 67 my_address = usb_drv_get_my_address(hc_phone, device);87 my_address = get_my_address(hc_phone, device); 68 88 if (my_address < 0) { 69 89 rc = my_address; -
uspace/lib/usb/src/pipesio.c
r7e7f0f5 r6edc69a 78 78 * Make call identifying target USB device and type of transfer. 79 79 */ 80 aid_t opening_request = async_send_ 3(pipe->hc_phone,80 aid_t opening_request = async_send_4(pipe->hc_phone, 81 81 DEV_IFACE_ID(USBHC_DEV_IFACE), ipc_method, 82 82 pipe->wire->address, pipe->endpoint_no, 83 pipe->max_packet_size, 83 84 NULL); 84 85 if (opening_request == 0) { … … 201 202 * Make call identifying target USB device and type of transfer. 202 203 */ 203 aid_t opening_request = async_send_ 3(pipe->hc_phone,204 aid_t opening_request = async_send_4(pipe->hc_phone, 204 205 DEV_IFACE_ID(USBHC_DEV_IFACE), ipc_method, 205 206 pipe->wire->address, pipe->endpoint_no, 207 pipe->max_packet_size, 206 208 NULL); 207 209 if (opening_request == 0) { … … 283 285 * Make call identifying target USB device and control transfer type. 284 286 */ 285 aid_t opening_request = async_send_ 3(pipe->hc_phone,287 aid_t opening_request = async_send_4(pipe->hc_phone, 286 288 DEV_IFACE_ID(USBHC_DEV_IFACE), IPC_M_USBHC_CONTROL_READ, 287 289 pipe->wire->address, pipe->endpoint_no, 290 pipe->max_packet_size, 288 291 NULL); 289 292 if (opening_request == 0) { … … 402 405 * Make call identifying target USB device and control transfer type. 403 406 */ 404 aid_t opening_request = async_send_ 4(pipe->hc_phone,407 aid_t opening_request = async_send_5(pipe->hc_phone, 405 408 DEV_IFACE_ID(USBHC_DEV_IFACE), IPC_M_USBHC_CONTROL_WRITE, 406 409 pipe->wire->address, pipe->endpoint_no, 407 410 data_buffer_size, 411 pipe->max_packet_size, 408 412 NULL); 409 413 if (opening_request == 0) { -
uspace/lib/usb/src/usbdrv.c
r7e7f0f5 r6edc69a 34 34 */ 35 35 #include <usb/usbdrv.h> 36 #include <usbhc_iface.h>37 #include <usb_iface.h>38 36 #include <errno.h> 39 #include <str_error.h> 40 41 /** Information about pending transaction on HC. */ 42 typedef struct { 43 /** Phone to host controller driver. */ 44 int phone; 45 /** Data buffer. */ 46 void *buffer; 47 /** Buffer size. */ 48 size_t size; 49 /** Storage for actual number of bytes transferred. */ 50 size_t *size_transferred; 51 /** Initial call reply data. */ 52 ipc_call_t reply; 53 /** Initial call identifier. */ 54 aid_t request; 55 /** Reply data for data read call. */ 56 ipc_call_t read_reply; 57 /** Data read call identifier. */ 58 aid_t read_request; 59 } transfer_info_t; 37 60 38 61 39 /** Find handle of host controller the device is physically attached to. … … 67 45 int usb_drv_find_hc(device_t *dev, devman_handle_t *handle) 68 46 { 69 if (dev == NULL) { 70 return EBADMEM; 71 } 72 if (handle == NULL) { 73 return EBADMEM; 74 } 75 76 int parent_phone = devman_parent_device_connect(dev->handle, 77 IPC_FLAG_BLOCKING); 78 if (parent_phone < 0) { 79 return parent_phone; 80 } 81 82 devman_handle_t h; 83 int rc = async_req_1_1(parent_phone, DEV_IFACE_ID(USB_DEV_IFACE), 84 IPC_M_USB_GET_HOST_CONTROLLER_HANDLE, &h); 85 86 async_hangup(parent_phone); 87 88 if (rc != EOK) { 89 return rc; 90 } 91 92 *handle = h; 93 94 return EOK; 47 return ENOTSUP; 95 48 } 96 49 … … 105 58 unsigned int flags) 106 59 { 107 return devman_device_connect(hc_handle, flags);60 return ENOTSUP; 108 61 } 109 62 … … 116 69 int usb_drv_hc_connect_auto(device_t *dev, unsigned int flags) 117 70 { 118 int rc; 119 devman_handle_t hc_handle; 120 121 /* 122 * Call parent hub to obtain device handle of respective HC. 123 */ 124 rc = usb_drv_find_hc(dev, &hc_handle); 125 if (rc != EOK) { 126 return rc; 127 } 128 129 return usb_drv_hc_connect(dev, hc_handle, flags); 71 return ENOTSUP; 130 72 } 131 73 … … 138 80 usb_address_t usb_drv_get_my_address(int phone, device_t *dev) 139 81 { 140 sysarg_t address; 141 int rc = async_req_2_1(phone, DEV_IFACE_ID(USBHC_DEV_IFACE), 142 IPC_M_USBHC_GET_ADDRESS, 143 dev->handle, &address); 144 145 if (rc != EOK) { 146 return rc; 147 } 148 149 return (usb_address_t) address; 82 return ENOTSUP; 150 83 } 151 84 … … 157 90 int usb_drv_reserve_default_address(int phone) 158 91 { 159 return async_req_1_0(phone, DEV_IFACE_ID(USBHC_DEV_IFACE), 160 IPC_M_USBHC_RESERVE_DEFAULT_ADDRESS); 92 return ENOTSUP; 161 93 } 162 94 … … 168 100 int usb_drv_release_default_address(int phone) 169 101 { 170 return async_req_1_0(phone, DEV_IFACE_ID(USBHC_DEV_IFACE), 171 IPC_M_USBHC_RELEASE_DEFAULT_ADDRESS); 102 return ENOTSUP; 172 103 } 173 104 … … 179 110 usb_address_t usb_drv_request_address(int phone) 180 111 { 181 sysarg_t address; 182 int rc = async_req_1_1(phone, DEV_IFACE_ID(USBHC_DEV_IFACE), 183 IPC_M_USBHC_REQUEST_ADDRESS, &address); 184 if (rc != EOK) { 185 return rc; 186 } else { 187 return (usb_address_t) address; 188 } 112 return ENOTSUP; 189 113 } 190 114 … … 199 123 devman_handle_t handle) 200 124 { 201 int rc = async_req_3_0(phone, DEV_IFACE_ID(USBHC_DEV_IFACE), 202 IPC_M_USBHC_BIND_ADDRESS, 203 address, handle); 204 205 return rc; 125 return ENOTSUP; 206 126 } 207 127 … … 214 134 int usb_drv_release_address(int phone, usb_address_t address) 215 135 { 216 return async_req_2_0(phone, DEV_IFACE_ID(USBHC_DEV_IFACE), 217 IPC_M_USBHC_RELEASE_ADDRESS, address); 218 } 219 220 /** Send data to HCD. 221 * 222 * @param phone Phone to HC. 223 * @param method Method used for calling. 224 * @param target Targeted device. 225 * @param buffer Data buffer (NULL to skip data transfer phase). 226 * @param size Buffer size (must be zero when @p buffer is NULL). 227 * @param handle Storage for transaction handle (cannot be NULL). 228 * @return Error status. 229 * @retval EINVAL Invalid parameter. 230 * @retval ENOMEM Not enough memory to complete the operation. 231 */ 232 static int async_send_buffer(int phone, int method, 233 usb_target_t target, 234 void *buffer, size_t size, 235 usb_handle_t *handle) 236 { 237 if (phone < 0) { 238 return EINVAL; 239 } 240 241 if ((buffer == NULL) && (size > 0)) { 242 return EINVAL; 243 } 244 245 if (handle == NULL) { 246 return EINVAL; 247 } 248 249 transfer_info_t *transfer 250 = (transfer_info_t *) malloc(sizeof(transfer_info_t)); 251 if (transfer == NULL) { 252 return ENOMEM; 253 } 254 255 transfer->read_request = 0; 256 transfer->size_transferred = NULL; 257 transfer->buffer = NULL; 258 transfer->size = 0; 259 transfer->phone = phone; 260 261 int rc; 262 263 transfer->request = async_send_4(phone, 264 DEV_IFACE_ID(USBHC_DEV_IFACE), 265 method, 266 target.address, target.endpoint, 267 size, 268 &transfer->reply); 269 270 if (size > 0) { 271 rc = async_data_write_start(phone, buffer, size); 272 if (rc != EOK) { 273 async_wait_for(transfer->request, NULL); 274 return rc; 275 } 276 } 277 278 *handle = (usb_handle_t) transfer; 279 280 return EOK; 281 } 282 283 /** Prepare data retrieval. 284 * 285 * @param phone Opened phone to HCD. 286 * @param method Method used for calling. 287 * @param target Targeted device. 288 * @param buffer Buffer where to store retrieved data 289 * (NULL to skip data transfer phase). 290 * @param size Buffer size (must be zero when @p buffer is NULL). 291 * @param actual_size Storage where actual number of bytes transferred will 292 * be stored. 293 * @param handle Storage for transaction handle (cannot be NULL). 294 * @return Error status. 295 * @retval EINVAL Invalid parameter. 296 * @retval ENOMEM Not enough memory to complete the operation. 297 */ 298 static int async_recv_buffer(int phone, int method, 299 usb_target_t target, 300 void *buffer, size_t size, size_t *actual_size, 301 usb_handle_t *handle) 302 { 303 if (phone < 0) { 304 return EINVAL; 305 } 306 307 if ((buffer == NULL) && (size > 0)) { 308 return EINVAL; 309 } 310 311 if (handle == NULL) { 312 return EINVAL; 313 } 314 315 transfer_info_t *transfer 316 = (transfer_info_t *) malloc(sizeof(transfer_info_t)); 317 if (transfer == NULL) { 318 return ENOMEM; 319 } 320 321 transfer->read_request = 0; 322 transfer->size_transferred = actual_size; 323 transfer->buffer = buffer; 324 transfer->size = size; 325 transfer->phone = phone; 326 327 transfer->request = async_send_4(phone, 328 DEV_IFACE_ID(USBHC_DEV_IFACE), 329 method, 330 target.address, target.endpoint, 331 size, 332 &transfer->reply); 333 334 if (buffer != NULL) { 335 transfer->read_request = async_data_read(phone, buffer, size, 336 &transfer->read_reply); 337 } 338 339 *handle = (usb_handle_t) transfer; 340 341 return EOK; 342 } 343 136 return ENOTSUP; 137 } 344 138 345 139 /** Blocks caller until given USB transaction is finished. … … 355 149 int usb_drv_async_wait_for(usb_handle_t handle) 356 150 { 357 if (handle == 0) { 358 return EBADMEM; 359 } 360 361 int rc = EOK; 362 363 transfer_info_t *transfer = (transfer_info_t *) handle; 364 365 sysarg_t answer_rc; 366 367 /* 368 * If the buffer is not NULL, we must accept some data. 369 */ 370 if ((transfer->buffer != NULL) && (transfer->size > 0)) { 371 async_wait_for(transfer->read_request, &answer_rc); 372 373 if (answer_rc != EOK) { 374 rc = (int) answer_rc; 375 goto leave; 376 } 377 378 if (transfer->size_transferred != NULL) { 379 *(transfer->size_transferred) 380 = IPC_GET_ARG2(transfer->read_reply); 381 } 382 } 383 384 async_wait_for(transfer->request, &answer_rc); 385 386 if (answer_rc != EOK) { 387 rc = (int) answer_rc; 388 goto leave; 389 } 390 391 leave: 392 free(transfer); 393 394 return rc; 151 return ENOTSUP; 395 152 } 396 153 … … 400 157 usb_handle_t *handle) 401 158 { 402 return async_send_buffer(phone, 403 IPC_M_USBHC_INTERRUPT_OUT, 404 target, 405 buffer, size, 406 handle); 159 return ENOTSUP; 407 160 } 408 161 … … 412 165 usb_handle_t *handle) 413 166 { 414 return async_recv_buffer(phone, 415 IPC_M_USBHC_INTERRUPT_IN, 416 target, 417 buffer, size, actual_size, 418 handle); 167 return ENOTSUP; 419 168 } 420 169 … … 424 173 usb_handle_t *handle) 425 174 { 426 return async_send_buffer(phone, 427 IPC_M_USBHC_CONTROL_WRITE_SETUP, 428 target, 429 buffer, size, 430 handle); 175 return ENOTSUP; 431 176 } 432 177 … … 436 181 usb_handle_t *handle) 437 182 { 438 return async_send_buffer(phone, 439 IPC_M_USBHC_CONTROL_WRITE_DATA, 440 target, 441 buffer, size, 442 handle); 183 return ENOTSUP; 443 184 } 444 185 … … 447 188 usb_handle_t *handle) 448 189 { 449 return async_recv_buffer(phone, 450 IPC_M_USBHC_CONTROL_WRITE_STATUS, 451 target, 452 NULL, 0, NULL, 453 handle); 190 return ENOTSUP; 454 191 } 455 192 … … 460 197 usb_handle_t *handle) 461 198 { 462 // FIXME - check input parameters instead of asserting them 463 assert(phone > 0); 464 assert(setup_packet != NULL); 465 assert(setup_packet_size > 0); 466 assert(((buffer != NULL) && (buffer_size > 0)) 467 || ((buffer == NULL) && (buffer_size == 0))); 468 assert(handle != NULL); 469 470 transfer_info_t *transfer 471 = (transfer_info_t *) malloc(sizeof(transfer_info_t)); 472 if (transfer == NULL) { 473 return ENOMEM; 474 } 475 476 transfer->read_request = 0; 477 transfer->size_transferred = NULL; 478 transfer->buffer = NULL; 479 transfer->size = 0; 480 transfer->phone = phone; 481 482 int rc; 483 484 transfer->request = async_send_3(phone, 485 DEV_IFACE_ID(USBHC_DEV_IFACE), 486 IPC_M_USBHC_CONTROL_WRITE, 487 target.address, target.endpoint, 488 &transfer->reply); 489 490 rc = async_data_write_start(phone, setup_packet, setup_packet_size); 491 if (rc != EOK) { 492 async_wait_for(transfer->request, NULL); 493 return rc; 494 } 495 496 if (buffer_size > 0) { 497 rc = async_data_write_start(phone, buffer, buffer_size); 498 if (rc != EOK) { 499 async_wait_for(transfer->request, NULL); 500 return rc; 501 } 502 } 503 504 *handle = (usb_handle_t) transfer; 505 506 return EOK; 199 return ENOTSUP; 507 200 } 508 201 … … 512 205 usb_handle_t *handle) 513 206 { 514 return async_send_buffer(phone, 515 IPC_M_USBHC_CONTROL_READ_SETUP, 516 target, 517 buffer, size, 518 handle); 207 return ENOTSUP; 519 208 } 520 209 … … 524 213 usb_handle_t *handle) 525 214 { 526 return async_recv_buffer(phone, 527 IPC_M_USBHC_CONTROL_READ_DATA, 528 target, 529 buffer, size, actual_size, 530 handle); 215 return ENOTSUP; 531 216 } 532 217 … … 535 220 usb_handle_t *handle) 536 221 { 537 return async_send_buffer(phone, 538 IPC_M_USBHC_CONTROL_READ_STATUS, 539 target, 540 NULL, 0, 541 handle); 222 return ENOTSUP; 542 223 } 543 224 … … 548 229 usb_handle_t *handle) 549 230 { 550 // FIXME - check input parameters instead of asserting them 551 assert(phone > 0); 552 assert(setup_packet != NULL); 553 assert(setup_packet_size > 0); 554 assert(buffer != NULL); 555 assert(buffer_size > 0); 556 assert(handle != NULL); 557 558 transfer_info_t *transfer 559 = (transfer_info_t *) malloc(sizeof(transfer_info_t)); 560 if (transfer == NULL) { 561 return ENOMEM; 562 } 563 564 transfer->size_transferred = actual_size; 565 transfer->buffer = buffer; 566 transfer->size = buffer_size; 567 transfer->phone = phone; 568 569 int rc; 570 571 transfer->request = async_send_4(phone, 572 DEV_IFACE_ID(USBHC_DEV_IFACE), 573 IPC_M_USBHC_CONTROL_READ, 574 target.address, target.endpoint, 575 buffer_size, 576 &transfer->reply); 577 578 rc = async_data_write_start(phone, setup_packet, setup_packet_size); 579 if (rc != EOK) { 580 async_wait_for(transfer->request, NULL); 581 return rc; 582 } 583 584 transfer->read_request = async_data_read(phone, buffer, buffer_size, 585 &transfer->read_reply); 586 587 *handle = (usb_handle_t) transfer; 588 589 return EOK; 231 return ENOTSUP; 590 232 } 591 233
Note:
See TracChangeset
for help on using the changeset viewer.