ffmpegServer.h

Go to the documentation of this file.

#ifndef ffmpegServer_H
#define ffmpegServer_H

#ifndef __STDC_CONSTANT_MACROS
#define __STDC_CONSTANT_MACROS
#endif

#include <epicsTypes.h>
#include <asynStandardInterfaces.h>

#include "NDPluginDriver.h"

/* null-httpd includes */
extern "C" {
#include "nullhttpd.h"
}
#include "ffmpegCommon.h"


#define MAX_FFMPEG_STREAMS 64

#define ffmpegServerQualityString  "FFMPEG_QUALITY"   /* JPEG quality (int32 read/write) */
#define ffmpegServerFalseColString "FFMPEG_FALSE_COL" /* False Colour toggle (int32 (enum) read/write)*/
#define ffmpegServerHttpPortString "FFMPEG_HTTP_PORT" /* Http port (int32 read)*/
#define ffmpegServerHostString     "FFMPEG_HOST"      /* Host string (string read)*/
#define ffmpegServerJpgUrlString   "FFMPEG_JPG_URL"   /* JPEG Snapshot URL string (string read)*/
#define ffmpegServerMjpgUrlString  "FFMPEG_MJPG_URL"  /* MJPG Stream URL string (string read)*/
#define ffmpegServerClientsString  "FFMPEG_CLIENTS"   /* Number of connected clients (int32 read)*/
#define ffmpegServerAlwaysOnString "FFMPEG_ALWAYS_ON" /* Always produce jpeg, even when no-one is listening (int32 read)*/
#define ffmpegServerMaxWString     "FFMPEG_MAXW"      /* Maximum width of jpg to produce (int32 read/write)*/
#define ffmpegServerMaxHString     "FFMPEG_MAXH"      /* Maximum height of jpg to produce (int32 read/write)*/
#define ffmpegServerSetWString     "FFMPEG_SETW"      /* Specify width of jpg, forcing rescale (int32 read/write)*/
#define ffmpegServerSetHString     "FFMPEG_SETH"      /* Specify height of jpg, forcing rescale (int32 read/write)*/

class ffmpegStream : public NDPluginDriver {
public:
    ffmpegStream(const char *portName, int queueSize, int blockingCallbacks, 
                 const char *NDArrayPort, int NDArrayAddr, int maxBuffers, int maxMemory,
                 int priority, int stackSize);                
    /* These methods override those in the base class */
    void processCallbacks(NDArray *pArray);
    /* These are used by the http server to access the data in this class */
    int send_frame(int sid, NDArray *pArray);
    void send_stream(int sid);
    void send_snapshot(int sid, int index);   

protected:
    int ffmpegServerQuality;
    #define FIRST_FFMPEG_SERVER_PARAM ffmpegServerQuality
    int ffmpegServerFalseCol;
    int ffmpegServerHttpPort;
    int ffmpegServerHost;
    int ffmpegServerJpgUrl;
    int ffmpegServerMjpgUrl;            
    int ffmpegServerClients;
    int ffmpegServerMaxW;
    int ffmpegServerMaxH;
    int ffmpegServerSetW;
    int ffmpegServerSetH;
    int ffmpegServerAlwaysOn;
                                
private:
    NDArray *scArray;    
    NDArray *jpeg;
    int nclients;
         
    AVCodec *codec;
    AVCodecContext *c;
    AVFrame *inPicture;
    AVFrame *scPicture;            
    struct SwsContext *ctx;      
    
    /* signal fresh frames */
    pthread_cond_t *cond;
    pthread_mutex_t mutex;    

    NDArray* get_jpeg();
    NDArray* wait_for_jpeg(int sid);    
    void allocScArray(size_t size);
};
                             
/* These are global to the http server */
static ffmpegStream **streams;
static int nstreams;
    
#endif