Commit 7c877db7 authored by Sidnei da Silva's avatar Sidnei da Silva

Move import inside methods so that the ZConfig overrides actually takes effect.

parent 2af37666
...@@ -32,7 +32,7 @@ from medusa import logger ...@@ -32,7 +32,7 @@ from medusa import logger
from medusa.counter import counter from medusa.counter import counter
from medusa.http_server import compute_timezone_for_log from medusa.http_server import compute_timezone_for_log
from ZServer import CONNECTION_LIMIT, requestCloseOnExec from ZServer import requestCloseOnExec
from PubCore import handle from PubCore import handle
from PubCore.ZEvent import Wakeup from PubCore.ZEvent import Wakeup
...@@ -642,6 +642,7 @@ class FCGIServer(asyncore.dispatcher): ...@@ -642,6 +642,7 @@ class FCGIServer(asyncore.dispatcher):
def readable(self): def readable(self):
from ZServer import CONNECTION_LIMIT
return len(asyncore.socket_map) < CONNECTION_LIMIT return len(asyncore.socket_map) < CONNECTION_LIMIT
......
...@@ -72,7 +72,7 @@ from medusa import filesys ...@@ -72,7 +72,7 @@ from medusa import filesys
from FTPResponse import make_response from FTPResponse import make_response
from FTPRequest import FTPRequest from FTPRequest import FTPRequest
from ZServer import CONNECTION_LIMIT, requestCloseOnExec from ZServer import requestCloseOnExec
from cStringIO import StringIO from cStringIO import StringIO
import os import os
...@@ -653,6 +653,7 @@ class FTPServer(ftp_server): ...@@ -653,6 +653,7 @@ class FTPServer(ftp_server):
self.ftp_channel_class (self, conn, addr, self.module) self.ftp_channel_class (self, conn, addr, self.module)
def readable(self): def readable(self):
from ZServer import CONNECTION_LIMIT
return len(asyncore.socket_map) < CONNECTION_LIMIT return len(asyncore.socket_map) < CONNECTION_LIMIT
def listen(self, num): def listen(self, num):
......
...@@ -52,8 +52,8 @@ from medusa.test import max_sockets ...@@ -52,8 +52,8 @@ from medusa.test import max_sockets
from medusa.default_handler import unquote from medusa.default_handler import unquote
from asyncore import compact_traceback, dispatcher from asyncore import compact_traceback, dispatcher
from ZServer import CONNECTION_LIMIT, ZOPE_VERSION, ZSERVER_VERSION from ZServer import ZOPE_VERSION, ZSERVER_VERSION
from ZServer import requestCloseOnExec, LARGE_FILE_THRESHOLD from ZServer import requestCloseOnExec
from zLOG import LOG, register_subsystem, BLATHER, INFO, WARNING, ERROR from zLOG import LOG, register_subsystem, BLATHER, INFO, WARNING, ERROR
import DebugLogger import DebugLogger
from medusa import logger from medusa import logger
...@@ -74,6 +74,7 @@ header2env={'content-length' : 'CONTENT_LENGTH', ...@@ -74,6 +74,7 @@ header2env={'content-length' : 'CONTENT_LENGTH',
class zhttp_collector: class zhttp_collector:
def __init__(self, handler, request, size): def __init__(self, handler, request, size):
from ZServer import LARGE_FILE_THRESHOLD
self.handler = handler self.handler = handler
self.request = request self.request = request
if size > LARGE_FILE_THRESHOLD: if size > LARGE_FILE_THRESHOLD:
...@@ -407,6 +408,7 @@ class zhttp_server(http_server): ...@@ -407,6 +408,7 @@ class zhttp_server(http_server):
requestCloseOnExec(self.socket) requestCloseOnExec(self.socket)
def readable(self): def readable(self):
from ZServer import CONNECTION_LIMIT
return self.accepting and \ return self.accepting and \
len(asyncore.socket_map) < CONNECTION_LIMIT len(asyncore.socket_map) < CONNECTION_LIMIT
......
...@@ -35,7 +35,7 @@ from medusa.http_server import compute_timezone_for_log ...@@ -35,7 +35,7 @@ from medusa.http_server import compute_timezone_for_log
from asyncore import compact_traceback from asyncore import compact_traceback
import ZServer import ZServer
from ZServer import CONNECTION_LIMIT, requestCloseOnExec from ZServer import requestCloseOnExec
from PubCore import handle from PubCore import handle
from PubCore.ZEvent import Wakeup from PubCore.ZEvent import Wakeup
...@@ -327,6 +327,7 @@ class PCGIServer(asyncore.dispatcher): ...@@ -327,6 +327,7 @@ class PCGIServer(asyncore.dispatcher):
self.channel_class(self, conn, addr) self.channel_class(self, conn, addr)
def readable(self): def readable(self):
from ZServer import CONNECTION_LIMIT
return len(asyncore.socket_map) < CONNECTION_LIMIT return len(asyncore.socket_map) < CONNECTION_LIMIT
def writable (self): def writable (self):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment