1 7a4ee46d 2003-11-23 devnull #include "stdinc.h"
2 7a4ee46d 2003-11-23 devnull #include "dat.h"
3 7a4ee46d 2003-11-23 devnull #include "fns.h"
5 7a4ee46d 2003-11-23 devnull u32int maxblocksize;
6 7a4ee46d 2003-11-23 devnull int readonly;
9 7a4ee46d 2003-11-23 devnull initpart(char *name, int writable)
11 7a4ee46d 2003-11-23 devnull Part *part;
12 7a4ee46d 2003-11-23 devnull Dir *dir;
15 7a4ee46d 2003-11-23 devnull part = MK(Part);
16 7a4ee46d 2003-11-23 devnull part->name = estrdup(name);
17 7a4ee46d 2003-11-23 devnull if(!writable && readonly)
18 7a4ee46d 2003-11-23 devnull how = OREAD;
20 7a4ee46d 2003-11-23 devnull how = ORDWR;
21 7a4ee46d 2003-11-23 devnull part->fd = open(name, how);
22 7a4ee46d 2003-11-23 devnull if(part->fd < 0){
23 7a4ee46d 2003-11-23 devnull if(how == ORDWR)
24 7a4ee46d 2003-11-23 devnull part->fd = open(name, OREAD);
25 7a4ee46d 2003-11-23 devnull if(part->fd < 0){
26 7a4ee46d 2003-11-23 devnull freepart(part);
27 7a4ee46d 2003-11-23 devnull seterr(EOk, "can't open partition='%s': %r", name);
28 7a4ee46d 2003-11-23 devnull return nil;
30 7a4ee46d 2003-11-23 devnull fprint(2, "warning: %s opened for reading only\n", name);
32 7a4ee46d 2003-11-23 devnull dir = dirfstat(part->fd);
33 7a4ee46d 2003-11-23 devnull if(dir == nil){
34 7a4ee46d 2003-11-23 devnull freepart(part);
35 7a4ee46d 2003-11-23 devnull seterr(EOk, "can't stat partition='%s': %r", name);
36 7a4ee46d 2003-11-23 devnull return nil;
38 7a4ee46d 2003-11-23 devnull part->size = dir->length;
39 7a4ee46d 2003-11-23 devnull part->blocksize = 0;
40 7a4ee46d 2003-11-23 devnull free(dir);
41 7a4ee46d 2003-11-23 devnull return part;
45 7a4ee46d 2003-11-23 devnull freepart(Part *part)
47 7a4ee46d 2003-11-23 devnull if(part == nil)
49 7a4ee46d 2003-11-23 devnull close(part->fd);
50 7a4ee46d 2003-11-23 devnull free(part->name);
51 7a4ee46d 2003-11-23 devnull free(part);
55 7a4ee46d 2003-11-23 devnull partblocksize(Part *part, u32int blocksize)
57 7a4ee46d 2003-11-23 devnull if(part->blocksize)
58 7a4ee46d 2003-11-23 devnull sysfatal("resetting partition=%s's block size", part->name);
59 7a4ee46d 2003-11-23 devnull part->blocksize = blocksize;
60 7a4ee46d 2003-11-23 devnull if(blocksize > maxblocksize)
61 7a4ee46d 2003-11-23 devnull maxblocksize = blocksize;
65 7a4ee46d 2003-11-23 devnull writepart(Part *part, u64int addr, u8int *buf, u32int n)
67 7a4ee46d 2003-11-23 devnull long m, mm, nn;
69 7a4ee46d 2003-11-23 devnull qlock(&stats.lock);
70 7a4ee46d 2003-11-23 devnull stats.diskwrites++;
71 7a4ee46d 2003-11-23 devnull stats.diskbwrites += n;
72 7a4ee46d 2003-11-23 devnull qunlock(&stats.lock);
74 7a4ee46d 2003-11-23 devnull if(addr > part->size || addr + n > part->size){
75 7a4ee46d 2003-11-23 devnull seterr(ECorrupt, "out of bounds write to partition='%s'", part->name);
76 7a4ee46d 2003-11-23 devnull return -1;
78 7a4ee46d 2003-11-23 devnull print("write %s %lud at %llud\n", part->name, n, addr);
79 7a4ee46d 2003-11-23 devnull for(nn = 0; nn < n; nn += m){
80 7a4ee46d 2003-11-23 devnull mm = n - nn;
81 7a4ee46d 2003-11-23 devnull if(mm > MaxIo)
82 7a4ee46d 2003-11-23 devnull mm = MaxIo;
83 7a4ee46d 2003-11-23 devnull m = pwrite(part->fd, &buf[nn], mm, addr + nn);
84 7a4ee46d 2003-11-23 devnull if(m != mm){
85 7a4ee46d 2003-11-23 devnull if(m < 0){
86 7a4ee46d 2003-11-23 devnull seterr(EOk, "can't write partition='%s': %r", part->name);
87 7a4ee46d 2003-11-23 devnull return -1;
89 7a4ee46d 2003-11-23 devnull logerr(EOk, "truncated write to partition='%s' n=%ld wrote=%ld", part->name, mm, m);
92 7a4ee46d 2003-11-23 devnull return 0;
96 7a4ee46d 2003-11-23 devnull readpart(Part *part, u64int addr, u8int *buf, u32int n)
98 7a4ee46d 2003-11-23 devnull long m, mm, nn;
101 7a4ee46d 2003-11-23 devnull qlock(&stats.lock);
102 7a4ee46d 2003-11-23 devnull stats.diskreads++;
103 7a4ee46d 2003-11-23 devnull stats.diskbreads += n;
104 7a4ee46d 2003-11-23 devnull qunlock(&stats.lock);
106 7a4ee46d 2003-11-23 devnull if(addr > part->size || addr + n > part->size){
107 7a4ee46d 2003-11-23 devnull seterr(ECorrupt, "out of bounds read from partition='%s': addr=%lld n=%d size=%lld", part->name, addr, n, part->size);
108 7a4ee46d 2003-11-23 devnull return -1;
110 7a4ee46d 2003-11-23 devnull print("read %s %lud at %llud\n", part->name, n, addr);
111 7a4ee46d 2003-11-23 devnull for(nn = 0; nn < n; nn += m){
112 7a4ee46d 2003-11-23 devnull mm = n - nn;
113 7a4ee46d 2003-11-23 devnull if(mm > MaxIo)
114 7a4ee46d 2003-11-23 devnull mm = MaxIo;
116 7a4ee46d 2003-11-23 devnull for(i=0; i<4; i++) {
117 7a4ee46d 2003-11-23 devnull m = pread(part->fd, &buf[nn], mm, addr + nn);
118 7a4ee46d 2003-11-23 devnull if(m == mm)
121 7a4ee46d 2003-11-23 devnull if(m != mm){
122 7a4ee46d 2003-11-23 devnull if(m < 0){
123 7a4ee46d 2003-11-23 devnull seterr(EOk, "can't read partition='%s': %r", part->name);
124 7a4ee46d 2003-11-23 devnull return -1;
126 7a4ee46d 2003-11-23 devnull logerr(EOk, "warning: truncated read from partition='%s' n=%ld read=%ld", part->name, mm, m);
129 7a4ee46d 2003-11-23 devnull return 0;
