blob: 37b4b894cbe23356c6154d0f68d67c753475e817 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
import uwsgi
current_node = 0
def application(e, s):
global current_node
nodes = uwsgi.cluster_nodes()
print nodes
if len(nodes) == 0:
print "no cluster node available"
raise StopIteration
if current_node >= len(nodes):
current_node = 0
node = nodes[current_node]
for part in uwsgi.send_message(node, 0, 0, e, 0, e['wsgi.input'].fileno(), uwsgi.cl()):
yield part
current_node += 1
|
