diff options
| author | Amitay Isaacs <amitay@gmail.com> | 2017-06-26 15:55:15 +1000 |
|---|---|---|
| committer | Martin Schwenke <martins@samba.org> | 2017-06-29 10:34:27 +0200 |
| commit | b1b6ceecedaa85529f33a17dd64ba307ee5cbe2e (patch) | |
| tree | 86343e0821e4bd4446ccbfc0a4637af1beccfd71 /ctdb/client | |
| parent | b783b930de52554457647258bd4d843db912a38b (diff) | |
| download | samba-b1b6ceecedaa85529f33a17dd64ba307ee5cbe2e.tar.gz | |
ctdb-client: Add sync api for DB_ATTACH_REPLICATED control
Signed-off-by: Amitay Isaacs <amitay@gmail.com>
Reviewed-by: Martin Schwenke <martin@meltin.net>
Diffstat (limited to 'ctdb/client')
| -rw-r--r-- | ctdb/client/client_control_sync.c | 30 | ||||
| -rw-r--r-- | ctdb/client/client_sync.h | 6 |
2 files changed, 36 insertions, 0 deletions
diff --git a/ctdb/client/client_control_sync.c b/ctdb/client/client_control_sync.c index db2d7be15be..43a941d79db 100644 --- a/ctdb/client/client_control_sync.c +++ b/ctdb/client/client_control_sync.c @@ -2728,3 +2728,33 @@ int ctdb_ctrl_db_open_flags(TALLOC_CTX *mem_ctx, struct tevent_context *ev, return 0; } + +int ctdb_ctrl_db_attach_replicated(TALLOC_CTX *mem_ctx, + struct tevent_context *ev, + struct ctdb_client_context *client, + int destnode, struct timeval timeout, + const char *db_name, uint32_t *db_id) +{ + struct ctdb_req_control request; + struct ctdb_reply_control *reply; + int ret; + + ctdb_req_control_db_attach_replicated(&request, db_name); + ret = ctdb_client_control(mem_ctx, ev, client, destnode, timeout, + &request, &reply); + if (ret != 0) { + DEBUG(DEBUG_ERR, + ("Control DB_ATTACH_REPLICATED failed to node %u," + " ret=%d\n", destnode, ret)); + return ret; + } + + ret = ctdb_reply_control_db_attach_replicated(reply, db_id); + if (ret != 0) { + DEBUG(DEBUG_ERR, + ("Control DB_ATTACH_REPLICATED failed, ret=%d\n", ret)); + return ret; + } + + return 0; +} diff --git a/ctdb/client/client_sync.h b/ctdb/client/client_sync.h index 7bf58e6e2dc..a4b5c49ab0b 100644 --- a/ctdb/client/client_sync.h +++ b/ctdb/client/client_sync.h @@ -488,6 +488,12 @@ int ctdb_ctrl_db_open_flags(TALLOC_CTX *mem_ctx, struct tevent_context *ev, int destnode, struct timeval timeout, uint32_t db_id, int *tdb_flags); +int ctdb_ctrl_db_attach_replicated(TALLOC_CTX *mem_ctx, + struct tevent_context *ev, + struct ctdb_client_context *client, + int destnode, struct timeval timeout, + const char *db_name, uint32_t *db_id); + /* from client/client_message_sync.c */ int ctdb_message_recd_update_ip(TALLOC_CTX *mem_ctx, struct tevent_context *ev, |