Merge pull request #15 from dgnorth/feature/gevent

Feature/gevent

Pipfile

@@ -12,6 +12,7 @@ greenlet = "*"
 python-decouple = "*"
 flask-restx = "*"
 python-driftconfig = "*"
+psycogreen = "*"
 
 [dev-packages]
 pytest = "*"

config/uwsgi.ini

@@ -1,18 +1,26 @@
 [uwsgi]
+# Accept only valid configuration options
+strict = true
 
 # Process management info
-threads = 4
-#gevent = 100
 master = true
+single-interpreter = true
+need-app = true
+auto-procname = true
+procname-prefix = "drift-base "
+die-on-term = true
+vacuum = true
 uid = uwsgi
-cheaper = 2
-workers = %(4 * %k)
-# max-worker-lifetime = 600
-idle = true
 pidfile = /tmp/uwsgi.pid
 
+# Threading management info
+enable-threads = true
+threads = without
+gevent = 1000
+workers = %(1 * %k)
+
 # Application info
-module=drift.contrib.flask.plainapp:app
+module=driftbase.flask.driftbaseapp:app
 
 # Web servers for nginx reverse proxy, local testing and uwsgitop.
 # Number of listening sockets set to a rather high number.

driftbase/api/messages.py

@@ -142,9 +142,6 @@ def get(self, exchange, exchange_id):
 
         args = self.get_args.parse_args()
         timeout = args.timeout or 0
-        #! Set timeout to 0 to disable long polling until we can
-        #! get gevent up and running in uwsgi.
-        timeout = 0
         min_message_number = int(args.messages_after or 0) + 1
         rows = args.rows
         if rows:

driftbase/flask/driftbaseapp.py

@@ -0,0 +1,13 @@
+"""
+Flask app with gevent monkey patching.
+"""
+import logging
+
+from gevent import monkey
+monkey.patch_all()
+from psycogreen.gevent import patch_psycopg
+patch_psycopg()
+
+from drift.flaskfactory import drift_app
+
+app = drift_app()