Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • uspace/drv/uhci-hcd/batch.c

    r20a1e76 rc15070c  
    4040#include "batch.h"
    4141#include "transfer_list.h"
    42 #include "hw_struct/transfer_descriptor.h"
     42#include "uhci_hc.h"
    4343#include "utils/malloc32.h"
     44#include "uhci_struct/transfer_descriptor.h"
    4445
    4546#define DEFAULT_ERROR_COUNT 3
     
    4849        qh_t *qh;
    4950        td_t *tds;
    50         size_t transfers;
    51         usb_device_keeper_t *manager;
     51        size_t packets;
     52        device_keeper_t *manager;
    5253} uhci_batch_t;
    5354
    54 static void batch_control(usb_transfer_batch_t *instance,
     55static void batch_control(batch_t *instance,
    5556    usb_packet_id data_stage, usb_packet_id status_stage);
    56 static void batch_data(usb_transfer_batch_t *instance, usb_packet_id pid);
    57 static void batch_call_in_and_dispose(usb_transfer_batch_t *instance);
    58 static void batch_call_out_and_dispose(usb_transfer_batch_t *instance);
     57static void batch_data(batch_t *instance, usb_packet_id pid);
     58static void batch_call_in_and_dispose(batch_t *instance);
     59static void batch_call_out_and_dispose(batch_t *instance);
    5960
    6061
     
    6465 * @param[in] target Device and endpoint target of the transaction.
    6566 * @param[in] transfer_type Interrupt, Control or Bulk.
    66  * @param[in] max_packet_size maximum allowed size of data transfers.
     67 * @param[in] max_packet_size maximum allowed size of data packets.
    6768 * @param[in] speed Speed of the transaction.
    6869 * @param[in] buffer Data source/destination.
     
    7778 * NULL otherwise.
    7879 *
    79  * Determines the number of needed transfers (TDs). Prepares a transport buffer
     80 * Determines the number of needed packets (TDs). Prepares a transport buffer
    8081 * (that is accessible by the hardware). Initializes parameters needed for the
    8182 * transaction and callback.
    8283 */
    83 usb_transfer_batch_t * batch_get(ddf_fun_t *fun, usb_target_t target,
     84batch_t * batch_get(ddf_fun_t *fun, usb_target_t target,
    8485    usb_transfer_type_t transfer_type, size_t max_packet_size,
    8586    usb_speed_t speed, char *buffer, size_t buffer_size,
     
    8788    usbhc_iface_transfer_in_callback_t func_in,
    8889    usbhc_iface_transfer_out_callback_t func_out, void *arg,
    89     usb_device_keeper_t *manager
     90    device_keeper_t *manager
    9091    )
    9192{
     
    102103        } else (void)0
    103104
    104         usb_transfer_batch_t *instance = malloc(sizeof(usb_transfer_batch_t));
     105        batch_t *instance = malloc(sizeof(batch_t));
    105106        CHECK_NULL_DISPOSE_RETURN(instance,
    106107            "Failed to allocate batch instance.\n");
    107         usb_transfer_batch_init(instance, target, transfer_type, speed, max_packet_size,
     108        batch_init(instance, target, transfer_type, speed, max_packet_size,
    108109            buffer, NULL, buffer_size, NULL, setup_size, func_in,
    109110            func_out, arg, fun, NULL);
     
    117118        instance->private_data = data;
    118119
    119         data->transfers = (buffer_size + max_packet_size - 1) / max_packet_size;
     120        data->packets = (buffer_size + max_packet_size - 1) / max_packet_size;
    120121        if (transfer_type == USB_TRANSFER_CONTROL) {
    121                 data->transfers += 2;
    122         }
    123 
    124         data->tds = malloc32(sizeof(td_t) * data->transfers);
     122                data->packets += 2;
     123        }
     124
     125        data->tds = malloc32(sizeof(td_t) * data->packets);
    125126        CHECK_NULL_DISPOSE_RETURN(
    126127            data->tds, "Failed to allocate transfer descriptors.\n");
    127         bzero(data->tds, sizeof(td_t) * data->transfers);
     128        bzero(data->tds, sizeof(td_t) * data->packets);
    128129
    129130        data->qh = malloc32(sizeof(qh_t));
     
    160161 * is reached.
    161162 */
    162 bool batch_is_complete(usb_transfer_batch_t *instance)
     163bool batch_is_complete(batch_t *instance)
    163164{
    164165        assert(instance);
     
    166167        assert(data);
    167168
    168         usb_log_debug2("Batch(%p) checking %d transfer(s) for completion.\n",
    169             instance, data->transfers);
     169        usb_log_debug2("Batch(%p) checking %d packet(s) for completion.\n",
     170            instance, data->packets);
    170171        instance->transfered_size = 0;
    171172        size_t i = 0;
    172         for (;i < data->transfers; ++i) {
     173        for (;i < data->packets; ++i) {
    173174                if (td_is_active(&data->tds[i])) {
    174175                        return false;
     
    181182                        td_print_status(&data->tds[i]);
    182183
    183                         usb_device_keeper_set_toggle(data->manager,
     184                        device_keeper_set_toggle(data->manager,
    184185                            instance->target, instance->direction,
    185186                            td_toggle(&data->tds[i]));
     
    204205 * Uses genercir control function with pids OUT and IN.
    205206 */
    206 void batch_control_write(usb_transfer_batch_t *instance)
     207void batch_control_write(batch_t *instance)
    207208{
    208209        assert(instance);
     
    221222 * Uses generic control with pids IN and OUT.
    222223 */
    223 void batch_control_read(usb_transfer_batch_t *instance)
     224void batch_control_read(batch_t *instance)
    224225{
    225226        assert(instance);
     
    235236 * Data transaction with PID_IN.
    236237 */
    237 void batch_interrupt_in(usb_transfer_batch_t *instance)
     238void batch_interrupt_in(batch_t *instance)
    238239{
    239240        assert(instance);
     
    250251 * Data transaction with PID_OUT.
    251252 */
    252 void batch_interrupt_out(usb_transfer_batch_t *instance)
     253void batch_interrupt_out(batch_t *instance)
    253254{
    254255        assert(instance);
     
    268269 * Data transaction with PID_IN.
    269270 */
    270 void batch_bulk_in(usb_transfer_batch_t *instance)
     271void batch_bulk_in(batch_t *instance)
    271272{
    272273        assert(instance);
     
    283284 * Data transaction with PID_OUT.
    284285 */
    285 void batch_bulk_out(usb_transfer_batch_t *instance)
     286void batch_bulk_out(batch_t *instance)
    286287{
    287288        assert(instance);
     
    298299 *
    299300 * @param[in] instance Batch structure to use.
    300  * @param[in] pid Pid to use for data transfers.
     301 * @param[in] pid to use for data packets.
    301302 *
    302303 * Packets with alternating toggle bit and supplied pid value.
    303  * The last transfer is marked with IOC flag.
    304  */
    305 void batch_data(usb_transfer_batch_t *instance, usb_packet_id pid)
     304 * The last packet is marked with IOC flag.
     305 */
     306void batch_data(batch_t *instance, usb_packet_id pid)
    306307{
    307308        assert(instance);
     
    310311
    311312        const bool low_speed = instance->speed == USB_SPEED_LOW;
    312         int toggle = usb_device_keeper_get_toggle(
     313        int toggle = device_keeper_get_toggle(
    313314            data->manager, instance->target, instance->direction);
    314315        assert(toggle == 0 || toggle == 1);
    315316
    316         size_t transfer = 0;
     317        size_t packet = 0;
    317318        size_t remain_size = instance->buffer_size;
    318319        while (remain_size > 0) {
     
    325326                    remain_size : instance->max_packet_size;
    326327
    327                 td_t *next_transfer = (transfer + 1 < data->transfers)
    328                     ? &data->tds[transfer + 1] : NULL;
    329 
    330                 assert(transfer < data->transfers);
     328                td_t *next_packet = (packet + 1 < data->packets)
     329                    ? &data->tds[packet + 1] : NULL;
     330
     331                assert(packet < data->packets);
    331332                assert(packet_size <= remain_size);
    332333
    333334                td_init(
    334                     &data->tds[transfer], DEFAULT_ERROR_COUNT, packet_size,
     335                    &data->tds[packet], DEFAULT_ERROR_COUNT, packet_size,
    335336                    toggle, false, low_speed, instance->target, pid, trans_data,
    336                     next_transfer);
     337                    next_packet);
    337338
    338339
    339340                toggle = 1 - toggle;
    340341                remain_size -= packet_size;
    341                 ++transfer;
    342         }
    343         td_set_ioc(&data->tds[transfer - 1]);
    344         usb_device_keeper_set_toggle(data->manager, instance->target,
     342                ++packet;
     343        }
     344        td_set_ioc(&data->tds[packet - 1]);
     345        device_keeper_set_toggle(data->manager, instance->target,
    345346            instance->direction, toggle);
    346347}
     
    349350 *
    350351 * @param[in] instance Batch structure to use.
    351  * @param[in] data_stage Pid to use for data transfers.
    352  * @param[in] status_stage Pid to use for data transfers.
     352 * @param[in] data_stage to use for data packets.
     353 * @param[in] status_stage to use for data packets.
    353354 *
    354355 * Setup stage with toggle 0 and USB_PID_SETUP.
    355356 * Data stage with alternating toggle and pid supplied by parameter.
    356357 * Status stage with toggle 1 and pid supplied by parameter.
    357  * The last transfer is marked with IOC.
    358  */
    359 void batch_control(usb_transfer_batch_t *instance,
     358 * The last packet is marked with IOC.
     359 */
     360void batch_control(batch_t *instance,
    360361   usb_packet_id data_stage, usb_packet_id status_stage)
    361362{
     
    363364        uhci_batch_t *data = instance->private_data;
    364365        assert(data);
    365         assert(data->transfers >= 2);
     366        assert(data->packets >= 2);
    366367
    367368        const bool low_speed = instance->speed == USB_SPEED_LOW;
     
    374375
    375376        /* data stage */
    376         size_t transfer = 1;
     377        size_t packet = 1;
    377378        size_t remain_size = instance->buffer_size;
    378379        while (remain_size > 0) {
     
    388389
    389390                td_init(
    390                     &data->tds[transfer], DEFAULT_ERROR_COUNT, packet_size,
     391                    &data->tds[packet], DEFAULT_ERROR_COUNT, packet_size,
    391392                    toggle, false, low_speed, instance->target, data_stage,
    392                     control_data, &data->tds[transfer + 1]);
    393 
    394                 ++transfer;
    395                 assert(transfer < data->transfers);
     393                    control_data, &data->tds[packet + 1]);
     394
     395                ++packet;
     396                assert(packet < data->packets);
    396397                assert(packet_size <= remain_size);
    397398                remain_size -= packet_size;
     
    399400
    400401        /* status stage */
    401         assert(transfer == data->transfers - 1);
     402        assert(packet == data->packets - 1);
    402403
    403404        td_init(
    404             &data->tds[transfer], DEFAULT_ERROR_COUNT, 0, 1, false, low_speed,
     405            &data->tds[packet], DEFAULT_ERROR_COUNT, 0, 1, false, low_speed,
    405406            instance->target, status_stage, NULL, NULL);
    406         td_set_ioc(&data->tds[transfer]);
     407        td_set_ioc(&data->tds[packet]);
    407408
    408409        usb_log_debug2("Control last TD status: %x.\n",
    409             data->tds[transfer].status);
    410 }
    411 /*----------------------------------------------------------------------------*/
    412 qh_t * batch_qh(usb_transfer_batch_t *instance)
     410            data->tds[packet].status);
     411}
     412/*----------------------------------------------------------------------------*/
     413qh_t * batch_qh(batch_t *instance)
    413414{
    414415        assert(instance);
     
    422423 * @param[in] instance Batch structure to use.
    423424 */
    424 void batch_call_in_and_dispose(usb_transfer_batch_t *instance)
    425 {
    426         assert(instance);
    427         usb_transfer_batch_call_in(instance);
     425void batch_call_in_and_dispose(batch_t *instance)
     426{
     427        assert(instance);
     428        batch_call_in(instance);
    428429        batch_dispose(instance);
    429430}
     
    433434 * @param[in] instance Batch structure to use.
    434435 */
    435 void batch_call_out_and_dispose(usb_transfer_batch_t *instance)
    436 {
    437         assert(instance);
    438         usb_transfer_batch_call_out(instance);
     436void batch_call_out_and_dispose(batch_t *instance)
     437{
     438        assert(instance);
     439        batch_call_out(instance);
    439440        batch_dispose(instance);
    440441}
     
    444445 * @param[in] instance Batch structure to use.
    445446 */
    446 void batch_dispose(usb_transfer_batch_t *instance)
     447void batch_dispose(batch_t *instance)
    447448{
    448449        assert(instance);
Note: See TracChangeset for help on using the changeset viewer.