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