1 files changed, 42 insertions, 0 deletions
diff --git a/doc/core/examples/pbbenchclient.py b/doc/core/examples/pbbenchclient.py
new file mode 100644
index 0000000..9cd2b31
--- /dev/null
+++ b/doc/core/examples/pbbenchclient.py
@@ -0,0 +1,42 @@
+
+from twisted.spread import pb
+from twisted.internet import defer, reactor
+from twisted.cred.credentials import UsernamePassword
+import time
+
+class PBBenchClient:
+    hostname = 'localhost'
+    portno = pb.portno
+    calledThisSecond = 0
+
+    def callLoop(self, ignored):
+        d1 = self.persp.callRemote("simple")
+        d2 = self.persp.callRemote("complexTypes")
+        defer.DeferredList([d1, d2]).addCallback(self.callLoop)
+        self.calledThisSecond += 1
+        thisSecond = int(time.time())
+        if thisSecond != self.lastSecond:
+            if thisSecond - self.lastSecond > 1:
+                print "WARNING it took more than one second"
+            print 'cps:', self.calledThisSecond
+            self.calledThisSecond = 0
+            self.lastSecond = thisSecond
+
+    def _cbPerspective(self, persp):
+        self.persp = persp
+        self.lastSecond = int(time.time())
+        self.callLoop(None)
+
+    def runTest(self):
+        factory = pb.PBClientFactory()
+        reactor.connectTCP(self.hostname, self.portno, factory)
+        factory.login(UsernamePassword("benchmark", "benchmark")).addCallback(self._cbPerspective)
+
+
+def main():
+    PBBenchClient().runTest()
+    from twisted.internet import reactor
+    reactor.run()
+
+if __name__ == '__main__':
+    main()