search

bosagora / agora

POC Node implementation for CoinNet
https://bosagora.io
MIT License
37 stars 22 forks source link

Control + C does not lead to immediate shutdown #3158

Open Geod24 opened 2 years ago

Geod24 commented 2 years ago 
2022-03-03 07:22:10,568 Info [agora.consensus.state.Ledger] - Completed externalization of block #561
Received signal 2, shutting down listeners...
[main(/uLN) INF] Stopped to listen for HTTP requests on 0.0.0.0:8080
[main(/uLN) INF] Stopped to listen for HTTP requests on :::44235
[main(/uLN) INF] Stopped to listen for HTTP requests on 0.0.0.0:45213
Calling node shutdown procedure...
2022-03-03 07:22:11,241 Info [agora.node.FullNode] - Shutting down..
2022-03-03 07:22:11,241 Info [agora.common.Task] - Tasks started: 400
Terminating event loop...
Received signal 2, shutting down listeners...
Calling node shutdown procedure...
Terminating event loop...
2022-03-03 07:22:11,717 Info [agora.consensus.state.Ledger] - Beginning externalization of block #562 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:11,717 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 5
2022-03-03 07:22:11,719 Info [agora.consensus.state.Ledger] - Validators: Active: 27 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:11,814 Info [agora.consensus.state.Ledger] - Completed externalization of block #562
2022-03-03 07:22:12,940 Info [agora.consensus.state.Ledger] - Beginning externalization of block #563 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:12,940 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:12,942 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:12,978 Info [agora.consensus.state.Ledger] - Completed externalization of block #563
2022-03-03 07:22:14,282 Info [agora.consensus.state.Ledger] - Beginning externalization of block #564 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:14,282 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 21
2022-03-03 07:22:14,283 Info [agora.consensus.state.Ledger] - Validators: Active: 11 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:14,477 Info [agora.consensus.state.Ledger] - Completed externalization of block #564
2022-03-03 07:22:15,604 Info [agora.consensus.state.Ledger] - Beginning externalization of block #565 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:15,604 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:15,605 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:15,645 Info [agora.consensus.state.Ledger] - Completed externalization of block #565
2022-03-03 07:22:16,724 Info [agora.consensus.state.Ledger] - Beginning externalization of block #566 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:16,724 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:16,726 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:16,757 Info [agora.consensus.state.Ledger] - Completed externalization of block #566
2022-03-03 07:22:17,861 Info [agora.consensus.state.Ledger] - Beginning externalization of block #567 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:17,861 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:17,862 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:17,904 Info [agora.consensus.state.Ledger] - Completed externalization of block #567
2022-03-03 07:22:19,41 Info [agora.consensus.state.Ledger] - Beginning externalization of block #568 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:19,41 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:19,42 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:19,76 Info [agora.consensus.state.Ledger] - Completed externalization of block #568
2022-03-03 07:22:20,245 Info [agora.consensus.state.Ledger] - Beginning externalization of block #569 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:20,245 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:20,247 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:20,293 Info [agora.consensus.state.Ledger] - Completed externalization of block #569
2022-03-03 07:22:21,422 Info [agora.consensus.state.Ledger] - Beginning externalization of block #570 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:21,422 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:21,423 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:21,453 Info [agora.consensus.state.Ledger] - Completed externalization of block #570
2022-03-03 07:22:22,581 Info [agora.consensus.state.Ledger] - Beginning externalization of block #571 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:22,581 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:22,583 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:22,624 Info [agora.consensus.state.Ledger] - Completed externalization of block #571
2022-03-03 07:22:23,776 Info [agora.consensus.state.Ledger] - Beginning externalization of block #572 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:23,776 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:23,778 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:23,811 Info [agora.consensus.state.Ledger] - Completed externalization of block #572
2022-03-03 07:22:24,901 Info [agora.consensus.state.Ledger] - Beginning externalization of block #573 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:24,901 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:24,903 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:24,946 Info [agora.consensus.state.Ledger] - Completed externalization of block #573
2022-03-03 07:22:26,73 Info [agora.consensus.state.Ledger] - Beginning externalization of block #574 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:26,73 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:26,74 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:26,109 Info [agora.consensus.state.Ledger] - Completed externalization of block #574
2022-03-03 07:22:27,226 Info [agora.consensus.state.Ledger] - Beginning externalization of block #575 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:27,226 Info [agora.consensus.state.Ledger] - Transactions: 1 - Enrollments: 0
2022-03-03 07:22:27,228 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:27,263 Info [agora.consensus.state.Ledger] - Completed externalization of block #575
2022-03-03 07:22:28,397 Info [agora.consensus.state.Ledger] - Beginning externalization of block #576 (previous block signatures: 11111111111111111111111111111111)
2022-03-03 07:22:28,397 Info [agora.consensus.state.Ledger] - Transactions: 2 - Enrollments: 0
2022-03-03 07:22:28,398 Info [agora.consensus.state.Ledger] - Validators: Active: 32 - Signing: 11111111111111111111111111111111 - Slashed: 0
2022-03-03 07:22:28,472 Info [agora.consensus.state.Ledger] - Completed externalization of block #576
2022-03-03 07:22:28,983 Info [agora.network.Manager] - Retrieving blocks [577..863] from [agora://eu-003.bosagora.io:4826/]..Warning (thread: main): leaking eventcore driver because there are still active handles
  FD 13 (streamSocket)
  FD 14 (streamSocket)
  FD 19 (streamSocket)
  FD 23 (streamSocket)
  FD 24 (streamSocket)
  FD 25 (streamSocket)
  FD 26 (streamSocket)
  FD 47 (streamSocket)
  FD 48 (streamSocket)
  FD 49 (streamSocket)
  FD 50 (streamSocket)
  FD 51 (streamSocket)
  FD 52 (streamSocket)
  FD 53 (streamSocket)
  FD 54 (streamSocket)
  FD 55 (streamSocket)
  FD 57 (streamSocket)
  FD 59 (streamSocket)
  FD 60 (streamSocket)
  FD 61 (streamSocket)
  FD 62 (streamSocket)
  FD 63 (streamSocket)
  FD 64 (streamSocket)
  FD 65 (streamSocket)
  FD 66 (streamSocket)
  FD 67 (streamSocket)
  FD 68 (streamSocket)
  FD 69 (streamSocket)
  FD 71 (streamSocket)
  FD 72 (streamSocket)
  FD 73 (streamSocket)
  FD 74 (streamSocket)
  FD 75 (streamSocket)
  FD 76 (streamSocket)
  FD 77 (streamSocket)
Use '-debug=EventCoreLeakTrace' to show where the instantiation happened
There were still 1 tasks running at exit.
Warning (thread: main): leaking eventcore driver because there are still active handles
  FD 13 (streamSocket)
  FD 14 (streamSocket)
  FD 19 (streamSocket)
  FD 23 (streamSocket)
  FD 24 (streamSocket)
  FD 25 (streamSocket)
  FD 26 (streamSocket)
  FD 47 (streamSocket)
  FD 48 (streamSocket)
  FD 49 (streamSocket)
  FD 50 (streamSocket)
  FD 51 (streamSocket)
  FD 52 (streamSocket)
  FD 53 (streamSocket)
  FD 54 (streamSocket)
  FD 55 (streamSocket)
  FD 57 (streamSocket)
  FD 59 (streamSocket)
  FD 60 (streamSocket)
  FD 61 (streamSocket)
  FD 62 (streamSocket)
  FD 63 (streamSocket)
  FD 64 (streamSocket)
  FD 65 (streamSocket)
  FD 66 (streamSocket)
  FD 67 (streamSocket)
  FD 68 (streamSocket)
  FD 69 (streamSocket)
  FD 71 (streamSocket)
  FD 72 (streamSocket)
  FD 73 (streamSocket)
  FD 74 (streamSocket)
  FD 75 (streamSocket)
  FD 76 (streamSocket)
  FD 77 (streamSocket)
Use '-debug=EventCoreLeakTrace' to show where the instantiation happened
hewison-chris commented 2 years ago

Running single node locally with a dub build including -debug=EventCoreLeakTrace.

after running for a couple of seconds causes:- ``` ^CReceived signal 2, shutting down listeners... shutting down HTTP listener. Calling node shutdown procedure... 2022-03-17 11:29:02,625 Info [agora.consensus.protocol.Nominator] - agora.consensus.protocol.Nominator.Nominator.shutdown: Shutdown timers 2022-03-17 11:29:02,627 Info [boa1xrval5rzmma29zh4aqgv3mvcarhwa0w8rgthy3l9vaj3fywf9894ycmjkm8] - Shutting down.. 2022-03-17 11:29:02,627 Info [agora.common.Task] - Tasks started: 9 [main(----) INF] Stopped to listen for HTTP requests on 0.0.0.0:9111 Terminating event loop... Warning (thread: main): leaking eventcore driver because there are still active handles FD 19 (streamSocket) Created by; ??:? object.Throwable.TraceInfo core.runtime.defaultTraceHandler(void*) [0x10d358d49] ??:? nothrow @nogc @safe eventcore.driver.StreamSocketFD eventcore.drivers.posix.driver.PosixEventLoop.initFD!(eventcore.driver.StreamSocketFD, eventcore.drivers.posix.sockets.StreamSocketSlot).initFD(ulong, eventcore.drivers.posix.driver.FDFlags, eventcore.drivers.posix.sockets.StreamSocketSlot) [0x10d15f0c6] ??:? nothrow @safe eventcore.driver.StreamSocketFD eventcore.drivers.posix.sockets.PosixEventDriverSockets!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverSockets.connectStream(scope std.socket.Address, std.socket.Address, void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe) [0x10d17a556] ??:? nothrow @safe eventcore.driver.StreamSocketFD vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda6!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe).__lambda6(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe) [0x10d100b0b] ??:? @safe void vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.TimerID) nothrow @safe, vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda6, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda7, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda8)).asyncAwaitAny(core.time.Duration, immutable(char)[]).__lambda4, vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda6, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda7, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda8)).asyncAwaitAny(core.time.Duration, immutable(char)[]).__lambda5, vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe... ??:? @safe void vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda6, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda7, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda8)).asyncAwaitAny(core.time.Duration, immutable(char)[]) [0x10d0fc07e] ??:? @trusted vibe.core.net.TCPConnection vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5() [0x10d0fbcf4] ??:? @safe vibe.core.net.TCPConnection vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration) [0x10d0fbb1e] ??:? @safe vibe.core.net.TCPConnection vibe.http.client.connectTCPWithTimeout(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration) [0x10ce4176f] ??:? @safe bool vibe.http.client.HTTPClient.doRequest(scope void delegate(vibe.http.client.HTTPClientRequest), ref bool, bool, std.datetime.systime.SysTime) [0x10ce41159] ??:? @safe bool vibe.http.client.HTTPClient.doRequestWithRetry(scope void delegate(vibe.http.client.HTTPClientRequest), bool, out bool, out std.datetime.systime.SysTime) [0x10ce3eb27] ??:? @safe vibe.http.client.HTTPClientResponse vibe.http.client.HTTPClient.request(scope void delegate(vibe.http.client.HTTPClientRequest)) [0x10ce3c25c] ??:? @safe vibe.http.client.HTTPClientResponse vibe.http.client.requestHTTP(vibe.inet.url.URL, void delegate(scope vibe.http.client.HTTPClientRequest), const(vibe.http.client.HTTPClientSettings)) [0x10ce3b723] ??:? @safe vibe.http.client.HTTPClientResponse vibe.web.rest.request(vibe.inet.url.URL, void delegate(vibe.http.client.HTTPClientRequest) @safe, scope void delegate(vibe.http.client.HTTPClientRequest, scope vibe.core.stream.InputStream) @safe, vibe.http.common.HTTPMethod, immutable(char)[], scope ref const(vibe.utils.dictionarylist.DictionaryList!(immutable(char)[], false, 12uL, false).DictionaryList), immutable(char)[], immutable(char)[], ref vibe.utils.dictionarylist.DictionaryList!(immutable(char)[], false, 12uL, false).DictionaryList, ref vibe.utils.dictionarylist.DictionaryList!(immutable(char)[], false, 12uL, false).DictionaryList, in vibe.http.client.HTTPClientSettings) [0x10ce2a187] ??:? @safe agora.api.FullNode.Identity vibe.web.rest.executeClientMethod!(agora.api.Validator.API, 4, vibe.web.rest.RestInterfaceClient!(agora.api.Validator.API).RestInterfaceClient.__mixin25.handshake(in ref agora.crypto.Key.PublicKey).peer).executeClientMethod(scope ref const(vibe.web.internal.rest.common.RestInterface!(agora.api.Validator.API).RestInterface), void delegate(vibe.http.client.HTTPClientRequest) @safe, scope void delegate(vibe.http.client.HTTPClientRequest, scope vibe.core.stream.InputStream) @safe) [0x10ca6f983] ??:? @safe agora.api.FullNode.Identity vibe.web.rest.RestInterfaceClient!(agora.api.Validator.API).RestInterfaceClient.__mixin25.handshake(in ref agora.crypto.Key.PublicKey) [0x10ca6f37d] ??:? _DThn16_4vibe3web4rest__T19RestInterfaceClientTC5agora3api9Validator3APIZQBw9__mixin259handshakeMFNfIKSQCd6crypto3Key9PublicKeyZSQDdQDa8FullNode8Identity [0x10ca7c017] ??:? void agora.network.Manager.NetworkManager.ConnectionTask.connect_canthrow() [0x10c8f2bd2] ??:? nothrow void agora.network.Manager.NetworkManager.ConnectionTask.connect() [0x10c8f2a17] ??:? nothrow void vibe.core.task.TaskFuncInfo.set!(void delegate() nothrow).set(ref void delegate() nothrow).callDelegate(ref vibe.core.task.TaskFuncInfo) [0x10c9a55be] ??:? void vibe.core.task.TaskFuncInfo.call() [0x10d12c54b] ??:? nothrow void vibe.core.task.TaskFiber.run() [0x10d12bc77] ??:? fiber_entryPoint [0x10d35b6a3] FD 20 (streamSocket) Created by; ??:? object.Throwable.TraceInfo core.runtime.defaultTraceHandler(void*) [0x10d358d49] ??:? nothrow @nogc @safe eventcore.driver.StreamSocketFD eventcore.drivers.posix.driver.PosixEventLoop.initFD!(eventcore.driver.StreamSocketFD, eventcore.drivers.posix.sockets.StreamSocketSlot).initFD(ulong, eventcore.drivers.posix.driver.FDFlags, eventcore.drivers.posix.sockets.StreamSocketSlot) [0x10d15f0c6] ??:? nothrow @safe void eventcore.drivers.posix.sockets.PosixEventDriverSockets!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverSockets.onAccept(eventcore.driver.FD) [0x10d17b3d0] ??:? nothrow @safe void eventcore.drivers.posix.driver.PosixEventLoop.notify!(0).notify(ulong) [0x10d15e46f] ??:? nothrow @trusted bool eventcore.drivers.posix.kqueue.KqueueEventLoopBase.doProcessEventsBase(core.time.Duration) [0x10d16268f] ??:? extern (C) nothrow @safe void eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop.processKqueue(eventcore.internal.corefoundation.__CFFileDescriptor*, eventcore.internal.corefoundation.CFOptionFlags, void*) [0x10d15676e] ??:? __CFFileDescriptorPerform [0x7fff20a85637] ??:? __CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE0_PERFORM_FUNCTION__ [0x7fff20a1d37b] ??:? __CFRunLoopDoSource0 [0x7fff20a1d2e3] ??:? __CFRunLoopDoSources0 [0x7fff20a1d063] ??:? __CFRunLoopRun [0x7fff20a1ba8b] ??:? CFRunLoopRunSpecific [0x7fff20a1b04b] ??:? nothrow @trusted bool eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop.doProcessEvents(core.time.Duration) [0x10d156882] ??:? nothrow @safe eventcore.driver.ExitReason eventcore.drivers.posix.driver.PosixEventDriverCore!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop, eventcore.drivers.timer.LoopTimeoutTimerDriver, eventcore.drivers.posix.events.PosixEventDriverEvents!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop, eventcore.drivers.posix.sockets.PosixEventDriverSockets!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverSockets).PosixEventDriverEvents, eventcore.drivers.posix.processes.PosixEventDriverProcesses!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverProcesses).PosixEventDriverCore.processEvents(core.time.Duration) [0x10d15c3e7] ??:? nothrow @safe eventcore.driver.ExitReason vibe.core.task.TaskScheduler.waitAndProcess() [0x10d12d7c4] ??:? nothrow @safe int vibe.core.core.runEventLoop() [0x10d0e3abc] ??:? _Dmain [0x10c802547] FD 21 (streamListen) Created by; ??:? object.Throwable.TraceInfo core.runtime.defaultTraceHandler(void*) [0x10d358d49] ??:? nothrow @nogc @safe eventcore.driver.StreamListenSocketFD eventcore.drivers.posix.driver.PosixEventLoop.initFD!(eventcore.driver.StreamListenSocketFD, eventcore.drivers.posix.sockets.StreamListenSocketSlot).initFD(ulong, eventcore.drivers.posix.driver.FDFlags, eventcore.drivers.posix.sockets.StreamListenSocketSlot) [0x10d15f473] ??:? nothrow @safe eventcore.driver.StreamListenSocketFD eventcore.drivers.posix.sockets.PosixEventDriverSockets!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverSockets.listenStream(scope std.socket.Address, eventcore.driver.StreamListenOptions, void delegate(eventcore.driver.StreamListenSocketFD, eventcore.driver.StreamSocketFD, eventcore.driver.RefAddress) nothrow @safe) [0x10d17af90] ??:? @safe vibe.core.net.TCPListener vibe.core.net.listenTCP(ushort, void delegate(vibe.core.net.TCPConnection) nothrow @safe, immutable(char)[], vibe.core.net.TCPListenOptions) [0x10d0fb06a] ??:? nothrow @safe vibe.core.net.TCPListener vibe.http.server.listenHTTPPlain(vibe.http.server.HTTPServerSettings, void delegate(vibe.http.server.HTTPServerRequest, vibe.http.server.HTTPServerResponse) @safe).doListen(vibe.http.server.HTTPServerContext, bool, bool, bool) [0x10cea7f1e] ??:? @safe vibe.http.server.HTTPListener vibe.http.server.listenHTTPPlain(vibe.http.server.HTTPServerSettings, void delegate(vibe.http.server.HTTPServerRequest, vibe.http.server.HTTPServerResponse) @safe) [0x10cea7c92] ??:? @safe vibe.http.server.HTTPListener vibe.http.server.listenHTTP!(vibe.http.server.HTTPServerSettings).listenHTTP(vibe.http.server.HTTPServerSettings, void delegate(vibe.http.server.HTTPServerRequest, vibe.http.server.HTTPServerResponse) @safe) [0x10ca569b6] ??:? @safe vibe.http.server.HTTPListener vibe.http.server.listenHTTP!(vibe.http.server.HTTPServerSettings).listenHTTP(vibe.http.server.HTTPServerSettings, vibe.http.server.HTTPServerRequestHandler) [0x10c7eddf3] ??:? std.typecons.Tuple!(agora.node.FullNode.FullNode, "node", agora.node.admin.AdminInterface.AdminInterface, "admin", agora.flash.Node.FlashNode, "flash", vibe.http.server.HTTPListener[], "http", vibe.core.net.TCPListener[], "tcp").Tuple agora.node.Runner.runNode(agora.node.Config.Config) [0x10c807047] ??:? nothrow void agora.node.main.main(immutable(char)[][]).__lambda16() [0x10c805e85] ??:? nothrow void vibe.core.task.TaskFuncInfo.set!(void delegate() nothrow).set(ref void delegate() nothrow).callDelegate(ref vibe.core.task.TaskFuncInfo) [0x10c9a55be] ??:? void vibe.core.task.TaskFuncInfo.call() [0x10d12c54b] ??:? nothrow void vibe.core.task.TaskFiber.run() [0x10d12bc77] ??:? fiber_entryPoint [0x10d35b6a3] Warning (thread: main): leaking eventcore driver because there are still active handles FD 19 (streamSocket) Created by; ??:? object.Throwable.TraceInfo core.runtime.defaultTraceHandler(void*) [0x10d358d49] ??:? nothrow @nogc @safe eventcore.driver.StreamSocketFD eventcore.drivers.posix.driver.PosixEventLoop.initFD!(eventcore.driver.StreamSocketFD, eventcore.drivers.posix.sockets.StreamSocketSlot).initFD(ulong, eventcore.drivers.posix.driver.FDFlags, eventcore.drivers.posix.sockets.StreamSocketSlot) [0x10d15f0c6] ??:? nothrow @safe eventcore.driver.StreamSocketFD eventcore.drivers.posix.sockets.PosixEventDriverSockets!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverSockets.connectStream(scope std.socket.Address, std.socket.Address, void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe) [0x10d17a556] ??:? nothrow @safe eventcore.driver.StreamSocketFD vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda6!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe).__lambda6(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe) [0x10d100b0b] ??:? @safe void vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.TimerID) nothrow @safe, vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda6, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda7, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda8)).asyncAwaitAny(core.time.Duration, immutable(char)[]).__lambda4, vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda6, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda7, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda8)).asyncAwaitAny(core.time.Duration, immutable(char)[]).__lambda5, vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe... ??:? @safe void vibe.internal.async.asyncAwaitAny!(true, vibe.internal.async.Waitable!(void delegate(eventcore.driver.StreamSocketFD, eventcore.driver.ConnectStatus) nothrow @safe, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda6, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda7, vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5().__lambda8)).asyncAwaitAny(core.time.Duration, immutable(char)[]) [0x10d0fc07e] ??:? @trusted vibe.core.net.TCPConnection vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration).__lambda5() [0x10d0fbcf4] ??:? @safe vibe.core.net.TCPConnection vibe.core.net.connectTCP(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration) [0x10d0fbb1e] ??:? @safe vibe.core.net.TCPConnection vibe.http.client.connectTCPWithTimeout(vibe.core.net.NetworkAddress, vibe.core.net.NetworkAddress, core.time.Duration) [0x10ce4176f] ??:? @safe bool vibe.http.client.HTTPClient.doRequest(scope void delegate(vibe.http.client.HTTPClientRequest), ref bool, bool, std.datetime.systime.SysTime) [0x10ce41159] ??:? @safe bool vibe.http.client.HTTPClient.doRequestWithRetry(scope void delegate(vibe.http.client.HTTPClientRequest), bool, out bool, out std.datetime.systime.SysTime) [0x10ce3eb27] ??:? @safe vibe.http.client.HTTPClientResponse vibe.http.client.HTTPClient.request(scope void delegate(vibe.http.client.HTTPClientRequest)) [0x10ce3c25c] ??:? @safe vibe.http.client.HTTPClientResponse vibe.http.client.requestHTTP(vibe.inet.url.URL, void delegate(scope vibe.http.client.HTTPClientRequest), const(vibe.http.client.HTTPClientSettings)) [0x10ce3b723] ??:? @safe vibe.http.client.HTTPClientResponse vibe.web.rest.request(vibe.inet.url.URL, void delegate(vibe.http.client.HTTPClientRequest) @safe, scope void delegate(vibe.http.client.HTTPClientRequest, scope vibe.core.stream.InputStream) @safe, vibe.http.common.HTTPMethod, immutable(char)[], scope ref const(vibe.utils.dictionarylist.DictionaryList!(immutable(char)[], false, 12uL, false).DictionaryList), immutable(char)[], immutable(char)[], ref vibe.utils.dictionarylist.DictionaryList!(immutable(char)[], false, 12uL, false).DictionaryList, ref vibe.utils.dictionarylist.DictionaryList!(immutable(char)[], false, 12uL, false).DictionaryList, in vibe.http.client.HTTPClientSettings) [0x10ce2a187] ??:? @safe agora.api.FullNode.Identity vibe.web.rest.executeClientMethod!(agora.api.Validator.API, 4, vibe.web.rest.RestInterfaceClient!(agora.api.Validator.API).RestInterfaceClient.__mixin25.handshake(in ref agora.crypto.Key.PublicKey).peer).executeClientMethod(scope ref const(vibe.web.internal.rest.common.RestInterface!(agora.api.Validator.API).RestInterface), void delegate(vibe.http.client.HTTPClientRequest) @safe, scope void delegate(vibe.http.client.HTTPClientRequest, scope vibe.core.stream.InputStream) @safe) [0x10ca6f983] ??:? @safe agora.api.FullNode.Identity vibe.web.rest.RestInterfaceClient!(agora.api.Validator.API).RestInterfaceClient.__mixin25.handshake(in ref agora.crypto.Key.PublicKey) [0x10ca6f37d] ??:? _DThn16_4vibe3web4rest__T19RestInterfaceClientTC5agora3api9Validator3APIZQBw9__mixin259handshakeMFNfIKSQCd6crypto3Key9PublicKeyZSQDdQDa8FullNode8Identity [0x10ca7c017] ??:? void agora.network.Manager.NetworkManager.ConnectionTask.connect_canthrow() [0x10c8f2bd2] ??:? nothrow void agora.network.Manager.NetworkManager.ConnectionTask.connect() [0x10c8f2a17] ??:? nothrow void vibe.core.task.TaskFuncInfo.set!(void delegate() nothrow).set(ref void delegate() nothrow).callDelegate(ref vibe.core.task.TaskFuncInfo) [0x10c9a55be] ??:? void vibe.core.task.TaskFuncInfo.call() [0x10d12c54b] ??:? nothrow void vibe.core.task.TaskFiber.run() [0x10d12bc77] ??:? fiber_entryPoint [0x10d35b6a3] FD 20 (streamSocket) Created by; ??:? object.Throwable.TraceInfo core.runtime.defaultTraceHandler(void*) [0x10d358d49] ??:? nothrow @nogc @safe eventcore.driver.StreamSocketFD eventcore.drivers.posix.driver.PosixEventLoop.initFD!(eventcore.driver.StreamSocketFD, eventcore.drivers.posix.sockets.StreamSocketSlot).initFD(ulong, eventcore.drivers.posix.driver.FDFlags, eventcore.drivers.posix.sockets.StreamSocketSlot) [0x10d15f0c6] ??:? nothrow @safe void eventcore.drivers.posix.sockets.PosixEventDriverSockets!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverSockets.onAccept(eventcore.driver.FD) [0x10d17b3d0] ??:? nothrow @safe void eventcore.drivers.posix.driver.PosixEventLoop.notify!(0).notify(ulong) [0x10d15e46f] ??:? nothrow @trusted bool eventcore.drivers.posix.kqueue.KqueueEventLoopBase.doProcessEventsBase(core.time.Duration) [0x10d16268f] ??:? extern (C) nothrow @safe void eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop.processKqueue(eventcore.internal.corefoundation.__CFFileDescriptor*, eventcore.internal.corefoundation.CFOptionFlags, void*) [0x10d15676e] ??:? __CFFileDescriptorPerform [0x7fff20a85637] ??:? __CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE0_PERFORM_FUNCTION__ [0x7fff20a1d37b] ??:? __CFRunLoopDoSource0 [0x7fff20a1d2e3] ??:? __CFRunLoopDoSources0 [0x7fff20a1d063] ??:? __CFRunLoopRun [0x7fff20a1ba8b] ??:? CFRunLoopRunSpecific [0x7fff20a1b04b] ??:? nothrow @trusted bool eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop.doProcessEvents(core.time.Duration) [0x10d156882] ??:? nothrow @safe eventcore.driver.ExitReason eventcore.drivers.posix.driver.PosixEventDriverCore!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop, eventcore.drivers.timer.LoopTimeoutTimerDriver, eventcore.drivers.posix.events.PosixEventDriverEvents!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop, eventcore.drivers.posix.sockets.PosixEventDriverSockets!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverSockets).PosixEventDriverEvents, eventcore.drivers.posix.processes.PosixEventDriverProcesses!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverProcesses).PosixEventDriverCore.processEvents(core.time.Duration) [0x10d15c3e7] ??:? nothrow @safe eventcore.driver.ExitReason vibe.core.task.TaskScheduler.waitAndProcess() [0x10d12d7c4] ??:? nothrow @safe int vibe.core.core.runEventLoop() [0x10d0e3abc] ??:? _Dmain [0x10c802547] FD 21 (streamListen) Created by; ??:? object.Throwable.TraceInfo core.runtime.defaultTraceHandler(void*) [0x10d358d49] ??:? nothrow @nogc @safe eventcore.driver.StreamListenSocketFD eventcore.drivers.posix.driver.PosixEventLoop.initFD!(eventcore.driver.StreamListenSocketFD, eventcore.drivers.posix.sockets.StreamListenSocketSlot).initFD(ulong, eventcore.drivers.posix.driver.FDFlags, eventcore.drivers.posix.sockets.StreamListenSocketSlot) [0x10d15f473] ??:? nothrow @safe eventcore.driver.StreamListenSocketFD eventcore.drivers.posix.sockets.PosixEventDriverSockets!(eventcore.drivers.posix.cfrunloop.CFRunLoopEventLoop).PosixEventDriverSockets.listenStream(scope std.socket.Address, eventcore.driver.StreamListenOptions, void delegate(eventcore.driver.StreamListenSocketFD, eventcore.driver.StreamSocketFD, eventcore.driver.RefAddress) nothrow @safe) [0x10d17af90] ??:? @safe vibe.core.net.TCPListener vibe.core.net.listenTCP(ushort, void delegate(vibe.core.net.TCPConnection) nothrow @safe, immutable(char)[], vibe.core.net.TCPListenOptions) [0x10d0fb06a] ??:? nothrow @safe vibe.core.net.TCPListener vibe.http.server.listenHTTPPlain(vibe.http.server.HTTPServerSettings, void delegate(vibe.http.server.HTTPServerRequest, vibe.http.server.HTTPServerResponse) @safe).doListen(vibe.http.server.HTTPServerContext, bool, bool, bool) [0x10cea7f1e] ??:? @safe vibe.http.server.HTTPListener vibe.http.server.listenHTTPPlain(vibe.http.server.HTTPServerSettings, void delegate(vibe.http.server.HTTPServerRequest, vibe.http.server.HTTPServerResponse) @safe) [0x10cea7c92] ??:? @safe vibe.http.server.HTTPListener vibe.http.server.listenHTTP!(vibe.http.server.HTTPServerSettings).listenHTTP(vibe.http.server.HTTPServerSettings, void delegate(vibe.http.server.HTTPServerRequest, vibe.http.server.HTTPServerResponse) @safe) [0x10ca569b6] ??:? @safe vibe.http.server.HTTPListener vibe.http.server.listenHTTP!(vibe.http.server.HTTPServerSettings).listenHTTP(vibe.http.server.HTTPServerSettings, vibe.http.server.HTTPServerRequestHandler) [0x10c7eddf3] ??:? std.typecons.Tuple!(agora.node.FullNode.FullNode, "node", agora.node.admin.AdminInterface.AdminInterface, "admin", agora.flash.Node.FlashNode, "flash", vibe.http.server.HTTPListener[], "http", vibe.core.net.TCPListener[], "tcp").Tuple agora.node.Runner.runNode(agora.node.Config.Config) [0x10c807047] ??:? nothrow void agora.node.main.main(immutable(char)[][]).__lambda16() [0x10c805e85] ??:? nothrow void vibe.core.task.TaskFuncInfo.set!(void delegate() nothrow).set(ref void delegate() nothrow).callDelegate(ref vibe.core.task.TaskFuncInfo) [0x10c9a55be] ??:? void vibe.core.task.TaskFuncInfo.call() [0x10d12c54b] ??:? nothrow void vibe.core.task.TaskFiber.run() [0x10d12bc77] ??:? fiber_entryPoint [0x10d35b6a3] ```