add is leader checker before any raft write option

conanfile.py

@@ -9,7 +9,7 @@
 
 class HomeObjectConan(ConanFile):
     name = "homeobject"
-    version = "2.1.10"
+    version = "2.1.11"
 
     homepage = "https://github.com/eBay/HomeObject"
     description = "Blob Store built on HomeReplication"

src/lib/homestore_backend/hs_blob_manager.cpp

@@ -99,6 +99,11 @@ BlobManager::AsyncResult< blob_id_t > HSHomeObject::_put_blob(ShardInfo const& s
 
     RELEASE_ASSERT(repl_dev != nullptr, "Repl dev instance null");
 
+    if (!repl_dev->is_leader()) {
+        LOGW("failed to put blob for pg [{}], not leader", pg_id);
+        return folly::makeUnexpected(BlobErrorCode::NOT_LEADER);
+    }
+
     // Create a put_blob request which allocates for header, key and blob_header, user_key. Data sgs are added later
     auto req = put_blob_req_ctx::make(sizeof(BlobHeader) + blob.user_key.size());
     req->header()->msg_type = ReplicationMessageType::PUT_BLOB_MSG;

src/lib/homestore_backend/hs_shard_manager.cpp

@@ -108,6 +108,11 @@ ShardManager::AsyncResult< ShardInfo > HSHomeObject::_create_shard(pg_id_t pg_ow
         return folly::makeUnexpected(ShardError::PG_NOT_READY);
     }
 
+    if (!repl_dev->is_leader()) {
+        LOGW("failed to create shard for pg [{}], not leader", pg_owner);
+        return folly::makeUnexpected(ShardError::NOT_LEADER);
+    }
+
     auto new_shard_id = generate_new_shard_id(pg_owner);
     auto create_time = get_current_timestamp();
 
@@ -172,6 +177,16 @@ ShardManager::AsyncResult< ShardInfo > HSHomeObject::_seal_shard(ShardInfo const
         RELEASE_ASSERT(repl_dev != nullptr, "Repl dev null");
     }
 
+    if (!repl_dev) {
+        LOGW("failed to get repl dev instance for pg [{}]", pg_id);
+        return folly::makeUnexpected(ShardError::PG_NOT_READY);
+    }
+
+    if (!repl_dev->is_leader()) {
+        LOGW("failed to create shard for pg [{}], not leader", pg_id);
+        return folly::makeUnexpected(ShardError::NOT_LEADER);
+    }
+
     ShardInfo tmp_info = info;
     tmp_info.state = ShardInfo::State::SEALED;
 

src/lib/homestore_backend/replication_state_machine.cpp

@@ -189,7 +189,7 @@ void ReplicationStateMachine::on_replace_member(const homestore::replica_member_
     home_object_->on_pg_replace_member(repl_dev()->group_id(), member_out, member_in);
 }
 
-void ReplicationStateMachine::on_destroy() {
+void ReplicationStateMachine::on_destroy(const homestore::group_id_t& group_id) {
     // TODO:: add the logic to handle destroy
     LOGI("replica destroyed");
 }

src/lib/homestore_backend/replication_state_machine.hpp

@@ -173,7 +173,7 @@ class ReplicationStateMachine : public homestore::ReplDevListener {
                            const homestore::replica_member_info& member_in) override;
 
     /// @brief Called when the replica is being destroyed by nuraft;
-    void on_destroy() override;
+    void on_destroy(const homestore::group_id_t& group_id) override;
 
     /// Not Implemented
     /// @brief Called when the snapshot is being created by nuraft;