mqtt/src/client.c - diff

Return to client.c CVS log

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

version 1.1.2.10, 2011/12/29 14:13:13	version 1.1.2.11, 2012/01/05 10:01:20
Line 83 CloseClient(int sock)	Line 83 CloseClient(int sock)
} else	} else
ioVERBOSE(3) printf("Sended DISCONNECT %d bytes\n", siz);	ioVERBOSE(3) printf("Sended DISCONNECT %d bytes\n", siz);

	shutdown(sock, SHUT_RDWR);
close(sock);	close(sock);
return siz;	return siz;
}	}
Line 129 KAClient(int sock)	Line 130 KAClient(int sock)
return (u_char) mqtt_readPINGRESP(args->msg);	return (u_char) mqtt_readPINGRESP(args->msg);
}	}

FILE *	void *
OpenFile(void)	OpenFile(void)
{	{
	int f, siz = 0;
	void *mem;

if (!args->isFile)	if (!args->isFile)
return NULL;	return NULL;

args->isFile = fopen(AIT_GET_STR(&args->Value), "r");	f = open(AIT_GET_STR(&args->Value), O_RDONLY);
if (!args->isFile) {	if (f == -1) {
printf("Error:: in open file #%d - %s\n", errno, strerror(errno));	printf("Error:: in open file #%d - %s\n", errno, strerror(errno));
return NULL;	return NULL;
}	}
	mem = mmap(NULL, siz, PROT_READ, MAP_PRIVATE, f, 0);
	if (mem == MAP_FAILED) {
	printf("Error:: in map file #%d - %s\n", errno, strerror(errno));
	close(f);
	return NULL;
	} else
	close(f);

return args->isFile;	AIT_SET_PTR(&args->Value, mem, siz);
	return mem;
}	}

void	void
CloseFile(void)	CloseFile(void)
{	{
if (args->isFile)	if (args->isFile) {
fclose(args->isFile);	munmap(AIT_GET_PTR(&args->Value), AIT_LEN(&args->Value));
	AIT_FREE_VAL(&args->Value);
	}
}	}