Lines Matching full:client
50 struct client { struct
75 static inline void client_get(struct client *client) in client_get() argument
77 kref_get(&client->kref); in client_get()
82 struct client *client = container_of(kref, struct client, kref); in client_release() local
84 fw_device_put(client->device); in client_release()
85 kfree(client); in client_release()
88 static void client_put(struct client *client) in client_put() argument
90 kref_put(&client->kref, client_release); in client_put()
94 typedef void (*client_resource_release_fn_t)(struct client *,
105 struct client *client; member
130 struct client *client; member
131 /* Schedule work and access todo only with client->lock held. */
161 static void release_iso_resource(struct client *, struct client_resource *);
168 static void release_transaction(struct client *client,
178 client_get(r->client); in schedule_iso_resource()
180 client_put(r->client); in schedule_iso_resource()
199 struct client *client; member
233 struct client *client; member
280 struct client *client; in fw_device_op_open() local
291 client = kzalloc(sizeof(*client), GFP_KERNEL); in fw_device_op_open()
292 if (client == NULL) { in fw_device_op_open()
297 client->device = device; in fw_device_op_open()
298 spin_lock_init(&client->lock); in fw_device_op_open()
299 xa_init_flags(&client->resource_xa, XA_FLAGS_ALLOC1 | XA_FLAGS_LOCK_BH); in fw_device_op_open()
300 INIT_LIST_HEAD(&client->event_list); in fw_device_op_open()
301 init_waitqueue_head(&client->wait); in fw_device_op_open()
302 init_waitqueue_head(&client->tx_flush_wait); in fw_device_op_open()
303 INIT_LIST_HEAD(&client->phy_receiver_link); in fw_device_op_open()
304 INIT_LIST_HEAD(&client->link); in fw_device_op_open()
305 kref_init(&client->kref); in fw_device_op_open()
307 file->private_data = client; in fw_device_op_open()
312 static void queue_event(struct client *client, struct event *event, in queue_event() argument
320 scoped_guard(spinlock_irqsave, &client->lock) { in queue_event()
321 if (client->in_shutdown) in queue_event()
324 list_add_tail(&event->link, &client->event_list); in queue_event()
327 wake_up_interruptible(&client->wait); in queue_event()
330 static int dequeue_event(struct client *client, in dequeue_event() argument
337 ret = wait_event_interruptible(client->wait, in dequeue_event()
338 !list_empty(&client->event_list) || in dequeue_event()
339 fw_device_is_shutdown(client->device)); in dequeue_event()
343 if (list_empty(&client->event_list) && in dequeue_event()
344 fw_device_is_shutdown(client->device)) in dequeue_event()
347 scoped_guard(spinlock_irq, &client->lock) { in dequeue_event()
348 event = list_first_entry(&client->event_list, struct event, link); in dequeue_event()
372 struct client *client = file->private_data; in fw_device_op_read() local
374 return dequeue_event(client, buffer, count); in fw_device_op_read()
378 struct client *client) in fill_bus_reset_event() argument
380 struct fw_card *card = client->device->card; in fill_bus_reset_event()
384 event->closure = client->bus_reset_closure; in fill_bus_reset_event()
386 event->generation = client->device->generation; in fill_bus_reset_event()
387 event->node_id = client->device->node_id; in fill_bus_reset_event()
395 void (*callback)(struct client *client)) in for_each_client() argument
397 struct client *c; in for_each_client()
405 static void queue_bus_reset_event(struct client *client) in queue_bus_reset_event() argument
415 fill_bus_reset_event(&e->reset, client); in queue_bus_reset_event()
417 queue_event(client, &e->event, in queue_bus_reset_event()
420 guard(spinlock_irq)(&client->lock); in queue_bus_reset_event()
422 xa_for_each(&client->resource_xa, index, resource) { in queue_bus_reset_event()
433 static void wake_up_client(struct client *client) in wake_up_client() argument
435 wake_up_interruptible(&client->wait); in wake_up_client()
466 static int ioctl_get_info(struct client *client, union ioctl_arg *arg) in ioctl_get_info() argument
472 client->version = a->version; in ioctl_get_info()
474 a->card = client->device->card->index; in ioctl_get_info()
479 size_t have = client->device->config_rom_length * 4; in ioctl_get_info()
481 ret = copy_to_user(u64_to_uptr(a->rom), client->device->config_rom, in ioctl_get_info()
486 a->rom_length = client->device->config_rom_length * 4; in ioctl_get_info()
489 guard(mutex)(&client->device->client_list_mutex); in ioctl_get_info()
491 client->bus_reset_closure = a->bus_reset_closure; in ioctl_get_info()
493 fill_bus_reset_event(&bus_reset, client); in ioctl_get_info()
497 if (ret == 0 && list_empty(&client->link)) in ioctl_get_info()
498 list_add_tail(&client->link, &client->device->client_list); in ioctl_get_info()
503 static int add_client_resource(struct client *client, struct client_resource *resource, in add_client_resource() argument
508 scoped_guard(spinlock_irqsave, &client->lock) { in add_client_resource()
511 if (client->in_shutdown) { in add_client_resource()
515 ret = xa_alloc(&client->resource_xa, &index, resource, xa_limit_32b, in add_client_resource()
518 ret = xa_alloc_bh(&client->resource_xa, &index, resource, in add_client_resource()
524 client_get(client); in add_client_resource()
533 static int release_client_resource(struct client *client, u32 handle, in release_client_resource() argument
540 scoped_guard(spinlock_irq, &client->lock) { in release_client_resource()
541 if (client->in_shutdown) in release_client_resource()
544 resource = xa_load(&client->resource_xa, index); in release_client_resource()
548 xa_erase(&client->resource_xa, handle); in release_client_resource()
554 resource->release(client, resource); in release_client_resource()
556 client_put(client); in release_client_resource()
561 static void release_transaction(struct client *client, in release_transaction() argument
570 struct client *client = e->client; in complete_transaction() local
573 scoped_guard(spinlock_irqsave, &client->lock) { in complete_transaction()
574 xa_erase(&client->resource_xa, index); in complete_transaction()
575 if (client->in_shutdown) in complete_transaction()
576 wake_up(&client->tx_flush_wait); in complete_transaction()
597 queue_event(client, &e->event, rsp, sizeof(*rsp), rsp->data, rsp->length); in complete_transaction()
599 queue_event(client, &e->event, rsp, sizeof(*rsp) + rsp->length, NULL, 0); in complete_transaction()
616 queue_event(client, &e->event, rsp, sizeof(*rsp) + rsp->length, NULL, 0); in complete_transaction()
626 client_put(client); in complete_transaction()
629 static int init_request(struct client *client, in init_request() argument
648 e->client = client; in init_request()
650 if (client->version < FW_CDEV_VERSION_EVENT_ASYNC_TSTAMP) { in init_request()
672 ret = add_client_resource(client, &e->r.resource, GFP_KERNEL); in init_request()
676 fw_send_request_with_tstamp(client->device->card, &e->r.transaction, request->tcode, in init_request()
687 static int ioctl_send_request(struct client *client, union ioctl_arg *arg) in ioctl_send_request() argument
706 return init_request(client, &arg->send_request, client->device->node_id, in ioctl_send_request()
707 client->device->max_speed); in ioctl_send_request()
710 static void release_request(struct client *client, in release_request() argument
736 /* card may be different from handler->client->device->card */ in handle_request()
740 // the process context for the client. in handle_request()
756 ret = add_client_resource(handler->client, &r->resource, GFP_ATOMIC); in handle_request()
760 if (handler->client->version < FW_CDEV_VERSION_EVENT_REQUEST2) { in handle_request()
773 } else if (handler->client->version < FW_CDEV_VERSION_EVENT_ASYNC_TSTAMP) { in handle_request()
804 queue_event(handler->client, &e->event, in handle_request()
820 static void release_address_handler(struct client *client, in release_address_handler() argument
829 static int ioctl_allocate(struct client *client, union ioctl_arg *arg) in ioctl_allocate() argument
841 if (client->version < FW_CDEV_VERSION_ALLOCATE_REGION_END) in ioctl_allocate()
850 r->client = client; in ioctl_allocate()
860 ret = add_client_resource(client, &r->resource, GFP_KERNEL); in ioctl_allocate()
862 release_address_handler(client, &r->resource); in ioctl_allocate()
870 static int ioctl_deallocate(struct client *client, union ioctl_arg *arg) in ioctl_deallocate() argument
872 return release_client_resource(client, arg->deallocate.handle, in ioctl_deallocate()
876 static int ioctl_send_response(struct client *client, union ioctl_arg *arg) in ioctl_send_response() argument
883 if (release_client_resource(client, a->handle, in ioctl_send_response()
911 static int ioctl_initiate_bus_reset(struct client *client, union ioctl_arg *arg) in ioctl_initiate_bus_reset() argument
913 fw_schedule_bus_reset(client->device->card, true, in ioctl_initiate_bus_reset()
918 static void release_descriptor(struct client *client, in release_descriptor() argument
927 static int ioctl_add_descriptor(struct client *client, union ioctl_arg *arg) in ioctl_add_descriptor() argument
934 if (!client->device->is_local) in ioctl_add_descriptor()
959 ret = add_client_resource(client, &r->resource, GFP_KERNEL); in ioctl_add_descriptor()
973 static int ioctl_remove_descriptor(struct client *client, union ioctl_arg *arg) in ioctl_remove_descriptor() argument
975 return release_client_resource(client, arg->remove_descriptor.handle, in ioctl_remove_descriptor()
982 struct client *client = data; in iso_callback() local
990 e->interrupt.closure = client->iso_closure; in iso_callback()
994 queue_event(client, &e->event, &e->interrupt, in iso_callback()
1001 struct client *client = data; in iso_mc_callback() local
1009 e->interrupt.closure = client->iso_closure; in iso_mc_callback()
1010 e->interrupt.completed = fw_iso_buffer_lookup(&client->buffer, in iso_mc_callback()
1012 queue_event(client, &e->event, &e->interrupt, in iso_mc_callback()
1038 static int ioctl_create_iso_context(struct client *client, union ioctl_arg *arg) in ioctl_create_iso_context() argument
1075 context = fw_iso_mc_context_create(client->device->card, cb.mc, in ioctl_create_iso_context()
1076 client); in ioctl_create_iso_context()
1078 context = fw_iso_context_create(client->device->card, a->type, in ioctl_create_iso_context()
1080 a->header_size, cb.sc, client); in ioctl_create_iso_context()
1083 if (client->version < FW_CDEV_VERSION_AUTO_FLUSH_ISO_OVERFLOW) in ioctl_create_iso_context()
1087 guard(spinlock_irq)(&client->lock); in ioctl_create_iso_context()
1089 if (client->iso_context != NULL) { in ioctl_create_iso_context()
1094 if (!client->buffer_is_mapped) { in ioctl_create_iso_context()
1095 ret = fw_iso_buffer_map_dma(&client->buffer, in ioctl_create_iso_context()
1096 client->device->card, in ioctl_create_iso_context()
1103 client->buffer_is_mapped = true; in ioctl_create_iso_context()
1105 client->iso_closure = a->closure; in ioctl_create_iso_context()
1106 client->iso_context = context; in ioctl_create_iso_context()
1113 static int ioctl_set_iso_channels(struct client *client, union ioctl_arg *arg) in ioctl_set_iso_channels() argument
1116 struct fw_iso_context *ctx = client->iso_context; in ioctl_set_iso_channels()
1132 static int ioctl_queue_iso(struct client *client, union ioctl_arg *arg) in ioctl_queue_iso() argument
1136 struct fw_iso_context *ctx = client->iso_context; in ioctl_queue_iso()
1157 payload = (unsigned long)a->data - client->vm_start; in ioctl_queue_iso()
1158 buffer_end = client->buffer.page_count << PAGE_SHIFT; in ioctl_queue_iso()
1159 if (a->data == 0 || client->buffer.pages == NULL || in ioctl_queue_iso()
1216 &client->buffer, payload)) in ioctl_queue_iso()
1227 a->data = client->vm_start + payload; in ioctl_queue_iso()
1232 static int ioctl_start_iso(struct client *client, union ioctl_arg *arg) in ioctl_start_iso() argument
1243 if (client->iso_context == NULL || a->handle != 0) in ioctl_start_iso()
1246 if (client->iso_context->type == FW_ISO_CONTEXT_RECEIVE && in ioctl_start_iso()
1250 return fw_iso_context_start(client->iso_context, in ioctl_start_iso()
1254 static int ioctl_stop_iso(struct client *client, union ioctl_arg *arg) in ioctl_stop_iso() argument
1258 if (client->iso_context == NULL || a->handle != 0) in ioctl_stop_iso()
1261 return fw_iso_context_stop(client->iso_context); in ioctl_stop_iso()
1264 static int ioctl_flush_iso(struct client *client, union ioctl_arg *arg) in ioctl_flush_iso() argument
1268 if (client->iso_context == NULL || a->handle != 0) in ioctl_flush_iso()
1271 return fw_iso_context_flush_completions(client->iso_context); in ioctl_flush_iso()
1274 static int ioctl_get_cycle_timer2(struct client *client, union ioctl_arg *arg) in ioctl_get_cycle_timer2() argument
1277 struct fw_card *card = client->device->card; in ioctl_get_cycle_timer2()
1303 static int ioctl_get_cycle_timer(struct client *client, union ioctl_arg *arg) in ioctl_get_cycle_timer() argument
1309 ioctl_get_cycle_timer2(client, (union ioctl_arg *)&ct2); in ioctl_get_cycle_timer()
1322 struct client *client = r->client; in iso_resource_work() local
1327 scoped_guard(spinlock_irq, &client->lock) { in iso_resource_work()
1328 generation = client->device->generation; in iso_resource_work()
1332 time_before64(get_jiffies_64(), client->device->card->reset_jiffies + HZ)) { in iso_resource_work()
1351 fw_iso_resource_manage(client->device->card, generation, in iso_resource_work()
1367 scoped_guard(spinlock_irq, &client->lock) { in iso_resource_work()
1368 // Transit from allocation to reallocation, except if the client in iso_resource_work()
1373 // xarray and prepare for deletion, unless the client is shutting down. in iso_resource_work()
1375 !client->in_shutdown && in iso_resource_work()
1376 xa_erase(&client->resource_xa, index)) { in iso_resource_work()
1377 client_put(client); in iso_resource_work()
1399 queue_event(client, &e->event, in iso_resource_work()
1409 client_put(client); in iso_resource_work()
1412 static void release_iso_resource(struct client *client, in release_iso_resource() argument
1417 guard(spinlock_irq)(&client->lock); in release_iso_resource()
1423 static int init_iso_resource(struct client *client, in init_iso_resource() argument
1443 r->client = client; in init_iso_resource()
1458 ret = add_client_resource(client, &r->resource, GFP_KERNEL); in init_iso_resource()
1477 static int ioctl_allocate_iso_resource(struct client *client, in ioctl_allocate_iso_resource() argument
1480 return init_iso_resource(client, in ioctl_allocate_iso_resource()
1484 static int ioctl_deallocate_iso_resource(struct client *client, in ioctl_deallocate_iso_resource() argument
1487 return release_client_resource(client, in ioctl_deallocate_iso_resource()
1491 static int ioctl_allocate_iso_resource_once(struct client *client, in ioctl_allocate_iso_resource_once() argument
1494 return init_iso_resource(client, in ioctl_allocate_iso_resource_once()
1498 static int ioctl_deallocate_iso_resource_once(struct client *client, in ioctl_deallocate_iso_resource_once() argument
1501 return init_iso_resource(client, in ioctl_deallocate_iso_resource_once()
1510 static int ioctl_get_speed(struct client *client, union ioctl_arg *arg) in ioctl_get_speed() argument
1512 return client->device->max_speed; in ioctl_get_speed()
1515 static int ioctl_send_broadcast_request(struct client *client, in ioctl_send_broadcast_request() argument
1532 return init_request(client, a, LOCAL_BUS | 0x3f, SCODE_100); in ioctl_send_broadcast_request()
1535 static int ioctl_send_stream_packet(struct client *client, union ioctl_arg *arg) in ioctl_send_stream_packet() argument
1541 if (a->speed > client->device->card->link_speed || in ioctl_send_stream_packet()
1555 return init_request(client, &request, dest, a->speed); in ioctl_send_stream_packet()
1563 struct client *e_client = e->client; in outbound_phy_packet_callback()
1602 queue_event(e->client, &e->event, &e->phy_packet, sizeof(*pp) + pp->length, in outbound_phy_packet_callback()
1612 queue_event(e->client, &e->event, &e->phy_packet, sizeof(*pp) + pp->length, in outbound_phy_packet_callback()
1624 static int ioctl_send_phy_packet(struct client *client, union ioctl_arg *arg) in ioctl_send_phy_packet() argument
1627 struct fw_card *card = client->device->card; in ioctl_send_phy_packet()
1631 if (!client->device->is_local) in ioctl_send_phy_packet()
1638 client_get(client); in ioctl_send_phy_packet()
1639 e->client = client; in ioctl_send_phy_packet()
1648 if (client->version < FW_CDEV_VERSION_EVENT_ASYNC_TSTAMP) { in ioctl_send_phy_packet()
1674 static int ioctl_receive_phy_packets(struct client *client, union ioctl_arg *arg) in ioctl_receive_phy_packets() argument
1677 struct fw_card *card = client->device->card; in ioctl_receive_phy_packets()
1680 if (!client->device->is_local) in ioctl_receive_phy_packets()
1685 list_move_tail(&client->phy_receiver_link, &card->phy_receiver_list); in ioctl_receive_phy_packets()
1686 client->phy_receiver_closure = a->closure; in ioctl_receive_phy_packets()
1693 struct client *client; in fw_cdev_handle_phy_packet() local
1697 list_for_each_entry(client, &card->phy_receiver_list, phy_receiver_link) { in fw_cdev_handle_phy_packet()
1702 if (client->version < FW_CDEV_VERSION_EVENT_ASYNC_TSTAMP) { in fw_cdev_handle_phy_packet()
1705 pp->closure = client->phy_receiver_closure; in fw_cdev_handle_phy_packet()
1711 queue_event(client, &e->event, &e->phy_packet, sizeof(*pp) + 8, NULL, 0); in fw_cdev_handle_phy_packet()
1716 pp->closure = client->phy_receiver_closure; in fw_cdev_handle_phy_packet()
1723 queue_event(client, &e->event, &e->phy_packet, sizeof(*pp) + 8, NULL, 0); in fw_cdev_handle_phy_packet()
1728 static int (* const ioctl_handlers[])(struct client *, union ioctl_arg *) = {
1756 static int dispatch_ioctl(struct client *client, in dispatch_ioctl() argument
1762 if (fw_device_is_shutdown(client->device)) in dispatch_ioctl()
1776 ret = ioctl_handlers[_IOC_NR(cmd)](client, &buffer); in dispatch_ioctl()
1795 struct client *client = file->private_data; in fw_device_op_mmap() local
1799 if (fw_device_is_shutdown(client->device)) in fw_device_op_mmap()
1803 if (client->buffer.pages != NULL) in fw_device_op_mmap()
1812 client->vm_start = vma->vm_start; in fw_device_op_mmap()
1818 ret = fw_iso_buffer_alloc(&client->buffer, page_count); in fw_device_op_mmap()
1822 scoped_guard(spinlock_irq, &client->lock) { in fw_device_op_mmap()
1823 if (client->iso_context) { in fw_device_op_mmap()
1824 ret = fw_iso_buffer_map_dma(&client->buffer, client->device->card, in fw_device_op_mmap()
1825 iso_dma_direction(client->iso_context)); in fw_device_op_mmap()
1828 client->buffer_is_mapped = true; in fw_device_op_mmap()
1832 ret = vm_map_pages_zero(vma, client->buffer.pages, in fw_device_op_mmap()
1833 client->buffer.page_count); in fw_device_op_mmap()
1839 fw_iso_buffer_destroy(&client->buffer, client->device->card); in fw_device_op_mmap()
1843 static bool has_outbound_transactions(struct client *client) in has_outbound_transactions() argument
1848 guard(spinlock_irq)(&client->lock); in has_outbound_transactions()
1850 xa_for_each(&client->resource_xa, index, resource) { in has_outbound_transactions()
1860 struct client *client = file->private_data; in fw_device_op_release() local
1865 scoped_guard(spinlock_irq, &client->device->card->lock) in fw_device_op_release()
1866 list_del(&client->phy_receiver_link); in fw_device_op_release()
1868 scoped_guard(mutex, &client->device->client_list_mutex) in fw_device_op_release()
1869 list_del(&client->link); in fw_device_op_release()
1871 if (client->iso_context) in fw_device_op_release()
1872 fw_iso_context_destroy(client->iso_context); in fw_device_op_release()
1874 if (client->buffer.pages) in fw_device_op_release()
1875 fw_iso_buffer_destroy(&client->buffer, client->device->card); in fw_device_op_release()
1877 // Freeze client->resource_xa and client->event_list. in fw_device_op_release()
1878 scoped_guard(spinlock_irq, &client->lock) in fw_device_op_release()
1879 client->in_shutdown = true; in fw_device_op_release()
1881 wait_event(client->tx_flush_wait, !has_outbound_transactions(client)); in fw_device_op_release()
1883 xa_for_each(&client->resource_xa, index, resource) { in fw_device_op_release()
1884 resource->release(client, resource); in fw_device_op_release()
1885 client_put(client); in fw_device_op_release()
1887 xa_destroy(&client->resource_xa); in fw_device_op_release()
1889 list_for_each_entry_safe(event, next_event, &client->event_list, link) in fw_device_op_release()
1892 client_put(client); in fw_device_op_release()
1899 struct client *client = file->private_data; in fw_device_op_poll() local
1902 poll_wait(file, &client->wait, pt); in fw_device_op_poll()
1904 if (fw_device_is_shutdown(client->device)) in fw_device_op_poll()
1906 if (!list_empty(&client->event_list)) in fw_device_op_poll()