/Users/craigcornelius/Projects/SPRING Mac Release 0.2/displayreplicator.h

Go to the documentation of this file.

// $Id: displayreplicator.h,v 1.33 2006/05/24 16:52:42 sean Exp $
// $Copyright: (c)2001 National Biocomputation Center, Stanford University $

//
// DisplayReplicator code:
//      National Biocomputation Center (http://biocomp.stanford.edu)
//
#ifndef DisplayReplicator_Header
#define DisplayReplicator_Header

#include "socket.h"
#include "timer.h"
#ifndef SGI
#include "jpeg.h"
#endif

#define MAX_BUF_SIZE (32 * 1024)
#define UDP_QUEUE_SIZE (4 * 1024) // In Blocks
#define PORT 1200
#define SYSTEM_INFO_CODE                0xe0
#define CHANNEL_REQUEST_CODE    0xf2
#define ECG_CODE                                0x02
#define RESPIRATION_CODE                0x07

class DisplayReplicator {
public:
    enum source_type {source_screen, source_memory};
    
    DisplayReplicator(int port=1200, source_type source = source_screen);
    ~DisplayReplicator();
    static const char* rcsid;
    static int debug;
    
    int NumConnections();
    
    void Connect(char* server, bool switchboard = true, char channel = -1, char* optBuffer = NULL, bool blocking = true);
    void Listen();
    void Disconnect(int connection_to_kill);
    void Reshape(int w, int h);
    void InitHeader(int conf_width, int conf_height);
    // these functions implement the main functionality
    // use data_in if from/to memory (source=source_memory), else unused
    void SendScreenUpdates(int which_buffer, void* data_in=NULL);
    void ReceiveScreenUpdate(int which_buffer, char* buf, int JPEG_size = 0);
    void Update(int nonblocking);       // sender should use nonblocking
    
    // compression stuff
    enum compression_type {color_24bit, color_16bit, color_8bit, greyscale, JPEG};
    void setCompression(compression_type comp);
    void SetParams(int res_reduction, compression_type compression, 
        int comparison_threshold, int from_win = 0);
    void GetParams(int* res_reduction_p, compression_type* compression_p,
        int* comparison_threshold_p);
    void setOrigin(int val) {from_windows = val;}
    
    // Event handlers- next best thing to being there
    void RegisterEventHandlers(void(*keyfn)(unsigned char,int,int),
        void(*specialfn)(int,int,int), void(*mousefn)(int,int,int,int),
        void (*motionfn)(int,int));
    void SendKeyEvent(char key, int x, int y);
    void SendSpecialKeyEvent(int key, int x, int y);
    void SendMouseEvent(int button, int state, int x, int y);
    void SendMotionEvent(int x, int y);
    
    // Menus
    void Menu();
    
    //private:
public:
    enum {unknown, sender, receiver} mode;
    source_type source; // where is the data coming from
    int port;
    int session_alive;
    int num_socks;
    Socket* sock[100];
    int width, height;
    void (*keyfn)(unsigned char,int,int);
    void (*specialfn)(int,int,int);
    void (*mousefn)(int,int,int,int);
    void (*motionfn)(int,int);
    
    // internal memory
    int block_size;
    char* block;
    int buf_size;
    char* buf;
    char* g_buf;
    char* gl_buf;
    char* JPEG_data;
    char *mySocketBuffer;
    int curBufLen;
#ifndef SGI
#ifndef __APPLE__
    BYTE *WHeader;
#endif // __APPLE__
#endif
    
    // compression vars
    int res_reduction;
    enum compression_type compression;
    int comparison_threshold;
    int comp_size;
    int from_windows;
    
    // metrics
    Timer global_timer;
    
    // internal functions
    void PaintBlock(int which_buffer, char x, char y, char* data,
                        bool paintAll = false);
    int SendBlock(int buf_code, int x, int y, char* block, 
        int which_socket=-1, int is_a_resend=0, 
                bool flushBuffer = true);       // socket -1 = all
    void SendWholeScreen(int which_buffer, int i);
    void SendScreenRefresh(int sock_index);
    static void Connect_CB(int);
    static void Params_CB(int);
    int encode_block_into_buf(int buf_code, int x, int y, int seq_id,
        char* block);
    void decode_block_from_buf(int* buf_code_p, int* x_p, int* y_p, 
        int* seq_id, char* block, int JPEG_size = 0);
    int send_buf_out_socket(int sock_index, int size, char *whichBuf = NULL);
    int compare_blocks(char* block1, char* block2);
};

inline int DisplayReplicator::NumConnections()
{ return(num_socks); }


inline void DisplayReplicator::GetParams(int* res_p, compression_type* ct_p,
                                         int* comp_p)
{ 
    *res_p = res_reduction; 
    *ct_p = compression; 
    *comp_p = comparison_threshold;
}

#endif

---