about summary refs log tree commit diff
path: root/streaming/index.js
diff options
context:
space:
mode:
authorAkihiko Odaki <akihiko.odaki.4i@stu.hosei.ac.jp>2017-04-22 02:24:31 +0900
committerEugen <eugen@zeonfederated.com>2017-04-21 19:24:31 +0200
commit16cd648181f892b075b0be9bb9941f9a28b25ee2 (patch)
tree725aeae4b326b216f756b518221f0ca8a4f86a4b /streaming/index.js
parent53b21ac1cde533c068f3b3efad7ab8ba70a0dad2 (diff)
Allow to listen Unix socket (#2085)
* Allow puma to listen Unix socket

* streaming: Show the whole listening address instead of the port

Port is not always appropriate (e.g. Unix socket)

* streaming: Close server before exiting

This change especially allows to remove Unix socket before exiting.
Diffstat (limited to 'streaming/index.js')
-rw-r--r--streaming/index.js10
1 files changed, 9 insertions, 1 deletions
diff --git a/streaming/index.js b/streaming/index.js
index 8395c9cf8..c7959b306 100644
--- a/streaming/index.js
+++ b/streaming/index.js
@@ -328,6 +328,14 @@ if (cluster.isMaster) {
 
   server.listen(process.env.PORT || 4000, () => {
     log.level = process.env.LOG_LEVEL || 'verbose'
-    log.info(`Starting streaming API server worker on port ${server.address().port}`)
+    log.info(`Starting streaming API server worker on ${server.address()}`)
   })
+
+  process.on('SIGINT', exit)
+  process.on('SIGTERM', exit)
+  process.on('exit', exit)
+
+  function exit() {
+    server.close()
+  }
 }