Mailman 3 November 2013 - Twisted

[Twisted-Python] How to call remote server method to read a file on the server machine useing perspective broker ?
by yangyouxiu 20 Nov '13

20 Nov '13

Hi, all! I'm trying to read a file on the server with pb, and got an error. Following is my code, what's the problem? ***********************pb1server.py #!/usr/bin/env python # Copyright (c) Twisted Matrix Laboratories. # See LICENSE for details. from twisted.spread import pb class Two(pb.Referenceable): def remote_three(self, arg): print "Two.three was given", arg f=open('/home/gddw/Desktop/test','wr') content = f.readline() print content class One(pb.Root): def remote_getTwo(self): two = Two() print "returning a Two called", two return two from twisted.internet import reactor reactor.listenTCP(8800, pb.PBServerFactory(One())) reactor.run() *************************pb1client.py #!/usr/bin/env python # Copyright (c) Twisted Matrix Laboratories. # See LICENSE for details. from twisted.spread import pb from twisted.internet import reactor def main(): factory = pb.PBClientFactory() reactor.connectTCP("localhost", 8800, factory) def1 = factory.getRootObject() def1.addCallbacks(got_obj1, err_obj1) reactor.run() def err_obj1(reason): print "error getting first object", reason reactor.stop() def got_obj1(obj1): print "got first object:", obj1 print "asking it to getTwo" def2 = obj1.callRemote("getTwo") def2.addCallbacks(got_obj2) def got_obj2(obj2): print "got second object:", obj2 print "telling it to do three(12)" obj2.callRemote("three", 12) main()

2 3

[Twisted-Python] perspective argument missing from Viewable.view_*
by Daniel Sank 19 Nov '13

19 Nov '13

I'm trying to understand exactly how context management works in perspective broker. I thought the point of Viewable was that you always know who's calling. However if I run the simple fully working example pasted below, I see that the perspective argument is None. What gives? Kind regards, Daniel Sank # Server import twisted.spread.pb as pb import twisted.internet.reactor as reactor class Server(pb.Root): def __init__(self): self.v = MyViewable() def remote_getViewable(self): return self.v class MyViewable(pb.Viewable): def view_foo(self, perspective): print ("Perspective %s"%perspective) if __name__ == "__main__": reactor.listenTCP(54321, pb.PBServerFactory(Server())) print("Starting reactor") reactor.run() # Client import twisted.spread.pb as pb import twisted.internet.reactor as reactor from twisted.internet.defer import inlineCallbacks @inlineCallbacks def gotRoot(root): v1 = yield root.callRemote("getViewable") v2 = yield root.callRemote("getViewable") print(v1) print(v2) yield v1.callRemote("foo") yield v2.callRemote("foo") factory = pb.PBClientFactory() reactor.connectTCP("localhost", 54321, factory) d = factory.getRootObject() d.addCallback(gotRoot) reactor.run()

2 3

[Twisted-Python] WG: FreeBSD buildslaves: change proposal
by Tobias Oberstein 18 Nov '13

18 Nov '13

somehow the Twisted list rejects my posts lately;( Von: Tobias Oberstein Gesendet: Dienstag, 12. November 2013 20:48 An: Twisted general discussion (twisted-python(a)twistedmatrix.com) Cc: pypy-dev(a)python.org Betreff: FreeBSD buildslaves: change proposal Hi, we (Tavendo) currently operate 2 Twisted/FreeBSD buildslaves: a) FreeBSD 8.2, i386 with 1 builder (CPy 2.7) => part of the list of "officially supported" builders b) FreeBSD 9.1, amd64 with 2 builders (CPy 2.7 and PyPy) => only listed under "unsupported" We would like to change that into the following: c) one FreeBSD amd64 host with 3 builders c1) CPy 2.7 (supported) c2) PyPy 2.2 (supported) c3) PyPy Nightly (unsupported) Here are some reasons: - FreeBSD 8.2 is very old (read, unsupported) now, FreeBSD 10 is around the corner, and 9.2 the current official stable release - i386 is .. getting obscure. Does _anybody_ run FreeBSD i386 anymore? - there are ongoing workarounds to support that thing .. time that could be spent better - we want to run a PyPy slave for the PyPy project on that same host (this allows to produce the PyPy/Nightlies .. on a daily basis .. and immediately run Twisted trials against that) - someone needs to run a PyPy slave anyway .. the current one is broken - the current Twisted 13.2 has run 100% clean on above b) (CPy) : http://buildbot.twistedmatrix.com/builders/freebsd-9.1-amd64-python2.7/buil… So, I'd like to ask Twisted developers if above makes sense, and you would support this way forward. I've been in contact with PyPy developers, and there seems to be clear interest in improving support for both Twisted and FreeBSD (hence the cross-post). In general, Tavendo is committed to contribute time & material making Twisted + CPy|PyPy + FreeBSD a combination fully (even better) supported and actually first-class in terms of features, compatibility and performance. We think < Twisted + PyPy + FreeBSD > in particular has great potential and can provide an extremely powerful stack: "The _complete_ power to serve." .. stealing from FreeBSD's motto here - heh, and sorry the the marketing blurb .. I just couldn't resist;) Thanks! /Tobias

1 1

[Twisted-Python] how to change an qt4 applicaion using twisted?
by yangyouxiu 18 Nov '13

18 Nov '13

Hi,all！ I have to change an QT application to client-server model, and i found twisted and qt4 reactor. But i don't know where to start? how should i do to split the qt application? what's the step. as for the server, what should i initialize? thanks all.

3 5

[Twisted-Python] Ticket #1330 - Socks V5 functionality
by David Stainton 17 Nov '13

17 Nov '13

Hi, I'd like to help out and write unit tests for the Socks v5 code in this ticket: https://twistedmatrix.com/trac/ticket/1330 Should I write something very similar to this?? :: http://twistedmatrix.com/trac/browser/trunk/twisted/test/test_socks.py My goal is getting socksv5 client and server code merged to mainline Twisted with unit tests. Cheers, David

3 3

[Twisted-Python] Returning a deferred from buildProtocol t.i.p.Factory
by Tom van Neerijnen 17 Nov '13

17 Nov '13

Hi all I'm building a simple TCP load balancer based on a code snippet from Glyph on SO: http://stackoverflow.com/questions/4096061/general-question-regarding-wethe… It's served me well but I can't work out how to convert Glyphs round robin retrieval of the server endpoint into an async balancing decision in the buildProtocol method of the Factory. If I return a deferred here it fails with an AttributeError: Deferred instance has no attribute 'makeConnection'. Currently I'm working around this by running a separate management loop that periodically updates a dictionary with all the data necessary to make my routing decision so that I can do it without a deferred. This worries me because I may be making my decision on slightly stale data and I'd really like this to be a real time decision as the connection comes in. Does anyone have a clever way of doing this? An example is below. The hashed out buildProtocol is a synchronous decision which works. Thanks in advance! from twisted.internet.protocol import Factory from twisted.protocols.portforward import ProxyFactory from twisted.internet import reactor, defer import random from twisted.python import log import sys log.startLogging(sys.stderr) local_ports = set([1024, 1025]) def port_routing_decision_sync(): return random.choice(list(local_ports)) def port_routing_decision_async(): d = defer.Deferred() reactor.callLater(1, d.callback, port_routing_decision_sync()) return d class Balancer(Factory): # def buildProtocol(self, addr): # port = port_routing_decision_sync() # print "connecting to local port {}".format(port) # return ProxyFactory("127.0.0.1", port).buildProtocol(addr) @defer.inlineCallbacks def buildProtocol(self, addr): port = yield port_routing_decision_async() print "connecting to local port {}".format(port) defer.returnValue(ProxyFactory("127.0.0.1", port).buildProtocol(addr)) def main(): factory = Balancer() reactor.listenTCP(5678, factory) reactor.run() if __name__ == "__main__": main()

4 4

[Twisted-Python] Is a Viewable Cacheable a good idea?
by Daniel Sank 17 Nov '13

17 Nov '13

Suppose I want to make a networked stockroom program with perspective broker. We have a user side client object, class Client(pb.Referenceable): def connect(self): # host, port, factory, and credentials come from elsewhere reactor.connectTCP(host, port, factory) d = self.factory.login(credentials, self) d.addCallback(self.connected) def connected(self, perspective): if perspective: self.perspective = perspective and a "corresponding" server side User, class User(pb.Avatar): def __init__(self, name, server, mind): self.name = name self.server = server self.client = mind #This is a remote reference to a Client def logout(self): ...logic... We have the IRealm implementer, @implementer(portal.IRealm) class Server(object): """I manage games and produce Avatars""" def __init__(self, loggingPath): self.users = {} self.stockrooms = set() def requestAvatar(self, avatarId, mind, *interfaces): assert pb.IPerspective in interfaces user = self.users.setdefault(avatarId, User(avatarId, self, mind)) return pb.IPerspective, user, user.logout and finally we have the Stockroom class Stockroom(object): ...logic... Now I'd like for my Clients to be able to remove/add items to the stockroom. Using only the code above I'd have to add perspective_* methods to the User. These methods would direct the Client's intent to the appropriate Stockroom. Changes made to the Stockroom would then have to be announced to any interested Clients by invoking the appropriate Users' mind property. This seems very awkward. I'd rather just have the Stockrooms be Viewable so that Clients can invoke methods on them directly. If the Stockroom were _also_ Cacheable then changes on a Stockroom would automatically propagate to the client process. Is simultaneously sub-classing Viewable and Cacheable a good idea? Am I thinking about this properly? Regards and thanks in advance, Daniel Sank -- Department of Physics Broida Hall University of California Santa Barbara, CA 93117 (805)893-3899

2 2

[Twisted-Python] question : use existing tac file with tap.
by bino＠indoakses-online.com 17 Nov '13

17 Nov '13

Dear All. Currently I have a single '.tac' file that use MultiService() Ended with ---------------- #Create Application print 'create application' application = service.Application("Serial MultiService Example") #Creating Multi Service multiService = service.MultiService() ... ... multiService.setServiceParent(application) -------------- currently it works just fine Now, i need to to able to run it using some parameter from the commandline. I kne that I have to take 'tap' path. I read http://docs.huihoo.com/python/twisted/howto/tap.html but (thanks to my lame brain) failed to understand on how to implement this to my existing script. Kindly please tell me how to do it or give me realy basic example on using/migrating tac file with Twisted Application Plugin. Sincerely -bino-

2 1

[Twisted-Python] Weekly Bug Summary
by trac＠twistedmatrix.com 17 Nov '13

17 Nov '13

1 0

[Twisted-Python] Xbmc Don´t close after run a script with Twisted
by Clayton Vicente 15 Nov '13

15 Nov '13

Hi guys, i start to play with Twisted. My main intention is to create a add-on for run in a Raspberry Pi (Raspbmc). For now almost every thing is working fine.Here is the link of the add-onhttps://dl.dropboxusercontent.com/u/89557567/script.cavplustcp-0.1.4.… only problem is that the Xbmc (running in a Raspbmc) never close if i have Twisted running.In the default.py i have a function that will run after the Xbmc abort request. def _killConnections(self): if(self.server1): self.server1.stopListening() if(self.server2): self.server2.stopListening() if(self.client1): self.client1.disconnect() if(self.client2): self.client2.disconnect() protocol.transport.loseConnection() xbmc.log(msg="reactor stop") reactor.stop()I tested in a Windows 7 and works fine, the script close the connections and then the Xbmc close. If i remove this function the Xbmc will never close.The problem is with this script running in a linux OS. The Xbmc try to close the script, but don´t work, so the Xbmc will freeze.Can you guys help me ?ThanksRegardsClayton

1 0