Twisted: UDP socket not closed.

2012-04-19 Thread Luther Edwards
Did anyone in the group ever have an answer to Kevac's question, I'm having a 
similar issue?

Thanks in advance, Luther

[Python] Twisted: UDP socket not closed.
[cid:image001.png@01CD1E6B.15DF6BB0]http://grokbase.com/user/Kevac-Marko/tTjuHcXzmQtuttsnhLfi5e

Kevac Markohttp://grokbase.com/user/Kevac-Marko/tTjuHcXzmQtuttsnhLfi5e
Dec 22, 2007 at 9:02 amhttp://grokbase.com/g/python/python-list/2007/12

Hi.

I have to send UDP packets very often. Approx twice in a second.
But socket is not closed after sending packet. So soon i bump into
open sockets\files limit.
How to close socket after sending data?

Python 2.5, Twisted

class DataClient(DatagramProtocol):

def __init__(self, address, datagram = PONG):
self.address, self.datagram = address, datagram

def startProtocol(self):
self.transport.socket.setsockopt(socket.SOL_SOCKET, \
socket.SO_BROADCAST, True)
self.transport.connect(self.address[0], self.address[1])
self.sendDatagram()

def sendDatagram(self):
self.transport.write(self.datagram)
debug(Data client: Sending to %s % repr(self.address))

while True:
clientprotocol = DataClient((255.255.255.255, 5999), data)
reactor.listenUDP(0, clientprotocol).stopListening()

knight at rknb:~$ ls -la /proc/15429/fd/ | wc -l
43
knight at rknb:~$ ls -la /proc/15429/fd/ | wc -l
44
knight at rknb:~$ ls -la /proc/15429/fd/ | wc -l
44
knight at rknb:~$ ls -la /proc/15429/fd/ | wc -l
44
knight at rknb:~$ ls -la /proc/15429/fd/ | wc -l
45
knight at rknb:~$ ls -la /proc/15429/fd/ | wc -l
45
knight at rknb:~$ ls -la /proc/15429/fd/ | wc -l
46

inline: image001.png-- 
http://mail.python.org/mailman/listinfo/python-list


Twisted: UDP socket not closed.

2007-12-22 Thread Kevac Marko
Hi.

I have to send UDP packets very often. Approx twice in a second.
But socket is not closed after sending packet. So soon i bump into
open sockets\files limit.
How to close socket after sending data?

Python 2.5, Twisted

class DataClient(DatagramProtocol):

def __init__(self, address, datagram = PONG):
self.address, self.datagram = address, datagram

def startProtocol(self):
self.transport.socket.setsockopt(socket.SOL_SOCKET, \
socket.SO_BROADCAST, True)
self.transport.connect(self.address[0], self.address[1])
self.sendDatagram()

def sendDatagram(self):
self.transport.write(self.datagram)
debug(Data client: Sending to %s % repr(self.address))

while True:
clientprotocol = DataClient((255.255.255.255, 5999), data)
reactor.listenUDP(0, clientprotocol).stopListening()

[EMAIL PROTECTED]:~$ ls -la /proc/15429/fd/ | wc -l
43
[EMAIL PROTECTED]:~$ ls -la /proc/15429/fd/ | wc -l
44
[EMAIL PROTECTED]:~$ ls -la /proc/15429/fd/ | wc -l
44
[EMAIL PROTECTED]:~$ ls -la /proc/15429/fd/ | wc -l
44
[EMAIL PROTECTED]:~$ ls -la /proc/15429/fd/ | wc -l
45
[EMAIL PROTECTED]:~$ ls -la /proc/15429/fd/ | wc -l
45
[EMAIL PROTECTED]:~$ ls -la /proc/15429/fd/ | wc -l
46

Thanks in advance.
-- 
http://mail.python.org/mailman/listinfo/python-list