C++ 简单远程调用中间件设计 (二) _c++中间件开发

class FileAgent :public SerAgent , FileCSArgBase
{
    protected:
    guint32 pos_file;
    bool end_file;
    guint32 size_file;
    guint32 size_read;

    public:
    gint32 init(CommunicateCli *ap_client);
    gint32 open(char* filename);
    gint32 read(char *ap_buf, guint32 a_size_read);
    gint32 seek(guint32 a_pos);
    gint32 close();
    gint32 erase();
    bool get_if_end(){return end_file;}
    guint32 get_size_read(){return size_read;}
};

class FileSer :public ModuleServer , FileCSArgBase
{
    protected:
    std::string name_module;
    static guint32 counter;
    IdObj m_id_obj;
    CommunicateSer *p_my_comm;
    Glib::Mutex mutex_clone;

        std::ifstream my_file;

    protected:
    typedef void (FileSer::*P_FUNC)(char *ap_recv, char *ap_send);

    P_FUNC p_func;

    std::map<guint32, P_FUNC> map_func;
    std::map<guint32, P_FUNC>::iterator it_map_func;
 
    typedef std::pair<guint32, P_FUNC> Ps_Func;


    public:
    void call_switch(char *ap_recv, char *ap_send);
    void init(CommunicateSer *ap_my_comm, IdObj a_id_obj);

    protected:
    //void init();


    void clone(char *ap_recv, char *ap_send);
    void open(char *ap_recv, char *ap_send);
    void read(char *ap_recv, char *ap_send);
    void seek(char *ap_recv, char *ap_send);
    void close(char *ap_recv, char *ap_send);
    void erase(char *ap_recv, char *ap_send);
};