sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-01-10 01:18:15 +03:00
Code

client: Add functions to handle server_id structure

Browse Source 
server_id records are stored in g_lock.tdb for persistent transactions.

Signed-off-by: Amitay Isaacs <amitay@gmail.com>

(This used to be ctdb commit 55f91ea4373c54ddb5faad87fa2826d86a4b6172)
This commit is contained in:
Amitay Isaacs 2013-10-04 15:37:24 +10:00
parent be33efa3e4
commit 0205d52657
1 changed files with 66 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
ctdb/client/ctdb_client.c
View File

@ -3730,6 +3730,72 @@ int ctdb_ctrl_getcapabilities(struct ctdb_context *ctdb, struct timeval timeout,
return ret;
}
struct server_id {
uint64_t pid;
uint32_t task_id;
uint32_t vnn;
uint64_t unique_id;
};
static struct server_id server_id_get(struct ctdb_context *ctdb, uint32_t reqid)
{
struct server_id id;
id.pid = getpid();
id.task_id = reqid;
id.vnn = ctdb_get_pnn(ctdb);
id.unique_id = id.vnn;
id.unique_id = (id.unique_id << 32) | reqid;
return id;
}
static bool server_id_equal(struct server_id *id1, struct server_id *id2)
{
if (id1->pid != id2->pid) {
return false;
}
if (id1->task_id != id2->task_id) {
return false;
}
if (id1->vnn != id2->vnn) {
return false;
}
if (id1->unique_id != id2->unique_id) {
return false;
}
return true;
}
static bool server_id_exists(struct ctdb_context *ctdb, struct server_id *id)
{
struct ctdb_server_id sid;
int ret;
uint32_t result;
sid.type = SERVER_TYPE_SAMBA;
sid.pnn = id->vnn;
sid.server_id = id->pid;
ret = ctdb_ctrl_check_server_id(ctdb, timeval_current_ofs(3,0),
id->vnn, &sid, &result);
if (ret != 0) {
/* If control times out, assume server_id exists. */
return true;
}
if (result) {
return true;
}
return false;
}
/**
* check whether a transaction is active on a given db on a given node
*/