libaitrpc/src/cli.c - diff

Return to cli.c CVS log

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

version 1.16.8.4, 2013/08/22 11:55:45	version 1.16.8.5, 2013/08/22 12:11:35
Line 353 rpc_pkt_Receive(int sock, int type, sockaddr_t * __res	Line 353 rpc_pkt_Receive(int sock, int type, sockaddr_t * __res
return -1;	return -1;
}	}

	payload:
if (type == SOCK_STREAM) {	if (type == SOCK_STREAM) {
memset(buf, 0, blen);	memset(buf, 0, blen);
ret = recv(sock, buf, blen, 0);	ret = recv(sock, buf, blen, 0);
Line 391 rpc_pkt_Receive(int sock, int type, sockaddr_t * __res	Line 392 rpc_pkt_Receive(int sock, int type, sockaddr_t * __res
/* calc estimated length */	/* calc estimated length */
rpc = (struct tagRPCCall*) buf;	rpc = (struct tagRPCCall*) buf;
estlen = ntohl(rpc->call_len) + blen;	estlen = ntohl(rpc->call_len) + blen;
printf("ret = %d len=%d\n", ret, estlen);
if (estlen > AIT_LEN(pkt))	if (estlen > AIT_LEN(pkt))
AIT_RE_BUF(pkt, estlen);	AIT_RE_BUF(pkt, estlen);
buf = AIT_GET_BUF(pkt) + blen;	buf = AIT_GET_BUF(pkt) + blen;
blen = AIT_LEN(pkt) - blen;	blen = AIT_LEN(pkt) - blen;
	goto payload;
} else	} else
ret += sizeof(struct tagRPCCall);	ret += sizeof(struct tagRPCCall);
}	}