#include #include #include #include #include #include #include #include #include #include #include int openList(int port) { int fd=-1; sockaddr_in sa; fd=socket(PF_INET, SOCK_STREAM, 0); if(fd<0) return -1; sa.sin_family=AF_INET; sa.sin_port=htons(port); sa.sin_addr.s_addr=htonl(INADDR_ANY); int s=1; setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,&s,sizeof(s)); if(bind(fd,(struct sockaddr*)&sa,sizeof(sa))<0) { shutdown(fd,2); fd=-1; return fd; }; if(listen(fd,1)<0) { shutdown(fd,2); fd=-1; return fd; }; return fd; }; int main(int argc, char** argv) { int listener=openList(argc>1?atoi(argv[1]):8001); int stream=accept(listener,NULL,NULL); size_t s; s=argc>2?atoi(argv[2]):3000; setsockopt(stream,SOL_SOCKET,SO_RCVBUF,&s,sizeof(s)); setsockopt(stream,SOL_SOCKET,SO_SNDBUF,&s,sizeof(s)); close(listener); char buff[200]; long long sent=0; for(int i=1;i;i++) { sprintf(buff,"%d\n",i); int writeres=write(stream,buff,strlen(buff)); if(writeres<0) { cerr<<"Write error "<