<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
  <meta content="text/html;charset=ISO-8859-1" http-equiv="Content-Type">
  <title></title>
</head>
<body bgcolor="#ffffff" text="#000000">
Andres, Richard,<br>
<br>
thanks for the input! <br>
Indeed I have a multi-threaded UDP server going. I was running out of
regular threads so I am porting it to stackless.<br>
<br>
What I learned over the past days is that unless you have a loop
constantly doing a blocking(!) recvfrom on a socket you will lose the
UDP packets that arrive when you are not actively listening. I sorted
all of that out now by creating a couple of threads, so I have a thread
that may block all it likes on the socket and a worker thread that
actually holds the tasklets to handle the incoming messages.<br>
<br>
My current problem is a logic problem. Halfway through my test scenario
the server calls itself. At some point a return on one of those calls
does not seem to find a tasklet waiting for it.<br>
<br>
It is one of those painful things when you have something massively
parallel....<br>
<br>
In the process I made the attached drop-in modules to replace the
regular queue and threading as part of a quick porting action. (i.e.
import muQueue as queue). This might be of use to people who have a
less complex problem on their hands ;-)<br>
<br>
Paul<br>
<br>
Andrew Francis wrote:
<blockquote cite="mid134822.24156.qm@web34215.mail.mud.yahoo.com"
 type="cite">
  <pre wrap="">Message: 6
Date: Wed, 28 Feb 2007 18:26:53 +0000
From: "Richard Tew" <a class="moz-txt-link-rfc2396E" href="mailto:richard.m.tew@gmail.com">&lt;richard.m.tew@gmail.com&gt;</a>
Subject: Re: [Stackless] stackless socket, curiouser
and curiouser
  </pre>
  <blockquote type="cite">
    <pre wrap="">To: "Paul Sijben" <a class="moz-txt-link-rfc2396E" href="mailto:sijben@eemvalley.com">&lt;sijben@eemvalley.com&gt;</a>
    </pre>
  </blockquote>
  <pre wrap=""><!---->Cc: <a class="moz-txt-link-abbreviated" href="mailto:stackless@stackless.com">stackless@stackless.com</a>
Message-ID:
        
  </pre>
  <blockquote type="cite">
    <pre wrap="">If it is more important to you to just get things
done, you might be better off to look at using a
networking framework which is known to
work with Stackless.  I do not have any personal
knowledge of any which do so without some other form
of shenanigans involved.  However there are some
people on the list with experience mixing Stackless
with Twisted who might wish to help out if you choose
to go that direction.
    </pre>
  </blockquote>
  <pre wrap=""><!---->
Paul, I am not sure what you are trying to do but it
seems to involve setting up a UDP server. I feel
packages like asyncore simply require too much work to
do even for the simplest of programmes.

Here is a quick example I wrote based on the Twisted
Echo server example at
<a class="moz-txt-link-freetext" href="http://twistedmatrix.com/projects/core/documentation/howto/udp.html">http://twistedmatrix.com/projects/core/documentation/howto/udp.html</a>

The server listens at port 9999. When a connection
comes in, a tasklet prints out connection information.
I feel the solution is relatively easy to follow.

~~~~

#!/usr/bin/env python
"""
UDPServer.py
Andrew Francis
March 1st, 2007

Simple example of a UDP server using Twisted and
Stackless

Based on the Echo server example at
<a class="moz-txt-link-freetext" href="http://twistedmatrix.com/projects/core/documentation/howto/udp.html">http://twistedmatrix.com/projects/core/documentation/howto/udp.html</a>

&lt;song&gt;Rebellion - Arcade Fire&lt;/song&gt;
"""


import stackless
from twisted.internet.protocol import DatagramProtocol
from twisted.internet import reactor

class Echo(DatagramProtocol):
    
    def __init__(self, requestChannel):
        self.channel = requestChannel
        return
    
    
    def datagramReceived(self, data, (host, port)):
        self.channel.send((data, host, port))
        self.transport.write(data, (host, port))


class EchoServer(object):
    def execute(self, port, requestChannel):
        reactor.listenUDP(port, Echo(requestChannel))
        reactor.run()


class EchoTasklet(object):
    def __init__(self, name, channel):
        self.channel = channel
        return

    def execute(self):
        while (1):
            data, host, port = self.channel.receive()
            print "received %r from %s:%d" % (data,
host, port)
            stackless.schedule()
            

if __name__ == "__main__":
    from twisted.internet import reactor
    
    """
    for simplicity - share the channel
    """
    requestChannel = stackless.channel()
    
    listener = EchoTasklet(requestChannel)
    server = EchoServer()
    
    stackless.tasklet(listener.execute)()
    stackless.tasklet(server.execute)(9999,
requestChannel)
    
    while (stackless.getruncount() &gt; 1):
       stackless.schedule()

Cheers,
Andrew


 
____________________________________________________________________________________
The fish are biting. 
Get more visitors on your site using Yahoo! Search Marketing.
<a class="moz-txt-link-freetext" href="http://searchmarketing.yahoo.com/arp/sponsoredsearch_v2.php">http://searchmarketing.yahoo.com/arp/sponsoredsearch_v2.php</a>
  </pre>
</blockquote>
<br>
<pre class="moz-signature" cols="72">-- 
Paul Sijben                            tel: +31334566488
Eemvalley Technology               fax: +31334557523
the Netherlands                        <a class="moz-txt-link-freetext" href="http://eemvalley.com">http://eemvalley.com</a>    
</pre>
</body>
</html>