@@ -116,19 +116,17 @@ func TestBackupRestore1(t *testing.T) {
116
116
117
117
func TestBackupRestore2 (t * testing.T ) {
118
118
tmpdir , err := ioutil .TempDir ("" , "badger-test" )
119
- if err != nil {
120
- t .Fatal (err )
121
- }
119
+ require .NoError (t , err )
120
+
122
121
defer removeDir (tmpdir )
123
122
124
123
s1Path := filepath .Join (tmpdir , "test1" )
125
124
s2Path := filepath .Join (tmpdir , "test2" )
126
125
s3Path := filepath .Join (tmpdir , "test3" )
127
126
128
127
db1 , err := Open (getTestOptions (s1Path ))
129
- if err != nil {
130
- t .Fatal (err )
131
- }
128
+ require .NoError (t , err )
129
+
132
130
defer db1 .Close ()
133
131
key1 := []byte ("key1" )
134
132
key2 := []byte ("key2" )
@@ -140,36 +138,30 @@ func TestBackupRestore2(t *testing.T) {
140
138
}
141
139
return tx .SetEntry (NewEntry (key2 , rawValue ))
142
140
})
143
- if err != nil {
144
- t .Fatal (err )
145
- }
141
+ require .NoError (t , err )
142
+
146
143
for i := byte (1 ); i < N ; i ++ {
147
144
err = db1 .Update (func (tx * Txn ) error {
148
145
if err := tx .SetEntry (NewEntry (append (key1 , i ), rawValue )); err != nil {
149
146
return err
150
147
}
151
148
return tx .SetEntry (NewEntry (append (key2 , i ), rawValue ))
152
149
})
153
- if err != nil {
154
- t .Fatal (err )
155
- }
150
+ require .NoError (t , err )
151
+
156
152
}
157
153
var backup bytes.Buffer
158
154
_ , err = db1 .Backup (& backup , 0 )
159
- if err != nil {
160
- t .Fatal (err )
161
- }
155
+ require .NoError (t , err )
156
+
162
157
fmt .Println ("backup1 length:" , backup .Len ())
163
158
164
159
db2 , err := Open (getTestOptions (s2Path ))
165
- if err != nil {
166
- t .Fatal (err )
167
- }
160
+ require .NoError (t , err )
161
+
168
162
defer db2 .Close ()
169
163
err = db2 .Load (& backup , 16 )
170
- if err != nil {
171
- t .Fatal (err )
172
- }
164
+ require .NoError (t , err )
173
165
174
166
for i := byte (1 ); i < N ; i ++ {
175
167
err = db2 .View (func (tx * Txn ) error {
@@ -190,9 +182,8 @@ func TestBackupRestore2(t *testing.T) {
190
182
}
191
183
return nil
192
184
})
193
- if err != nil {
194
- t .Fatal (err )
195
- }
185
+ require .NoError (t , err )
186
+
196
187
}
197
188
198
189
for i := byte (1 ); i < N ; i ++ {
@@ -202,27 +193,22 @@ func TestBackupRestore2(t *testing.T) {
202
193
}
203
194
return tx .SetEntry (NewEntry (append (key2 , i ), rawValue ))
204
195
})
205
- if err != nil {
206
- t .Fatal (err )
207
- }
196
+ require .NoError (t , err )
197
+
208
198
}
209
199
210
200
backup .Reset ()
211
201
_ , err = db2 .Backup (& backup , 0 )
212
- if err != nil {
213
- t .Fatal (err )
214
- }
202
+ require .NoError (t , err )
203
+
215
204
fmt .Println ("backup2 length:" , backup .Len ())
216
205
db3 , err := Open (getTestOptions (s3Path ))
217
- if err != nil {
218
- t .Fatal (err )
219
- }
206
+ require .NoError (t , err )
207
+
220
208
defer db3 .Close ()
221
209
222
210
err = db3 .Load (& backup , 16 )
223
- if err != nil {
224
- t .Fatal (err )
225
- }
211
+ require .NoError (t , err )
226
212
227
213
for i := byte (1 ); i < N ; i ++ {
228
214
err = db3 .View (func (tx * Txn ) error {
@@ -243,9 +229,8 @@ func TestBackupRestore2(t *testing.T) {
243
229
}
244
230
return nil
245
231
})
246
- if err != nil {
247
- t .Fatal (err )
248
- }
232
+ require .NoError (t , err )
233
+
249
234
}
250
235
251
236
}
@@ -313,9 +298,8 @@ func TestBackup(t *testing.T) {
313
298
}
314
299
t .Run ("disk mode" , func (t * testing.T ) {
315
300
tmpdir , err := ioutil .TempDir ("" , "badger-test" )
316
- if err != nil {
317
- t .Fatal (err )
318
- }
301
+ require .NoError (t , err )
302
+
319
303
defer removeDir (tmpdir )
320
304
opt := DefaultOptions (filepath .Join (tmpdir , "backup0" ))
321
305
runBadgerTest (t , & opt , func (t * testing.T , db * DB ) {
@@ -334,9 +318,8 @@ func TestBackup(t *testing.T) {
334
318
func TestBackupRestore3 (t * testing.T ) {
335
319
var bb bytes.Buffer
336
320
tmpdir , err := ioutil .TempDir ("" , "badger-test" )
337
- if err != nil {
338
- t .Fatal (err )
339
- }
321
+ require .NoError (t , err )
322
+
340
323
defer removeDir (tmpdir )
341
324
342
325
N := 1000
@@ -345,9 +328,8 @@ func TestBackupRestore3(t *testing.T) {
345
328
// backup
346
329
{
347
330
db1 , err := Open (DefaultOptions (filepath .Join (tmpdir , "backup1" )))
348
- if err != nil {
349
- t .Fatal (err )
350
- }
331
+ require .NoError (t , err )
332
+
351
333
defer db1 .Close ()
352
334
require .NoError (t , populateEntries (db1 , entries ))
353
335
@@ -360,9 +342,8 @@ func TestBackupRestore3(t *testing.T) {
360
342
361
343
// restore
362
344
db2 , err := Open (DefaultOptions (filepath .Join (tmpdir , "restore1" )))
363
- if err != nil {
364
- t .Fatal (err )
365
- }
345
+ require .NoError (t , err )
346
+
366
347
defer db2 .Close ()
367
348
require .NoError (t , db2 .Load (& bb , 16 ))
368
349
@@ -393,9 +374,8 @@ func TestBackupRestore3(t *testing.T) {
393
374
394
375
func TestBackupLoadIncremental (t * testing.T ) {
395
376
tmpdir , err := ioutil .TempDir ("" , "badger-test" )
396
- if err != nil {
397
- t .Fatal (err )
398
- }
377
+ require .NoError (t , err )
378
+
399
379
defer removeDir (tmpdir )
400
380
401
381
N := 100
@@ -406,9 +386,8 @@ func TestBackupLoadIncremental(t *testing.T) {
406
386
// backup
407
387
{
408
388
db1 , err := Open (DefaultOptions (filepath .Join (tmpdir , "backup2" )))
409
- if err != nil {
410
- t .Fatal (err )
411
- }
389
+ require .NoError (t , err )
390
+
412
391
defer db1 .Close ()
413
392
414
393
require .NoError (t , populateEntries (db1 , entries ))
@@ -467,9 +446,8 @@ func TestBackupLoadIncremental(t *testing.T) {
467
446
468
447
// restore
469
448
db2 , err := Open (getTestOptions (filepath .Join (tmpdir , "restore2" )))
470
- if err != nil {
471
- t .Fatal (err )
472
- }
449
+ require .NoError (t , err )
450
+
473
451
defer db2 .Close ()
474
452
475
453
require .NoError (t , db2 .Load (& bb , 16 ))
0 commit comments