sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-23 17:34:34 +03:00
Code

Add a test to read back the message

Browse Source 
Volker

(This used to be ctdb commit b7f134fe6e160d7ec70c466f8f3e7fb3dabd0774)
This commit is contained in:
Volker Lendecke 2007-04-11 16:51:25 +02:00
parent 2597931dfd
commit 6961f32eb7
1 changed files with 37 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
ctdb/direct/ctdbd_test.c
View File

@ -132,12 +132,48 @@ int send_a_message(int fd, int ourvnn, int vnn, int pid, TDB_DATA data)
if(data.dsize){ if(data.dsize){
cnt=write(fd, data.dptr, data.dsize); cnt=write(fd, data.dptr, data.dsize);
} }
return 0;
}
int receive_a_message(int fd, struct ctdb_req_message **preply)
{
int cnt,tot;
struct ctdb_req_message *rep;
uint32_t length;
/* read the 4 bytes of length for the pdu */
cnt=0;
tot=4;
while(cnt!=tot){
int numread;
numread=read(fd, ((char *)&length)+cnt, tot-cnt);
if(numread>0){
cnt+=numread;
}
}
/* read the rest of the pdu */
rep = malloc(length);
rep->hdr.length = length;
cnt = 0;
tot = length-4;
while(cnt!=tot){
int numread;
numread=read(fd, ((char *)rep)+cnt, tot-cnt);
if(numread>0){
cnt+=numread;
}
}
*preply = rep;
return 0;
} }
int main(int argc, const char *argv[]) int main(int argc, const char *argv[])
{ {
int fd, pid, vnn, dstvnn, dstpid; int fd, pid, vnn, dstvnn, dstpid;
TDB_DATA message; TDB_DATA message;
struct ctdb_req_message *reply;
/* open the socket to talk to the local ctdb daemon */ /* open the socket to talk to the local ctdb daemon */
fd=ux_socket_connect(CTDB_SOCKET); fd=ux_socket_connect(CTDB_SOCKET);
@ -171,6 +207,7 @@ int main(int argc, const char *argv[])
message.dsize=strlen(message.dptr)+1; message.dsize=strlen(message.dptr)+1;
send_a_message(fd, vnn, dstvnn, dstpid, message); send_a_message(fd, vnn, dstvnn, dstpid, message);
receive_a_message(fd, &reply);
/* wait for the message to come back */ /* wait for the message to come back */