|
@@ -26,6 +26,7 @@ import errno
|
|
import re
|
|
import re
|
|
import datetime
|
|
import datetime
|
|
import pickle
|
|
import pickle
|
|
|
|
+import gc
|
|
import bb.server.xmlrpcserver
|
|
import bb.server.xmlrpcserver
|
|
from bb import daemonize
|
|
from bb import daemonize
|
|
from multiprocessing import queues
|
|
from multiprocessing import queues
|
|
@@ -737,8 +738,10 @@ class ConnectionWriter(object):
|
|
|
|
|
|
def send(self, obj):
|
|
def send(self, obj):
|
|
obj = multiprocessing.reduction.ForkingPickler.dumps(obj)
|
|
obj = multiprocessing.reduction.ForkingPickler.dumps(obj)
|
|
|
|
+ gc.disable()
|
|
with self.wlock:
|
|
with self.wlock:
|
|
self.writer.send_bytes(obj)
|
|
self.writer.send_bytes(obj)
|
|
|
|
+ gc.enable()
|
|
|
|
|
|
def fileno(self):
|
|
def fileno(self):
|
|
return self.writer.fileno()
|
|
return self.writer.fileno()
|