Plz help..SocketSer ver UDP server losing lots of packets

[id.engg]

logFileName = 'log.txt'
logfile = open(logFileNam e, "a")
class MyUDPServer(Soc ketServer.UDPSe rver):
def server_bind(sel f):
self.socket.set sockopt(socket. SOL_SOCKET,
socket.SO_RCVBU F, 8388608)
self.socket.bin d(self.server_a ddress)

class LogsDumpHandler (SocketServer.D atagramRequestH andler):
def handle(self):
global logfile
# fileExists is a function which checks the existence of a file
if not fileExists(logF ileName):
logfile = open(logFileNam e, "a")
logfile.writeli nes(self.rfile. readlines())

server = MyUDPServer(("" ,PORT), LogsDumpHandler )
server.serve_fo rever()
logfile.close()

The above python code is a UDP server based on SocketServer framework
and I am losing a lot of messages, I have tried almost everything,
increasing the size of the receive buffer, changing the way i read the
messages coming into server.
The above code is supposed to work as a tracing server and it does but
is losing messages.
Is there a way I can improve this code?
Any help will be highly appreciated.

Thanks,
Sam

[James Mills]

On Thu, Nov 6, 2008 at 9:53 AM, <id*****@gmail. comwrote:

logFileName = 'log.txt'
logfile = open(logFileNam e, "a")
class MyUDPServer(Soc ketServer.UDPSe rver):
def server_bind(sel f):
self.socket.set sockopt(socket. SOL_SOCKET,
socket.SO_RCVBU F, 8388608)
self.socket.bin d(self.server_a ddress)

class LogsDumpHandler (SocketServer.D atagramRequestH andler):
def handle(self):
global logfile
# fileExists is a function which checks the existence of a file
if not fileExists(logF ileName):
logfile = open(logFileNam e, "a")
logfile.writeli nes(self.rfile. readlines())

server = MyUDPServer(("" ,PORT), LogsDumpHandler )
server.serve_fo rever()
logfile.close()

This is horrible code :/

Try these instead:
* UDPServer ->
http://trac.softcircuit.com.au/circu...s/udpserver.py
* UDPClient ->
http://trac.softcircuit.com.au/circu...s/udpclient.py

Example usage
----------------------

~/circuits/examples
$ ./udpserver.py
127.0.0.1, 9000:
test
127.0.0.1, 9000:
hi

~/circuits/examples
$ ./udpclient.py -b 127.0.0.1:9000 127.0.0.1:8000
test
127.0.0.1, 8000:
test
hi
127.0.0.1, 8000:
hi

You can download circuits from http://trac.softcircuit.com.au/circuits/
or get the latest development version by using Mercurial (1):
hg clone http://hg.softcircuit.com.au/projects/circuits/

cheers
James

[1] http://www.selenic.com/mercurial/wiki/

--
--
-- "Problems are solved by method"

[Ben Sizer]

On Nov 6, 12:46*am, "James Mills" <prolo...@short circuit.net.au>
wrote:

>
Try these instead:
** UDPServer ->http://trac.softcircuit.com.au/circu...s/udpserver.py
** UDPClient *->http://trac.softcircuit.com.au/circu...s/udpclient.py

Since there's no contact details on the Circuits site, and the guest
Trac account doesn't work (it asks the admin to verify the email),
then I'll post here: it appears that the Hello World example is wrong,
trying to add an instance of a 'hello' object that doesn't exist. I've
not tried to run the example, but it certainly confused me when trying
to work out how Circuits works.

--
Ben Sizer

[Steve Holden]

I D wrote:

Hello James,
Thanks for your response.
But I cannot use a third party software, I need to use the exisiting
API's within python.
As I am new to python, I suspected that I should go by a simpler
approach and so
scrapped off the below code and wrote a very simple UDP server code as
follows:

logFileName = '/home/msat/gsc/logs/' + compNum + '/logparsertraced ump.log'
logfile = open(logFileNam e, "w")
from socket import *
host = "121.3.0.1 <http://121.3.0.1>"
port = PORT
buf = 4096
addr = (host,port)
# Create socket and bind to address
UDPSock = socket(AF_INET, SOCK_DGRAM)
UDPSock.setsock opt(SOL_SOCKET, SO_RCVBUF, 8388608)
UDPSock.bind(ad dr)
while 1:
data,addr = UDPSock.recvfro m(buf)
if not fileExists(logF ileName):
logfile = open(logFileNam e, "a")
logfile.writeli nes(data)

It would make more sense to leave the file open outside the loop. If
it's important to have each packet individually logged you can call the
file's .flush() method after each .writelines() call. No need to
continually re-open it. I doubt this is the source of your packet loss,
however. Maybe there's a bug in fileExists (for which you could have
used os.path.exists, by the way).

# Close socket
UDPSock.close()

How do you anticipate this line will ever be executed?

Your network code looks basically OK, though a little horrible with
things like 8388608 for the socket options. See if you get any ideas from

http://holdenweb.com/docs/NetProg.pdf

though it doesn't tell you much you don't appear to know already.

regards
Steve

Even this seems to lose packets, I would really appreciate if any
pointers can be provided to improve my code.

Thanks,
Sam

On Wed, Nov 5, 2008 at 7:46 PM, James Mills
<pr******@short circuit.net.au <mailto:pr***** *@shortcircuit. net.au>wrote:

On Thu, Nov 6, 2008 at 9:53 AM, <id*****@gmail. com
<mailto:id***** @gmail.com>wrot e:

logFileName = 'log.txt'
logfile = open(logFileNam e, "a")
class MyUDPServer(Soc ketServer.UDPSe rver):
def server_bind(sel f):
self.socket.set sockopt(socket. SOL_SOCKET,
socket.SO_RCVBU F, 8388608)
self.socket.bin d(self.server_a ddress)
>
class LogsDumpHandler (SocketServer.D atagramRequestH andler):
def handle(self):
global logfile
# fileExists is a function which checks the existence of a file
if not fileExists(logF ileName):
logfile = open(logFileNam e, "a")
logfile.writeli nes(self.rfile. readlines())
>
server = MyUDPServer(("" ,PORT), LogsDumpHandler )
server.serve_fo rever()
logfile.close()

This is horrible code :/

Try these instead:
* UDPServer ->
http://trac.softcircuit.com.au/circu...s/udpserver.py
* UDPClient ->
http://trac.softcircuit.com.au/circu...s/udpclient.py

Example usage
----------------------

~/circuits/examples
$ ./udpserver.py
127.0.0.1 <http://127.0.0.1/>, 9000:
test
127.0.0.1 <http://127.0.0.1/>, 9000:
hi

~/circuits/examples
$ ./udpclient.py -b 127.0.0.1:9000 <http://127.0.0.1:9000/>
127.0.0.1:8000 <http://127.0.0.1:8000/>
test
127.0.0.1 <http://127.0.0.1/>, 8000:
test
hi
127.0.0.1 <http://127.0.0.1/>, 8000:
hi

You can download circuits from http://trac.softcircuit.com.au/circuits/
or get the latest development version by using Mercurial (1):
hg clone http://hg.softcircuit.com.au/projects/circuits/

cheers
James

[1] http://www.selenic.com/mercurial/wiki/

--
--
-- "Problems are solved by method"

------------------------------------------------------------------------

--
http://mail.python.org/mailman/listinfo/python-list

--
Steve Holden [phone] [phone]
Holden Web LLC http://www.holdenweb.com/

[James Mills]

On Fri, Nov 7, 2008 at 1:43 AM, Ben Sizer <ky*****@gmail. comwrote:

On Nov 6, 12:46 am, "James Mills" <prolo...@short circuit.net.au>
wrote:

>>
Try these instead:
* UDPServer ->http://trac.softcircuit.com.au/circu...s/udpserver.py
* UDPClient ->http://trac.softcircuit.com.au/circu...s/udpclient.py

Since there's no contact details on the Circuits site, and the guest
Trac account doesn't work (it asks the admin to verify the email),
then I'll post here: it appears that the Hello World example is wrong,
trying to add an instance of a 'hello' object that doesn't exist. I've
not tried to run the example, but it certainly confused me when trying
to work out how Circuits works.

Ben, thanks for your feedback! I've fixed this
now! I've also added come contact details for
myself on the website and fixed the guest
account! Thanks for taking an interest.

--JamesMills

--
--
-- "Problems are solved by method"