home *** CD-ROM | disk | FTP | other *** search
/ NetNews Usenet Archive 1992 #20 / NN_1992_20.iso / spool / comp / sources / misc / 3918 < prev    next >
Encoding:
Text File  |  1992-09-10  |  20.7 KB  |  840 lines
  1. Newsgroups: comp.sources.misc
  2. Path: sparky!kent
  3. From: Guido van Rossum <guido@cwi.nl>
  4. Subject:  v32i027:  radio2.0 - Broadcast FM/AM over Local Area Network, Patch01
  5. Message-ID: <1992Sep10.141840.16231@sparky.imd.sterling.com>
  6. Followup-To: comp.sources.d
  7. X-Md4-Signature: 96c8204ea252af922347fbab0d001977
  8. Sender: kent@sparky.imd.sterling.com (Kent Landfield)
  9. Organization: Sterling Software
  10. Date: Thu, 10 Sep 1992 14:18:40 GMT
  11. Approved: kent@sparky.imd.sterling.com
  12. Lines: 826
  13.  
  14. Submitted-by: Guido van Rossum <guido@cwi.nl>
  15. Posting-number: Volume 32, Issue 27
  16. Archive-name: radio2.0/patch01
  17. Patch-To: radio2.0: Volume30, Issue 85-86
  18. Environment: Sun, SGI, NeXT
  19.  
  20. Here is the first patch to radio 2.0.
  21.  
  22. The original was posted to alt.sources, and to comp.sources.misc.  It 
  23. is also available by anonymous ftp from ftp.cwi.nl [192.16.184.180], 
  24. directory pub, files radio2.0.tar.Z (main distribution) and tuner1.3.shar 
  25. (Motif tuner program).
  26.   
  27. Changes in 2.0 patchlevel 1
  28. ---------------------------
  29.  
  30. - On the sun and sgi, radio tries to open a connection to the X server
  31.   (specified by the $DISPLAY environment variable) and every now and
  32.   then makes a small request to exercise the connection.  This ensures
  33.   that if the user logs out, radio will quit.  If no connection to the X
  34.   server can be made, these checks are not made and a warning is printed
  35.   that reminds the user to kill radio when logging out.
  36.  
  37. - The usage message is more informative.
  38.  
  39. - The new option '-t' (tee) sends output to both stdout and the audio
  40.   device.  Thanks to Scott Hazen Mueller for suggesting this.
  41.  
  42. - The experimental option '-m mcastgrp' (for SGI only) specifies a
  43.   multicast group.  By multicasting instead of broadcasting, you can
  44.   reduce the load on hosts that aren't listening (see the man page).
  45.  
  46. Here are the patches -- happy listening!
  47.  
  48. diff -rcN ../orig/MANIFEST ./MANIFEST
  49. *** ../orig/MANIFEST    Thu Sep 10 08:55:29 1992
  50. --- ./MANIFEST    Thu Sep 10 08:57:14 1992
  51. ***************
  52. *** 16,20 ****
  53. --- 16,21 ----
  54.    recordulaw.c               1    
  55.    sndulaw.c                  1    
  56.    socklib.c                  1    
  57. +  stations.pl                0    
  58.    stations.py                1    
  59.    ttytuner.py                2    
  60. diff -rcN ../orig/Makefile ./Makefile
  61. *** ../orig/Makefile    Thu Sep 10 08:55:30 1992
  62. --- ./Makefile    Thu Sep 10 08:57:14 1992
  63. ***************
  64. *** 33,46 ****
  65.   # Platform-specific entries
  66.   
  67.   sun4.0:        # For SunOS 4.x
  68. !         make all
  69.   
  70.   sun4.1:        # For SunOS  4.1 with audio library (/usr/demo/SOUND)
  71. !         make all LIBS=/usr/demo/SOUND/libaudio.a \
  72.               CFLAGS='-DREMHDR -I/usr/demo/SOUND'
  73.   
  74.   sgi:        # For SGI IRIX 4.0
  75. !         make all recordulaw playulaw LIBS=-laudio
  76.   
  77.   next:        # NeXT 2.1
  78.           make all sndulaw
  79. --- 33,46 ----
  80.   # Platform-specific entries
  81.   
  82.   sun4.0:        # For SunOS 4.x
  83. !         make all LIBS=-lX11
  84.   
  85.   sun4.1:        # For SunOS  4.1 with audio library (/usr/demo/SOUND)
  86. !         make all LIBS='-lX11 /usr/demo/SOUND/libaudio.a' \
  87.               CFLAGS='-DREMHDR -I/usr/demo/SOUND'
  88.   
  89.   sgi:        # For SGI IRIX 4.0
  90. !         make all recordulaw playulaw LIBS='-lX11 -laudio'
  91.   
  92.   next:        # NeXT 2.1
  93.           make all sndulaw
  94. diff -rcN ../orig/README ./README
  95. *** ../orig/README    Thu Sep 10 08:55:31 1992
  96. --- ./README    Thu Sep 10 08:57:15 1992
  97. ***************
  98. *** 1,7 ****
  99.   Welcome to the wonderful world of Local Area Network radio!
  100.   ===========================================================
  101.   
  102. ! This is Radio version 2.0, patchlevel 0.
  103.   
  104.   If you have a local area network full of workstations with audio
  105.   capabilities and at least one FM/AM radio or other audio source, you
  106. --- 1,7 ----
  107.   Welcome to the wonderful world of Local Area Network radio!
  108.   ===========================================================
  109.   
  110. ! This is Radio version 2.0, patchlevel 1.
  111.   
  112.   If you have a local area network full of workstations with audio
  113.   capabilities and at least one FM/AM radio or other audio source, you
  114. ***************
  115. *** 48,53 ****
  116. --- 48,73 ----
  117.   This software is copyrighted.  See the notice at the end of this file.
  118.   
  119.   
  120. + Changes in 2.0 patchlevel 1
  121. + ---------------------------
  122. + 
  123. + On the sun and sgi, radio tries to open a connection to the X server
  124. + (specified by the $DISPLAY environment variable) and every now and
  125. + then makes a small request to exercise the connection.  This ensures
  126. + that if the user logs out, radio will quit.  If no connection to the X
  127. + server can be made, these checks are not made and a warning is printed
  128. + that reminds the user to kill radio when logging out.
  129. + 
  130. + The usage message is more informative.
  131. + 
  132. + The new option '-t' (tee) sends output to both stdout and the audio
  133. + device.  Thanks to Scott Hazen Mueller for suggesting this.
  134. + 
  135. + The experimental option '-m mcastgrp' (for SGI only) specifies a
  136. + multicast group.  By multicasting instead of broadcasting, you can
  137. + reduce the load on hosts that aren't listening (see the man page).
  138. + 
  139. + 
  140.   Changes since version 1.0 patchlevel 4
  141.   --------------------------------------
  142.   
  143. ***************
  144. *** 217,222 ****
  145. --- 237,250 ----
  146.   the users on each host where it finds a listener.  You must then be
  147.   able to log in to that host remotely (with rlogin or rsh) without
  148.   typing your password.
  149. + 
  150. + There is also one Perl program, just to show that you don't need to be
  151. + entirely helpless if you don't have Python nor Motif:
  152. + 
  153. + The Perl program "stations.pl" listens for and prints essential
  154. + information about stations.  Extension to the functionality if
  155. + "stations.py" is left as an exercise to the reader.
  156. + 
  157.   
  158.   Author
  159.   ------
  160. diff -rcN ../orig/patchlevel.h ./patchlevel.h
  161. *** ../orig/patchlevel.h    Thu Sep 10 08:55:36 1992
  162. --- ./patchlevel.h    Thu Sep 10 08:57:15 1992
  163. ***************
  164. *** 1,1 ****
  165. ! #define PATCHLEVEL 0
  166. --- 1,1 ----
  167. ! #define PATCHLEVEL 1
  168. diff -rcN ../orig/playulaw.c ./playulaw.c
  169. *** ../orig/playulaw.c    Thu Sep 10 08:55:36 1992
  170. --- ./playulaw.c    Thu Sep 10 08:57:15 1992
  171. ***************
  172. *** 114,124 ****
  173.       signal(SIGINT, cleanup_handler);
  174.       signal(SIGTERM, cleanup_handler);
  175.   
  176. -     /* Set the output sampling rate to 8000 Hz */
  177. -     pvbuf[0] = AL_OUTPUT_RATE;
  178. -     pvbuf[1] = AL_RATE_8000;
  179. -     ALsetparams(AL_DEFAULT_DEVICE, pvbuf, 2L);
  180. - 
  181.       /* Configure and open an SGI audio port */
  182.       config = ALnewconfig();
  183.       ALsetchannels(config, AL_MONO);
  184. --- 114,119 ----
  185. ***************
  186. *** 129,134 ****
  187. --- 124,135 ----
  188.           perror("ALopenport");
  189.           exit(1);
  190.       }
  191. + 
  192. +     /* Set the output sampling rate to 8000 Hz */
  193. +     /* Do this after ALopenport so we needn't undo it if that fails */
  194. +     pvbuf[0] = AL_OUTPUT_RATE;
  195. +     pvbuf[1] = AL_RATE_8000;
  196. +     ALsetparams(AL_DEFAULT_DEVICE, pvbuf, 2L);
  197.   #else
  198.       /* Write to /dev/audio */
  199.       if ((ofd = open("/dev/audio", O_WRONLY | O_NDELAY)) < 0) {
  200. diff -rcN ../orig/radio.c ./radio.c
  201. *** ../orig/radio.c    Thu Sep 10 08:55:49 1992
  202. --- ./radio.c    Thu Sep 10 08:57:15 1992
  203. ***************
  204. *** 41,46 ****
  205. --- 41,48 ----
  206.      -n           noninterruptable -- by default radio will be interruptable
  207.           by other sound outputting programs, hoping they do not
  208.           take too long.  This option turns off that feature.
  209. +    -t        tee mode: send output to stdout as well as to audio h/w
  210. +    -m mcastgrp    multicast group (SGI only)
  211.   */
  212.   
  213.   #define BCASTCTLPORT      54319
  214. ***************
  215. *** 53,61 ****
  216. --- 55,66 ----
  217.   
  218.   #ifdef sgi
  219.   #define USE_AL
  220. + #define CHECK_X_SERVER
  221. + #define HAVE_MCAST
  222.   #endif
  223.   #ifdef sun
  224.   #define USE_SUN
  225. + #define CHECK_X_SERVER
  226.   #endif
  227.   #ifdef NeXT
  228.   #define USE_NX
  229. ***************
  230. *** 72,77 ****
  231. --- 77,86 ----
  232.   #include <sys/time.h>
  233.   #include <netinet/in.h>
  234.   
  235. + #ifdef HAVE_MCAST
  236. + #include <arpa/inet.h>
  237. + #endif
  238. + 
  239.   #ifdef USE_AL
  240.   #include <audio.h>
  241.   #include "libst.h"
  242. ***************
  243. *** 96,101 ****
  244. --- 105,111 ----
  245.   
  246.   int interruptable = 1;
  247.   int actlfd = -1;
  248. + int afd = -1;
  249.   
  250.   void sigpoll_handler();
  251.   #endif /* USE_SUN */
  252. ***************
  253. *** 106,111 ****
  254. --- 116,126 ----
  255.   SNDSoundStruct *snd[NUM_BUFFER];
  256.   #endif /* USE_NX */
  257.   
  258. + #ifdef CHECK_X_SERVER
  259. + #include <X11/Xlib.h>
  260. + Display *xdisplay = 0;
  261. + #endif
  262. + 
  263.   /* getopt() interface */
  264.   extern int optind;
  265.   extern char * optarg;
  266. ***************
  267. *** 114,123 ****
  268. --- 129,142 ----
  269.   int pausing = 0; /* Flag set when pausing */
  270.   int ofd = -1; /* Output file descriptor */
  271.   int volume = -1; /* -v parameter */
  272. + int pdebug = 0; /* -p parameter */
  273. + char *mcastgrp = 0; /* -m parameter */
  274.   
  275.   /* Forward functions */
  276.   void open_speaker();
  277.   void close_speaker();
  278. + void checkalive();
  279. + void setmcast();
  280.   
  281.   main(argc, argv)
  282.       int argc;
  283. ***************
  284. *** 131,142 ****
  285.       int fromlen;
  286.       int c;
  287.       int filter = 0;
  288.       int nfds;
  289.       fd_set inputset;
  290.       int n;
  291. -     int pdebug = 0;
  292.       char *localname = (char *) NULL;
  293.       char *remotename = (char *) NULL;
  294.   #ifdef USE_AL
  295.       short obuf[BUFFERSIZE];
  296.       int i;
  297. --- 150,163 ----
  298.       int fromlen;
  299.       int c;
  300.       int filter = 0;
  301. +     int tee = 0;
  302.       int nfds;
  303.       fd_set inputset;
  304.       int n;
  305.       char *localname = (char *) NULL;
  306.       char *remotename = (char *) NULL;
  307. +     struct timeval timeout;
  308. +     int packetcount;
  309.   #ifdef USE_AL
  310.       short obuf[BUFFERSIZE];
  311.       int i;
  312. ***************
  313. *** 145,153 ****
  314.       int akt_buf;
  315.   #endif
  316.   
  317. ! /* Always change these two macros together! */
  318. ! #define OPTIONS "c:dfl:np:r:sv:"
  319. ! #define USAGE "usage: %s [-c ctlport] [-d] [-f] [-l localhost] [-n] [-p port]\n\t[-r remotehost] [-s] [-v volume(0-100)]\n"
  320.   
  321.       while ((c = getopt(argc, argv, OPTIONS)) != EOF) {
  322.           switch (c) {
  323. --- 166,189 ----
  324.       int akt_buf;
  325.   #endif
  326.   
  327. ! /* Always change these two macros and the following switch together! */
  328. ! #define OPTIONS "c:dfl:m:np:r:stv:"
  329. ! #define USAGE "usage: %s [options]\n\
  330. ! User options:\n\
  331. ! -p port      : port to listen to (default 54321; 1..99 ==> 54321..54419)\n\
  332. ! -v volume    : volume setting (1-100; default unchanged)\n\
  333. ! Expert options:\n\
  334. ! -f           : filter mode (write data to stdout)\n\
  335. ! -t           : tee mode (write data to stdout as well as to audio device)\n\
  336. ! -n           : not interruptable by other sources (Sun only)\n\
  337. ! -c ctlport   : control port for tuner programs (default 54320)\n\
  338. ! -s           : secure mode: no control port (disallow tuner programs)\n\
  339. ! Guru options:\n\
  340. ! -l localhost : listen to packets to this host only\n\
  341. ! -r remothost : receive packets from that host only\n\
  342. ! -m mcastgrp  : multicast group (SGI only)\n\
  343. ! -d           : debugging mode (writes messages to stderr)\n\
  344. ! "
  345.   
  346.       while ((c = getopt(argc, argv, OPTIONS)) != EOF) {
  347.           switch (c) {
  348. ***************
  349. *** 171,186 ****
  350.           case 'd':
  351.               pdebug = 1;
  352.               break;
  353. ! #ifdef USE_SUN
  354.           case 'n':
  355.               interruptable = 0;
  356.               break;
  357. - #endif /* USE_SUN */
  358.           case 's':
  359.               ctlport = -1;
  360.               break;
  361.           case 'f':
  362.               filter = 1;
  363.               break;
  364.           case 'v':
  365.               volume = atoi(optarg);
  366. --- 207,236 ----
  367.           case 'd':
  368.               pdebug = 1;
  369.               break;
  370. !         case 'm':
  371. ! #ifdef HAVE_MCAST
  372. !             mcastgrp = optarg;
  373. ! #else
  374. !             fprintf(stderr, "(-m not supported here)\n");
  375. ! #endif
  376. !             break;
  377.           case 'n':
  378. + #ifdef USE_SUN
  379.               interruptable = 0;
  380. + #else
  381. +             fprintf(stderr, "(-n not supported here)\n");
  382. + #endif
  383.               break;
  384.           case 's':
  385.               ctlport = -1;
  386.               break;
  387.           case 'f':
  388.               filter = 1;
  389. +             tee = 0;
  390. +             break;
  391. +         case 't':
  392. +             tee = 1;
  393. +             filter = 0;
  394.               break;
  395.           case 'v':
  396.               volume = atoi(optarg);
  397. ***************
  398. *** 188,198 ****
  399.           }
  400.       }
  401.   
  402. !     if (filter) {
  403.           ofd = fileno(stdout);
  404. !     }
  405. !     else {
  406.           open_speaker();
  407.       }
  408.   
  409.       if (ctlport >= 0)
  410. --- 238,261 ----
  411.           }
  412.       }
  413.   
  414. !     /* Meaning of the 'tee' and 'filter' flags:
  415. !        At most one of these can be on.
  416. !        if tee is on: write stdout and "/dev/audio";
  417. !        if filter is on: write stdout only;
  418. !        if both are off: write "/dev/audio" only;
  419. !        where "/dev/audio" stands for whatever audio hardware we have. */
  420. ! 
  421. !     if (filter || tee)
  422.           ofd = fileno(stdout);
  423. !     if (!filter) {
  424.           open_speaker();
  425. + #ifdef CHECK_X_SERVER
  426. +         xdisplay = XOpenDisplay((char *)NULL);
  427. +         if (xdisplay == NULL) {
  428. +             fprintf(stderr,
  429. + "radio: warning: no X server -- you must kill radio when you log out!\n");
  430. +         }
  431. + #endif
  432.       }
  433.   
  434.       if (ctlport >= 0)
  435. ***************
  436. *** 202,219 ****
  437.           ctls = -1;
  438.   
  439.       s = opensock("data", localname, receiveport, remotename, SENDPORT, 0);
  440.   
  441.       for (;;) {
  442.           /*
  443.           ** Wait until one of the sockets becomes ready
  444.           */
  445. !         nfds = (s > ctls ? s : ctls) + 1;
  446. !         FD_ZERO(&inputset);
  447. !         FD_SET(s, &inputset);
  448. !         if (ctls >= 0)
  449. !             FD_SET(ctls, &inputset);
  450. !         while (select(nfds, &inputset, 0, 0, 0) < 1) {
  451. !             if(errno != EINTR) {
  452.                   perror("select");
  453.                   exit(1);
  454.               }
  455. --- 265,294 ----
  456.           ctls = -1;
  457.   
  458.       s = opensock("data", localname, receiveport, remotename, SENDPORT, 0);
  459. +     if (mcastgrp)
  460. +         setmcast(s, mcastgrp);
  461. + 
  462. +     packetcount = 0;
  463.   
  464.       for (;;) {
  465.           /*
  466.           ** Wait until one of the sockets becomes ready
  467.           */
  468. !         for (;;) {
  469. !             nfds = (s > ctls ? s : ctls) + 1;
  470. !             FD_ZERO(&inputset);
  471. !             FD_SET(s, &inputset);
  472. !             if (ctls >= 0)
  473. !                 FD_SET(ctls, &inputset);
  474. !             timeout.tv_sec = 30;
  475. !             timeout.tv_usec = 0;
  476. !             n = select(nfds, &inputset, 0, 0, &timeout);
  477. !             if (n > 0)
  478. !                 break;
  479. !             if (n == 0) {
  480. !                 checkalive();
  481. !             }
  482. !             else if (errno != EINTR) {
  483.                   perror("select");
  484.                   exit(1);
  485.               }
  486. ***************
  487. *** 241,247 ****
  488.               else
  489.                   pdebug++;
  490.           }
  491. !         if ( n <= CTLPKTSIZE ) {
  492.               /*
  493.               ** It looks like a control packet. Check it.
  494.               */
  495. --- 316,322 ----
  496.               else
  497.                   pdebug++;
  498.           }
  499. !         if (n <= CTLPKTSIZE) {
  500.               /*
  501.               ** It looks like a control packet. Check it.
  502.               */
  503. ***************
  504. *** 278,283 ****
  505. --- 353,360 ----
  506.                       s = opensock("new data", localname,
  507.                                receiveport, remotename,
  508.                                SENDPORT, 0);
  509. +                     if (mcastgrp)
  510. +                         setmcast(s, mcastgrp);
  511.                       break;
  512.                   case 'i':        /* Info */
  513.                       sprintf(buf, "radio:I:%d:%d",
  514. ***************
  515. *** 320,326 ****
  516.                       obuf[i] = st_ulaw_to_linear(buf[i]);
  517.                   ALwritesamps(aport, obuf, (long)n);
  518.               }
  519. -             else
  520.   #endif /* USE_AL */
  521.   #ifdef USE_NX
  522.               if (!filter) {
  523. --- 397,402 ----
  524. ***************
  525. *** 337,349 ****
  526.                           akt_buf+1, 5, 0, 0, 0);
  527.                   akt_buf = (akt_buf + 1) % NUM_BUFFER;
  528.               }
  529. !             else
  530. ! #endif/* USE_NX */
  531. !             if (write(ofd, buf, n) != n) {
  532. !                 perror("write");
  533. !                 break;
  534.               }
  535.           }
  536.       }
  537.   
  538.       exit(0);
  539. --- 413,438 ----
  540.                           akt_buf+1, 5, 0, 0, 0);
  541.                   akt_buf = (akt_buf + 1) % NUM_BUFFER;
  542.               }
  543. ! #endif /* USE_NX */
  544. ! #ifdef USE_SUN
  545. !             if (!filter) {
  546. !                 if (write(afd, buf, n) != n) {
  547. !                     perror("write afd");
  548. !                     break;
  549. !                 }
  550. !             }
  551. ! #endif /* USE_SUN */
  552. !             if (filter || tee) {
  553. !                 if (write(ofd, buf, n) != n) {
  554. !                     perror("write ofd");
  555. !                     break;
  556. !                 }
  557.               }
  558.           }
  559. +         if (++packetcount > (30*8000 / BUFFERSIZE)) {
  560. +             checkalive();
  561. +             packetcount = 0;
  562. +         }
  563.       }
  564.   
  565.       exit(0);
  566. ***************
  567. *** 416,422 ****
  568.       audio_info_t info;
  569.   
  570.       /* Write to AUDIO_IODEV */
  571. !     if ((ofd = open(AUDIO_IODEV, O_WRONLY)) < 0) {
  572.           perror(AUDIO_IODEV);
  573.           exit(1);
  574.       }
  575. --- 505,511 ----
  576.       audio_info_t info;
  577.   
  578.       /* Write to AUDIO_IODEV */
  579. !     if ((afd = open(AUDIO_IODEV, O_WRONLY)) < 0) {
  580.           perror(AUDIO_IODEV);
  581.           exit(1);
  582.       }
  583. ***************
  584. *** 425,431 ****
  585.       if (volume >= 0) {
  586.           AUDIO_INITINFO(&info);
  587.           info.play.gain = (AUDIO_MAX_GAIN * volume) / 100;
  588. !         if (ioctl(ofd, AUDIO_SETINFO, &info))
  589.               perror("volume setting");
  590.       }
  591.   
  592. --- 514,520 ----
  593.       if (volume >= 0) {
  594.           AUDIO_INITINFO(&info);
  595.           info.play.gain = (AUDIO_MAX_GAIN * volume) / 100;
  596. !         if (ioctl(afd, AUDIO_SETINFO, &info))
  597.               perror("volume setting");
  598.       }
  599.   
  600. ***************
  601. *** 449,458 ****
  602.   
  603.   void close_speaker()
  604.   {
  605. !     (void) ioctl(ofd, I_FLUSH, FLUSHW);
  606. !     close(ofd);
  607.       close(actlfd);
  608. !     ofd = actlfd = -1;
  609.   }
  610.   
  611.   void sigpoll_handler()
  612. --- 538,547 ----
  613.   
  614.   void close_speaker()
  615.   {
  616. !     (void) ioctl(afd, I_FLUSH, FLUSHW);
  617. !     close(afd);
  618.       close(actlfd);
  619. !     afd = actlfd = -1;
  620.   }
  621.   
  622.   void sigpoll_handler()
  623. ***************
  624. *** 463,472 ****
  625.           perror("AUDIO_GETINFO");
  626.       }
  627.       else if (ap.play.waiting) {
  628. !         (void) ioctl(ofd, I_FLUSH, FLUSHW);
  629. !         close(ofd);
  630.           /* The open() call blocks until we can use the device again */
  631. !         if ((ofd = open(AUDIO_IODEV, O_WRONLY)) < 0) {
  632.               perror(AUDIO_IODEV);
  633.               exit(1);
  634.           }
  635. --- 552,561 ----
  636.           perror("AUDIO_GETINFO");
  637.       }
  638.       else if (ap.play.waiting) {
  639. !         (void) ioctl(afd, I_FLUSH, FLUSHW);
  640. !         close(afd);
  641.           /* The open() call blocks until we can use the device again */
  642. !         if ((afd = open(AUDIO_IODEV, O_WRONLY)) < 0) {
  643.               perror(AUDIO_IODEV);
  644.               exit(1);
  645.           }
  646. ***************
  647. *** 488,494 ****
  648.       int err;
  649.   
  650.       /* Alloc NUM_BUFFER Sounds */
  651. !     for( akt_buf = NUM_BUFFER; akt_buf > 0; akt_buf--) {
  652.           if (err = SNDAlloc(&snd[akt_buf-1], BUFFERSIZE,
  653.                      SND_FORMAT_MULAW_8,
  654.                      SND_RATE_CODEC, 1, 4)) {
  655. --- 577,583 ----
  656.       int err;
  657.   
  658.       /* Alloc NUM_BUFFER Sounds */
  659. !     for (akt_buf = NUM_BUFFER; akt_buf > 0; akt_buf--) {
  660.           if (err = SNDAlloc(&snd[akt_buf-1], BUFFERSIZE,
  661.                      SND_FORMAT_MULAW_8,
  662.                      SND_RATE_CODEC, 1, 4)) {
  663. ***************
  664. *** 505,507 ****
  665. --- 594,644 ----
  666.   }
  667.   
  668.   #endif /* USE_NX */
  669. + 
  670. + 
  671. + void checkalive()
  672. + {
  673. + #ifdef CHECK_X_SERVER
  674. +     if (xdisplay) {
  675. +         Window focus;
  676. +         int revert_to;
  677. +         if (pdebug)
  678. +             fprintf(stderr, "polling X server...\n");
  679. +         /* Do a simple X request that needs a server round trip...
  680. +            The error handler will kill us when the server is dead,
  681. +            so that radio dies when the user logs out. */
  682. +         XGetInputFocus(xdisplay, &focus, &revert_to);
  683. +         if (pdebug)
  684. +             fprintf(stderr, "X server OK\n");
  685. +     }
  686. +     else if (pdebug)
  687. +         fprintf(stderr, "checkalive() is a no-op\n");
  688. + #endif /* CHECK_X_SERVER */
  689. + }
  690. + 
  691. + void setmcast(s, group)
  692. +     int s;
  693. +     char *group;
  694. + {
  695. + #ifdef HAVE_MCAST
  696. +     struct in_addr grpaddr;
  697. +     struct in_addr ifaddr;
  698. +     struct ip_mreq mreq;
  699. + 
  700. +     grpaddr.s_addr = inet_addr(group);
  701. +     if (!IN_MULTICAST(grpaddr.s_addr)) {
  702. +         fprintf(stderr, "Bad multicast group: %s\n", group);
  703. +         exit(1);
  704. +     }
  705. +     
  706. +     ifaddr.s_addr = htonl(INADDR_ANY);
  707. +     
  708. +     mreq.imr_multiaddr = grpaddr;
  709. +     mreq.imr_interface = ifaddr;
  710. +     if (setsockopt(s, IPPROTO_IP, IP_ADD_MEMBERSHIP,
  711. +                &mreq, sizeof(mreq)) < 0) {
  712. +         perror("setsockopt mreq");
  713. +         exit(1);
  714. +     }
  715. + #endif
  716. + }
  717. diff -rcN ../orig/radio.man ./radio.man
  718. *** ../orig/radio.man    Thu Sep 10 08:55:37 1992
  719. --- ./radio.man    Thu Sep 10 08:57:16 1992
  720. ***************
  721. *** 14,22 ****
  722.   .B \-l
  723.   .I addr
  724.   ] [
  725. ! .B \-n
  726.   ]
  727. !       [
  728.   .B \-p
  729.   .I port
  730.   ] [
  731. --- 14,25 ----
  732.   .B \-l
  733.   .I addr
  734.   ] [
  735. ! .B \-m
  736. ! .I mcastgrp
  737.   ]
  738. !  [
  739. ! .B \-n
  740. ! ] [
  741.   .B \-p
  742.   .I port
  743.   ] [
  744. ***************
  745. *** 25,30 ****
  746. --- 28,35 ----
  747.   ] [
  748.   .B \-s
  749.   ] [
  750. + .B \-t
  751. + ] [
  752.   .B \-v
  753.   .I volume
  754.   ]
  755. ***************
  756. *** 73,78 ****
  757. --- 78,94 ----
  758.   .I addr
  759.   (useful for forwarding stations).
  760.   .TP 10
  761. + .BI "\-m " mcastgrp
  762. + Multicast group (SGI only).
  763. + This only makes sense if the same multicast group is passed to the
  764. + .B \-b
  765. + option of
  766. + .IR broadcast (1).
  767. + Using multicasting instead of broadcasting reduces the load on
  768. + machines that aren't listening.
  769. + Unfortunately, the choice of multicast groups is a black art.
  770. + In any case you probably need a multicast group per station.
  771. + .TP 10
  772.   .B \-n
  773.   Noninterruptable mode (Sun Sparc only).
  774.   By default,
  775. ***************
  776. *** 99,104 ****
  777. --- 115,124 ----
  778.   can override the port specified with \fB\-p\fP by sending a control
  779.   message to the control port of your radio program.
  780.   .TP 10
  781. + .B \-t
  782. + Tee mode: write the U-LAW audio data to stdout as well as
  783. + sending it to the audio hardware.
  784. + .TP 10
  785.   .BI "\-v " volume
  786.   Set the initial volume, on a scale from 0 to 100.  (SGI and Sun Sparc only.)
  787.   By default, the volume is left unchanged.
  788. ***************
  789. *** 107,113 ****
  790.   .SH AUTHOR
  791.   Guido van Rossum
  792.   .SH VERSION
  793. ! This manual page documents radio version 2.0, patchlevel 0.
  794.   .SH SEE ALSO
  795.   broadcast(1)
  796.   .SH COPYRIGHT
  797. --- 127,133 ----
  798.   .SH AUTHOR
  799.   Guido van Rossum
  800.   .SH VERSION
  801. ! This manual page documents radio version 2.0, patchlevel 1.
  802.   .SH SEE ALSO
  803.   broadcast(1)
  804.   .SH COPYRIGHT
  805. diff -rcN ../orig/stations.pl ./stations.pl
  806. *** ../orig/stations.pl    Wed Dec 31 18:00:00 1969
  807. --- ./stations.pl    Thu Sep 10 08:57:45 1992
  808. ***************
  809. *** 0 ****
  810. --- 1,28 ----
  811. + #!/usr/bin/perl
  812. + ##
  813. + ## Find radio stations
  814. + ##
  815. + ## (A small subset of the functionality of stations.py for now)
  816. + ##
  817. + ## Written by;  Jeff Beadles  jeff@onion.rain.com
  818. + ##
  819. + # this emulates #! processing on machines that don't support it.
  820. + eval "exec /usr/bin/perl -S $0 $*"
  821. +     if $running_under_some_shell_and_not_perl;
  822. + 
  823. + require 'sys/socket.ph';
  824. + 
  825. + ($name, $aliases, $proto) = getprotobyname('udp');
  826. + 
  827. + $this = pack('S n a4 x8' , &AF_INET, 54317, "\0\0\0\0");
  828. + 
  829. + socket(S, &AF_INET, &SOCK_DGRAM, $proto)  || die "socket: $!";
  830. + bind(S, $this)                            || die "bind:   $!";
  831. + 
  832. + while (1) {
  833. +     recv(S, $buf, 1024, 0) || die "recv:  $!\n";
  834. +     chop($buf);
  835. +     ($t_radio,$t_s,$t_name,$t_port,$t_xmit,$t_log,$t_age) = split(/:/,$buf,7);
  836. +     print "Bogus message '$buf'\n" if ($t_radio ne "radio");
  837. +     print "Receiving station '$t_name' on port $t_port\n";
  838. + }
  839. exit 0 # Just in case...
  840.