/* * Copyright (C) 2011 Andrea Mazzoleni * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program 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 this program. If not, see . */ #ifndef __PARITY_H #define __PARITY_H #include "support.h" /****************************************************************************/ /* parity */ struct snapraid_parity_handle { char path[PATH_MAX]; /**< Path of the file. */ int f; /**< Handle of the file. */ struct stat st; /**< Stat info of the opened file. */ data_off_t valid_size; /**< Size of the valid data. */ }; /** * Compute the size of the allocated parity data in number of blocks. * * This includes parity blocks not yet written and still invalid. */ block_off_t parity_allocated_size(struct snapraid_state* state); /** * Compute the size of the used parity data in number of blocks. * * This includes only parity blocks used for files, not counting * potential invalid parity at the end. * * If the array is fully synched there is no difference between * parity_allocate_size() and parity_used_size(). * But if the sync is interrupted, the parity_used_size() returns * the position of the latest BLK block, ignoring CHG, REL and DELETED ones, * because their parity may be still not even written in the parity file. */ block_off_t parity_used_size(struct snapraid_state* state); /** * Check if the parity needs to be updated with a "sync". * * This is the same logic used in "status" to detect an incomplete "sync", * that ignores invalid block, if they are not used by a file in any disk. * This means that DELETED blocks won't necessarely imply an invalid parity. */ int parity_is_invalid(struct snapraid_state* state); /** * If parity has some */ int parity_is_invalid(struct snapraid_state* state); /** * Report all the files outside the specified parity size. */ void parity_overflow(struct snapraid_state* state, data_off_t size); /** * Create the parity file. * \param out_size Return the size of the parity file. */ int parity_create(struct snapraid_parity_handle* parity, const char* path, data_off_t* out_size, int mode); /** * Change the parity size. * \param out_size Return the size of the parity file. The out_size is set also on error to reflect a partial resize. */ int parity_chsize(struct snapraid_parity_handle* parity, data_off_t size, data_off_t* out_size, int skip_fallocate); /** * Open an already existing parity file. */ int parity_open(struct snapraid_parity_handle* parity, const char* path, int mode); /** * Flush the parity file in the disk. */ int parity_sync(struct snapraid_parity_handle* parity); /** * Close the parity file. */ int parity_close(struct snapraid_parity_handle* parity); /** * Read a block from the parity file. */ int parity_read(struct snapraid_parity_handle* parity, block_off_t pos, unsigned char* block_buffer, unsigned block_size, fptr* out); /** * Write a block in the parity file. */ int parity_write(struct snapraid_parity_handle* parity, block_off_t pos, unsigned char* block_buffer, unsigned block_size); #endif