Lines Matching defs:bulk
1169 /* Called by the slot handler - don't hold the bulk mutex */
1184 VCHIQ_BULK_T *bulk =
1186 int msgtype = (bulk->dir == VCHIQ_BULK_TRANSMIT) ?
1190 VCHIQ_ELEMENT_T element = { &bulk->actual, 4 };
1191 /* Only reply to non-dummy bulk requests */
1192 if (bulk->remote_data) {
1206 VCHIQ_BULK_T *bulk =
1209 /* Only generate callbacks for non-dummy bulk
1211 if (bulk->data && service->instance) {
1212 if (bulk->actual != VCHIQ_BULK_ACTUAL_ABORTED) {
1213 if (bulk->dir == VCHIQ_BULK_TRANSMIT) {
1218 bulk->actual);
1224 bulk->actual);
1230 if (bulk->mode == VCHIQ_BULK_MODE_BLOCKING) {
1233 waiter = bulk->userdata;
1235 waiter->actual = bulk->actual;
1239 } else if (bulk->mode ==
1241 VCHIQ_REASON_T reason = (bulk->dir ==
1243 ((bulk->actual ==
1247 ((bulk->actual ==
1252 reason, NULL, bulk->userdata);
1337 /* Called by the slot handler or application threads, holding the bulk mutex. */
1347 VCHIQ_BULK_T *bulk = &queue->bulks[BULK_INDEX(queue->process)];
1363 vchiq_transfer_bulk(bulk);
1369 if (bulk->actual != VCHIQ_BULK_ACTUAL_ABORTED)
1376 bulk->size,
1377 (unsigned int)bulk->data,
1378 (unsigned int)bulk->remote_data);
1387 bulk->size,
1388 bulk->remote_size,
1389 (unsigned int)bulk->data,
1390 (unsigned int)bulk->remote_data);
1393 vchiq_complete_bulk(bulk);
1415 VCHIQ_BULK_T *bulk = &queue->bulks[BULK_INDEX(queue->process)];
1418 /* fabricate a matching dummy bulk */
1419 bulk->remote_data = NULL;
1420 bulk->remote_size = 0;
1425 vchiq_complete_bulk(bulk);
1433 bulk->size,
1434 bulk->remote_size);
1436 /* fabricate a matching dummy bulk */
1437 bulk->data = NULL;
1438 bulk->size = 0;
1439 bulk->actual = VCHIQ_BULK_ACTUAL_ABORTED;
1440 bulk->dir = is_tx ? VCHIQ_BULK_TRANSMIT :
1459 /* Block bulk transfers from all services */
1474 /* Allow bulk transfers from all services */
1483 * interim - just process all bulk queues for all services */
1837 VCHIQ_BULK_T *bulk;
1849 bulk = &queue->bulks[
1851 bulk->remote_data =
1853 bulk->remote_size = ((int *)header->data)[1];
1861 bulk->remote_size,
1862 (unsigned int)bulk->remote_data);
1869 "%s: deferring bulk (%d)",
1901 VCHIQ_BULK_T *bulk;
1929 bulk = &queue->bulks[
1931 bulk->actual = *(int *)header->data;
1939 bulk->actual, (unsigned int)bulk->data);
1951 vchiq_complete_bulk(bulk);
2804 /* Abort any outstanding bulk transfers */
3288 VCHIQ_BULK_T *bulk;
3310 bulk_waiter->bulk = NULL;
3314 bulk = bulk_waiter->bulk;
3348 bulk = &queue->bulks[BULK_INDEX(queue->local_insert)];
3350 bulk->mode = mode;
3351 bulk->dir = dir;
3352 bulk->userdata = userdata;
3353 bulk->size = size;
3354 bulk->actual = VCHIQ_BULK_ACTUAL_ABORTED;
3356 if (vchiq_prepare_bulk_data(bulk, memhandle, offset, size, dir) !=
3366 size, (unsigned int)bulk->data, (unsigned int)userdata);
3385 int payload[2] = { (int)bulk->data, bulk->size };
3416 bulk_waiter->bulk = bulk;
3428 vchiq_complete_bulk(bulk);
3839 "%d bulk stalls, %d aborted, %d errors",