termreader.c

Go to the documentation of this file.

/*
 * Copyright (C) 2006  SRI International
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 *
 * SRI International: 333 Ravenswood Ave, Menlo Park, CA 94025
 */

#include "termreader.h"
#include <stdlib.h>
#ifndef _WINDOWS
#include <unistd.h>
#endif
#include "libicl.h"

struct TermReaderStruct
{
  TermReaderGetNext getNext;
  TermReaderType type;
  gint listenSocket;
  gint error;
  TermReaderCleanup cleanup;
  gpointer readerSpecificData;
}
;

TermReader* termReader_create()
{
  TermReader* t = (TermReader*)malloc(sizeof(TermReader));
  t->getNext = NULL;
  t->type = UNKNOWNTERMREADERTYPE;
  t->listenSocket = -1;
  t->error = TERMREADER_OKAY;
  t->cleanup = NULL;
  t->readerSpecificData = NULL;
  return t;
}

void termReader_free(TermReader* t)
{
  if(t->cleanup != NULL) {
    t->cleanup(t);
  }
  free(t);
}

ICLTerm* termReader_getNextTerm(TermReader* t, double timeout)
{
  if(t->getNext != NULL) {
    return t->getNext(t, timeout);
  }
  else {
    t->error = TERMREADER_NOTINITIALIZED;
    return NULL;
  }
}

void termReader_setError(TermReader* t, gint errnum)
{
  t->error = errnum;
}

gint termReader_getError(TermReader* t)
{
  return t->error;
}

void termReader_setSocket(TermReader* t, gint newsocket)
{
  t->listenSocket = newsocket;
}

gint termReader_getSocket(TermReader* t)
{
  return t->listenSocket;
}

void termReader_setType(TermReader* t, TermReaderType type)
{
  t->type = type;
}

TermReaderType termReader_getType(TermReader* t)
{
  return t->type;
}

void termReader_setReaderSpecificData(TermReader* t, gpointer g)
{
  t->readerSpecificData = g;
}

gpointer termReader_getReaderSpecificData(TermReader* t)
{
  return t->readerSpecificData;
}

void termReader_setGetNextCallback(TermReader* t, TermReaderGetNext g)
{
  t->getNext = g;
}

void termReader_setCleanupCallback(TermReader* t, TermReaderCleanup c)
{
  t->cleanup = c;
}

---