Hi, there.
I have been trying to figure out how to use the twisted.internet.pollreactor so that I can use it to monitor a Linux named PIPE (i.e. a FIFO created using mkfifo()). I tried without success to Google some examples but I couldn't find anything.
Now, for a simple TCP server, the setup looks something like this (i.e. like the QOTD example in the documentation):
from twisted.internet.protocol import Protocol, Factory
from twisted.internet import reactor
class QOTD(Protocol):
def connectionMade(self):
self.transport.write("An apple a day keeps the doctor away\r\n")
self.transport.loseConnection()
# Next lines are magic:
factory = Factory()
factory.protocol = QOTD
# 8007 is the port you want to run under. Choose something >1024
reactor.listenTCP(8007, factory)
reactor.run()
So, the TCP type of reactor has something that tells it to listen to port 8007 and use some form of factory or object to take care of things when a connection occurs. As far as I can guess, I would need to do some steps like this (NOTE: using mixture of real and pseudo code):
from twisted.internet import pollreactor
pollreactor.install()