server-l-zmg/client.cpp

#include "log.h"
#include "zio.h"
#include "message_file.h"

int main()
{
	int sock=zio::build_stream();

	if(zio::connect(sock,"127.0.0.1",4000))
	{
		return -1;
	}

	zio::setiobuf(sock,32<<10,64<<10);
	zio::setblocking(sock,false);
	int len=1;
	int count=0x400+2;
	char buf[8192];
	uint64_t time;
#if 1

	for(int i=0;i<8000;i++)
	{
		buf[i]='1';
	}

	buf[0]=0x04;
	buf[1]=0x00;



	char recv_buf[8192];
	for(;;)
	{
		while(zio::read(sock,recv_buf,sizeof(recv_buf))>0);
		if(count!=zio::writev(sock,buf,count))
			break;
	}
#else
	message_file mf(stdin);
	count=0;
	while(len>0)
	{
		while((len=mf.get_line(&time,&buf[count],sizeof(buf)-count)))
		{
			count+=len;
			if(count>1024)
				break;
		}

		log_info("count=%d",count);
		if(count!=zio::writev(sock,buf,count))
			break;

		count=0;
	}
#endif

	zio::close(sock);

	return 0;
}