117 static int vtest_client_dispatch_commands(struct vtest_client *client);
289    struct vtest_client *client;  in vtest_server_add_client()  local
291    client = calloc(1, sizeof(*client));  in vtest_server_add_client()
292    if (!client)  in vtest_server_add_client()
295    client->in_fd = in_fd;  in vtest_server_add_client()
296    client->out_fd = out_fd;  in vtest_server_add_client()
298    client->input.data.fd = in_fd;  in vtest_server_add_client()
299    client->input.read = vtest_block_read;  in vtest_server_add_client()
301    list_addtail(&client->head, &server.new_clients);  in vtest_server_add_client()
362    struct vtest_client *client;  in vtest_server_wait_clients()  local
369    LIST_FOR_EACH_ENTRY(client, &server.active_clients, head) {  in vtest_server_wait_clients()
370       FD_SET(client->in_fd, &read_fds);  in vtest_server_wait_clients()
371       max_fd = MAX2(client->in_fd, max_fd);  in vtest_server_wait_clients()
395    LIST_FOR_EACH_ENTRY(client, &server.active_clients, head) {  in vtest_server_wait_clients()
396       if (FD_ISSET(client->in_fd, &read_fds)) {  in vtest_server_wait_clients()
397          client->in_fd_ready = true;  in vtest_server_wait_clients()
432    struct vtest_client *client, *tmp;  in vtest_server_dispatch_clients()  local
434    LIST_FOR_EACH_ENTRY_SAFE(client, tmp, &server.active_clients, head) {  in vtest_server_dispatch_clients()
437       if (!client->in_fd_ready)  in vtest_server_dispatch_clients()
439       client->in_fd_ready = false;  in vtest_server_dispatch_clients()
441       err = vtest_client_dispatch_commands(client);  in vtest_server_dispatch_clients()
445          list_del(&client->head);  in vtest_server_dispatch_clients()
446          list_addtail(&client->head, &server.inactive_clients);  in vtest_server_dispatch_clients()
470    struct vtest_client *client, *tmp;  in vtest_server_fork_clients()  local
472    LIST_FOR_EACH_ENTRY_SAFE(client, tmp, &server.new_clients, head) {  in vtest_server_fork_clients()
475          list_del(&client->head);  in vtest_server_fork_clients()
476          list_addtail(&client->head, &server.inactive_clients);  in vtest_server_fork_clients()
479          list_del(&client->head);  in vtest_server_fork_clients()
480          list_addtail(&client->head, &server.active_clients);  in vtest_server_fork_clients()
483          LIST_FOR_EACH_ENTRY_SAFE(client, tmp, &server.new_clients, head) {  in vtest_server_fork_clients()
484             list_del(&client->head);  in vtest_server_fork_clients()
485             list_addtail(&client->head, &server.inactive_clients);  in vtest_server_fork_clients()
493    struct vtest_client *client, *tmp;  in vtest_server_activate_clients()  local
496    LIST_FOR_EACH_ENTRY_SAFE(client, tmp, &server.new_clients, head) {  in vtest_server_activate_clients()
497       list_addtail(&client->head, &server.active_clients);  in vtest_server_activate_clients()
504    struct vtest_client *client, *tmp;  in vtest_server_inactivate_clients()  local
507    LIST_FOR_EACH_ENTRY_SAFE(client, tmp, &server.active_clients, head) {  in vtest_server_inactivate_clients()
508       list_addtail(&client->head, &server.inactive_clients);  in vtest_server_inactivate_clients()
515    struct vtest_client *client, *tmp;  in vtest_server_tidy_clients()  local
517    LIST_FOR_EACH_ENTRY_SAFE(client, tmp, &server.inactive_clients, head) {  in vtest_server_tidy_clients()
518       if (client->context) {  in vtest_server_tidy_clients()
519          vtest_destroy_context(client->context);  in vtest_server_tidy_clients()
522       if (client->in_fd >= 0) {  in vtest_server_tidy_clients()
523          close(client->in_fd);  in vtest_server_tidy_clients()
526       if (client->out_fd >= 0 && client->out_fd != client->in_fd) {  in vtest_server_tidy_clients()
527          close(client->out_fd);  in vtest_server_tidy_clients()
530       free(client);  in vtest_server_tidy_clients()
613 static int vtest_client_dispatch_commands(struct vtest_client *client)  in vtest_client_dispatch_commands()  argument
619    ret = client->input.read(&client->input, &header, sizeof(header));  in vtest_client_dispatch_commands()
624    if (!client->context) {  in vtest_client_dispatch_commands()
630       ret = vtest_create_context(&client->input, client->out_fd,  in vtest_client_dispatch_commands()
631                                  header[0], &client->context);  in vtest_client_dispatch_commands()
653       ret = vtest_lazy_init_context(client->context);  in vtest_client_dispatch_commands()
659    vtest_set_current_context(client->context);  in vtest_client_dispatch_commands()