| | |
| | | private: |
| | | void initCNode(); |
| | | |
| | | // 向erlang端直接发送sql语句 |
| | | bool getExecSqlResult(const std::string &strSql); |
| | | |
| | | public: |
| | | //#todo setCNodeName |
| | | |
| | | // 将c节点名称设置给erlang使其可以在接收到消息时,能通知到本节点 |
| | | bool setCNodeName(); |
| | | |
| | | // 向erlang发送消息, #TODO 目前仅实现了信号,待实现消息体 |
| | | bool sendMessage(); |
| | | |
| | | //#todo sendMessage |
| | | |
| | | // 设置匿名c节点接受erlang节点向c节点发送的消息 |
| | | void test(pthread_cond_t *, pthread_mutex_t *); |
| | | |
| | | /*** |
| | |
| | | */ |
| | | bool removeNode(); |
| | | |
| | | |
| | | /** |
| | | * 修改集群名称 |
| | | * @param CluId |
| | | * @param CluName |
| | | * @return |
| | | */ |
| | | bool modifyCluName(std::string CluId, std::string CluName); |
| | | |
| | | |
| | |
| | | std::string PerPicUrl, std::string PerFea); |
| | | // private: |
| | | /*** |
| | | * 重新连接节点 |
| | | * 为了防止过长时间连接被关闭,主动重新连接节点 |
| | | * @return 连接状态 |
| | | */ |
| | | bool resetConn(); |
| | |
| | | private: |
| | | //存储路径 |
| | | std::string m_path; |
| | | // erlang 节点名称 |
| | | std::string m_nodeName; |
| | | // 程序内的c节点名称 进程名+pid@127.0.0.1 |
| | | std::string m_cNodeName; |
| | | // 进程名+pid?#TODO |
| | | std::string m_pName; |
| | | std::string m_cookie; |
| | | |