On Mon, Feb 22, 2010 at 12:51 PM, Luiz Capitulino
lcapitul...@redhat.com wrote:
How do you reproduce it?
Here's a test program that reproduces the problem. Start qemu with
-chardev socket,id=monitor,path=/tmp/qemu-monitor,server,nowait -mon
chardev=monitor,mode=readline
and run check_getfd /tmp/qemu-monitor. It will print an error and
return nonzero if the monitor output indicates getfd or closefd
failed.
--Ed
/*
* check_getfd
*
* Tests the qemu getfd monitor command
*
* Copyright (c) 2010 Arista Networks, Inc.
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the Software), to deal
* in the Software without restriction, including without limitation the rights
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED AS IS, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
* THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
* THE SOFTWARE.
*/
#include stdio.h
#include stdlib.h
#include unistd.h
#include fcntl.h
#include sys/types.h
#include sys/socket.h
#include sys/un.h
int receive_output(int s, char *m) {
unsigned int i = 0;
char buf[10240];
buf[0] = '\0';
while (1) {
if (recv(s, buf[i], 1, 0) 0) {
perror(Failed to receive);
return -1;
}
buf[++i] = '\0';
if ((i 7) !strcmp(buf[i-7], (qemu) ))
break;
}
if (m
((i strlen(m) + 7) || strncmp(buf[i-7-strlen(m)], m, strlen(m {
fprintf(stderr, %s\n, buf);
return -1;
}
return 0;
}
int main(int argc, char *argv[]) {
struct sockaddr_un addr;
int s;
int fd;
char fdbuf[CMSG_SPACE(sizeof(fd))];
struct msghdr msg;
struct cmsghdr *cmsg;
struct iovec mvec;
char *cmd = getfd MYFD\nclosefd MYFD\n;
if (argc != 2) {
printf(Usage: %s QEMU_MONITOR\n\n, argv[0]);
printf( (start qemu with -chardev socket,id=monitor,path=QEMU_MONITOR
,server,nowait -mon chardev=monitor,mode=readline)\n);
return 1;
}
fd = open(/dev/null, O_RDWR);
if (fd 0) {
perror(Failed to open /dev/null);
return 1;
}
memset(addr, 0, sizeof(addr));
addr.sun_family = AF_UNIX;
strncpy(addr.sun_path, argv[1], sizeof(addr.sun_path));
s = socket(PF_UNIX, SOCK_STREAM, 0);
if (s 0) {
perror(No socket);
return 1;
}
if (connect(s, (struct sockaddr *) addr, sizeof(addr)) 0) {
perror(Failed to connect);
return 1;
}
if (receive_output(s, NULL) 0)
return 1;
mvec.iov_base = cmd;
mvec.iov_len = strlen(cmd) + 1;
msg.msg_name = NULL;
msg.msg_namelen = 0;
msg.msg_iov = mvec;
msg.msg_iovlen = 1;
msg.msg_control = fdbuf;
msg.msg_controllen = CMSG_LEN(sizeof(fd));
msg.msg_flags = 0;
cmsg = CMSG_FIRSTHDR(msg);
cmsg-cmsg_level = SOL_SOCKET;
cmsg-cmsg_type = SCM_RIGHTS;
cmsg-cmsg_len = msg.msg_controllen;
memcpy(CMSG_DATA(cmsg), fd, sizeof(fd));
if (sendmsg(s, msg, 0) 0) {
perror(Failed to send);
return 1;
}
if (receive_output(s, \033[K\r\n) 0)
return 1;
if (receive_output(s, \033[K\r\n) 0)
return 1;
return 0;
}
