libaitmqtt/src/cmds.c - diff

Return to cmds.c CVS log

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

version 1.1.2.2, 2012/05/05 13:10:24	version 1.1.2.3, 2012/05/08 09:07:31
Line 1	Line 1
#include "global.h"	#include "global.h"


static inline int	#pragma GCC visibility push(hidden)
_wait4data(int sock, u_short ka, short events)
	inline int
	mqtt_wait4data(int sock, u_short ka, short events)
{	{
int ret = 0;	int ret = 0;
struct pollfd pfd;	struct pollfd pfd;
Line 22 _wait4data(int sock, u_short ka, short events)	Line 24 _wait4data(int sock, u_short ka, short events)
return 0; /* ready */	return 0; /* ready */
}	}

	#pragma GCC visibility pop


/*	/*
* mqtt_KeepAlive() - Keep Alive check routine	* mqtt_KeepAlive() - Keep Alive check routine
*	*
Line 40 mqtt_KeepAlive(int sock, u_short ka, u_char tries)	Line 44 mqtt_KeepAlive(int sock, u_short ka, u_char tries)
if (sock < 3)	if (sock < 3)
return -1; /* error */	return -1; /* error */

if ((ret = _wait4data(sock, ka, POLLOUT)))	if ((ret = mqtt_wait4data(sock, ka, POLLOUT)))
return ret;	return ret;
/* ping request */	/* ping request */
if ((ret = mqtt_msgPINGREQ(&msg)) == -1)	if ((ret = mqtt_msgPINGREQ(&msg)) == -1)
Line 51 mqtt_KeepAlive(int sock, u_short ka, u_char tries)	Line 55 mqtt_KeepAlive(int sock, u_short ka, u_char tries)
}	}

while (tries--) {	while (tries--) {
if ((ret = _wait4data(sock, ka, POLLIN \| POLLPRI))) {	if ((ret = mqtt_wait4data(sock, ka, POLLIN \| POLLPRI))) {
if (ret == -1)	if (ret == -1)
break;	break;
else	else