Lines Matching refs:operation
534 struct gb_operation *operation; in gb_connection_shutdown_operation() local
537 operation = gb_operation_create_core(connection, in gb_connection_shutdown_operation()
541 if (!operation) in gb_connection_shutdown_operation()
544 req = operation->request->payload; in gb_connection_shutdown_operation()
547 ret = gb_operation_request_send_sync(operation); in gb_connection_shutdown_operation()
549 gb_operation_put(operation); in gb_connection_shutdown_operation()
605 struct gb_operation *operation; in gb_connection_cancel_operations() local
608 operation = list_last_entry(&connection->operations, in gb_connection_cancel_operations()
610 gb_operation_get(operation); in gb_connection_cancel_operations()
613 if (gb_operation_is_incoming(operation)) in gb_connection_cancel_operations()
614 gb_operation_cancel_incoming(operation, errno); in gb_connection_cancel_operations()
616 gb_operation_cancel(operation, errno); in gb_connection_cancel_operations()
618 gb_operation_put(operation); in gb_connection_cancel_operations()
634 struct gb_operation *operation; in gb_connection_flush_incoming_operations() local
639 list_for_each_entry(operation, &connection->operations, in gb_connection_flush_incoming_operations()
641 if (gb_operation_is_incoming(operation)) { in gb_connection_flush_incoming_operations()
642 gb_operation_get(operation); in gb_connection_flush_incoming_operations()
654 gb_operation_cancel_incoming(operation, errno); in gb_connection_flush_incoming_operations()
655 gb_operation_put(operation); in gb_connection_flush_incoming_operations()