1 /* 2 * Copyright (C) 2021 Jakub Kruszona-Zawadzki, Core Technology Sp. z o.o. 3 * 4 * This file is part of MooseFS. 5 * 6 * MooseFS is free software; you can redistribute it and/or modify 7 * it under the terms of the GNU General Public License as published by 8 * the Free Software Foundation, version 2 (only). 9 * 10 * MooseFS is distributed in the hope that it will be useful, 11 * but WITHOUT ANY WARRANTY; without even the implied warranty of 12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 13 * GNU General Public License for more details. 14 * 15 * You should have received a copy of the GNU General Public License 16 * along with MooseFS; if not, write to the Free Software 17 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02111-1301, USA 18 * or visit http://www.gnu.org/licenses/gpl-2.0.html 19 */ 20 21 #ifndef _HDDSPACEMGR_H_ 22 #define _HDDSPACEMGR_H_ 23 24 #include <inttypes.h> 25 26 #include "MFSCommunication.h" 27 28 void hdd_stats(uint64_t *br,uint64_t *bw,uint32_t *opr,uint32_t *opw,uint32_t *dbr,uint32_t *dbw,uint32_t *dopr,uint32_t *dopw,uint32_t *movl,uint32_t *movh,uint64_t *rtime,uint64_t *wtime); 29 void hdd_op_stats(uint32_t *op_create,uint32_t *op_delete,uint32_t *op_version,uint32_t *op_duplicate,uint32_t *op_truncate,uint32_t *op_duptrunc,uint32_t *op_test); 30 uint32_t hdd_errorcounter(void); 31 32 /* lock/unlock pair */ 33 uint32_t hdd_get_damaged_chunk_count(void); 34 void hdd_get_damaged_chunk_data(uint8_t *buff); 35 /* lock/unlock pair */ 36 uint32_t hdd_get_lost_chunk_count(uint32_t limit); 37 void hdd_get_lost_chunk_data(uint8_t *buff,uint32_t limit); 38 /* lock/unlock pair */ 39 uint32_t hdd_get_new_chunk_count(uint32_t limit); 40 void hdd_get_new_chunk_data(uint8_t *buff,uint32_t limit); 41 /* lock/unlock pair */ 42 uint32_t hdd_get_changed_chunk_count(uint32_t limit); 43 void hdd_get_changed_chunk_data(uint8_t *buffl,uint8_t *buffn,uint32_t limit); 44 /* lock/unlock pair */ 45 uint32_t hdd_diskinfo_size(void); 46 void hdd_diskinfo_data(uint8_t *buff); 47 uint32_t hdd_diskinfo_monotonic_size(void); 48 void hdd_diskinfo_monotonic_data(uint8_t *buff); 49 /* lock/unlock pair */ 50 void hdd_get_chunks_begin(uint8_t partialmode); 51 void hdd_get_chunks_end(void); 52 uint32_t hdd_get_chunks_next_list_count(uint32_t stopcount); 53 void hdd_get_chunks_next_list_data(uint32_t stopcount,uint8_t *buff); 54 //uint32_t hdd_get_chunks_count(); 55 //void hdd_get_chunks_data(uint8_t *buff); 56 57 //uint32_t get_changedchunkscount(); 58 //void fill_changedchunksinfo(uint8_t *buff); 59 uint8_t hdd_spacechanged(void); 60 void hdd_get_space(uint64_t *usedspace,uint64_t *totalspace,uint32_t *chunkcount,uint64_t *tdusedspace,uint64_t *tdtotalspace,uint32_t *tdchunkcount); 61 62 uint8_t hdd_is_rebalance_on(void); 63 64 /* emergency chunk read - ignore errors, do retries */ 65 int hdd_emergency_read(uint64_t chunkid,uint32_t *version,uint16_t blocknum,uint8_t buffer[MFSBLOCKSIZE],uint8_t retries,uint8_t *errorflags); 66 67 /* precache data */ 68 void hdd_precache_data(uint64_t chunkid,uint32_t offset,uint32_t size); 69 70 /* I/O operations */ 71 int hdd_open(uint64_t chunkid,uint32_t version); 72 int hdd_close(uint64_t chunkid); 73 int hdd_read(uint64_t chunkid,uint32_t version,uint16_t blocknum,uint8_t *buffer,uint32_t offset,uint32_t size,uint8_t *crcbuff); 74 int hdd_write(uint64_t chunkid,uint32_t version,uint16_t blocknum,const uint8_t *buffer,uint32_t offset,uint32_t size,const uint8_t *crcbuff); 75 76 /* chunk info */ 77 // int hdd_check_version(uint64_t chunkid,uint32_t version); 78 int hdd_get_blocks(uint64_t chunkid,uint32_t version,uint8_t *blocks_buff); 79 int hdd_get_checksum(uint64_t chunkid, uint32_t version, uint8_t *checksum_buff); 80 int hdd_get_checksum_tab(uint64_t chunkid, uint32_t version, uint8_t *checksum_tab); 81 82 int hdd_move(void *fsrcv,void *fdstv); 83 84 /* chunk operations */ 85 86 /* all chunk operations in one call */ 87 // newversion>0 && length==0xFFFFFFFF && copychunkid==0 -> change version 88 // newversion>0 && length==0xFFFFFFFF && copychunkid>0 -> duplicate 89 // newversion>0 && length<=MFSCHUNKSIZE && copychunkid==0 -> truncate 90 // newversion>0 && length<=MFSCHUNKSIZE && copychunkid>0 -> duplicate and truncate 91 // newversion==0 && length==0 -> delete 92 // newversion==0 && length==1 -> create 93 // newversion==0 && length==2 -> test 94 int hdd_chunkop(uint64_t chunkid,uint32_t version,uint32_t newversion,uint64_t copychunkid,uint32_t copyversion,uint32_t length); 95 96 #define hdd_delete(_chunkid,_version) hdd_chunkop(_chunkid,_version,0,0,0,0) 97 #define hdd_create(_chunkid,_version) hdd_chunkop(_chunkid,_version,0,0,0,1) 98 #define hdd_test(_chunkid,_version) hdd_chunkop(_chunkid,_version,0,0,0,2) 99 #define hdd_version(_chunkid,_version,_newversion) (((_newversion)>0)?hdd_chunkop(_chunkid,_version,_newversion,0,0,0xFFFFFFFF):MFS_ERROR_EINVAL) 100 #define hdd_truncate(_chunkid,_version,_newversion,_length) (((_newversion)>0&&(_length)!=0xFFFFFFFF)?hdd_chunkop(_chunkid,_version,_newversion,0,0,_length):MFS_ERROR_EINVAL) 101 #define hdd_duplicate(_chunkid,_version,_newversion,_copychunkid,_copyversion) (((_newversion>0)&&(_copychunkid)>0)?hdd_chunkop(_chunkid,_version,_newversion,_copychunkid,_copyversion,0xFFFFFFFF):MFS_ERROR_EINVAL) 102 #define hdd_duptrunc(_chunkid,_version,_newversion,_copychunkid,_copyversion,_length) (((_newversion>0)&&(_copychunkid)>0&&(_length)!=0xFFFFFFFF)?hdd_chunkop(_chunkid,_version,_newversion,_copychunkid,_copyversion,_length):MFS_ERROR_EINVAL) 103 104 /* meta id */ 105 void hdd_setmetaid(uint64_t metaid); 106 107 /* restore */ 108 int hdd_restore(void); 109 110 /* initialization */ 111 int hdd_late_init(void); 112 int hdd_init(void); 113 114 /* debug only */ 115 void hdd_test_show_chunks(void); 116 void hdd_test_show_openedchunks(void); 117 #endif 118