node/deps/evnet/test/test.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <assert.h>

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <netinet/in.h>

#include <ev.h>
#include <evnet.h>

#if EVNET_HAVE_GNUTLS
# include <gnutls/gnutls.h>
#endif

static const struct addrinfo tcp_hints = 
/* ai_flags      */ { .ai_flags = 0 
/* ai_family     */ , .ai_family = AF_UNSPEC
/* ai_socktype   */ , .ai_socktype = SOCK_STREAM
                    , 0
                    };

#define MARK_PROGRESS write(STDERR_FILENO, ".", 1)

#define HOST "127.0.0.1"
#define SOCKFILE "/tmp/oi.sock"
#define PORT "5000"

static evnet_server server;
static int nconnections; 
static int use_tls;
static int got_server_close;

static void
common_on_server_close (evnet_server *server, int errorno)
{
  assert(server);
  assert(errorno == 0);
  got_server_close = 1;
}

static void 
common_on_peer_close (evnet_socket *socket)
{
  assert(socket->errorno == 0);
  printf("server connection closed\n");
#if EVNET_HAVE_GNUTLS
  assert(socket->gnutls_errorno == 0);
  if (use_tls) gnutls_deinit(socket->session);
#endif
  free(socket);
}

static void 
common_on_client_timeout (evnet_socket *socket)
{
  assert(socket);
  printf("client connection timeout\n");
}

static void 
common_on_peer_timeout (evnet_socket *socket)
{
  assert(socket);
  fprintf(stderr, "peer connection timeout\n");
  assert(0);
}

#if EVNET_HAVE_GNUTLS
#define DH_BITS 768
static gnutls_anon_server_credentials_t server_credentials;
const int kx_prio[] = { GNUTLS_KX_ANON_DH, 0 };
static gnutls_dh_params_t dh_params;

void anon_tls_server (evnet_socket *socket)
{
  gnutls_session_t session;
  socket->data = session;

  int r = gnutls_init(&session, GNUTLS_SERVER);
  assert(r == 0);
  gnutls_set_default_priority(session);
  gnutls_kx_set_priority (session, kx_prio);
  gnutls_credentials_set(session, GNUTLS_CRD_ANON, server_credentials);
  gnutls_dh_set_prime_bits(session, DH_BITS);

  evnet_socket_set_secure_session(socket, session);
}

void anon_tls_client (evnet_socket *socket)
{
  gnutls_session_t client_session;
  gnutls_anon_client_credentials_t client_credentials;

  gnutls_anon_allocate_client_credentials (&client_credentials);
  gnutls_init(&client_session, GNUTLS_CLIENT);
  gnutls_set_default_priority(client_session);
  gnutls_kx_set_priority(client_session, kx_prio);
  /* Need to enable anonymous KX specifically. */
  gnutls_credentials_set(client_session, GNUTLS_CRD_ANON, client_credentials);

  evnet_socket_set_secure_session(socket, client_session);
  assert(socket->secure);
}

#endif // EVNET_HAVE_GNUTLS





#define PING "PING"
#define PONG "PONG"
#define EXCHANGES 5000
#define PINGPONG_TIMEOUT 5.0

static int successful_ping_count; 

static void 
pingpong_on_peer_read (evnet_socket *socket, const void *base, size_t len)
{
  if (len == 0) {
    evnet_socket_close(socket);
    return;
  }

  char buf[2000];
  strncpy(buf, base, len);
  buf[len] = 0;
  printf("server got message: %s\n", buf);

  evnet_socket_write_simple(socket, PONG, sizeof PONG);
}

static void 
pingpong_on_client_close (evnet_socket *socket)
{
  assert(socket);
  printf("client connection closed\n");
  evnet_server_close(&server);
}

static evnet_socket* 
pingpong_on_server_connection (evnet_server *_server, struct sockaddr *addr)
{
  assert(_server == &server);
  assert(addr);

  evnet_socket *socket = malloc(sizeof(evnet_socket));
  evnet_socket_init(socket, PINGPONG_TIMEOUT);
  socket->on_read = pingpong_on_peer_read;
  socket->on_close = common_on_peer_close;
  socket->on_timeout = common_on_peer_timeout;

  nconnections++;

#if EVNET_HAVE_GNUTLS
  if (use_tls) anon_tls_server(socket);
#endif

  printf("on server connection\n");

  return socket;
}

static void 
pingpong_on_client_connect (evnet_socket *socket)
{
  printf("client connected. sending ping\n");
  evnet_socket_write_simple(socket, PING, sizeof PING);
}

static void 
pingpong_on_client_read (evnet_socket *socket, const void *base, size_t len)
{
  if(len == 0) {
    evnet_socket_close(socket);
    return;
  }

  assert(len = strlen(PONG));

  char buf[len+1];
  strncpy(buf, base, len);
  buf[len] = 0;
  printf("client got message: %s\n", buf);
  
  assert(strcmp(buf, PONG) == 0);

  if (++successful_ping_count > EXCHANGES) {
    evnet_socket_close(socket);
    return;
  } 

  if (successful_ping_count % (EXCHANGES/20) == 0) MARK_PROGRESS;

  evnet_socket_write_simple(socket, PING, sizeof PING);
}

int
pingpong (struct addrinfo *servinfo)
{
  int r;
  evnet_socket client;
  
  successful_ping_count = 0;
  nconnections = 0;
  got_server_close = 0;

  printf("sizeof(evnet_server): %d\n", sizeof(evnet_server));
  printf("sizeof(evnet_socket): %d\n", sizeof(evnet_socket));

  evnet_server_init(&server);
  server.on_connection = pingpong_on_server_connection;
  server.on_close = common_on_server_close;

  r = evnet_server_listen(&server, servinfo, 10);
  assert(r == 0);
  evnet_server_attach(EV_DEFAULT_ &server);

  evnet_socket_init(&client, PINGPONG_TIMEOUT);
  client.on_read    = pingpong_on_client_read;
  client.on_connect = pingpong_on_client_connect;
  client.on_close   = pingpong_on_client_close;
  client.on_timeout = common_on_client_timeout;

#if EVNET_HAVE_GNUTLS
  if (use_tls) anon_tls_client(&client);
#endif

  r = evnet_socket_connect(&client, servinfo);
  assert(r == 0 && "problem connecting");
  evnet_socket_attach(EV_DEFAULT_ &client);

  ev_loop(EV_DEFAULT_ 0);

  printf("successful_ping_count = %d\n", successful_ping_count);
  assert(successful_ping_count == EXCHANGES + 1);
  assert(nconnections == 1);
  assert(got_server_close);

  return 0;
}




#define NCONN 100
#define CONNINT_TIMEOUT 1000.0

static void 
connint_on_peer_read(evnet_socket *socket, const void *base, size_t len)
{
  assert(base);
  assert(len == 0);
  evnet_socket_write_simple(socket, "BYE", 3);
  printf("server wrote bye\n");
}

static void 
connint_on_peer_drain(evnet_socket *socket)
{
  evnet_socket_close(socket);
}

static evnet_socket* 
connint_on_server_connection(evnet_server *_server, struct sockaddr *addr)
{
  assert(_server == &server);
  assert(addr);

  evnet_socket *socket = malloc(sizeof(evnet_socket));
  evnet_socket_init(socket, CONNINT_TIMEOUT);
  socket->on_read    = connint_on_peer_read;
  socket->on_drain   = connint_on_peer_drain;
  socket->on_close   = common_on_peer_close;
  socket->on_timeout = common_on_peer_timeout;

#if EVNET_HAVE_GNUTLS
  if (use_tls) anon_tls_server(socket);
#endif

  printf("on server connection\n");

  return socket;
}

static void 
connint_on_client_connect (evnet_socket *socket)
{
  printf("on client connection\n");
  evnet_socket_close(socket);
}

static void 
connint_on_client_close (evnet_socket *socket)
{
  evnet_socket_close(socket); // already closed, but it shouldn't crash if we try to do it again

  printf("client connection closed\n");

  if (nconnections % (NCONN/20) == 0) MARK_PROGRESS;

  if(++nconnections == NCONN) {
    evnet_server_close(&server);
    printf("closing server\n");
  }
}

static void 
connint_on_client_read (evnet_socket *socket, const void *base, size_t len)
{
  if (len == 0) {
    evnet_socket_close(socket);
    return;
  }

  char buf[200000];
  strncpy(buf, base, len);
  buf[len] = 0;

  printf("client got message: %s\n", buf);
  
  assert(strcmp(buf, "BYE") == 0);
  evnet_socket_close(socket);
}

int 
connint (struct addrinfo *servinfo)
{
  int r;

  nconnections = 0;
  got_server_close = 0;

  evnet_server_init(&server);
  server.on_connection = connint_on_server_connection;
  server.on_close = common_on_server_close;


  evnet_server_listen(&server, servinfo, 1000);
  evnet_server_attach(EV_DEFAULT_ &server);

  evnet_socket clients[NCONN];
  int i;
  for (i = 0; i < NCONN; i++) {
    evnet_socket *client = &clients[i];
    evnet_socket_init(client, CONNINT_TIMEOUT);
    client->on_read    = connint_on_client_read;
    client->on_connect = connint_on_client_connect;
    client->on_close   = connint_on_client_close;
    client->on_timeout = common_on_client_timeout;
#if EVNET_HAVE_GNUTLS
    if (use_tls) anon_tls_client(client);
#endif
    r = evnet_socket_connect(client, servinfo);
    assert(r == 0 && "problem connecting");
    evnet_socket_attach(EV_DEFAULT_ client);
  }

  ev_loop(EV_DEFAULT_ 0);

  assert(nconnections == NCONN);
  assert(got_server_close);

  return 0;
}


struct addrinfo *
create_tcp_address (void)
{
  struct addrinfo *servinfo;
  int r = getaddrinfo(NULL, PORT, &tcp_hints, &servinfo);
  assert(r == 0);
  return servinfo;
}

void
free_tcp_address (struct addrinfo *servinfo)
{
  freeaddrinfo(servinfo);
}


struct addrinfo *
create_unix_address (void)
{
  struct addrinfo *servinfo;
  struct stat tstat;
  if (lstat(SOCKFILE, &tstat) == 0) {
    assert(S_ISSOCK(tstat.st_mode));
    unlink(SOCKFILE);
  }

  servinfo = malloc(sizeof(struct addrinfo));
  servinfo->ai_family = AF_UNIX;
  servinfo->ai_socktype = SOCK_STREAM;
  servinfo->ai_protocol = 0;

  struct sockaddr_un *sockaddr = calloc(sizeof(struct sockaddr_un), 1);
  sockaddr->sun_family = AF_UNIX;
  strcpy(sockaddr->sun_path, SOCKFILE);

  servinfo->ai_addr = (struct sockaddr*)sockaddr;
  servinfo->ai_addrlen = sizeof(struct sockaddr_un);

  return servinfo;
}

void
free_unix_address (struct addrinfo *servinfo)
{
  free(servinfo->ai_addr);
  free(servinfo);
}


int
main (void)
{
#if EVNET_HAVE_GNUTLS
  gnutls_global_init();

  gnutls_dh_params_init (&dh_params);

  fsync((int)stderr);
  gnutls_dh_params_generate2 (dh_params, DH_BITS);

  gnutls_anon_allocate_server_credentials (&server_credentials);
  gnutls_anon_set_server_dh_params (server_credentials, dh_params);
#endif

  struct addrinfo *tcp_address = create_tcp_address();
  struct addrinfo *unix_address;

  
  use_tls = 0;
  assert(pingpong(tcp_address) == 0);
  assert(connint(tcp_address) == 0);

#if EVNET_HAVE_GNUTLS
  use_tls = 1;
  assert(pingpong(tcp_address) == 0);
  assert(connint(tcp_address) == 0);
#endif 


  
  use_tls = 0;

  unix_address = create_unix_address();
  assert(pingpong(unix_address) == 0);
  free_unix_address(unix_address);

  unix_address = create_unix_address();
  assert(connint(unix_address) == 0);
  free_unix_address(unix_address);

#if EVNET_HAVE_GNUTLS
  use_tls = 1;

  unix_address = create_unix_address();
  assert(pingpong(unix_address) == 0);
  free_unix_address(unix_address);

  unix_address = create_unix_address();
  assert(connint(unix_address) == 0);
  free_unix_address(unix_address);
#endif 


  free_tcp_address(tcp_address);
  return 0;
}