Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Control + C does not lead to immediate shutdown #3158

Open
Geod24 opened this issue Mar 3, 2022 · 1 comment
Open

Control + C does not lead to immediate shutdown #3158

Geod24 opened this issue Mar 3, 2022 · 1 comment
Assignees
@hewison-chris
Milestone
6.1 TestNet Phase A

Comments

@Geod24
Copy link
Collaborator

Geod24 commented Mar 3, 2022 

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
@Geod24 Geod24 mentioned this issue Mar 4, 2022
Open
@Geod24 Geod24 added this to the 6. Stabilization milestone Mar 15, 2022
@hewison-chris
Copy link
Contributor

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]

@hewison-chris hewison-chris linked a pull request Mar 17, 2022 that will close this issue
Issue3158 clean shutdown #3205
Closed
@mkykadir mkykadir mentioned this issue Mar 21, 2022
Closed
2 tasks
@mkykadir mkykadir mentioned this issue Apr 18, 2022
Merged
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@hewison-chris hewison-chris

Labels
None yet
Projects
None yet
Milestone
6.1 TestNet Phase A
Development

Successfully merging a pull request may close this issue.

Issue3158 clean shutdown hewison-chris/agora
3 participants
@Geod24 @hewison-chris and others