@@ -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
- db1 , err := Open (DefaultOptions (s1Path ))
129
- if err != nil {
130
- t .Fatal (err )
131
- }
127
+ db1 , err := Open (getTestOptions (s1Path ))
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
- db2 , err := Open (DefaultOptions (s2Path ))
165
- if err != nil {
166
- t .Fatal (err )
167
- }
159
+ db2 , err := Open (getTestOptions (s2Path ))
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
- db3 , err := Open (DefaultOptions (s3Path ))
217
- if err != nil {
218
- t .Fatal (err )
219
- }
205
+ db3 , err := Open (getTestOptions (s3Path ))
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
}
@@ -326,9 +311,8 @@ func TestBackup(t *testing.T) {
326
311
func TestBackupRestore3 (t * testing.T ) {
327
312
var bb bytes.Buffer
328
313
tmpdir , err := ioutil .TempDir ("" , "badger-test" )
329
- if err != nil {
330
- t .Fatal (err )
331
- }
314
+ require .NoError (t , err )
315
+
332
316
defer removeDir (tmpdir )
333
317
334
318
N := 1000
@@ -337,9 +321,8 @@ func TestBackupRestore3(t *testing.T) {
337
321
// backup
338
322
{
339
323
db1 , err := Open (DefaultOptions (filepath .Join (tmpdir , "backup1" )))
340
- if err != nil {
341
- t .Fatal (err )
342
- }
324
+ require .NoError (t , err )
325
+
343
326
defer db1 .Close ()
344
327
require .NoError (t , populateEntries (db1 , entries ))
345
328
@@ -352,9 +335,8 @@ func TestBackupRestore3(t *testing.T) {
352
335
353
336
// restore
354
337
db2 , err := Open (DefaultOptions (filepath .Join (tmpdir , "restore1" )))
355
- if err != nil {
356
- t .Fatal (err )
357
- }
338
+ require .NoError (t , err )
339
+
358
340
defer db2 .Close ()
359
341
require .NoError (t , db2 .Load (& bb , 16 ))
360
342
@@ -385,9 +367,8 @@ func TestBackupRestore3(t *testing.T) {
385
367
386
368
func TestBackupLoadIncremental (t * testing.T ) {
387
369
tmpdir , err := ioutil .TempDir ("" , "badger-test" )
388
- if err != nil {
389
- t .Fatal (err )
390
- }
370
+ require .NoError (t , err )
371
+
391
372
defer removeDir (tmpdir )
392
373
393
374
N := 100
@@ -398,9 +379,8 @@ func TestBackupLoadIncremental(t *testing.T) {
398
379
// backup
399
380
{
400
381
db1 , err := Open (DefaultOptions (filepath .Join (tmpdir , "backup2" )))
401
- if err != nil {
402
- t .Fatal (err )
403
- }
382
+ require .NoError (t , err )
383
+
404
384
defer db1 .Close ()
405
385
406
386
require .NoError (t , populateEntries (db1 , entries ))
@@ -458,10 +438,9 @@ func TestBackupLoadIncremental(t *testing.T) {
458
438
require .True (t , bb .Len () > 0 )
459
439
460
440
// restore
461
- db2 , err := Open (DefaultOptions (filepath .Join (tmpdir , "restore2" )))
462
- if err != nil {
463
- t .Fatal (err )
464
- }
441
+ db2 , err := Open (getTestOptions (filepath .Join (tmpdir , "restore2" )))
442
+ require .NoError (t , err )
443
+
465
444
defer db2 .Close ()
466
445
467
446
require .NoError (t , db2 .Load (& bb , 16 ))
0 commit comments