Subversion Repositories pc_fpga_com

/*

 * Copyright (C) 2011 Simon A. Berger

 *

 *  This program is free software; you may redistribute it and/or modify its

 *  under the terms of the GNU Lesser General Public License as published by the Free

 *  Software Foundation; either version 2 of the License, or (at your option)

 *  any later version.

 *

 *  This program 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 General Public License

 *  for more details.

 */

#ifndef BACKGROUND_READER_H

#define BACKGROUND_READER_H

#ifdef __cplusplus

#include <boost/thread/mutex.hpp>

#include <boost/thread/thread.hpp>

#include <boost/thread/barrier.hpp>

#include <boost/scoped_ptr.hpp>

#include <deque>

#include <vector>

#include <pthread.h>

#include <stdint.h>

// the all singing, all dancing background reader, written in shiny new c++

class background_reader

{

    typedef boost::mutex mutex_t;

    //typedef boost::unique_lock<mutex_t> unique_lock_t;

    typedef boost::lock_guard<mutex_t> lock_guard_t;

    boost::condition_variable m_can_read_condition;

    boost::mutex m_pq_mtx;

    //boost::scoped_ptr<boost::thread> m_thread;

    boost::thread_group m_thread_group;

    volatile bool m_stop; // FIXME: use atomic var

    int m_socket;

    size_t m_max_size;

    std::deque<std::string> m_pq;

    size_t m_pq_mem;

    size_t m_pq_max_mem;

    size_t m_pq_max_depth;

    //pthread_t m_native_handle;

    boost::mutex m_nh_mtx;

    std::vector<pthread_t> m_native_handles;

    const size_t N_THREADS;

    boost::barrier m_run_barrier;

    bool m_threads_joined;

    void run();

public:

    background_reader( int s, size_t size );

    virtual ~background_reader();

    void start();

    void interrupt();

    void stop() { m_stop = true; __sync_synchronize(); } // try to make sure that the new value of m_stop is visible to all bg threads before interrupt is called.

    void join();

    ssize_t block_recv( void* buf, size_t size );

    ssize_t poll();

    ssize_t purge();

};

#endif

// the boring old ansi c interface

#ifdef __cplusplus

extern "C" {

#endif

typedef struct fpga_bgr_s {

    void *bgr_cpp;

} fpga_bgr_t;

void fpga_bgr_init( fpga_bgr_t *bgr, int socket, size_t size );

void fpga_bgr_delete( fpga_bgr_t *bgr );

void fpga_bgr_start( fpga_bgr_t *bgr);

ssize_t fpga_bgr_block_recv( fpga_bgr_t *bgr, void *buf, size_t size );

ssize_t fpga_bgr_poll();

void fpga_bgr_stop_interrupt_join( fpga_bgr_t *bgr);

// high level functions

int fpga_bgr_recv_charv( fpga_bgr_t *bgr, char *buf, size_t n );

int fpga_bgr_recv_shortv( fpga_bgr_t *bgr, int16_t *buf, size_t n );

int fpga_bgr_recv_intv( fpga_bgr_t *bgr, int32_t *buf, size_t n );

int fpga_bgr_recv_longv( fpga_bgr_t *bgr, int64_t *buf, size_t n );

int fpga_bgr_recv_floatv( fpga_bgr_t *bgr, float *buf, size_t n );

int fpga_bgr_recv_doublev( fpga_bgr_t *bgr, double *buf, size_t n );

#ifdef __cplusplus

}

#endif

#endif // BACKGROUND_READER_H