/* * Copyright (C) 2011 * Boaz Harrosh * * Public Declarations of the ORE API * * This file is part of the ORE (Object Raid Engine) library. * * ORE is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License version 2 as published * by the Free Software Foundation. (GPL v2) * * ORE is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with the ORE; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ #ifndef __ORE_H__ #define __ORE_H__ #include #include #include #include struct ore_comp { struct osd_obj_id obj; u8 cred[OSD_CAP_LEN]; }; struct ore_layout { /* Our way of looking at the data_map */ unsigned stripe_unit; unsigned mirrors_p1; unsigned group_width; u64 group_depth; unsigned group_count; }; struct ore_components { unsigned numdevs; /* Num of devices in array */ /* If @single_comp == EC_SINGLE_COMP, @comps points to a single * component. else there are @numdevs components */ enum EC_COMP_USAGE { EC_SINGLE_COMP = 0, EC_MULTPLE_COMPS = 0xffffffff } single_comp; struct ore_comp *comps; struct osd_dev **ods; /* osd_dev array */ }; struct ore_io_state; typedef void (*ore_io_done_fn)(struct ore_io_state *ios, void *private); struct ore_io_state { struct kref kref; void *private; ore_io_done_fn done; struct ore_layout *layout; struct ore_components *comps; /* Global read/write IO*/ loff_t offset; unsigned long length; void *kern_buff; struct page **pages; unsigned nr_pages; unsigned pgbase; unsigned pages_consumed; /* Attributes */ unsigned in_attr_len; struct osd_attr *in_attr; unsigned out_attr_len; struct osd_attr *out_attr; bool reading; /* Variable array of size numdevs */ unsigned numdevs; struct ore_per_dev_state { struct osd_request *or; struct bio *bio; loff_t offset; unsigned length; unsigned dev; } per_dev[]; }; static inline unsigned ore_io_state_size(unsigned numdevs) { return sizeof(struct ore_io_state) + sizeof(struct ore_per_dev_state) * numdevs; } /* ore.c */ int ore_get_rw_state(struct ore_layout *layout, struct ore_components *comps, bool is_reading, u64 offset, u64 length, struct ore_io_state **ios); int ore_get_io_state(struct ore_layout *layout, struct ore_components *comps, struct ore_io_state **ios); void ore_put_io_state(struct ore_io_state *ios); int ore_check_io(struct ore_io_state *ios, u64 *resid); int ore_create(struct ore_io_state *ios); int ore_remove(struct ore_io_state *ios); int ore_write(struct ore_io_state *ios); int ore_read(struct ore_io_state *ios); int ore_truncate(struct ore_layout *layout, struct ore_components *comps, u64 size); int extract_attr_from_ios(struct ore_io_state *ios, struct osd_attr *attr); extern const struct osd_attr g_attr_logical_length; #endif