@@ -37,26 +37,18 @@ struct sqliterk {
37
37
};
38
38
39
39
//declaration
40
- static void sqliterkNotify_onBeginParseBtree (sqliterk * rk ,
41
- sqliterk_btree * btree );
42
- static void
43
- sqliterkNotify_onEndParseBtree (sqliterk * rk , sqliterk_btree * btree , int result );
40
+ static void sqliterkNotify_onBeginParseBtree (sqliterk * rk , sqliterk_btree * btree );
41
+ static void sqliterkNotify_onEndParseBtree (sqliterk * rk , sqliterk_btree * btree , int result );
44
42
static int sqliterkNotify_onParseColumn (sqliterk * rk ,
45
43
sqliterk_btree * btree ,
46
44
sqliterk_page * page ,
47
45
sqliterk_column * column );
48
- static int sqliterkNotify_onBeginParsePage (sqliterk * rk ,
49
- sqliterk_btree * btree ,
50
- int pageno );
51
- static void sqliterkNotify_onEndParsePage (sqliterk * rk ,
52
- sqliterk_btree * btree ,
53
- int pageno ,
54
- int result );
46
+ static int sqliterkNotify_onBeginParsePage (sqliterk * rk , sqliterk_btree * btree , int pageno );
47
+ static void
48
+ sqliterkNotify_onEndParsePage (sqliterk * rk , sqliterk_btree * btree , int pageno , int result );
55
49
static int sqliterkParseBtree (sqliterk * rk , sqliterk_btree * btree );
56
50
57
- int sqliterkOpen (const char * path ,
58
- const sqliterk_cipher_conf * cipher ,
59
- sqliterk * * rk )
51
+ int sqliterkOpen (const char * path , const sqliterk_cipher_conf * cipher , sqliterk * * rk )
60
52
{
61
53
if (!rk ) {
62
54
return SQLITERK_MISUSE ;
@@ -65,8 +57,7 @@ int sqliterkOpen(const char *path,
65
57
sqliterk * therk = sqliterkOSMalloc (sizeof (sqliterk ));
66
58
if (!therk ) {
67
59
rc = SQLITERK_NOMEM ;
68
- sqliterkOSError (rc , "Not enough memory, required: %zu bytes" ,
69
- sizeof (sqliterk ));
60
+ sqliterkOSError (rc , "Not enough memory, required: %zu bytes" , sizeof (sqliterk ));
70
61
goto sqliterkOpen_Failed ;
71
62
}
72
63
@@ -83,8 +74,8 @@ int sqliterkOpen(const char *path,
83
74
therk -> recursive = 1 ;
84
75
85
76
* rk = therk ;
86
- sqliterkOSInfo (SQLITERK_OK , "RepairKit on '%s' opened, %s." , path ,
87
- cipher ? "encrypted" : "plain-text" );
77
+ sqliterkOSInfo (
78
+ SQLITERK_OK , "RepairKit on '%s' opened, %s." , path , cipher ? "encrypted" : "plain-text" );
88
79
return SQLITERK_OK ;
89
80
90
81
sqliterkOpen_Failed :
@@ -119,8 +110,7 @@ int sqliterkParsePage(sqliterk *rk, int pageno)
119
110
if (!rk ) {
120
111
return SQLITERK_MISUSE ;
121
112
}
122
- if (sqliterkPagerGetStatus (rk -> pager , pageno ) !=
123
- sqliterk_status_unchecked ) {
113
+ if (sqliterkPagerGetStatus (rk -> pager , pageno ) != sqliterk_status_unchecked ) {
124
114
return SQLITERK_OK ;
125
115
}
126
116
int rc = SQLITERK_OK ;
@@ -173,21 +163,20 @@ int sqliterkClose(sqliterk *rk)
173
163
return SQLITERK_OK ;
174
164
}
175
165
176
- static void sqliterkNotify_onBeginParseBtree (sqliterk * rk ,
177
- sqliterk_btree * btree )
166
+ static void sqliterkNotify_onBeginParseBtree (sqliterk * rk , sqliterk_btree * btree )
178
167
{
179
168
if (rk -> notify .onBeginParseTable ) {
180
169
rk -> notify .onBeginParseTable (rk , (sqliterk_table * ) btree );
181
170
}
182
171
sqliterk_page * rootpage = sqliterkBtreeGetRootPage (btree );
183
- sqliterkOSDebug (
184
- SQLITERK_OK , "Parsing B-tree -> [root: %d, name: %s, type: %s]" ,
185
- sqliterkPageGetPageno (rootpage ), sqliterkBtreeGetName (btree ),
186
- sqliterkBtreeGetTypeName (sqliterkBtreeGetType (btree )));
172
+ sqliterkOSDebug (SQLITERK_OK ,
173
+ "Parsing B-tree -> [root: %d, name: %s, type: %s]" ,
174
+ sqliterkPageGetPageno (rootpage ),
175
+ sqliterkBtreeGetName (btree ),
176
+ sqliterkBtreeGetTypeName (sqliterkBtreeGetType (btree )));
187
177
}
188
178
189
- static void
190
- sqliterkNotify_onEndParseBtree (sqliterk * rk , sqliterk_btree * btree , int result )
179
+ static void sqliterkNotify_onEndParseBtree (sqliterk * rk , sqliterk_btree * btree , int result )
191
180
{
192
181
if (rk -> notify .onEndParseTable ) {
193
182
rk -> notify .onEndParseTable (rk , (sqliterk_table * ) btree );
@@ -210,24 +199,21 @@ static int sqliterkNotify_onParseColumn(sqliterk *rk,
210
199
return result ;
211
200
} else if (result != SQLITERK_OK ) {
212
201
int pageno = sqliterkPageGetPageno (page );
213
- sqliterkPagerSetStatus (rk -> pager , pageno ,
214
- sqliterk_status_discarded );
215
- sqliterk_values * overflowPages =
216
- sqliterkColumnGetOverflowPages (column );
202
+ sqliterkPagerSetStatus (rk -> pager , pageno , sqliterk_status_discarded );
203
+ sqliterk_values * overflowPages = sqliterkColumnGetOverflowPages (column );
217
204
218
205
int i ;
219
206
for (i = 0 ; i < sqliterkValuesGetCount (overflowPages ); i ++ ) {
220
- sqliterkPagerSetStatus (
221
- rk -> pager , sqliterkValuesGetInteger (overflowPages , i ),
222
- sqliterk_status_discarded );
207
+ sqliterkPagerSetStatus (rk -> pager ,
208
+ sqliterkValuesGetInteger (overflowPages , i ),
209
+ sqliterk_status_discarded );
223
210
}
224
211
}
225
212
} else {
226
213
result = SQLITERK_OK ;
227
214
}
228
215
229
- if (sqliterkBtreeGetType (btree ) == sqliterk_btree_type_master &&
230
- rk -> recursive ) {
216
+ if (sqliterkBtreeGetType (btree ) == sqliterk_btree_type_master && rk -> recursive ) {
231
217
// Recursively decode the page since the mapping of [table]->[rootPageno] is known
232
218
sqliterk_values * values = sqliterkColumnGetValues (column );
233
219
const char * type = sqliterkValuesGetText (values , 0 );
@@ -239,26 +225,22 @@ static int sqliterkNotify_onParseColumn(sqliterk *rk,
239
225
rc = sqliterkBtreeOpen (rk , rk -> pager , rootPageno , & subbtree );
240
226
if (rc == SQLITERK_OK ) {
241
227
if (memcmp ("table" , type , 5 ) == 0 ) {
242
- sqliterkBtreeSetMeta (subbtree , name ,
243
- sqliterk_btree_type_table );
228
+ sqliterkBtreeSetMeta (subbtree , name , sqliterk_btree_type_table );
244
229
} else if (memcmp ("index" , type , 5 ) == 0 ) {
245
- sqliterkBtreeSetMeta (subbtree , name ,
246
- sqliterk_btree_type_index );
230
+ sqliterkBtreeSetMeta (subbtree , name , sqliterk_btree_type_index );
247
231
} else {
248
- sqliterkBtreeSetMeta (subbtree , name ,
249
- sqliterk_btree_type_unknown );
232
+ sqliterkBtreeSetMeta (subbtree , name , sqliterk_btree_type_unknown );
250
233
}
251
234
rc = sqliterkParseBtree (rk , subbtree );
252
235
}
253
236
if (rc != SQLITERK_OK ) {
254
237
sqliterk_page * rootpage = sqliterkBtreeGetRootPage (subbtree );
255
- sqliterkOSError (
256
- rc ,
257
- "sqliterkNotify_onParseColumn: failed to parse known "
258
- "table with root page no. %d, name %s, type %s" ,
259
- sqliterkPageGetPageno (rootpage ),
260
- sqliterkBtreeGetName (subbtree ),
261
- sqliterkBtreeGetTypeName (sqliterkBtreeGetType (subbtree )));
238
+ sqliterkOSError (rc ,
239
+ "sqliterkNotify_onParseColumn: failed to parse known "
240
+ "table with root page no. %d, name %s, type %s" ,
241
+ sqliterkPageGetPageno (rootpage ),
242
+ sqliterkBtreeGetName (subbtree ),
243
+ sqliterkBtreeGetTypeName (sqliterkBtreeGetType (subbtree )));
262
244
}
263
245
if (subbtree ) {
264
246
sqliterkBtreeClose (subbtree );
@@ -269,8 +251,7 @@ static int sqliterkNotify_onParseColumn(sqliterk *rk,
269
251
return result ;
270
252
}
271
253
272
- static int
273
- sqliterkNotify_onBeginParsePage (sqliterk * rk , sqliterk_btree * btree , int pageno )
254
+ static int sqliterkNotify_onBeginParsePage (sqliterk * rk , sqliterk_btree * btree , int pageno )
274
255
{
275
256
//sqliterkOSDebug(SQLITERK_OK, "sqliterkNotify_onBeginParsePage: %d", pageno);
276
257
if (sqliterkPagerGetStatus (rk -> pager , pageno ) == sqliterk_status_checking ) {
@@ -280,30 +261,26 @@ sqliterkNotify_onBeginParsePage(sqliterk *rk, sqliterk_btree *btree, int pageno)
280
261
return SQLITERK_OK ;
281
262
}
282
263
283
- static void sqliterkNotify_onEndParsePage (sqliterk * rk ,
284
- sqliterk_btree * btree ,
285
- int pageno ,
286
- int result )
264
+ static void
265
+ sqliterkNotify_onEndParsePage (sqliterk * rk , sqliterk_btree * btree , int pageno , int result )
287
266
{
288
267
if (!rk ) {
289
268
return ;
290
269
}
291
270
switch (result ) {
292
- case SQLITERK_OK :
293
- sqliterkPagerSetStatus (rk -> pager , pageno , sqliterk_status_checked );
294
- break ;
295
- case SQLITERK_DAMAGED :
296
- sqliterkPagerSetStatus (rk -> pager , pageno , sqliterk_status_damaged );
297
- break ;
298
- case SQLITERK_CANCELLED :
299
- sqliterkOSDebug (SQLITERK_CANCELLED , "Cancelled parsing page %d." ,
300
- pageno );
301
- break ;
302
- default :
303
- sqliterkOSWarning (SQLITERK_MISUSE ,
304
- "Cannot parse page %d. Invalid type." , pageno );
305
- sqliterkPagerSetStatus (rk -> pager , pageno , sqliterk_status_invalid );
306
- break ;
271
+ case SQLITERK_OK :
272
+ sqliterkPagerSetStatus (rk -> pager , pageno , sqliterk_status_checked );
273
+ break ;
274
+ case SQLITERK_DAMAGED :
275
+ sqliterkPagerSetStatus (rk -> pager , pageno , sqliterk_status_damaged );
276
+ break ;
277
+ case SQLITERK_CANCELLED :
278
+ sqliterkOSDebug (SQLITERK_CANCELLED , "Cancelled parsing page %d." , pageno );
279
+ break ;
280
+ default :
281
+ sqliterkOSWarning (SQLITERK_MISUSE , "Cannot parse page %d. Invalid type." , pageno );
282
+ sqliterkPagerSetStatus (rk -> pager , pageno , sqliterk_status_invalid );
283
+ break ;
307
284
}
308
285
//sqliterkOSDebug(result, "sqliterkNotify_onEndParsePage: %d", pageno);
309
286
if (rk -> notify .didParsePage ) {
0 commit comments