/root/bitcoin/src/leveldb/db/builder.cc
Line | Count | Source |
1 | | // Copyright (c) 2011 The LevelDB Authors. All rights reserved. |
2 | | // Use of this source code is governed by a BSD-style license that can be |
3 | | // found in the LICENSE file. See the AUTHORS file for names of contributors. |
4 | | |
5 | | #include "db/builder.h" |
6 | | |
7 | | #include "db/dbformat.h" |
8 | | #include "db/filename.h" |
9 | | #include "db/table_cache.h" |
10 | | #include "db/version_edit.h" |
11 | | #include "leveldb/db.h" |
12 | | #include "leveldb/env.h" |
13 | | #include "leveldb/iterator.h" |
14 | | |
15 | | namespace leveldb { |
16 | | |
17 | | Status BuildTable(const std::string& dbname, Env* env, const Options& options, |
18 | 254k | TableCache* table_cache, Iterator* iter, FileMetaData* meta) { |
19 | 254k | Status s; |
20 | 254k | meta->file_size = 0; |
21 | 254k | iter->SeekToFirst(); |
22 | | |
23 | 254k | std::string fname = TableFileName(dbname, meta->number); |
24 | 254k | if (iter->Valid()) { Branch (24:7): [True: 200k, False: 53.9k]
|
25 | 200k | WritableFile* file; |
26 | 200k | s = env->NewWritableFile(fname, &file); |
27 | 200k | if (!s.ok()) { Branch (27:9): [True: 0, False: 200k]
|
28 | 0 | return s; |
29 | 0 | } |
30 | | |
31 | 200k | TableBuilder* builder = new TableBuilder(options, file); |
32 | 200k | meta->smallest.DecodeFrom(iter->key()); |
33 | 18.5M | for (; iter->Valid(); iter->Next()) { Branch (33:12): [True: 18.3M, False: 200k]
|
34 | 18.3M | Slice key = iter->key(); |
35 | 18.3M | meta->largest.DecodeFrom(key); |
36 | 18.3M | builder->Add(key, iter->value()); |
37 | 18.3M | } |
38 | | |
39 | | // Finish and check for builder errors |
40 | 200k | s = builder->Finish(); |
41 | 200k | if (s.ok()) { Branch (41:9): [True: 200k, False: 0]
|
42 | 200k | meta->file_size = builder->FileSize(); |
43 | 200k | assert(meta->file_size > 0); Branch (43:7): [True: 200k, False: 0]
|
44 | 200k | } |
45 | 200k | delete builder; |
46 | | |
47 | | // Finish and check for file errors |
48 | 200k | if (s.ok()) { Branch (48:9): [True: 200k, False: 0]
|
49 | 200k | s = file->Sync(); |
50 | 200k | } |
51 | 200k | if (s.ok()) { Branch (51:9): [True: 200k, False: 0]
|
52 | 200k | s = file->Close(); |
53 | 200k | } |
54 | 200k | delete file; |
55 | 200k | file = nullptr; |
56 | | |
57 | 200k | if (s.ok()) { Branch (57:9): [True: 200k, False: 0]
|
58 | | // Verify that the table is usable |
59 | 200k | Iterator* it = table_cache->NewIterator(ReadOptions(), meta->number, |
60 | 200k | meta->file_size); |
61 | 200k | s = it->status(); |
62 | 200k | delete it; |
63 | 200k | } |
64 | 200k | } |
65 | | |
66 | | // Check for input iterator errors |
67 | 254k | if (!iter->status().ok()) { Branch (67:7): [True: 0, False: 254k]
|
68 | 0 | s = iter->status(); |
69 | 0 | } |
70 | | |
71 | 254k | if (s.ok() && meta->file_size > 0) { Branch (71:7): [True: 254k, False: 0]
Branch (71:17): [True: 200k, False: 53.9k]
|
72 | | // Keep it |
73 | 200k | } else { |
74 | 53.9k | env->DeleteFile(fname); |
75 | 53.9k | } |
76 | 254k | return s; |
77 | 254k | } |
78 | | |
79 | | } // namespace leveldb |