/*
 * =====================================================================================
 *
 *       Filename:  EpollTest.cpp
 *
 *    Description:
 *
 *        Version:  1.0
 *        Created:  08/31/2017 02:46:29 PM
 *  Last Modified:  08/31/2017 02:46:29 PM
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  zt (),
 *   Organization:
 *
 * =====================================================================================
 */

#include <stdio.h>
#include <stdlib.h>
#include <sys/epoll.h>
#include <vector>

#include "Network.cpp"


int main ( int argc, char* argv[] )
{
  int i = 0;
  int fd = 0;
  int ret = -1;
  std::vector<int> fdvec;
  const int max_cnt = 50 * 1000;
  fdvec.reserve ( max_cnt );
  char buf[] = "test testssasdfasdfasdfsadfasdf";

  for ( i = 0; i < max_cnt; ++i )
  {
    do
    {
      #ifdef TEST2
      fd = Network::MakeTCPClient ( "127.0.0.1", 28000 );
      //fd = Network::MakeTCPClient ( "39.108.167.69", 28000 );
      #else
      sockaddr_in addr;
      memset ( &addr, 0, sizeof ( addr ) );
      fd = socket ( AF_INET, SOCK_STREAM, IPPROTO_TCP );

      addr.sin_addr.s_addr  = inet_addr ( "127.0.0.1" );
      //addr.sin_addr.s_addr  = inet_addr ( "39.108.167.69" );
      addr.sin_family     = AF_INET;
      addr.sin_port       =  htons ( 28000 );

      ret = connect ( fd, reinterpret_cast<struct sockaddr*> ( &addr ), sizeof ( addr ) );
      #endif
    }
    while ( ret < 0 );

    if ( fd > 0 )
    {
      fdvec.push_back ( fd );
      //Network::Sendn ( fd, buf, strlen ( buf ) );
    }

    printf ( "fd =%d\n", fd );
    //usleep ( 10 );
  }


  sleep ( 5 );

  for ( auto& ele : fdvec )
  {
    shutdown ( ele, SHUT_RDWR );
    close ( ele );
  }

  return 0;
}