blob: dc9905e8b619df6b277691dba6c5858b3a2fb7bc (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
# Copyright (c) Twisted Matrix Laboratories.
# See LICENSE for details.
"""
PB copy receiver example.
This is a Twisted Application Configuration (tac) file. Run with e.g.
twistd -ny copy_receiver.tac
See the twistd(1) man page or
http://twistedmatrix.com/documents/current/howto/application for details.
"""
import sys
if __name__ == '__main__':
print __doc__
sys.exit(1)
from twisted.application import service, internet
from twisted.internet import reactor
from twisted.spread import pb
from copy_sender import LilyPond, CopyPond
from twisted.python import log
#log.startLogging(sys.stdout)
class ReceiverPond(pb.RemoteCopy, LilyPond):
pass
pb.setUnjellyableForClass(CopyPond, ReceiverPond)
class Receiver(pb.Root):
def remote_takePond(self, pond):
print " got pond:", pond
pond.countFrogs()
return "safe and sound" # positive acknowledgement
def remote_shutdown(self):
reactor.stop()
application = service.Application("copy_receiver")
internet.TCPServer(8800, pb.PBServerFactory(Receiver())).setServiceParent(
service.IServiceCollection(application))
|
