TechEmpower.FrameworkBenchmarks/frameworks/Python/socketify.py/app.py

import threading
import time
import os

from datetime import datetime

from socketify import App


def plaintext(res, req):
    res.write_header("Server", "socketify")
    res.write_header("Content-Type", "text/plain")
    res.end("Hello, World!")

def applicationjson(res, req):
    res.write_header("Server", "socketify")
    res.end({"message":"Hello, World!"})


def run_app():
    app = App()
    app.get("/", plaintext)
    app.get("/json", applicationjson)
    app.get("/plaintext", plaintext)
    app.listen(3000, None)
    app.run()

def create_fork():
    n = os.fork()
    # n greater than 0 means parent process
    if not n > 0:
        run_app()

def get_worker_count():
    try:
        return int(os.environ["WORKER_COUNT"])
    except:
        return 2

WORKER_COUNT = get_worker_count() - 1

for index in range(WORKER_COUNT):
    create_fork()

run_app()
#sudo ./tfb --mode benchmark --test socketify.py --type plaintext
#sudo ./tfb --mode benchmark --test socketify.py --type json --network=tfb