add api BHQueryProcs.

lichao

2021-05-19 34cd75f77d0ca94dbdba4e6cc9451fe4d33e78b3

 src/defs.h

@@ -19,6 +19,7 @@
#ifndef DEFS_KP8LKGD0
#define DEFS_KP8LKGD0

#include "robust.h"
#include <atomic>
#include <string>

@@ -35,8 +36,8 @@
struct CenterInfo {
   MQInfo mq_center_;
   MQInfo mq_bus_;
   MQInfo mq_init_;
   MQInfo mq_sender_;
   robust::AtomicReqRep init_rr_;
   std::atomic<MQId> mqid_;
   CenterInfo() :
       mqid_(100000) {}
@@ -62,6 +63,10 @@
const MQInfo &BHGlobalSenderAddress();
const MQInfo &BHTopicCenterAddress();
const MQInfo &BHTopicBusAddress();
const MQInfo &BHCenterReplyAddress();
bool BHNodeInit(const int64_t request, int64_t &reply);
void BHCenterHandleInit(std::function<int64_t(const int64_t)> const &onReq);

// node mq is avail with in timeout; after that may get killed.
int NodeTimeoutSec();

#endif // end of include guard: DEFS_KP8LKGD0