nostr/strfry
1
0
Fork 0
mirror of https://github.com/hoytech/strfry.git synced 2025-06-17 08:48:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

optimise import

Browse Source
This commit is contained in:
Doug Hoyte
2024-08-31 00:29:34 -04:00
parent 2b10fea6e7
commit 684d083c6b
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/apps/dbutils/cmd_import.cpp
View File

@ -1,3 +1,6 @@
#include <stdio.h>
#include <stdlib.h>
#include <iostream> #include <iostream>
#include <docopt.h> #include <docopt.h>
@ -37,11 +40,11 @@ void cmd_import(const std::vector<std::string> &subArgs) {
bool showRejected = args["--show-rejected"].asBool(); bool showRejected = args["--show-rejected"].asBool();
bool noVerify = args["--no-verify"].asBool(); bool noVerify = args["--no-verify"].asBool();
bool fried = args["--fried"].asBool();
uint64_t debounceMillis = 1'000; uint64_t debounceMillis = 1'000;
if (args["--debounce-millis"]) debounceMillis = args["--debounce-millis"].asLong(); if (args["--debounce-millis"]) debounceMillis = args["--debounce-millis"].asLong();
uint64_t writeBatch = 10'000; uint64_t writeBatch = fried ? 100'000 : 10'000;
if (args["--write-batch"]) writeBatch = args["--write-batch"].asLong(); if (args["--write-batch"]) writeBatch = args["--write-batch"].asLong();
bool fried = args["--fried"].asBool();
if (noVerify) LW << "not verifying event IDs or signatures!"; if (noVerify) LW << "not verifying event IDs or signatures!";
@ -58,13 +61,16 @@ void cmd_import(const std::vector<std::string> &subArgs) {
<< ". Processed " << writer.totalProcessed << " lines. " << writer.totalWritten << " added, " << writer.totalRejected << " rejected, " << writer.totalDups << " dups"; << ". Processed " << writer.totalProcessed << " lines. " << writer.totalWritten << " added, " << writer.totalRejected << " rejected, " << writer.totalDups << " dups";
}; };
std::string line; size_t bufLen = 65536;
char *buf = (char*)::malloc(bufLen);
uint64_t currLine = 0; uint64_t currLine = 0;
while (std::cin) { while (ssize_t numRead = ::getline(&buf, &bufLen, ::stdin)) {
if (numRead <= 0) break;
currLine++; currLine++;
std::getline(std::cin, line);
if (!line.size()) continue; std::string line(buf, (size_t)numRead-1);
if (fried) { if (fried) {
try { try {