[ruby-talk:18925] RE: IP multicast with UDPSocket

< ^ > P N |<>|^_>< --- | ~ ...Help
This message is in MIME format. Since your mail reader does not understand
this format, some or all of this message may not be legible.

------_extPart_001_01C11A1F.2CECF680
Content-Type: text/plain;
	charsetso-8859-1"

 
Something I threw together a few weeks ago. It has only been tested using
Ruby 1.7.1 on Win32, but It should work on the other platforms as well. You
may have to take out the definition of the constants since they should
already be defined in socket.c. There are some some differences in the C
headers #defines of these constants, but I did not have time to look into
this and fix it on Windows. 
 
enjoy...
 
- Will
 
<SNIP filenameulticast.rb' >

require 'socket'
 
#struct ip_mreq {
#        struct in_addr  imr_multiaddr;  /* IP multicast address of group */
#        struct in_addr  imr_interface;  /* local IP address of interface */
#};
 

class MulticastSocket < UDPSocket
 
 # Some constants that are not set in Win32 version of socket.c
 IPPROTO_IP  
 IPPROTO_UDP  7
 IP_DROP_MEMBERSHIP  
 
 def convAddr(a)
  h  il
  case a
  when String
   h  .split('.').collect! { |b| b.to_i }.pack('CCCC')
 
  when Array
   h  .pack('CCCC')
 
  else
   raise "Bad address"
  end
  h
 end
 private :convAddr
 
 def addMembership(mcaddr)
  mreq  onvAddr(mcaddr) + Socket.gethostbyname(Socket.gethostname)[3]
  setsockopt(IPPROTO_IP, Socket::IP_ADD_MEMBERSHIP, mreq)
 end
 
 def dropMembership(mcaddr)
  mreq  onvAddr(mcaddr) + Socket.gethostbyname(Socket.gethostname)[3]
  setsockopt(IPPROTO_IP, IP_DROP_MEMBERSHIP, mreq)
 end
 
 def setMCTTL(ttl)
  setsockopt(IPPROTO_IP, Socket::IP_MULTICAST_TTL, ttl)
 end
 
 def setMCLoop(loop)
  setsockopt(IPPROTO_IP, Socket::IP_MULTICAST_LOOP, loop)
 end
 
 def setMCInterface(int)
  host  ocket.gethostbyname(int)[3]
  setsockopt(IPPROTO_IP, Socket::IP_MULTICAST_IF, host)
 end
 
end
 
if $0 __FILE__
 
 $port  900
 $addr  239.192.0.1'
 
 sock  ulticastSocket.open
 sock.bind(Socket.gethostname, $port)
 sock.addMembership($addr)
  
 thread  hread.start do
  2.times { p sock.recvfrom(8000) }
 end
 
 sock.send('Hello', 0, $addr, $port)
 sock.send('There', 0, $addr, $port)
 
 thread.join
 sock.dropMembership($addr)
end
 

</SNIP>

-----Original Message-----
From: Nat Pryce [mailto:nat.pryce / b13media.com]
Sent: Tuesday, July 31, 2001 5:09 AM
To: ruby-talk / ruby-lang.org
Subject: [ruby-talk:18883] IP multicast with UDPSocket


Does anyone have example code for joining/leaving multicast groups using the
UDPSocket?
 
Also, how is it possible to write this in a platform independent manner?  As
far as I can tell, the API for setting socket options seems to be completely
platform dependent.  It is also hard to code to, because you have to build
strings of binary data that contain valid C structures used by the OS APIs.
Would there be interest in code to replace or wrap setsockopt/getsockopt
with methods and attribute accessors?  
 
For example:
 
socket  DPSocket.new
socket.add_membership "240.212.100.200"  # or whatever a valid IP group
number is
socket.ip_multicast_ttl  ocket::TTL_LOCAL_NETWORK
socket.ip_multicast_loopback  alse
socket.sol_reuse_address  rue
socket.bind( 15630 )
 
Or:
 
socket  CPSocket.new( 'www.b13media.com', 80 )
socket.sol_sndbuf  12
socket.sol_rcvbuf  096
 
Would this be a useful RCR?
 
Cheers,
    Nat.
 
 


------_extPart_001_01C11A1F.2CECF680
Content-Type: text/html;
	charsetso-8859-1"

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<HTML><HEAD>
<META HTTP-EQUIVontent-Type" CONTENText/html; charseto-8859-1">


<META contentSHTML 5.50.4134.600" name石瓜丟民乩穴丟本
扑乒乩伙白瓜本扑永乒乩伙白瓜本
扑永生瓜民玄本
扑汁穴玄伙 氾fffff>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><SPAN class#4145223-31072001><FONT face 阬摐 蜧斀偽唳
size Something I threw together a few weeks ago.&nbsp;It has only been 
tested&nbsp;using Ruby&nbsp;1.7.1 on Win32, but&nbsp;It should work on the other 
platforms as well. You may have to take out the definition of the constants 
since they should already be defined in socket.c. There are some&nbsp;some 
differences in the C headers #defines of these constants, but I did not have 
time to look into this and fix it&nbsp;on Windows. </FONT></SPAN></DIV>
<DIV><SPAN class#4145223-31072001></SPAN><SPAN class#4145223-31072001><FONT 
face 阬摐 蜧斀偽唳鶅义 摩廴拏噯耗釓徆佇碥蟧摩馨祩
<DIV><SPAN class#4145223-31072001></SPAN><SPAN class#4145223-31072001><FONT 
face 阬摐 蜧斀偽唳鶅义 槴膬顳悅摩廴拏噯耗釓徆摩馨祩
<DIV><SPAN class#4145223-31072001><FONT face 阬摐 蜧斀偽唳
size </FONT></SPAN>&nbsp;</DIV>
<DIV><SPAN class#4145223-31072001><FONT face 阬摐 蜧斀偽唳鶅义 
Will</FONT></SPAN></DIV>
<DIV><SPAN class#4145223-31072001><FONT face 阬摐 蜧斀偽唳
size </FONT></SPAN>&nbsp;</DIV>
<DIV><SPAN class#4145223-31072001><FONT face 阬摐 蜧斀偽唳
size &lt;SNIP filenameulticast.rb' &gt;</FONT></SPAN></DIV><SPAN 
class#4145223-31072001>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏噯廴拏 糌蜲 阬摐 蜧斀偽唳
size </FONT><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏噯廴拏 糌蜲 阬摐 
color000ff size </FONT><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏噯廴拏 
face 阬摐 蜧斀偽唳鶅义 摩廴拏噯觴噯廴拏 糌蜲 阬摐 蜧斀偽唳
size require 'socket'</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 �鐍礯潞蜁蠈
{<BR>#&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; struct in_addr&nbsp; 
imr_multiaddr;&nbsp; /* IP multicast address of group 
*/<BR>#&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; struct in_addr&nbsp; 
imr_interface;&nbsp; /* local IP address of interface */<BR>#};</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏噯廴拏 糌蜲 阬摐 蜧斀偽唳
size </FONT><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏噯廴拏 糌蜲 阬摐 
color000ff size </FONT><BR><FONT face 阬摐 蜧斀偽唳鶅义 蜵摷
MulticastSocket &lt; UDPSocket</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧逄翴 蜧閷酃隮鐓敳 摥闀
set in Win32 version of socket.c<BR>&nbsp;IPPROTO_IP  <BR>&nbsp;IPPROTO_UDP  17<BR>&nbsp;IP_DROP_MEMBERSHIP  </FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧麧
convAddr(a)<BR>&nbsp;&nbsp;h  il<BR>&nbsp;&nbsp;case a<BR>&nbsp;&nbsp;when 
String<BR>&nbsp;&nbsp;&nbsp;h  .split('.').collect! { |b| b.to_i 
}.pack('CCCC')</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧佇碥蟧玁槴 
Array<BR>&nbsp;&nbsp;&nbsp;h  .pack('CCCC')</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳
size &nbsp;&nbsp;else<BR>&nbsp;&nbsp;&nbsp;raise "Bad 
address"<BR>&nbsp;&nbsp;end<BR>&nbsp;&nbsp;h<BR>&nbsp;end<BR>&nbsp;private 
:convAddr<BR>&nbsp;<BR>&nbsp;def addMembership(mcaddr)<BR>&nbsp;&nbsp;mreq  convAddr(mcaddr) + 
Socket.gethostbyname(Socket.gethostname)[3]<BR>&nbsp;&nbsp;setsockopt(IPPROTO_IP, 
Socket::IP_ADD_MEMBERSHIP, mreq)<BR>&nbsp;end</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧麧
dropMembership(mcaddr)<BR>&nbsp;&nbsp;mreq  onvAddr(mcaddr) + 
Socket.gethostbyname(Socket.gethostname)[3]<BR>&nbsp;&nbsp;setsockopt(IPPROTO_IP, 
IP_DROP_MEMBERSHIP, mreq)<BR>&nbsp;end</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧麧
setMCTTL(ttl)<BR>&nbsp;&nbsp;setsockopt(IPPROTO_IP, Socket::IP_MULTICAST_TTL, 
ttl)<BR>&nbsp;end</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧麧
setMCLoop(loop)<BR>&nbsp;&nbsp;setsockopt(IPPROTO_IP, Socket::IP_MULTICAST_LOOP, 
loop)<BR>&nbsp;end</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧麧
setMCInterface(int)<BR>&nbsp;&nbsp;host  Socket.gethostbyname(int)[3]<BR>&nbsp;&nbsp;setsockopt(IPPROTO_IP, 
Socket::IP_MULTICAST_IF, host)<BR>&nbsp;end</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 槴隡紜玴埲摩馨祩
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 氄 什 葔厶旼葔摩廴拏噯紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧毋濿 僭側觴齒鍒鶇誘撦劋  妓章拳僕扇拳尬紜玴埲摩馨祩
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧鵿蜱  卼檖殫摷譥檶錼纁瀔槴撢瓴佇碥蟧鵿蜱栽濎鋮逄蜱殦桃殦鴄黀鍕翴
$port)<BR>&nbsp;sock.addMembership($addr)<BR>&nbsp;&nbsp;<BR>&nbsp;thread  Thread.start do<BR>&nbsp;&nbsp;2.times { p sock.recvfrom(8000) 
}<BR>&nbsp;end</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 佇碥蟧鵿蜱氦槴鋮庇樦斀妞 鬲 戶鳵簻 
$port)<BR>&nbsp;sock.send('There', 0, $addr, $port)</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳
size &nbsp;thread.join<BR>&nbsp;sock.dropMembership($addr)<BR>end</FONT></DIV>
<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏齒鍒鶇遞紕屼<DIV><FONT face 阬摐 蜧斀偽唳鶅义 摩廴拏噯廴拏 糌蜲 阬摐 蜧斀偽唳
size </FONT><BR><SPAN class#4145223-31072001><FONT face 阬摐 蜧斀偽唳
size &lt;/SNIP&gt;</FONT></SPAN></SPAN></DIV>
<BLOCKQUOTE dirr styleARGIN-RIGHT: 0px">
  <DIV classtlookMessageHeader dirr align本扑瓦穴石乩 
 
   亙亙亙亙亙穴 目亙亙亙亙亙扑汁丟本扑汁本瓦戊扑永汁本 石 立 
  伕戊亦正失它亦件扑汁丟本扑汁本乒戊扑永汁本 乩乓 甩 它失乓 奶□□失 左戊□弗 
  民目扑汁丟本扑汁本乩戊扑永汁本 亙正亙亦扑汁丟本扑汁本乒戊扑永汁本 伕亙戊失弁弁弁它件 
  用立   交玄立乒扑汁丟本扑汁丟本扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  玄      永 
      交玄立乒末扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本仲扔扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  民乓          
    末仲扔 民   用  乓 扑永瓦穴石乩本扑瓦穴石乩 
   阬   民立用         
   亦仲扔 用  仲扔   乓     
          氾     穴乒 
  民立用亦仲扔 仿          
  永     末仲扔 
扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  扑永瓦穴石乩本仲扔扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  瓦 戊扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  扑永瓦穴石乩本仲扔扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬    玄立乒亦扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  亦′ ＞奶巨□亦奶失奶亦失□□亦奶□□＞仲扔 ＝ 
      用立   扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  亦′′    乒戊戊乩乩皿白穴氾民皿石瓜乩仿穴丟甲扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  亦′′  扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  亦′′  扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  亦奴 失左市它□ 孕扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  扑永瓦穴石乩本仲扔扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  穴戊扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  扑永瓦穴石乩本仲扔扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬    氾立乒亦奴 央亦失它亦央乓 弁□ 
  孕扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  亦′  失奶扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  亦′  □弗市扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  扑永瓦穴石乩本仲扔扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  仿     丟氾丟末扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  扑永瓦穴石乩本仲扔扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  氾乓扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  仲扔仲扔仲扔 石亦扑永瓦穴石乩本扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  扑永瓦穴石乩本仲扔扑永玄用亥本
  扑玄用亥本扑瓦穴石乩  阬  扑永瓦穴石乩本仲扔扑永玄用亥本扑永汁白穴氾甲丞交穴乩瓜本扑永汁穴玄伙本扑永生乩目白本

亙亙亙亙亙亙′立′□□失′□失氾失失民失瓦亦奶氾瓜氾瓦市弁□亙亙