mqtt/src/client.c - diff

Return to client.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

version 1.2.2.3, 2012/04/27 10:07:50	version 1.2.2.4, 2012/04/27 16:41:56
Line 56 ConnectClient(int sock)	Line 56 ConnectClient(int sock)
if (pfd.revents & (POLLERR \| POLLHUP \| POLLNVAL))	if (pfd.revents & (POLLERR \| POLLHUP \| POLLNVAL))
return -1;	return -1;

	memset(args->msg->msg_base, 0, args->msg->msg_len);
siz = recv(sock, args->msg->msg_base, args->msg->msg_len, 0);	siz = recv(sock, args->msg->msg_base, args->msg->msg_len, 0);
if (siz == -1) {	if (siz == -1) {
printf("Error:: recv() #%d - %s\n", errno, strerror(errno));	printf("Error:: recv() #%d - %s\n", errno, strerror(errno));
Line 142 RecvFrom(int sock)	Line 143 RecvFrom(int sock)
{	{
struct pollfd pfd;	struct pollfd pfd;
int siz = 0;	int siz = 0;

	memset(args->msg->msg_base, 0, args->msg->msg_len);

pfd.fd = sock;	pfd.fd = sock;
pfd.events = POLLIN \| POLLPRI;	pfd.events = POLLIN \| POLLPRI;