introduce online state in proto rpc adapter

this is to ensure we do not start server stuff until we are officially
online.

3 files changed, 8 insertions, 0 deletions

diff --git a/searchcore/src/vespa/searchcore/proton/server/proton.cpp b/searchcore/src/vespa/searchcore/proton/server/proton.cpp
index f39d9d8620c..772be9049db 100644
--- a/searchcore/src/vespa/searchcore/proton/server/proton.cpp
+++ b/searchcore/src/vespa/searchcore/proton/server/proton.cpp
@@ -332,6 +332,7 @@ Proton::init(const BootstrapConfig::SP & configSnapshot)
     _executor.sync();
     waitForOnlineState();
     _isReplayDone = true;
+    _rpcHooks->set_online();
     if ( ! _fs4Server->start() ) {
         throw vespalib::PortListenException(protonConfig.ptport, "FS4");
     }
diff --git a/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp b/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp
index 99cc62ce30c..fca49a52553 100644
--- a/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp
+++ b/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp
@@ -216,6 +216,12 @@ RPCHooksBase::open(Params & params)
     LOG(debug, "started monitoring interface");
 }
 
+void
+RPCHooksBase::set_online()
+{
+    _proto_rpc_adapter->set_online();
+}
+
 RPCHooksBase::~RPCHooksBase() = default;
 
 void
diff --git a/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.h b/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.h
index f16237381d6..21b433acf7b 100644
--- a/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.h
+++ b/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.h
@@ -99,6 +99,7 @@ public:
     RPCHooksBase(const RPCHooksBase &) = delete;
     RPCHooksBase & operator = (const RPCHooksBase &) = delete;
     RPCHooksBase(Params &params);
+    void set_online();
     virtual ~RPCHooksBase();
     void close();