]> git.sesse.net Git - plocate/commitdiff
Rerun clang-format.
authorSteinar H. Gunderson <steinar+git@gunderson.no>
Wed, 30 Sep 2020 19:52:16 +0000 (21:52 +0200)
committerSteinar H. Gunderson <steinar+git@gunderson.no>
Wed, 30 Sep 2020 19:52:16 +0000 (21:52 +0200)
db.h
io_uring_engine.cpp
io_uring_engine.h
plocate-build.cpp
plocate.cpp

diff --git a/db.h b/db.h
index d4baf530096f0f640628b86b03623f6d168dfa24..dfdc0d58a36d5f2a964b4442191a9b88a04303d5 100644 (file)
--- a/db.h
+++ b/db.h
@@ -4,13 +4,13 @@
 #include <stdint.h>
 
 struct Header {
-       char magic[8]; // "\0plocate";
+       char magic[8];  // "\0plocate";
        uint32_t version;  // 0.
        uint32_t hashtable_size;
        uint32_t extra_ht_slots;
        uint64_t hash_table_offset_bytes;
        uint64_t filename_index_offset_bytes;
-}; 
+};
 
 struct Trigram {
        uint32_t trgm;
index 7714cdb4f8295f69f6909e712eaf3a9c2523e98f..fb0a4de443d25ec99ff13ff6c1b11ca6a5897962 100644 (file)
@@ -2,12 +2,12 @@
 #ifndef WITHOUT_URING
 #include <liburing.h>
 #endif
+#include "io_uring_engine.h"
+
+#include <functional>
+#include <memory>
 #include <stdint.h>
 #include <unistd.h>
-#include <memory>
-#include <functional>
-
-#include "io_uring_engine.h"
 
 using namespace std;
 
@@ -163,5 +163,3 @@ void complete_pread(int fd, void *ptr, size_t len, off_t offset)
                offset -= ret;
        }
 }
-
-
index 59a9d6651f506e28f9675e910e18fbba34dfd13d..232b636d73f1b6922cdd3f805c7593f3578870bc 100644 (file)
@@ -3,8 +3,8 @@
 
 #include <functional>
 #include <queue>
-#include <string>
 #include <stdint.h>
+#include <string>
 #ifndef WITHOUT_URING
 #include <liburing.h>
 #endif
index 40ce2ff893ad455e6816b73c43e567c0aea1ac16..37a3271c35efd2843c86a5d54d02246766524803 100644 (file)
@@ -1,3 +1,4 @@
+#include "db.h"
 #include "vp4.h"
 
 #include <algorithm>
@@ -19,8 +20,6 @@
 #include <vector>
 #include <zstd.h>
 
-#include "db.h"
-
 #define P4NENC_BOUND(n) ((n + 127) / 128 + (n + 32) * sizeof(uint32_t))
 #define dprintf(...)
 //#define dprintf(...) fprintf(stderr, __VA_ARGS__);
@@ -304,7 +303,7 @@ unique_ptr<Trigram[]> create_hashtable(const Corpus &corpus, const vector<uint32
        }
        for (uint32_t trgm : all_trigrams) {
                // We don't know offset yet, so set it to zero.
-               Trigram to_insert{trgm, uint32_t(corpus.invindex.find(trgm)->second.num_docids), 0};
+               Trigram to_insert{ trgm, uint32_t(corpus.invindex.find(trgm)->second.num_docids), 0 };
 
                uint32_t bucket = hash_trigram(trgm, ht_size);
                unsigned distance = 0;
@@ -375,7 +374,7 @@ void do_build(const char *infile, const char *outfile, int block_size)
        unique_ptr<Trigram[]> hashtable;
        uint32_t ht_size = next_prime(all_trigrams.size());
        constexpr unsigned num_overflow_slots = 16;
-       for ( ;; ) {
+       for (;;) {
                hashtable = create_hashtable(corpus, all_trigrams, ht_size, num_overflow_slots);
                if (hashtable == nullptr) {
                        dprintf("Failed creating hash table of size %u, increasing by 5%% and trying again.\n", ht_size);
index ea7a4e818e7eb5361a80894a5dedf5a12016c71e..672ba52981a832ebbf06636fa427549ce55ee577 100644 (file)
@@ -1,6 +1,6 @@
 #include "db.h"
-#include "vp4.h"
 #include "io_uring_engine.h"
+#include "vp4.h"
 
 #include <algorithm>
 #include <arpa/inet.h>
@@ -103,7 +103,8 @@ public:
        void find_trigram(uint32_t trgm, function<void(const Trigram *trgmptr, size_t len)> cb);
        void get_compressed_filename_block(uint32_t docid, function<void(string)> cb) const;
        size_t get_num_filename_blocks() const;
-       off_t offset_for_block(uint32_t docid) const {
+       off_t offset_for_block(uint32_t docid) const
+       {
                return hdr.filename_index_offset_bytes + docid * sizeof(uint64_t);
        }
 
@@ -197,7 +198,7 @@ size_t scan_file_block(const string &needle, string_view compressed,
        block.resize(uncompressed_len + 1);
 
        size_t err = ZSTD_decompress(&block[0], block.size(), compressed.data(),
-                       compressed.size());
+                                    compressed.size());
        if (ZSTD_isError(err)) {
                fprintf(stderr, "ZSTD_decompress(): %s\n", ZSTD_getErrorName(err));
                exit(1);
@@ -256,7 +257,7 @@ void scan_all_docids(const string &needle, int fd, const Corpus &corpus, IOUring
                for (uint32_t docid = io_docid; docid < last_docid; ++docid) {
                        size_t relative_offset = offsets[docid] - offsets[io_docid];
                        size_t len = offsets[docid + 1] - offsets[docid];
-                       scan_file_block(needle, {&compressed[relative_offset], len}, &access_rx_cache);
+                       scan_file_block(needle, { &compressed[relative_offset], len }, &access_rx_cache);
                }
        }
 }
@@ -339,7 +340,8 @@ void do_search_file(const string &needle, const char *filename)
                                break;
                }
                engine.submit_read(fd, len, trgmptr.offset, [trgmptr, len, &done, &in1, &in2, &out](string s) {
-                       if (done) return;
+                       if (done)
+                               return;
                        uint32_t trgm __attribute__((unused)) = trgmptr.trgm;
                        size_t num = trgmptr.num_docids;
                        unsigned char *pldata = reinterpret_cast<unsigned char *>(s.data());