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

use the new connect_wait code in the ctdb_messaging test

Browse Source 
(This used to be ctdb commit 36980878141c5e506dd7ee021fba6ca7d0ff5ad3)
This commit is contained in:
Andrew Tridgell 2007-04-11 15:09:22 +10:00
parent 8386b0e345
commit 06e4f9b968
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
ctdb/tests/ctdb_messaging.c
View File

@ -35,7 +35,7 @@ static int num_repeats = 100;
static void message_handler(struct ctdb_context *ctdb, uint32_t srvid,
TDB_DATA data, void *private)
{
printf("client vnn:%d received a message to srvid:%d\n",ctdb_get_vnn(ctdb),srvid);
printf("client vnn:%d received a message to srvid:%d\n",ctdb_get_vnn(ctdb),srvid);
}
/*
@ -142,8 +142,6 @@ int main(int argc, const char *argv[])
/* start the protocol running */
ret = ctdb_start(ctdb);
/*XXX why does this block forever? ctdb_connect_wait(ctdb);*/
pid=fork();
if (pid) {
srvid=0;
@ -157,8 +155,11 @@ int main(int argc, const char *argv[])
data.dsize=0;
ctdb_set_message_handler(ctdb, srvid, message_handler, NULL);
sleep(3);
printf("sending message from vnn:%d to vnn:%d/srvid:%d\n",ctdb_get_vnn(ctdb),ctdb_get_vnn(ctdb), 1-srvid);
ctdb_connect_wait(ctdb);
sleep(2);
printf("sending message from vnn:%d to vnn:%d/srvid:%d\n",ctdb_get_vnn(ctdb),ctdb_get_vnn(ctdb), 1-srvid);
ctdb_send_message(ctdb, ctdb_get_vnn(ctdb), 1-srvid, data);
while(1){