appaquet

goroutine 5464 [running]:
runtime/pprof.writeGoroutineStacks({0xe5bb60, 0xc0002000e0})
	/usr/local/go/src/runtime/pprof/pprof.go:692 +0x70
runtime/pprof.writeGoroutine({0xe5bb60?, 0xc0002000e0?}, 0xc00072a270?)
	/usr/local/go/src/runtime/pprof/pprof.go:681 +0x2b
runtime/pprof.(*Profile).WriteTo(0xc9ab40?, {0xe5bb60?, 0xc0002000e0?}, 0xc?)
	/usr/local/go/src/runtime/pprof/pprof.go:330 +0x14b
net/http/pprof.handler.ServeHTTP({0xc000112191, 0x9}, {0xe61190, 0xc0002000e0}, 0x736f686c61636f6c?)
	/usr/local/go/src/net/http/pprof/pprof.go:253 +0x4a5
net/http/pprof.Index({0xe61190?, 0xc0002000e0}, 0xc000647900)

appaquet

30 09:57:53.013 DEBUG libp2p_tcp                     - listening on 0.0.0.0:3365
30 09:57:53.014 DEBUG libp2p_tcp                     - listening on 0.0.0.0:3465
30 09:57:53.014 DEBUG libp2p_tcp                     - New listen address: /ip4/192.168.2.125/tcp/3465
30 09:57:53.014 DEBUG libp2p_websocket::framed       - Listening on /ip4/192.168.2.125/tcp/3465/ws
30 09:57:53.014 DEBUG libp2p_swarm                   - Listener ListenerId(2); New address: "/ip4/192.168.2.125/tcp/3465/ws"
30 09:57:53.014 DEBUG libp2p_tcp                     - New listen address: /ip4/192.168.2.129/tcp/3365
30 09:57:53.014 DEBUG libp2p_swarm                   - Listener ListenerId(1); New address: "/ip4/192.168.2.129/tcp/3365"
30 09:57:53.014 DEBUG libp2p_tcp                     - New listen address: /ip4/100.107.135.110/tcp/3465
30 09:57:53.014 DEBUG libp2p_websocket::framed       - Listening on /ip4/100.107.135.110/tcp/3465/ws
30 09:57:53.014 DEBUG libp2p_swarm                   - Listener ListenerId(2); New address: "/ip4/100.10

appaquet

{
  "entities": [
    {
      "id": "entity-HCEDSXGFSVPXJPBFYUMKTWZ5",
      "key": "postal-code",
      "values": {
        "[ABCEGHJ-NPRSTVXY]\\d[ABCEGHJ-NPRSTV-Z][ -]?\\d[ABCEGHJ-NPRSTV-Z]\\d": {
          "keyValue": "[ABCEGHJ-NPRSTVXY]\\d[ABCEGHJ-NPRSTV-Z][ -]?\\d[ABCEGHJ-NPRSTV-Z]\\d",
          "id": "entval-EVE4YEKAVZGGPIWLEBU4L5HY",
          "entityId": "entity-HCEDSXGFSVPXJPBFYUMKTWZ5",

appaquet

diff --git a/src/directory/mmap_directory.rs b/src/directory/mmap_directory.rs
index bc56c9d84..3c80ebdac 100644
--- a/src/directory/mmap_directory.rs
+++ b/src/directory/mmap_directory.rs
@@ -343,8 +343,11 @@ impl Write for SafeFileWriter {
     }
 
     fn flush(&mut self) -> io::Result<()> {
+        let before = std::time::Instant::now();
         self.0.flush()?;

appaquet

total 117M
-rw-rw-r-- 1 appaquet appaquet  557 Jul 31 10:26 03251b4dd37d4d028241eeec87aef657.fast
-rw-rw-r-- 1 appaquet appaquet  473 Jul 31 10:26 03251b4dd37d4d028241eeec87aef657.fieldnorm
-rw-rw-r-- 1 appaquet appaquet  619 Jul 31 10:26 03251b4dd37d4d028241eeec87aef657.idx
-rw-rw-r-- 1 appaquet appaquet  463 Jul 31 10:26 03251b4dd37d4d028241eeec87aef657.pos
-rw-rw-r-- 1 appaquet appaquet  849 Jul 31 10:26 03251b4dd37d4d028241eeec87aef657.store
-rw-rw-r-- 1 appaquet appaquet 3.3K Jul 31 10:26 03251b4dd37d4d028241eeec87aef657.term
-rw-rw-r-- 1 appaquet appaquet  302 Jul 31 10:26 04b8edae47e74eb59b7f9e9c584d54fb.fast
-rw-rw-r-- 1 appaquet appaquet  252 Jul 31 10:26 04b8edae47e74eb59b7f9e9c584d54fb.fieldnorm
-rw-rw-r-- 1 appaquet appaquet  159 Jul 31 10:26 04b8edae47e74eb59b7f9e9c584d54fb.idx

appaquet

use std::{collections::HashSet, path::PathBuf};

use tantivy::{
    collector::{Count, TopDocs},
    directory::MmapDirectory,
    query::{AllQuery, TermQuery},
    schema,
    schema::*,
    Index,
};

appaquet

thread 'merge_thread2' panicked at 'attempt to shift left with overflow', src/common/vint.rs:157:31
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace
thread 'merge_thread2' panicked at 'You forgot to flush "00000059000000000000000000000000.fast" before its writter got Drop. Do not rely on drop.', src/directory/ram_directory.rs:48:13
stack backtrace:
   0:     0x5562d9229b80 - std::backtrace_rs::backtrace::libunwind::trace::h63b7a90188ab5fb3
                               at /rustc/9bc8c42bb2f19e745a63f3445f1ac248fb015e53/library/std/src/../../backtrace/src/backtrace/libunwind.rs:90:5
   1:     0x5562d9229b80 - std::backtrace_rs::backtrace::trace_unsynchronized::h80aefbf9b851eca7
                               at /rustc/9bc8c42bb2f19e745a63f3445f1ac248fb015e53/library/std/src/../../backtrace/src/backtrace/mod.rs:66:5
   2:     0x5562d9229b80 - std::sys_common::backtrace::_print_fmt::hbef05ae4237a4d72
                               at /rustc/9bc8c42bb2f19e745a63f3445f1ac248fb015e53/l

appaquet

use futures::channel::{mpsc, oneshot};
use futures::StreamExt;
use std::time::Duration;
use tokio::runtime::Runtime;

fn main() {
    for _ in 0..100 {
        let rt = Runtime::new().unwrap();

        let (done_tx, done_rx) = oneshot::channel::<()>();

appaquet

diff --git a/tokio/src/runtime/thread_pool/queue/global.rs b/tokio/src/runtime/thread_pool/queue/global.rs
index a6f49c01..36dcc729 100644
--- a/tokio/src/runtime/thread_pool/queue/global.rs
+++ b/tokio/src/runtime/thread_pool/queue/global.rs
@@ -92,6 +92,7 @@ impl<T: 'static> Queue<T> {
             // Check if the queue is closed. This must happen in the lock.
             let len = self.len.unsync_load();
             if len & CLOSED == CLOSED {
+                drop(p);
                 f(Err(task));

appaquet

[package]
name = "tokiotest"
version = "0.1.0"
authors = ["APP <appaquet@gmail.com>"]
edition = "2018"

[dependencies]
tokio = { version = "0.2", features = ["blocking"] }
futures = "0.3"