daqc_listener.h

Go to the documentation of this file.

/* -*- tab-width:8 c-basic-offset:4  indent-tabs-mode:nil -*- */
/* set vi: ts=8:softtabstop=4,shiftwidth=4,expandtab */
 
#ifndef DAQ_LISTENER_H
#define DAQ_LISTENER_H
 
#include "daqc.h"
 
struct sockaddr_in;
 
#if HAVE_PTHREAD_H
typedef pthread_t       thread_t;
typedef pthread_mutex_t mutex_t;
#elif _WIN32
typedef HANDLE thread_t;
typedef HANDLE mutex_t;
#else /* HAVE_PTHREAD_H */
#endif /* HAVE_PTHREAD_H */
 
#ifndef VXWORKS
 
typedef struct
{
 
    daq_t* daq;
 
    struct sockaddr_in* listener_addr;
 
    void* ( *interpreter )( void* );
 
    int shutting_down;
 
    thread_t listener_tid;
 
    thread_t interpreter_tid;
 
    mutex_t lock;
 
} daq_listen_t;
 
daq_listen_t* daq_initialize( daq_listen_t* lstn,
                              daq_t*        daq,
                              int*          tcp_port,
                              void* ( *start_func )(void*));
 
int daq_shutdown( daq_listen_t* lstn );
 
#endif /* defined(VXWORKS) */
#endif /* defined(DAQ_LISTENER_H) */