diff options
| -rw-r--r-- | ctdb/common/ctdb_ltdb.c | 4 | ||||
| -rw-r--r-- | ctdb/include/ctdb_private.h | 5 | ||||
| -rw-r--r-- | ctdb/server/ctdb_ltdb_server.c | 2 |
3 files changed, 11 insertions, 0 deletions
diff --git a/ctdb/common/ctdb_ltdb.c b/ctdb/common/ctdb_ltdb.c index 200cca41dc..b5e586568c 100644 --- a/ctdb/common/ctdb_ltdb.c +++ b/ctdb/common/ctdb_ltdb.c @@ -129,6 +129,10 @@ int ctdb_ltdb_store(struct ctdb_db_context *ctdb_db, TDB_DATA key, int ret; bool seqnum_suppressed = false; + if (ctdb_db->ctdb_ltdb_store_fn) { + return ctdb_db->ctdb_ltdb_store_fn(ctdb_db, key, header, data); + } + if (ctdb->flags & CTDB_FLAG_TORTURE) { struct ctdb_ltdb_header *h2; rec = tdb_fetch(ctdb_db->ltdb->tdb, key); diff --git a/ctdb/include/ctdb_private.h b/ctdb/include/ctdb_private.h index e3f77e905e..396427bfa6 100644 --- a/ctdb/include/ctdb_private.h +++ b/ctdb/include/ctdb_private.h @@ -516,6 +516,11 @@ struct ctdb_db_context { struct lockwait_handle *lockwait_overflow; struct ctdb_persistent_state *persistent_state; struct trbt_tree *delete_queue; + int (*ctdb_ltdb_store_fn)(struct ctdb_db_context *ctdb_db, + TDB_DATA key, + struct ctdb_ltdb_header *header, + TDB_DATA data); + }; diff --git a/ctdb/server/ctdb_ltdb_server.c b/ctdb/server/ctdb_ltdb_server.c index 8de6ad2f8e..c00a048246 100644 --- a/ctdb/server/ctdb_ltdb_server.c +++ b/ctdb/server/ctdb_ltdb_server.c @@ -604,6 +604,8 @@ static int ctdb_local_attach(struct ctdb_context *ctdb, const char *db_name, if (ctdb_db->delete_queue == NULL) { CTDB_NO_MEMORY(ctdb, ctdb_db->delete_queue); } + + ctdb_db->ctdb_ltdb_store_fn = ctdb_ltdb_store_server; } /* check for hash collisions */ |