Lines Matching refs:connection
91 struct tapdisk_control_connection *connection; in tapdisk_control_allocate_connection() local
94 connection = calloc(1, sizeof(*connection)); in tapdisk_control_allocate_connection()
95 if (!connection) { in tapdisk_control_allocate_connection()
100 connection->socket = fd; in tapdisk_control_allocate_connection()
101 return connection; in tapdisk_control_allocate_connection()
105 tapdisk_control_close_connection(struct tapdisk_control_connection *connection) in tapdisk_control_close_connection() argument
107 tapdisk_server_unregister_event(connection->event_id); in tapdisk_control_close_connection()
108 close(connection->socket); in tapdisk_control_close_connection()
109 free(connection); in tapdisk_control_close_connection()
218 tapdisk_control_list_minors(struct tapdisk_control_connection *connection, in tapdisk_control_list_minors() argument
244 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_list_minors()
245 tapdisk_control_close_connection(connection); in tapdisk_control_list_minors()
249 tapdisk_control_list(struct tapdisk_control_connection *connection, in tapdisk_control_list() argument
283 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_list()
290 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_list()
291 tapdisk_control_close_connection(connection); in tapdisk_control_list()
295 tapdisk_control_get_pid(struct tapdisk_control_connection *connection, in tapdisk_control_get_pid() argument
305 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_get_pid()
306 tapdisk_control_close_connection(connection); in tapdisk_control_get_pid()
310 tapdisk_control_attach_vbd(struct tapdisk_control_connection *connection, in tapdisk_control_attach_vbd() argument
361 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_attach_vbd()
362 tapdisk_control_close_connection(connection); in tapdisk_control_attach_vbd()
374 tapdisk_control_detach_vbd(struct tapdisk_control_connection *connection, in tapdisk_control_detach_vbd() argument
401 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_detach_vbd()
402 tapdisk_control_close_connection(connection); in tapdisk_control_detach_vbd()
406 tapdisk_control_open_image(struct tapdisk_control_connection *connection, in tapdisk_control_open_image() argument
490 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_open_image()
491 tapdisk_control_close_connection(connection); in tapdisk_control_open_image()
503 tapdisk_control_close_image(struct tapdisk_control_connection *connection, in tapdisk_control_close_image() argument
541 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_close_image()
542 tapdisk_control_close_connection(connection); in tapdisk_control_close_image()
546 tapdisk_control_pause_vbd(struct tapdisk_control_connection *connection, in tapdisk_control_pause_vbd() argument
575 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_pause_vbd()
576 tapdisk_control_close_connection(connection); in tapdisk_control_pause_vbd()
580 tapdisk_control_resume_vbd(struct tapdisk_control_connection *connection, in tapdisk_control_resume_vbd() argument
626 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_resume_vbd()
627 tapdisk_control_close_connection(connection); in tapdisk_control_resume_vbd()
635 struct tapdisk_control_connection *connection = in tapdisk_control_handle_request() local
638 if (tapdisk_control_read_message(connection->socket, &message, 2)) { in tapdisk_control_handle_request()
639 EPRINTF("failed to read message from %d\n", connection->socket); in tapdisk_control_handle_request()
640 tapdisk_control_close_connection(connection); in tapdisk_control_handle_request()
650 return tapdisk_control_get_pid(connection, &message); in tapdisk_control_handle_request()
652 return tapdisk_control_list_minors(connection, &message); in tapdisk_control_handle_request()
654 return tapdisk_control_list(connection, &message); in tapdisk_control_handle_request()
656 return tapdisk_control_attach_vbd(connection, &message); in tapdisk_control_handle_request()
658 return tapdisk_control_detach_vbd(connection, &message); in tapdisk_control_handle_request()
660 return tapdisk_control_open_image(connection, &message); in tapdisk_control_handle_request()
662 return tapdisk_control_pause_vbd(connection, &message); in tapdisk_control_handle_request()
664 return tapdisk_control_resume_vbd(connection, &message); in tapdisk_control_handle_request()
666 return tapdisk_control_close_image(connection, &message); in tapdisk_control_handle_request()
678 tapdisk_control_write_message(connection->socket, &response, 2); in tapdisk_control_handle_request()
680 tapdisk_control_close_connection(connection); in tapdisk_control_handle_request()
690 struct tapdisk_control_connection *connection; in tapdisk_control_accept() local
698 connection = tapdisk_control_allocate_connection(fd); in tapdisk_control_accept()
699 if (!connection) { in tapdisk_control_accept()
705 connection->socket, 0, in tapdisk_control_accept()
707 connection); in tapdisk_control_accept()
710 free(connection); in tapdisk_control_accept()
714 connection->event_id = err; in tapdisk_control_accept()