netdata_tsrelay.nim
changeset 7 c0bcf3bea772
parent 6 1f366fc61592
child 8 1ef3f2d6d10e
--- a/netdata_tsrelay.nim	Wed Feb 14 17:27:29 2018 -0800
+++ b/netdata_tsrelay.nim	Thu Feb 15 10:29:37 2018 -0800
@@ -191,7 +191,6 @@
             " in ", hl($( round(cpu_time() - t0, 3) ), fgWhite, bright=true), " seconds."
             # " ", hl($(round((get_occupied_mem()/1024/1024),1)), fgWhite, bright=true), "MB memory used."
         )
-    when defined( testing ): dumpNumberOfInstances()
 
 
 proc serverloop: void =
@@ -200,7 +199,9 @@
     let db = open( "", "", "", conf.dbopts )
     if conf.verbose: echo( "Successfully connected to the backend database.".hl( fgGreen ) )
 
-    var server = newSocket()
+    var
+        conn_count = 0
+        server = newSocket()
 
     server.set_sock_opt( OptReuseAddr, true )
     server.bind_addr( Port(conf.listen_port), conf.listen_addr )
@@ -219,16 +220,18 @@
         var client  = newSocket()
         var address = ""
 
+        # Force a garbage collection pass.
+        #
+        conn_count = conn_count + 1
+        if conn_count == 25:
+            when defined( testing ): echo "Forcing GC pass."
+            GC_full_collect()
+            conn_count = 1
+
         client.close
         server.acceptAddr( client, address ) # blocking call
         spawn runthread( client, address, db, conf )
-
-
-proc atexit() {.noconv.} =
-    ## Exit cleanly after waiting on any running threads.
-    echo "Exiting..."
-    sync()
-    quit( 0 )
+        when defined( testing ): dumpNumberOfInstances()
 
 
 proc parse_cmdline: void =
@@ -273,10 +276,9 @@
 
 when isMainModule:
     system.addQuitProc( resetAttributes )
-    system.addQuitProc( atexit )
 
     parse_cmdline()
+    if conf.debug: echo hl( $conf, fgYellow )
 
-    if conf.debug: echo hl( $conf, fgYellow )
     serverloop()