jDttSP/chan.c

   1 /* chan.c
   2
   3 fast inter-user-process single-reader/single-writer channels
   4 using a modified version of jack ringbuffers and memory-mapped files.
   5
   6 This file is part of a program that implements a Software-Defined Radio.
   7
   8 Copyright (C) 2004 by Frank Brickle, AB2KT and Bob McGwier, N4HY
   9
  10 This program is free software; you can redistribute it and/or modify
  11 it under the terms of the GNU General Public License as published by
  12 the Free Software Foundation; either version 2 of the License, or
  13 (at your option) any later version.
  14
  15 This program is distributed in the hope that it will be useful,
  16 but WITHOUT ANY WARRANTY; without even the implied warranty of
  17 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18 GNU General Public License for more details.
  19
  20 You should have received a copy of the GNU General Public License
  21 along with this program; if not, write to the Free Software
  22 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  23
  24 The authors can be reached by email at
  25
  26 ab2kt@arrl.net
  27 or
  28 rwmcgwier@comcast.net
  29
  30 or by paper mail at
  31
  32 The DTTS Microwave Society
  33 6 Kathleen Place
  34 Bridgewater, NJ 08807
  35 */
  36
  37 #include <chan.h>
  38
  39 size_t
  40 putChan(Chan c, char *data, size_t size) {
  41   return ringb_write(c->rb, data, size);
  42 }
  43
  44 size_t
  45 getChan(Chan c, char *data, size_t size) {
  46   return ringb_read(c->rb, data, size);
  47 }
  48
  49 BOOLEAN
  50 putChan_nowait(Chan c, char *data, size_t size) {
  51   if (ringb_write_space(c->rb) >= size) {
  52     ringb_write(c->rb, data, size);
  53     return TRUE;
  54   } else return FALSE;
  55 }
  56
  57 BOOLEAN
  58 getChan_nowait(Chan c, char *data, size_t size) {
  59   if (ringb_read_space(c->rb) >= size) {
  60     ringb_read(c->rb, data, size);
  61     return TRUE;
  62   } else return FALSE;
  63 }
  64
  65 Chan
  66 openChan(char *path, size_t want) {
  67   Chan c = (Chan) safealloc(sizeof(ChanDesc), 1, "Chan header");
  68   c->size.rib = sizeof(ringb_t);
  69   c->size.buf = nblock2(want);
  70   c->file.path = path;
  71   if ((c->file.desc = open(c->file.path, O_RDWR)) == -1) {
  72     fprintf(stderr, "can't open Chan file %s\n", c->file.path);
  73     exit(1);
  74   }
  75   c->size.tot = c->size.rib + c->size.buf;
  76   if ((c->size.tru = fdsize(c->file.desc)) < c->size.tot) {
  77     fprintf(stderr,
  78             "Chan file %s is too small (%d) for required size (%s)\n",
  79             c->file.path, c->size.tru, c->size.tot);
  80     exit(1);
  81   }
  82   if (!(c->map.base = (char *) mmap(0,
  83                                     c->size.tot,
  84                                     PROT_READ | PROT_WRITE,
  85                                     MAP_SHARED,
  86                                     c->file.desc,
  87                                     0))) {
  88     fprintf(stderr, "can't memory map %s for Chan\n",
  89             c->file.path);
  90     exit(1);
  91   }
  92   if (!(c->rb = ringb_create(c->map.base, c->size.buf))) {
  93     fprintf(stderr, "can't map RB for Chan\n");
  94     exit(1);
  95   }
  96   return c;
  97 }
  98
  99 void
 100 closeChan(Chan c) {
 101   if (c) {
 102     close(c->file.desc);
 103     munmap(c->map.base, c->size.tot);
 104     safefree((char *) c);
 105   }
 106 }