From 8c985fe2cb6d5264bc3117eab0e3ffc68f5464ae Mon Sep 17 00:00:00 2001 From: Darko Poljak Date: Sun, 30 Oct 2016 20:25:32 +0100 Subject: [PATCH] Add forking support. --- cdist/trigger.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/cdist/trigger.py b/cdist/trigger.py index 9027c063..937a1d40 100644 --- a/cdist/trigger.py +++ b/cdist/trigger.py @@ -24,6 +24,7 @@ import logging import re import socket import http.server +import socketserver from http.server import BaseHTTPRequestHandler, HTTPServer @@ -49,10 +50,6 @@ class Trigger(): # can only be set once multiprocessing.set_start_method('forkserver') - # Create pool suitable for passing objects - def __init_pool(self): - pass - def run_httpd(self): server_address = ('', self.http_port) @@ -78,7 +75,6 @@ class Trigger(): class TriggerHttp(BaseHTTPRequestHandler): def do_GET(self): - # FIXME: dispatch to pool instead of single process host = self.client_address[0] code = 200 mode = None @@ -124,7 +120,7 @@ class TriggerHttp(BaseHTTPRequestHandler): parallel=False) -class HTTPServerV6(http.server.HTTPServer): +class HTTPServerV6(socketserver.ForkingMixIn, http.server.HTTPServer): """ Server that listens both to IPv4 and IPv6 requests. """