Lines 22-28
import logging
Link Here
|
22 |
import ThreadedAsync |
22 |
import ThreadedAsync |
23 |
from ZEO.zrpc import smac |
23 |
from ZEO.zrpc import smac |
24 |
from ZEO.zrpc.error import ZRPCError, DisconnectedError |
24 |
from ZEO.zrpc.error import ZRPCError, DisconnectedError |
25 |
from ZEO.zrpc.marshal import Marshaller |
25 |
from ZEO.zrpc.marshal import Marshaller, ServerMarshaller |
26 |
from ZEO.zrpc.trigger import trigger |
26 |
from ZEO.zrpc.trigger import trigger |
27 |
from ZEO.zrpc.log import short_repr, log |
27 |
from ZEO.zrpc.log import short_repr, log |
28 |
from ZODB.loglevels import BLATHER, TRACE |
28 |
from ZODB.loglevels import BLATHER, TRACE |
Lines 716-721
class ManagedServerConnection(Connection
Link Here
|
716 |
def __init__(self, sock, addr, obj, mgr): |
716 |
def __init__(self, sock, addr, obj, mgr): |
717 |
self.mgr = mgr |
717 |
self.mgr = mgr |
718 |
self.__super_init(sock, addr, obj, 'S') |
718 |
self.__super_init(sock, addr, obj, 'S') |
|
|
719 |
self.marshal = ServerMarshaller() |
719 |
self.obj.notifyConnected(self) |
720 |
self.obj.notifyConnected(self) |
720 |
|
721 |
|
721 |
def handshake(self): |
722 |
def handshake(self): |