<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 3.2//EN">
<HTML>
<HEAD>
<META HTTP-EQUIV="Content-Type" CONTENT="text/html; charset=iso-8859-1">
<META NAME="Generator" CONTENT="MS Exchange Server version 6.5.7651.59">
<TITLE>TCP client that can connect to a server at periodic intervals</TITLE>
</HEAD>
<BODY>
<!-- Converted from text/plain format -->
<BR>
<P><FONT SIZE=2>I am trying to write a TCP client that at regular intervals connects to a server makes a request and then closes the connection. Below is the code I've been playing with. I've seen an example of LoopingCall used for periodically sending UPD packets but am not sure how it would apply here because it would seem I need to periodically create new Protocol instances in the ClientFactory class. I've looked for examples and through the documentation but have come up empty. Any pointers would be greatly appreceiated.<BR>
<BR>
class AnnouncementFetcher(protocol.Protocol):<BR>
<BR>
def connectionMade(self):<BR>
print "connectionMade called"<BR>
self.transport.write(MSG_INFO_IPC)<BR>
<BR>
def dataReceived(self, data):<BR>
print "Received: ", repr(data)<BR>
# self.factory.share.saveData(data)<BR>
self.transport.loseConnection()<BR>
<BR>
<BR>
class AnnouncementFetcherFactory(protocol.ClientFactory):<BR>
protocol = AnnouncementFetcher<BR>
<BR>
def __init__(self, share):<BR>
self.share = share<BR>
<BR>
def buildProtocol(self, addr):<BR>
print 'Connected.'<BR>
p = AnnouncementFetcher()<BR>
p.factory = self<BR>
return p<BR>
<BR>
def clientConnectionLost(self, connector, reason):<BR>
print 'Lost connection, Reason:', reason<BR>
reactor.callLater(5, self.buildProtocol, 'localhost')<BR>
<BR>
def clientConnectionFailed(self, connector, reason):<BR>
print 'Connection failed. Reason:', reason</FONT>
</P>
</BODY>
</HTML>