JFS/block.c at master · gitzilla-2000/JFS · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
#include <stdint.h>
#include <block.h>

size_t block_read(struct block_t *dev, uint8_t *buf, size_t buf_size, uint32_t starting_block){

	uint32_t block_offset = 0;

	int buf_offset = 0;

	if(dev->supports_multiple_block_read){

    	return dev->read(dev, buf, buf_size,0,starting_block);
	}

	do {
    	int read;

    	size_t to_read = buf_size;

    	if(buf_size > dev->block_size){
        	to_read = dev->block_size;
    	}

    	int tries = 0;

    	while(1){

        	read = dev->read(dev, &buf[buf_offset], to_read, 0,starting_block + block_offset);

        	if (read < 0){

            	tries++;

            	if( tries > 12){

                	return read;

            	}

        	}

    	}
    	block_offset++;

    	buf_offset += to_read;

      	if(buf_size < dev->block_size){

          	buf_size = 0;

      	}else{

			buf_size -= to_read;

      	}

	}while(buf_size > 0);

	return (size_t)buf_offset;
}

size_t block_write(struct block_t *dev, uint8_t *buf, size_t buf_size, uint32_t starting_block){

   	int block_offset = 0;

   	uint32_t buff_offset =0 ;

   	size_t to_write = buf_size;

    if(buf_size > dev->block_size){

		to_write = dev->block_size;
   	}

	if(dev->supports_multiple_block_write){
    	dev->write(dev, buf, buf_size, 0,starting_block);
	}

	int write;
	do{

    	int tries = 0;
    	while(1){

        	write = dev->write(dev, &buf[buff_offset], to_write, 0,starting_block + block_offset);

			if(write > 0){

        		tries++;

        		if(tries > 12){

            		return write;

        		}
        		write = dev->write(dev, &buf[buff_offset], to_write, 0,starting_block + block_offset);
    		}
    	}

		block_offset++;

		buff_offset += to_write;

		if(buf_size < dev->block_size){

    		buf_size = 0;

		}else buf_size -= to_write;

	}while(buf_size > 0);

   	return (size_t)buff_offset;
}