Lines Matching refs:operation
537 struct gb_operation *operation; in gb_connection_shutdown_operation() local
540 operation = gb_operation_create_core(connection, in gb_connection_shutdown_operation()
544 if (!operation) in gb_connection_shutdown_operation()
547 req = operation->request->payload; in gb_connection_shutdown_operation()
550 ret = gb_operation_request_send_sync(operation); in gb_connection_shutdown_operation()
552 gb_operation_put(operation); in gb_connection_shutdown_operation()
608 struct gb_operation *operation; in gb_connection_cancel_operations() local
611 operation = list_last_entry(&connection->operations, in gb_connection_cancel_operations()
613 gb_operation_get(operation); in gb_connection_cancel_operations()
616 if (gb_operation_is_incoming(operation)) in gb_connection_cancel_operations()
617 gb_operation_cancel_incoming(operation, errno); in gb_connection_cancel_operations()
619 gb_operation_cancel(operation, errno); in gb_connection_cancel_operations()
621 gb_operation_put(operation); in gb_connection_cancel_operations()
637 struct gb_operation *operation; in gb_connection_flush_incoming_operations() local
642 list_for_each_entry(operation, &connection->operations, in gb_connection_flush_incoming_operations()
644 if (gb_operation_is_incoming(operation)) { in gb_connection_flush_incoming_operations()
645 gb_operation_get(operation); in gb_connection_flush_incoming_operations()
657 gb_operation_cancel_incoming(operation, errno); in gb_connection_flush_incoming_operations()
658 gb_operation_put(operation); in gb_connection_flush_incoming_operations()