sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-08-29 13:49:30 +03:00
Code Activity

Use ctdb_fetch_lock rather than ctdb_call.

Browse Source 
Signed-off-by: Martin Schwenke <martin@meltin.net>

(This used to be ctdb commit 5f3d2e29a446972ac244e20a08e48f4c2f4ffef4)
This commit is contained in:
Martin Schwenke
2009-05-05 16:02:30 +10:00
committed by Ronnie Sahlberg
parent 86ad711c37
commit 9666d7bf0a
1 changed files with 9 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
ctdb/tests/src/ctdb_fetch.c
View File

@ -145,17 +145,6 @@ static void bench_fetch(struct ctdb_context *ctdb, struct event_context *ev)
printf("Fetch: %.2f msgs/sec\n", msg_count/end_timer());
}
enum my_functions {FUNC_FETCH=1};
/*
ctdb call function to fetch a record
*/
static int fetch_func(struct ctdb_call_info *call)
{
call->reply_data = &call->record_data;
return 0;
}
/*
handler for reconfigure message
*/
@ -185,10 +174,10 @@ int main(int argc, const char *argv[])
int opt;
const char **extra_argv;
int extra_argc = 0;
int ret;
poptContext pc;
struct event_context *ev;
struct ctdb_call call;
TDB_DATA key, data;
struct ctdb_record_handle *h;
int cluster_ready=0;
pc = poptGetContext(argv[0], argc, argv, popt_options, POPT_CONTEXT_KEEP_FIRST);
@ -225,8 +214,6 @@ int main(int argc, const char *argv[])
exit(1);
}
ret = ctdb_set_call(ctdb_db, fetch_func, FUNC_FETCH);
ctdb_set_message_handler(ctdb, 0, message_handler, &msg_count);
printf("Waiting for cluster\n");
@ -239,24 +226,20 @@ int main(int argc, const char *argv[])
bench_fetch(ctdb, ev);
ZERO_STRUCT(call);
call.key.dptr = discard_const(TESTKEY);
call.key.dsize = strlen(TESTKEY);
key.dptr = discard_const(TESTKEY);
key.dsize = strlen(TESTKEY);
printf("Fetching final record\n");
/* fetch the record */
call.call_id = FUNC_FETCH;
call.call_data.dptr = NULL;
call.call_data.dsize = 0;
h = ctdb_fetch_lock(ctdb_db, ctdb, key, &data);
ret = ctdb_call(ctdb_db, &call);
if (ret == -1) {
printf("ctdb_call FUNC_FETCH failed - %s\n", ctdb_errstr(ctdb));
if (h == NULL) {
printf("Failed to fetch record '%s' on node %d\n",
(const char *)key.dptr, ctdb_get_pnn(ctdb));
exit(1);
}
printf("DATA:\n%s\n", (char *)call.reply_data.dptr);
printf("DATA:\n%s\n", (char *)data.dptr);
return 0;
}