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) */