[9] | 1 | /****************************************************************/
|
---|
| 2 | /* */
|
---|
| 3 | /* de_diskio.c */
|
---|
| 4 | /* */
|
---|
| 5 | /* Reading and writing to a file system device. */
|
---|
| 6 | /* */
|
---|
| 7 | /****************************************************************/
|
---|
| 8 | /* origination 1989-Jan-15 Terrence W. Holm */
|
---|
| 9 | /****************************************************************/
|
---|
| 10 |
|
---|
| 11 |
|
---|
| 12 | #include <minix/config.h>
|
---|
| 13 | #include <sys/types.h>
|
---|
| 14 | #include <unistd.h>
|
---|
| 15 | #include <limits.h>
|
---|
| 16 | #include <string.h>
|
---|
| 17 | #include <dirent.h>
|
---|
| 18 |
|
---|
| 19 | #include <minix/const.h>
|
---|
| 20 | #include <minix/type.h>
|
---|
| 21 | #include "../../servers/fs/const.h"
|
---|
| 22 | #include "../../servers/fs/type.h"
|
---|
| 23 | #include "../../servers/fs/super.h"
|
---|
| 24 | #include "../../servers/fs/inode.h"
|
---|
| 25 | #include <minix/fslib.h>
|
---|
| 26 |
|
---|
| 27 | #include "de.h"
|
---|
| 28 |
|
---|
| 29 |
|
---|
| 30 |
|
---|
| 31 |
|
---|
| 32 | /****************************************************************/
|
---|
| 33 | /* */
|
---|
| 34 | /* Read_Disk( state, block_addr, buffer ) */
|
---|
| 35 | /* */
|
---|
| 36 | /* Reads a 1k block at "block_addr" into "buffer". */
|
---|
| 37 | /* */
|
---|
| 38 | /****************************************************************/
|
---|
| 39 |
|
---|
| 40 |
|
---|
| 41 | void Read_Disk( s, block_addr, buffer )
|
---|
| 42 | de_state *s;
|
---|
| 43 | off_t block_addr;
|
---|
| 44 | char *buffer;
|
---|
| 45 |
|
---|
| 46 | {
|
---|
| 47 | if ( lseek( s->device_d, block_addr, SEEK_SET ) == -1 )
|
---|
| 48 | Error( "Error seeking %s", s->device_name );
|
---|
| 49 |
|
---|
| 50 | if ( read( s->device_d, buffer, s->block_size ) != s->block_size )
|
---|
| 51 | Error( "Error reading %s", s->device_name );
|
---|
| 52 | }
|
---|
| 53 |
|
---|
| 54 |
|
---|
| 55 |
|
---|
| 56 |
|
---|
| 57 |
|
---|
| 58 |
|
---|
| 59 | /****************************************************************/
|
---|
| 60 | /* */
|
---|
| 61 | /* Read_Block( state, buffer ) */
|
---|
| 62 | /* */
|
---|
| 63 | /* Reads a 1k block from "state->address" into */
|
---|
| 64 | /* "buffer". Checks "address", and updates */
|
---|
| 65 | /* "block" and "offset". */
|
---|
| 66 | /* */
|
---|
| 67 | /****************************************************************/
|
---|
| 68 |
|
---|
| 69 |
|
---|
| 70 | void Read_Block( s, buffer )
|
---|
| 71 | de_state *s;
|
---|
| 72 | char *buffer;
|
---|
| 73 |
|
---|
| 74 | {
|
---|
| 75 | off_t end_addr;
|
---|
| 76 | off_t block_addr;
|
---|
| 77 | end_addr = (long) s->device_size * s->block_size - 1;
|
---|
| 78 |
|
---|
| 79 | if ( s->address < 0 )
|
---|
| 80 | s->address = 0L;
|
---|
| 81 |
|
---|
| 82 | if ( s->address > end_addr )
|
---|
| 83 | s->address = end_addr;
|
---|
| 84 |
|
---|
| 85 | /* The address must be rounded off for */
|
---|
| 86 | /* certain visual display modes. */
|
---|
| 87 |
|
---|
| 88 | if ( s->mode == WORD )
|
---|
| 89 | s->address &= ~1L;
|
---|
| 90 | else if ( s->mode == MAP )
|
---|
| 91 | s->address &= ~3L;
|
---|
| 92 |
|
---|
| 93 |
|
---|
| 94 | block_addr = s->address & K_MASK;
|
---|
| 95 |
|
---|
| 96 | s->block = (zone_t) (block_addr >> K_SHIFT);
|
---|
| 97 | s->offset = (unsigned) (s->address - block_addr);
|
---|
| 98 |
|
---|
| 99 | Read_Disk( s, block_addr, buffer );
|
---|
| 100 | }
|
---|
| 101 |
|
---|
| 102 |
|
---|
| 103 |
|
---|
| 104 |
|
---|
| 105 |
|
---|
| 106 |
|
---|
| 107 | /****************************************************************/
|
---|
| 108 | /* */
|
---|
| 109 | /* Read_Super_Block( state ) */
|
---|
| 110 | /* */
|
---|
| 111 | /* Read and check the super block. */
|
---|
| 112 | /* */
|
---|
| 113 | /****************************************************************/
|
---|
| 114 |
|
---|
| 115 |
|
---|
| 116 | void Read_Super_Block( s )
|
---|
| 117 | de_state *s;
|
---|
| 118 |
|
---|
| 119 | {
|
---|
| 120 | struct super_block *super = (struct super_block *) s->buffer;
|
---|
| 121 | unsigned inodes_per_block;
|
---|
| 122 | off_t size;
|
---|
| 123 |
|
---|
| 124 | s->block_size = K;
|
---|
| 125 | Read_Disk( s, (long) SUPER_BLOCK_BYTES, s->buffer );
|
---|
| 126 |
|
---|
| 127 | s->magic = super->s_magic;
|
---|
| 128 | if ( s->magic == SUPER_MAGIC )
|
---|
| 129 | {
|
---|
| 130 | s->is_fs = TRUE;
|
---|
| 131 | s->v1 = TRUE;
|
---|
| 132 | s->inode_size = V1_INODE_SIZE;
|
---|
| 133 | inodes_per_block = V1_INODES_PER_BLOCK;
|
---|
| 134 | s->nr_indirects = V1_INDIRECTS;
|
---|
| 135 | s->zone_num_size = V1_ZONE_NUM_SIZE;
|
---|
| 136 | s->zones = super->s_nzones;
|
---|
| 137 | s->ndzones = V1_NR_DZONES;
|
---|
| 138 | s->block_size = _STATIC_BLOCK_SIZE;
|
---|
| 139 | }
|
---|
| 140 | else if ( s->magic == SUPER_V2 || s->magic == SUPER_V3)
|
---|
| 141 | {
|
---|
| 142 | if(s->magic == SUPER_V3)
|
---|
| 143 | s->block_size = super->s_block_size;
|
---|
| 144 | else
|
---|
| 145 | s->block_size = _STATIC_BLOCK_SIZE;
|
---|
| 146 | s->is_fs = TRUE;
|
---|
| 147 | s->v1 = FALSE;
|
---|
| 148 | s->inode_size = V2_INODE_SIZE;
|
---|
| 149 | inodes_per_block = V2_INODES_PER_BLOCK(s->block_size);
|
---|
| 150 | s->nr_indirects = V2_INDIRECTS(s->block_size);
|
---|
| 151 | s->zone_num_size = V2_ZONE_NUM_SIZE;
|
---|
| 152 | s->zones = super->s_zones;
|
---|
| 153 | s->ndzones = V2_NR_DZONES;
|
---|
| 154 | }
|
---|
| 155 | else
|
---|
| 156 | {
|
---|
| 157 | if ( super->s_magic == SUPER_REV )
|
---|
| 158 | Warning( "V1-bytes-swapped file system (?)" );
|
---|
| 159 | else if ( super->s_magic == SUPER_V2_REV )
|
---|
| 160 | Warning( "V2-bytes-swapped file system (?)" );
|
---|
| 161 | else
|
---|
| 162 | Warning( "Not a Minix file system" );
|
---|
| 163 | Warning( "The file system features will not be available" );
|
---|
| 164 | s->zones = 100000L;
|
---|
| 165 | return;
|
---|
| 166 | }
|
---|
| 167 |
|
---|
| 168 | s->inodes = super->s_ninodes;
|
---|
| 169 | s->inode_maps = bitmapsize( (bit_t) s->inodes + 1 , s->block_size);
|
---|
| 170 | if ( s->inode_maps != super->s_imap_blocks )
|
---|
| 171 | {
|
---|
| 172 | if ( s->inode_maps > super->s_imap_blocks )
|
---|
| 173 | Error( "Corrupted inode map count or inode count in super block" );
|
---|
| 174 | else
|
---|
| 175 | Warning( "Count of inode map blocks in super block suspiciously high" );
|
---|
| 176 | s->inode_maps = super->s_imap_blocks;
|
---|
| 177 | }
|
---|
| 178 |
|
---|
| 179 | s->zone_maps = bitmapsize( (bit_t) s->zones , s->block_size);
|
---|
| 180 | if ( s->zone_maps != super->s_zmap_blocks )
|
---|
| 181 | {
|
---|
| 182 | if ( s->zone_maps > super->s_zmap_blocks )
|
---|
| 183 | Error( "Corrupted zone map count or zone count in super block" );
|
---|
| 184 | else
|
---|
| 185 | Warning( "Count of zone map blocks in super block suspiciously high" );
|
---|
| 186 | s->zone_maps = super->s_zmap_blocks;
|
---|
| 187 | }
|
---|
| 188 |
|
---|
| 189 | s->inode_blocks = (s->inodes + inodes_per_block - 1) / inodes_per_block;
|
---|
| 190 | s->first_data = 2 + s->inode_maps + s->zone_maps + s->inode_blocks;
|
---|
| 191 | if ( s->first_data != super->s_firstdatazone )
|
---|
| 192 | {
|
---|
| 193 | if ( s->first_data > super->s_firstdatazone )
|
---|
| 194 | Error( "Corrupted first data zone offset or inode count in super block" );
|
---|
| 195 | else
|
---|
| 196 | Warning( "First data zone in super block suspiciously high" );
|
---|
| 197 | s->first_data = super->s_firstdatazone;
|
---|
| 198 | }
|
---|
| 199 |
|
---|
| 200 | s->inodes_in_map = s->inodes + 1;
|
---|
| 201 | s->zones_in_map = s->zones + 1 - s->first_data;
|
---|
| 202 |
|
---|
| 203 | /*
|
---|
| 204 | if ( s->zones != s->device_size )
|
---|
| 205 | Warning( "Zone count does not equal device size" );
|
---|
| 206 | */
|
---|
| 207 |
|
---|
| 208 | s->device_size = s->zones;
|
---|
| 209 |
|
---|
| 210 | if ( super->s_log_zone_size != 0 )
|
---|
| 211 | Error( "Can not handle multiple blocks per zone" );
|
---|
| 212 | }
|
---|
| 213 |
|
---|
| 214 |
|
---|
| 215 |
|
---|
| 216 |
|
---|
| 217 |
|
---|
| 218 |
|
---|
| 219 | /****************************************************************/
|
---|
| 220 | /* */
|
---|
| 221 | /* Read_Bit_Maps( state ) */
|
---|
| 222 | /* */
|
---|
| 223 | /* Read in the i-node and zone bit maps from the */
|
---|
| 224 | /* specified file system device. */
|
---|
| 225 | /* */
|
---|
| 226 | /****************************************************************/
|
---|
| 227 |
|
---|
| 228 |
|
---|
| 229 | void Read_Bit_Maps( s )
|
---|
| 230 | de_state *s;
|
---|
| 231 |
|
---|
| 232 | {
|
---|
| 233 | int i;
|
---|
| 234 |
|
---|
| 235 | if ( s->inode_maps > I_MAP_SLOTS || s->zone_maps > Z_MAP_SLOTS )
|
---|
| 236 | {
|
---|
| 237 | Warning( "Super block specifies too many bit map blocks" );
|
---|
| 238 | return;
|
---|
| 239 | }
|
---|
| 240 |
|
---|
| 241 | for ( i = 0; i < s->inode_maps; ++i )
|
---|
| 242 | {
|
---|
| 243 | Read_Disk( s, (long) (2 + i) * K,
|
---|
| 244 | (char *) &s->inode_map[ i * K / sizeof (bitchunk_t ) ] );
|
---|
| 245 | }
|
---|
| 246 |
|
---|
| 247 | for ( i = 0; i < s->zone_maps; ++i )
|
---|
| 248 | {
|
---|
| 249 | Read_Disk( s, (long) (2 + s->inode_maps + i) * K,
|
---|
| 250 | (char *) &s->zone_map[ i * K / sizeof (bitchunk_t ) ] );
|
---|
| 251 | }
|
---|
| 252 | }
|
---|
| 253 |
|
---|
| 254 |
|
---|
| 255 |
|
---|
| 256 |
|
---|
| 257 |
|
---|
| 258 |
|
---|
| 259 | /****************************************************************/
|
---|
| 260 | /* */
|
---|
| 261 | /* Search( state, string ) */
|
---|
| 262 | /* */
|
---|
| 263 | /* Search from the current address for the ASCII */
|
---|
| 264 | /* "string" on the device. */
|
---|
| 265 | /* */
|
---|
| 266 | /****************************************************************/
|
---|
| 267 |
|
---|
| 268 |
|
---|
| 269 | off_t Search( s, string )
|
---|
| 270 | de_state *s;
|
---|
| 271 | char *string;
|
---|
| 272 |
|
---|
| 273 | {
|
---|
| 274 | off_t address = s->address + 1;
|
---|
| 275 | off_t last_addr = address;
|
---|
| 276 | char buffer[ SEARCH_BUFFER ];
|
---|
| 277 | int offset;
|
---|
| 278 | int tail_length = strlen( string ) - 1;
|
---|
| 279 | int count = SEARCH_BUFFER;
|
---|
| 280 | int last_offset;
|
---|
| 281 |
|
---|
| 282 |
|
---|
| 283 | for ( ; count == SEARCH_BUFFER; address += SEARCH_BUFFER - tail_length )
|
---|
| 284 | {
|
---|
| 285 | if ( lseek( s->device_d, address, SEEK_SET ) == -1 )
|
---|
| 286 | Error( "Error seeking %s", s->device_name );
|
---|
| 287 |
|
---|
| 288 | if ( (count = read( s->device_d, buffer, SEARCH_BUFFER)) == -1 )
|
---|
| 289 | Error( "Error reading %s", s->device_name );
|
---|
| 290 |
|
---|
| 291 |
|
---|
| 292 | if ( address - last_addr >= 500L * K )
|
---|
| 293 | {
|
---|
| 294 | putchar( '.' );
|
---|
| 295 | fflush( stdout );
|
---|
| 296 |
|
---|
| 297 | last_addr += 500L * K;
|
---|
| 298 | }
|
---|
| 299 |
|
---|
| 300 |
|
---|
| 301 | last_offset = count - tail_length;
|
---|
| 302 |
|
---|
| 303 | for ( offset = 0; offset < last_offset; ++offset )
|
---|
| 304 | {
|
---|
| 305 | register char c = buffer[ offset ];
|
---|
| 306 |
|
---|
| 307 | if ( c == *string )
|
---|
| 308 | {
|
---|
| 309 | char *tail_buffer = &buffer[ offset + 1 ];
|
---|
| 310 | char *tail_string = string + 1;
|
---|
| 311 |
|
---|
| 312 | do
|
---|
| 313 | {
|
---|
| 314 | if ( *tail_string == '\0' )
|
---|
| 315 | return( address + offset );
|
---|
| 316 | }
|
---|
| 317 | while ( *tail_buffer++ == *tail_string++ );
|
---|
| 318 | }
|
---|
| 319 | } /* end for ( offset ) */
|
---|
| 320 | } /* end for ( address ) */
|
---|
| 321 |
|
---|
| 322 | return( -1L );
|
---|
| 323 | }
|
---|
| 324 |
|
---|
| 325 |
|
---|
| 326 |
|
---|
| 327 |
|
---|
| 328 |
|
---|
| 329 |
|
---|
| 330 | /****************************************************************/
|
---|
| 331 | /* */
|
---|
| 332 | /* Write_Word( state, word ) */
|
---|
| 333 | /* */
|
---|
| 334 | /* Write a word at address. */
|
---|
| 335 | /* */
|
---|
| 336 | /****************************************************************/
|
---|
| 337 |
|
---|
| 338 |
|
---|
| 339 | void Write_Word( s, word )
|
---|
| 340 | de_state *s;
|
---|
| 341 | word_t word;
|
---|
| 342 |
|
---|
| 343 | {
|
---|
| 344 | if ( s->address & 01 )
|
---|
| 345 | Error( "Internal fault (unaligned address)" );
|
---|
| 346 |
|
---|
| 347 | if ( lseek( s->device_d, s->address, SEEK_SET ) == -1 )
|
---|
| 348 | Error( "Error seeking %s", s->device_name );
|
---|
| 349 |
|
---|
| 350 | if ( write( s->device_d, (char *) &word, sizeof word ) != sizeof word )
|
---|
| 351 | Error( "Error writing %s", s->device_name );
|
---|
| 352 | }
|
---|