Re: Twisted Matrix and multicast broadcast

[Jean-Paul Calderone]

On Thu, 9 Oct 2008 06:03:44 -0700 (PDT), Stodge <st****@gmail.comwrote:

[snip]
class MulticastServerUDP(DatagramProtocol):
def startProtocol(self):
print 'Started Listening'
# Join a specific multicast group, which is the IP we will
respond to
self.transport.joinGroup('224.0.0.1')

[snip]

class MulticastClientUDP(DatagramProtocol):
def startProtocol(self):
print 'Started Listening'
# Join a specific multicast group, which is the IP we will
respond to
self.transport.joinGroup('224.0.0.1')

[snip]

No surprises there! But how do I get the server to send to all clients
using multicast? transport.write requires an address. Any suggestions
appreciated.

Your server and client are both listening on the multicast address
224.0.0.1. Traffic sent to that address will be delivered to both
of them. If you want to send something to all clients listening on
that address, then that's the address to pass to transport.write.

Jean-Paul

[Stodge]

On Oct 9, 9:33*am, Jean-Paul Calderone <[e-mail]:

On Thu, 9 Oct 2008 06:03:44 -0700 (PDT), Stodge <[e-mail]:

[snip]
class MulticastServerUDP(DatagramProtocol):
* *def startProtocol(self):
* * * *print 'Started Listening'
* * * *# Join a specific multicast group, which is the IP we will
respond to
* * * *self.transport.joinGroup('224.0.0.1')

[snip]

class MulticastClientUDP(DatagramProtocol):
* *def startProtocol(self):
* * * *print 'Started Listening'
* * * *# Join a specific multicast group, which is the IP we will
respond to
* * * *self.transport.joinGroup('224.0.0.1')

[snip]

No surprises there! But how do I get the server to send to all clients
using multicast? transport.write requires an address. Any suggestions
appreciated.

Your server and client are both listening on the multicast address
224.0.0.1. *Traffic sent to that address will be delivered to both
of them. *If you want to send something to all clients listening on
that address, then that's the address to pass to transport.write.

Jean-Paul

Thanks. So the server write should be:

self.transport.write("data", ('224.0.0.1', 8005))

I guess I can't run multiple peers on the same PC as they'll all be
listening on port 8005.