home *** CD-ROM | disk | FTP | other *** search
/ Super Net 1 / SUPERNET_1.iso / PC / OTROS / MSDOS / WATTCP / MCAST.ZIP / MCAST.DIF next >
Encoding:
Text File  |  1993-11-10  |  23.8 KB  |  884 lines
  1. *** apps/makefile    Tue Nov 09 00:51:06 1993
  2. --- apps/makefile    Wed Nov 10 02:31:48 1993
  3. ***************
  4. *** 13,22 ****
  5.   #
  6.   
  7.   !if '$(DEBUG)'=='E'
  8. ! IDEBUG=-v
  9.   TEXTDEBUG=enabled
  10.   !elif '$(DEBUG)'=='D'
  11. ! IDEBUG=-v-
  12.   TEXTDEBUG=disabled
  13.   #!else
  14.   #!error  DEBUG must be set to either E or D
  15. --- 13,22 ----
  16.   #
  17.   
  18.   !if '$(DEBUG)'=='E'
  19. ! IDEBUG=-v -DMULTICAST
  20.   TEXTDEBUG=enabled
  21.   !elif '$(DEBUG)'=='D'
  22. ! IDEBUG=-v- -DMULTICAST
  23.   TEXTDEBUG=disabled
  24.   #!else
  25.   #!error  DEBUG must be set to either E or D
  26. ***************
  27. *** 49,55 ****
  28.   
  29.   exes.arc: ping.exe daytime.exe finger.exe lpr.exe lpq.exe \
  30.           tcpport.exe rexec.exe ntime.exe tcpinfo.exe cookie.exe \
  31. !         popdump.exe ph.exe tcptalk.exe
  32.   # host.exe
  33.           echo done $(TEXTMODEL) make with debugging $(TEXTDEBUG)
  34.   
  35. --- 49,55 ----
  36.   
  37.   exes.arc: ping.exe daytime.exe finger.exe lpr.exe lpq.exe \
  38.           tcpport.exe rexec.exe ntime.exe tcpinfo.exe cookie.exe \
  39. !         popdump.exe ph.exe tcptalk.exe lister.exe blather.exe
  40.   # host.exe
  41.           echo done $(TEXTMODEL) make with debugging $(TEXTDEBUG)
  42.   
  43. ***************
  44. *** 92,97 ****
  45. --- 92,103 ----
  46.   
  47.   tcptalk.exe: tcptalk.c
  48.           $(CC)  tcptalk.c $(CLIB)
  49. + 
  50. + lister.exe: lister.c
  51. +         $(CC)  lister.c $(CLIB)
  52. + 
  53. + blather.exe: blather.c
  54. +         $(CC)  blather.c $(CLIB)
  55.   
  56.   host.exe: host.c
  57.           $(CC)  host.c $(CLIB)
  58. *** include/tcp.h    Thu Aug 05 10:13:58 1993
  59. --- include/tcp.h    Tue Nov 09 23:26:36 1993
  60. ***************
  61. *** 281,284 ****
  62. --- 281,293 ----
  63.   extern int addwattcpd( void (*p)() );
  64.   extern int delwattcpd( void (*p)() );
  65.   extern int tap_add( void *socket, void *userid );
  66. + 
  67. + #if defined(MULTICAST)
  68. + /* Stuff for Multicast Support - JRM 6/7/93 */
  69. + 
  70. + extern int udp_SetTTL(udp_Socket *, byte );
  71. + extern int join_mcast_group( longword );
  72. + extern int leave_mcast_group( longword );
  73. + #endif /* MULTICAST */
  74. + 
  75.   #endif /* WTCP_VER */
  76. *** include/wattcp.h    Thu Jul 15 11:16:48 1993
  77. --- include/wattcp.h    Tue Nov 09 23:38:10 1993
  78. ***************
  79. *** 17,22 ****
  80. --- 17,26 ----
  81.   
  82.   #include <stdio.h>
  83.   #include <elib.h>
  84. + #if defined(MULTICAST)
  85. + #include <stdlib.h>
  86. + #include <time.h>
  87. + #endif /* MULTICAST */
  88.   
  89.   #define set_mstimeout( x ) (set_timeout(0)+ (x / 55))
  90.   
  91. ***************
  92. *** 45,50 ****
  93. --- 49,57 ----
  94.   #define UDP_PROTO  0x11
  95.   #define TCP_PROTO  0x06
  96.   #define ICMP_PROTO 0x01
  97. + #if defined(MULTICAST)
  98. + #define    IGMP_PROTO 0x02
  99. + #endif /* MULTICAST */
  100.   
  101.   #define TCP_MODE_BINARY  0       /* default mode */
  102.   #define TCP_MODE_ASCII   1
  103. ***************
  104. *** 74,79 ****
  105. --- 81,90 ----
  106.   
  107.   extern word sock_inactive;      /* in pcbootp.c */
  108.   extern word _pktdevclass;
  109. + #if defined(MULTICAST)
  110. + extern byte _pktdevlevel;
  111. + extern byte pkterror;
  112. + #endif /* MULTICAST */
  113.   extern word _mss;
  114.   extern word _bootptimeout;    /* in pcbootp.c */
  115.   extern longword _bootphost;    /* in pcbootp.c */
  116. ***************
  117. *** 102,107 ****
  118. --- 113,132 ----
  119.       longword        destination;
  120.   } in_Header;
  121.   
  122. + #if defined(MULTICAST)
  123. + /* The Internet Group Management Protocol (IGMP) Packet */
  124. + typedef struct {
  125. +     unsigned       type         : 4;
  126. +     unsigned       version   : 4;
  127. +     byte       mbz;
  128. +     word       checksum;
  129. +     longword       address;
  130. + } IGMP_packet;
  131. + 
  132. + #define IGMP_Version  1
  133. + #define IGMP_Query    1
  134. + #define IGMP_Report   2
  135. + #endif /* MULTICAST */
  136.   
  137.   #define in_GetVersion(ip) ( (ip)->ver )
  138.   #define in_GetHdrlen(ip)  ( (ip)->hdrlen )  /* 32 bit word size */
  139. ***************
  140. *** 179,184 ****
  141. --- 204,212 ----
  142.   typedef struct _udp_socket {
  143.       struct _udp_socket *next;
  144.       word        ip_type;        /* always set to UDP_PROTO */
  145. + #if defined(MULTICAST)
  146. +     byte        ttl;        /* mainly for use with multicast */
  147. + #endif /* MULTICAST */
  148.       char       *err_msg;        /* null when all is ok */
  149.       char           *usr_name;
  150.       void      (*usr_yield)();
  151. ***************
  152. *** 425,427 ****
  153. --- 453,508 ----
  154.   extern int tcp_listen(tcp_Socket *s, word lport, longword ina, word port, procref datahandler, word timeout);
  155.   extern int sock_gets(sock_type *, byte *, int );
  156.   extern int sock_close(sock_type * );
  157. + 
  158. + #if defined(MULTICAST)
  159. + /* Stuff for Multicast Support - JRM 6/7/93 */
  160. + 
  161. + extern int udp_SetTTL(udp_Socket *, byte );
  162. + extern int join_mcast_group( longword );
  163. + extern int leave_mcast_group( longword );
  164. + extern int _eth_join_mcast_group( int );
  165. + extern int _eth_leave_mcast_group( int );
  166. + extern int is_multicast( longword );
  167. + extern int multi_to_eth( longword , eth_address );
  168. + extern void igmp_handler( in_Header * );
  169. + extern int igmp_report( longword );
  170. + extern int _pkt_set_rcv_mode( int , int );
  171. + extern int _pkt_get_rcv_mode( int );
  172. + extern int _pkt_get_multicast_list( byte , eth_address * );
  173. + extern int _pkt_set_multicast_list( byte , eth_address * );
  174. + extern int _pkt_get_ip_rcv_mode( );
  175. + extern int _pkt_set_ip_rcv_mode( int );
  176. + 
  177. + #define CLASS_D_MASK 0xE0000000  /* the mask that defines IP Class D */
  178. + #define IPMULTI_MASK 0x007FFFFF  /* to get the low-order 23 bits */
  179. + #define ETH_MULTI 0x01005E       /* high order bits of multi eth addr */
  180. + #define IPMULTI_SIZE 20         /* the size of the ipmulti table */
  181. + #define ALL_SYSTEMS 0xE0000001     /* the default mcast addr 224.0.0.1 */
  182. + 
  183. + typedef struct {
  184. +     longword    ina;        /* IP address of group */
  185. +     eth_address    ethaddr;    /* Ethernet address of group */
  186. +     byte        processes;    /* number of interested processes */
  187. +     time_t        replytime;    /* IGMP query reply timer */
  188. +     byte        active;        /* is this an active entry */
  189. + } multicast;
  190. + extern multicast _ipmulti[IPMULTI_SIZE];
  191. + 
  192. + /* PD Error Returns */
  193. + #define BASIC_DVR    0
  194. + #define BAD_HANDLE    1
  195. + #define NO_CLASS    2
  196. + #define NO_TYPE        3
  197. + #define NO_NUMBER    4
  198. + #define BAD_TYPE    5
  199. + #define NO_MULTICAST    6
  200. + #define CANT_TERMINATE    7
  201. + #define BAD_MODE    8
  202. + #define NO_SPACE    9
  203. + #define TYPE_INUSE    10
  204. + #define BAD_COMMAND    11
  205. + #define CANT_SEND    12
  206. + #define CANT_SET    13
  207. + #define BAD_ADDRESS    14
  208. + 
  209. + #endif /* MULTICAST */
  210. *** src/makefile    Tue Nov 09 00:51:34 1993
  211. --- src/makefile    Tue Nov 09 23:42:34 1993
  212. ***************
  213. *** 7,13 ****
  214.   #    TRACE        - turn on tracing/debugging code
  215.   #
  216.   #
  217. ! DEBUGS= -v
  218.   
  219.   CFLAGS= $(DEBUGS) -DMSDOS -Ic:\borlandc\include -I..\include -g200
  220.   MODELS=-ms
  221. --- 7,13 ----
  222.   #    TRACE        - turn on tracing/debugging code
  223.   #
  224.   #
  225. ! DEBUGS= -v -DMULTICAST
  226.   
  227.   CFLAGS= $(DEBUGS) -DMSDOS -Ic:\borlandc\include -I..\include -g200
  228.   MODELS=-ms
  229. ***************
  230. *** 37,44 ****
  231.           sock_prn.obj sock_ini.obj pcbsd.obj pcrecv.obj \
  232.           udp_nds.obj udp_dom.obj pcconfig.obj pc_cbrk.obj pcbuf.obj \
  233.           pcbootp.obj sock_dbu.obj pcdbug.obj test.obj pcintr.obj pcstat.obj \
  234. !         bsdname.obj fragment.obj \
  235. !         netback.obj select.obj
  236.   
  237.   ..\lib\wattcpsm.lib: $(objs)
  238.           echo done
  239. --- 37,44 ----
  240.           sock_prn.obj sock_ini.obj pcbsd.obj pcrecv.obj \
  241.           udp_nds.obj udp_dom.obj pcconfig.obj pc_cbrk.obj pcbuf.obj \
  242.           pcbootp.obj sock_dbu.obj pcdbug.obj test.obj pcintr.obj pcstat.obj \
  243. !         bsdname.obj fragment.obj netback.obj select.obj \
  244. !     pcigmp.obj pcmulti.obj
  245.   
  246.   ..\lib\wattcpsm.lib: $(objs)
  247.           echo done
  248. ***************
  249. *** 70,75 ****
  250. --- 70,78 ----
  251.   pcstat.obj: pcstat.c ..\include\wattcp.h
  252.   netback.obj: netback.c ..\include\elib.h ..\include\tcp.h
  253.   bsdname.obj: bsdname.c ..\include\wattcp.h
  254. + pcigmp.obj: pcigmp.c ..\include\wattcp.h
  255. + pcmulti.obj: pcmulti.c ..\include\wattcp.h
  256. + 
  257.   
  258.   
  259.   
  260. *** src/pcpkt.c    Wed Aug 04 11:14:30 1993
  261. --- src/pcpkt.c    Tue Nov 09 23:43:48 1993
  262. ***************
  263. *** 22,32 ****
  264. --- 22,45 ----
  265.   
  266.   #define INT_FIRST 0x60
  267.   #define INT_LAST  0x80
  268. + 
  269. + /* Basic PD Functions */
  270.   #define PD_DRIVER_INFO    0x1ff
  271.   #define PD_ACCESS     0x200
  272.   #define PD_RELEASE    0x300
  273.   #define PD_SEND        0x400
  274. + #define PD_TERMINATE    0x500
  275.   #define PD_GET_ADDRESS    0x600
  276. + #define PD_RESET    0x700
  277. + 
  278. + /* Extended PD Functions */
  279. + #define PD_SET_RCV    0x1400
  280. + #define PD_GET_RCV    0x1500
  281. + #define PD_SET_MULTI    0x1600
  282. + #define PD_GET_MULTI    0x1700
  283. + #define PD_GET_STATS    0x1800
  284. + #define PD_SET_ADDR    0x1900
  285. + 
  286.   #define  CARRY         1         /* carry bit in flags register */
  287.   
  288.   word _pktipofs = 0;            /* offset from header to start of pkt */
  289. ***************
  290. *** 102,107 ****
  291. --- 115,123 ----
  292.       }
  293.       } else {
  294.       pd_type = regs.r_dx;
  295. + #if defined(MULTICAST)
  296. +     _pktdevlevel = (regs.r_ax & 0xff);
  297. + #endif /* MULTICAST */
  298.       switch ( _pktdevclass = (regs.r_cx >> 8)) {
  299.           case PD_ETHER : _pktipofs = 14;
  300.   
  301. ***************
  302. *** 158,163 ****
  303. --- 174,184 ----
  304.       return( 1 );
  305.       }
  306.   
  307. + #if defined(MULTICAST)
  308. +     /* set recieve mode for IP */
  309. +     _pkt_set_ip_rcv_mode( 4 );
  310. + #endif /* MULTICAST */
  311. + 
  312.       return( 0 );
  313.   }
  314.   void pkt_release()
  315. ***************
  316. *** 269,273 ****
  317. --- 290,507 ----
  318.       return( eth_addr );
  319.   }
  320.   
  321. + #if defined(MULTICAST)
  322. + /* 
  323. +  * _pkt_set_rcv_mode - sets the recieve mode of the interface
  324. +  *
  325. +  * int _pkt_set_rcv_mode( int handle, int mode )
  326. +  * Where:
  327. +  *    handle    is the handle returned by access_type
  328. +  *    mode    is one of the following modes:
  329. +  *        1    turn off reciever
  330. +  *        2    recieve only packets sent to this interface
  331. +  *        3    mode 2 plus broadcast packets <default>
  332. +  *        4    mode 3 plus limited multicast packets
  333. +  *        5    mode 3 plus all multicast packets
  334. +  *        6    all packets (AKA promiscuous mode )
  335. +  * Returns:
  336. +  *    -1    upon error - pkterror is set
  337. +  *    0    if the mode was set successfully
  338. +  */
  339. + 
  340. + int _pkt_set_rcv_mode( handle, mode )
  341. + int handle;
  342. + int mode;
  343. + {
  344. +     struct REGPACK regs;
  345. + 
  346. +     /* This needs an Extended driver */
  347. +     if ( _pktdevlevel < 2 ){
  348. +         pkterror = BASIC_DVR;
  349. +         return(-1);
  350. +     }
  351. + 
  352. +     regs.r_ax = PD_SET_RCV;
  353. +     regs.r_bx = handle;
  354. +     regs.r_cx = mode;
  355. +         intr( pkt_interrupt, ®s );
  356. + 
  357. +     /* The carry flag indicates an error return */
  358. +         if ( regs.r_flags & CARRY ){
  359. +         pkterror = regs.r_dx >> 8;
  360. +         return( -1 );
  361. +         }
  362. + 
  363. +     return( 0 );
  364. + }
  365. + 
  366. + 
  367. + /* 
  368. +  * _pkt_get_rcv_mode - gets the recieve mode of the interface
  369. +  *
  370. +  * int _pkt_get_rcv_mode( int handle )
  371. +  * Where:
  372. +  *    handle    is the handle returned by access_type
  373. +  *
  374. +  * Returns:
  375. +  *    -1    upon error - pkterror is set
  376. +  *    mode    is one of the following modes: (upon return)
  377. +  *        1    turn off reciever
  378. +  *        2    recieve only packets sent to this interface
  379. +  *        3    mode 2 plus broadcast packets <default>
  380. +  *        4    mode 3 plus limited multicast packets
  381. +  *        5    mode 3 plus all multicast packets
  382. +  *        6    all packets (AKA promiscuous mode )
  383. +  */
  384. + 
  385. + int _pkt_get_rcv_mode( handle )
  386. + int handle;
  387. + {
  388. +     struct REGPACK regs;
  389. + 
  390. +     /* This needs an Extended driver */
  391. +     if ( _pktdevlevel < 2 ){
  392. +         pkterror = BASIC_DVR;
  393. +         return( -1 );
  394. +     }
  395. +     regs.r_ax = PD_GET_RCV;
  396. +     regs.r_bx = handle;
  397. +         intr( pkt_interrupt, ®s );
  398. + 
  399. +     /* The carry flag indicates an error return */
  400. +         if ( regs.r_flags & CARRY ){
  401. +         pkterror = regs.r_dx >> 8;
  402. +         return( -1 );
  403. +         }
  404. + 
  405. +     return( regs.r_ax );
  406. + }
  407. + 
  408. + /*
  409. +  * _pkt_get_multicast_list - gets the current list of multicast addresses
  410. +  *                           from the packet driver
  411. +  *
  412. +  * int _pkt_get_multicast_list( byte len, eth_address *listbuf )
  413. +  * Where:
  414. +  *    len    is the length of listbuf
  415. +  *    listbuf    is the buffer into which the list is placed
  416. +  * Returns:
  417. +  *    -1    upon error - pkterror is set
  418. +  *    len    if retrieval was successful
  419. +  *
  420. +  */
  421. + 
  422. + int _pkt_get_multicast_list( len, listbuf )
  423. + byte len;
  424. + eth_address *listbuf;
  425. + {
  426. +     struct REGPACK regs;
  427. + 
  428. +     /* Basic drivers don't support multicast */
  429. +     if ( _pktdevlevel < 2 ) {
  430. +         pkterror = BASIC_DVR;
  431. +         return( -1 );
  432. +     }
  433. + 
  434. +     regs.r_ax = PD_GET_MULTI;
  435. +         intr( pkt_interrupt, ®s );
  436. + 
  437. +     /* The carry flag indicates an error return */
  438. +         if ( regs.r_flags & CARRY ) {
  439. +         pkterror = regs.r_dx >> 8;
  440. +             return( -1 );
  441. +         }
  442. + 
  443. +     /* move it into the caller's buffer and return happily */
  444. +     len = min( len, regs.r_cx );
  445. +     movedata(regs.r_es, regs.r_di, FP_SEG( listbuf ), FP_OFF( listbuf ),
  446. +         len);
  447. +     return(len);
  448. + }
  449. + 
  450. + /* 
  451. +  * _pkt_set_multicast_list - sets the list of multicast addresses for which
  452. +  *                 the PD is responsible.
  453. +  *
  454. +  * int _pkt_set_multicast_list( byte len, eth_address *listbuf )
  455. +  * Where:
  456. +  *    len    is the length of listbuf
  457. +  *    listbuf    is the buffer containing the list
  458. +  * Returns:
  459. +  *    -1    upon error - pkterror is set
  460. +  *    0    if set was successful
  461. +  */
  462. + 
  463. + _pkt_set_multicast_list( len, listbuf )
  464. + byte len;
  465. + eth_address *listbuf;
  466. + {
  467. +     struct REGPACK regs;
  468. + 
  469. +     /* Basic drivers don't support multicast */
  470. +     if ( _pktdevlevel < 2 ){
  471. +         pkterror = BASIC_DVR;
  472. +         return( -1 );
  473. +     }
  474. + 
  475. +     regs.r_ax = PD_SET_MULTI;
  476. +     regs.r_cx = len;
  477. +     regs.r_es = FP_SEG( listbuf );
  478. +     regs.r_di = FP_OFF( listbuf );
  479. +         intr( pkt_interrupt, ®s );
  480. + 
  481. +     /* The carry flag indicates an error return */
  482. +         if ( regs.r_flags & CARRY ){
  483. +         pkterror = regs.r_dx >> 8;
  484. +         return( -1 );
  485. +         }
  486. + 
  487. +     return( 0 );
  488. + }
  489. + 
  490. + /* 
  491. +  * _pkt_get_ip_rcv_mode - gets the recieve mode of the interface for
  492. +  *              the IP handle
  493. +  *
  494. +  * int _pkt_get_ip_rcv_mode( )
  495. +  * Returns:
  496. +  *    -1    if the request failed - pkterror is set
  497. +  *    mode    is one of the following modes: (upon return)
  498. +  *        1    turn off reciever
  499. +  *        2    recieve only packets sent to this interface
  500. +  *        3    mode 2 plus broadcast packets <default>
  501. +  *        4    mode 3 plus limited multicast packets
  502. +  *        5    mode 3 plus all multicast packets
  503. +  *        6    all packets (AKA promiscuous mode )
  504. +  */
  505.   
  506. + int _pkt_get_ip_rcv_mode()
  507. + {
  508. +     return( _pkt_get_rcv_mode(pkt_ip_handle));
  509. + }
  510. + 
  511. + /* 
  512. +  * _pkt_set_ip_rcv_mode - sets the recieve mode of the interface for
  513. +  *              the IP handle
  514. +  *
  515. +  * int _pkt_set_ip_rcv_mode( int mode )
  516. +  * Where:
  517. +  *    mode    is one of the following modes: (upon return)
  518. +  *        1    turn off reciever
  519. +  *        2    recieve only packets sent to this interface
  520. +  *        3    mode 2 plus broadcast packets <default>
  521. +  *        4    mode 3 plus limited multicast packets
  522. +  *        5    mode 3 plus all multicast packets
  523. +  *        6    all packets (AKA promiscuous mode )
  524. +  * Returns:
  525. +  *    -1    if the request failed - pkterror is set
  526. +  *    0    mode set was successful
  527. +  */
  528. + 
  529. + int _pkt_set_ip_rcv_mode( mode )
  530. + int mode;
  531. + {
  532. +     return( _pkt_set_rcv_mode(pkt_ip_handle, mode));
  533. + }
  534. + #endif /* MULTICAST */
  535.                                
  536. *** src/pcsed.c    Thu Jul 15 11:15:56 1993
  537. --- src/pcsed.c    Tue Nov 09 23:43:48 1993
  538. ***************
  539. *** 19,28 ****
  540. --- 19,35 ----
  541.   #include <wattcp.h>
  542.   #include <ethdev.h>
  543.   #include <mem.h>
  544. + #if defined(MULTICAST)
  545. + #include <dos.h>
  546. + #endif
  547.   
  548.   eth_address _eth_addr;        /* local ethernet address */
  549.   eth_address _eth_brdcast;    /* Ethernet broadcast address */
  550.   word _pktdevclass = 1;        /* Ethernet = 1, SLIP = 6 */
  551. + #if defined(MULTICAST)
  552. + byte  _pktdevlevel = 1;        /* assume basic unless otherwise specified */
  553. + byte pkterror;
  554. + #endif /* MULTICAST */
  555.   
  556.   /*
  557.    *  Initialize the Ethernet Interface, and this package.  Enable input on
  558. ***************
  559. *** 117,120 ****
  560. --- 124,264 ----
  561.   {
  562.       return( p - 8 );
  563.   }
  564. + 
  565. + #if defined(MULTICAST)
  566. + /*
  567. +  * _eth_join_mcast_group - joins a multicast group (at the physical layer)
  568. +  *
  569. +  * int _eth_join_mcast_group( int entry )
  570. +  * Where:
  571. +  *    entry    the entry # in the _ipmulti table
  572. +  * Returns:
  573. +  *    1    if the group was joined successfully
  574. +  *    0    if attempt failed
  575. +  */
  576. + 
  577. + int _eth_join_mcast_group( entry )
  578. + int entry;
  579. + {
  580. +     eth_address list[IPMULTI_SIZE];
  581. +     int mode;
  582. +     int i;
  583. +     byte len;
  584. +     byte nextentry = 0;
  585. + 
  586. +     /* initialize a few things */
  587. +     _ipmulti[entry].active = 0;
  588. +     _ipmulti[entry].replytime = time(NULL);
  589. +     _ipmulti[entry].processes = 1;
  590. + 
  591. +     /* Fill in the hardware address */
  592. +     if( ! multi_to_eth( _ipmulti[entry].ina, _ipmulti[entry].ethaddr ))
  593. +         return( 0 );    /* can't convert it */
  594. + 
  595. +     mode=_pkt_get_ip_rcv_mode();
  596. +     if( mode == -1 )    /* something seems to be broken */
  597. +         return( 0 );
  598. +     else if ( mode == 5 ) {    /* we are in all mcast mode, so don't bother */
  599. +         _ipmulti[entry].active = 1;
  600. +         return( 1 );
  601. +     }
  602. + 
  603. +     if( (len = _pkt_get_multicast_list( sizeof list, &list[0] )) == -1)
  604. +         return( 0 );
  605. + 
  606. +     /* check to see if the address is already in the list */
  607. +     for (i = 0; i< (len/sizeof list[0]); i++){
  608. +         if( !memcmp(list[i],_ipmulti[entry].ethaddr,sizeof list[0])){
  609. +             _ipmulti[entry].active = 1;
  610. +             return(1);
  611. +         }
  612. +     }
  613. + 
  614. +     if ( len )
  615. +         nextentry = len / (sizeof list[0]);
  616. + 
  617. +     movedata(FP_SEG(_ipmulti[entry].ethaddr),FP_OFF(_ipmulti[entry].ethaddr),
  618. +          FP_SEG(&list[nextentry]),FP_OFF(&list[nextentry]), 6);
  619. + 
  620. +     len+= sizeof list[0];
  621. + 
  622. +     if( _pkt_set_multicast_list( len, &list[0] ) == -1)
  623. +         if( pkterror == NO_SPACE ){    /* out of space, switch mode */
  624. +             if( _pkt_set_ip_rcv_mode( 5 ) == -1 )
  625. +                 return( 0 );
  626. +         } else
  627. +             return( 0 );
  628. +     _ipmulti[entry].active = 1;
  629. +     return( 1 );
  630. + }
  631. + 
  632. + 
  633. + /* 
  634. +  * _eth_leave_mcast_group - leaves a multicast group (at the physical layer)
  635. +  *
  636. +  * int _eth_leave_mcast_group( int entry )
  637. +  * Where:
  638. +  *    entry    the entry # in the _ipmulti table
  639. +  * Returns:
  640. +  *    1    if the group was left successfully
  641. +  *    0    if attempt failed
  642. +  */
  643. + 
  644. + int _eth_leave_mcast_group( entry )
  645. + int entry;
  646. + {
  647. +     eth_address list[IPMULTI_SIZE];
  648. +     int mode;
  649. +     int i;
  650. +     int ethindex = -1;
  651. +     byte len;
  652. + 
  653. + 
  654. +     /* NOTE: This should be expanded to include switching back to mode 4
  655. +        if the list of multicast addresses has shrunk sufficiently */
  656. + 
  657. +     /* First check to see if we're in mode 5. if so, mark the entry
  658. +        as inactive and return */
  659. +     mode=_pkt_get_ip_rcv_mode();
  660. +     if( mode == -1 )    /* something seems to be broken */
  661. +         return( 0 );
  662. +     else if ( mode == 5 ) {    /* we are in all mcast mode, so don't bother */
  663. +         _ipmulti[entry].active = 0;
  664. +         return( 1 );
  665. +     }
  666. + 
  667. +     /* get the list of current multicast addresses */
  668. +     if( (len = _pkt_get_multicast_list( sizeof list, &list[0] )) == -1)
  669. +         return( 0 );
  670. + 
  671. +     /* find the apropriate entry */
  672. +     for (i = 0; i< (len/(sizeof list[0])); i++)
  673. +         if( !memcmp(list[i],_ipmulti[entry].ethaddr,sizeof list[0]))
  674. +             ethindex = i;
  675. + 
  676. +     /* if it's not in the list, just set the entry inactive and return */
  677. +     if ( ethindex == -1 ){
  678. +         _ipmulti[entry].active = 0;
  679. +         return( 1 );
  680. +     }
  681. + 
  682. +     /* ahh, but it _is_ in the list. So shorten the list and send it
  683. +        back to the PD */
  684. +     if( ethindex+1 < (len/(sizeof list[0]))){
  685. +         movedata(FP_SEG(&list[ethindex+1]),FP_OFF(&list[ethindex+1]),
  686. +                  FP_SEG(&list[ethindex]),FP_OFF(&list[ethindex]),
  687. +                  len - ((ethindex+1)*(sizeof list[0])));
  688. +     }
  689. +     len -= sizeof list[0];
  690. + 
  691. +     if( _pkt_set_multicast_list( len, &list[0] ) == -1)
  692. +         if( pkterror == NO_SPACE ){    /* out of space, switch mode */
  693. +             if( _pkt_set_ip_rcv_mode( 5 ) == -1 )
  694. +                 return( 0 );
  695. +         } else
  696. +             return( 0 );
  697. +     _ipmulti[entry].active = 0;
  698. +     return( 1 );
  699. + }
  700. + #endif /* MUTICAST */
  701.   
  702. *** src/pctcp.c    Thu Sep 30 13:47:42 1993
  703. --- src/pctcp.c    Wed Nov 10 01:48:12 1993
  704. ***************
  705. *** 293,299 ****
  706. --- 293,308 ----
  707.       /* check for broadcast */
  708.       if ( (long)(ina) == -1 || !ina )
  709.       memset( s->hisethaddr, 0xff, sizeof( eth_address ));
  710. + #if defined(MULTICAST)
  711. +     else  /* check for multicast */
  712. +     if ( is_multicast( ina )){
  713. +     if ( ! multi_to_eth( ina, &s->hisethaddr[0] ))
  714. +         return( 0 );
  715. +     s->ttl = 1;    /* so we don't send worldwide as default */
  716. +     } else if ( ! _arp_resolve(ina, &s->hisethaddr[0], 0) )
  717. + #else
  718.       else if ( ! _arp_resolve(ina, (eth_address *) &s->hisethaddr[0], 0) )
  719. + #endif
  720.       return( 0 );
  721.   
  722.       s->hisaddr = ina;
  723. ***************
  724. *** 306,312 ****
  725. --- 315,339 ----
  726.       return( 1 );
  727.   }
  728.   
  729. + #if defined(MULTICAST)
  730.   /*
  731. +  * Set the TTL on an outgoing UDP datagram.
  732. +  * udp_SetTTL(udp_Socket *s, byte ttl)
  733. +  * where:
  734. +  *    s    the socket of the UDP connection (?!?) in question
  735. +  *    ttl    the desired ttl for the outgoing datagrams
  736. +  */
  737. + 
  738. + int udp_SetTTL( s, ttl )
  739. + udp_Socket *s;
  740. + byte ttl;
  741. + {
  742. +     s->ttl = ttl;
  743. +     return( 1 );
  744. + }
  745. + #endif /* MULTICAST */
  746. + 
  747. + /*
  748.    * Actively open a TCP connection to a particular destination.
  749.    *    - 0 on error
  750.    */
  751. ***************
  752. *** 595,600 ****
  753. --- 622,630 ----
  754.       static longword timeout = 0;
  755.       static longword start = 0;
  756.   
  757. + #if defined(MULTICAST)
  758. +     int i;
  759. + #endif /* MULTICAST */
  760.       int x;
  761.       int packettype;
  762.   
  763. ***************
  764. *** 631,636 ****
  765. --- 661,671 ----
  766.               case ICMP_PROTO :
  767.               icmp_handler(ip);
  768.               break;
  769. + #if defined(MULTICAST)
  770. +             case IGMP_PROTO :
  771. +             igmp_handler(ip);
  772. +             break;
  773. + #endif
  774.           }
  775.           } else  {
  776.           if (debug_on)
  777. ***************
  778. *** 649,654 ****
  779. --- 684,702 ----
  780.       /* check for our outstanding packets */
  781.       tcp_Retransmitter();
  782.   
  783. + #if defined(MULTICAST)
  784. +     /* check to see if we owe any IGMP Reports */
  785. +     for(i=0; i < IPMULTI_SIZE ; i++){
  786. +         if( _ipmulti[i].active &&
  787. +         ( _ipmulti[i].ina != ALL_SYSTEMS ) &&
  788. +         ( _ipmulti[i].replytime ) &&
  789. +             ( _ipmulti[i].replytime <= time(NULL) )){
  790. +                 igmp_report(_ipmulti[i].ina);
  791. +             _ipmulti[i].replytime = 0;
  792. +             }
  793. +     }
  794. + #endif /* MULTICAST */
  795. + 
  796.       return( s->udp.ip_type );
  797.   }
  798.   
  799. ***************
  800. *** 700,706 ****
  801. --- 748,758 ----
  802.   /* inp->vht = 0x4500;*/   /* version 4, hdrlen 5, tos 0 */
  803.       inp->identification = intel16( ++ip_id );   /* was post inc */
  804.   //    inp->frag = 0;
  805. + #if defined(MULTICAST)
  806. +     inp->ttl = s->ttl ? s->ttl : 254 ; /* if set, us it. Otherwise 254 */
  807. + #else
  808.       inp->ttl = 254;
  809. + #endif
  810.       inp->proto = UDP_PROTO;    /* udp */
  811.   /* inp->ttlProtocol = (250<<8) + 6; */
  812.       inp->checksum = 0;
  813. ***************
  814. *** 912,922 ****
  815.   
  816.       temp = intel( ip->destination );
  817.   
  818.       if ( ((~temp & ~sin_mask) != 0) &&  /* not a broadcast packet*/
  819.           ((( temp - my_ip_addr) > multihomes )   /* not my address */
  820.           && my_ip_addr))                 /* and I know my address */
  821.             return;
  822. ! 
  823.   
  824.       len = in_GetHdrlenBytes(ip);
  825.       up = (udp_Header *)((byte *)ip + len);    /* udp segment pointer */
  826. --- 964,980 ----
  827.   
  828.       temp = intel( ip->destination );
  829.   
  830. + #if defined(MULTICAST)
  831. + /* This is the only really gross hack in the multicasting stuff.
  832. +  * I'll fix it as soon as I can figure out what I want to do here.
  833. +  * -JRM 8/1/93
  834. +  */
  835. + #else
  836.       if ( ((~temp & ~sin_mask) != 0) &&  /* not a broadcast packet*/
  837.           ((( temp - my_ip_addr) > multihomes )   /* not my address */
  838.           && my_ip_addr))                 /* and I know my address */
  839.             return;
  840. ! #endif /* MULTICAST */
  841.   
  842.       len = in_GetHdrlenBytes(ip);
  843.       up = (udp_Header *)((byte *)ip + len);    /* udp segment pointer */
  844. ***************
  845. *** 949,954 ****
  846. --- 1007,1027 ----
  847.           break;
  848.           }
  849.       }
  850. + 
  851. + #if defined(MULTICAST)
  852. +     if ( !s ) {
  853. +     /* demux to multicast sockets */
  854. +     for ( s = udp_allsocs; s; s = s->next ){
  855. +         if ( s->hisport != 0 &&
  856. +          s->hisaddr == intel( ip->destination ) &&
  857. +          intel16( up->dstPort ) == s->myport &&
  858. +          is_multicast( intel( ip->destination ))){
  859. +              break;
  860. +          }
  861. +     }
  862. +     }
  863. + #endif /* MULTICAST */
  864. + 
  865.       if ( !s ) {
  866.       /* demux to broadcast sockets */
  867.       for ( s = udp_allsocs; s; s = s->next )
  868. *** src/sock_ini.c    Thu Oct 22 17:26:16 1992
  869. --- src/sock_ini.c    Tue Nov 09 23:43:48 1993
  870. ***************
  871. *** 37,40 ****
  872. --- 37,47 ----
  873.           if ( !_survivebootp )
  874.           exit( 3 );
  875.       }
  876. + #if defined(MULTICAST)
  877. +     /* to initialize the random number generator */
  878. +     randomize();
  879. + 
  880. +     /* all multicast level 2 systems must join at startup */
  881. +     join_mcast_group(ALL_SYSTEMS);
  882. + #endif /* MULTICAST */
  883.   }
  884.