Attachment 87548 Details for Bug 69492 – test_setsockopt.c

test_setsockopt.c

test_setsockopt.c (text/x-csrc), 5.03 KB, created by Svante Signell on 2013-10-13 10:24:16 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Svante Signell

Created: 2013-10-13 10:24:16 UTC

Size: 5.03 KB

patch

obsolete

>/*
>File test-setsckopt from gnulibs test-poll.c
>*/
>
>#include <poll.h>
>#include <stdio.h>
>#include <string.h>
>#include <sys/socket.h>
>#include <netinet/in.h>
>#include <arpa/inet.h>
>#include <fcntl.h>
>#include <stdlib.h>
>#include <stdbool.h>
>#include <sys/ioctl.h>
>#include <errno.h>
>#include <unistd.h>
>#include <arpa/inet.h>
>#include <netinet/in.h>
>/*
>typedef uint32_t in_addr_t;
>struct in_addr {
>  in_addr_t s_addr;
>};
>
> */
>#define TEST_PORT       12345
>#ifndef SO_REUSEPORT
>#define SO_REUSEPORT    SO_REUSEADDR
>#endif
>
>FILE *fp1;
>
>static int
>open_server_socket ()
>{
>  int s, x, ret;
>  struct sockaddr_in ia;
>  int reuseaddr=0;  /* Local addresses reusable? */
>  socklen_t optlen; /* Option length */
>
>  fprintf(fp1,"\ntest-setsockopt.c: open_server_socket()\n");
>  fprintf(fp1,"open_server_socket(): Before calling socket()\n");
>  fflush(fp1);
>  s = socket (AF_INET, SOCK_STREAM, 0);
>  fprintf(fp1,"open_server_socket(): After calling socket()\n");
>  fflush(fp1);
>
>  memset (&ia, 0, sizeof (ia));
>  ia.sin_family = AF_INET;
>  inet_pton (AF_INET, "127.0.0.1", &ia.sin_addr);
>  printf("inet addr converted back: %s\n", inet_ntoa(ia.sin_addr));
>  ia.sin_port = htons (TEST_PORT);
>  fprintf(fp1,"open_server_socket(): Before calling bind()\n");
>  fflush(fp1);
>  ret = bind (s, (struct sockaddr *) &ia, sizeof (ia));
>  fprintf(fp1,"open_server_socket(): After calling bind()\n");
>  fflush(fp1);
>
>  if (ret < 0)
>    {
>      perror ("bind");
>      exit (77);
>    }
>
>  x = 1;
>  fprintf(fp1,"open_server_socket(): Before calling setsockopt()\n");
>  fflush(fp1);
>  ret = setsockopt (s, SOL_SOCKET, SO_REUSEADDR, &x, sizeof (x));
>  fprintf(fp1,"open_server_socket(): After calling setsockopt(), ret=%d\n",ret);
>  fflush(fp1);
>  printf("reuseaddr (from setsockopt) = %d, ret = %d\n", x, ret);
>  if (ret == -1)
>    printf("error: %s\n", strerror(errno));
>
>  optlen = sizeof reuseaddr;
>  ret = getsockopt(s, SOL_SOCKET, SO_REUSEADDR, &reuseaddr, &optlen);
>  printf("reuseaddr (from getsockopt) = %d, ret = %d\n", reuseaddr, ret);
>  fprintf(fp1,"open_server_socket(): After calling getsockopt(), ret=%d\n",ret);
>  fflush(fp1);
>
>  if (ret == -1)
>    printf("error: %s\n", strerror(errno));
>
>  ret = listen (s, 1);
>  if (ret < 0)
>    {
>      perror ("listen");
>      exit (77);
>    }
>
>  fprintf(fp1,"open_socket_server() After calling listen(), ret=%d\n",ret);
>  fflush(fp1);
>
>  return s;
>}
>
>static int
>connect_to_socket (int blocking)
>{
>  int s, ret;
>  struct sockaddr_in ia;
>
>  fprintf(fp1,"\ntest-setsockopt.c: connect_to_socket()\n");
>  fprintf(fp1,"connect_to_socket(): Before calling socket()\n");
>  fflush(fp1);
>  s = socket (AF_INET, SOCK_STREAM, 0);
>  fprintf(fp1,"connect_to_socket(): After calling socket()\n");
>  fflush(fp1);
>
>  memset (&ia, 0, sizeof (ia));
>  ia.sin_family = AF_INET;
>  inet_pton (AF_INET, "127.0.0.1", &ia.sin_addr);
>  ia.sin_port = htons (TEST_PORT);
>
>  if (!blocking)
>    {
>      int oldflags = fcntl (s, F_GETFL, NULL);
>
>      if (!(oldflags & O_NONBLOCK))
>	fcntl (s, F_SETFL, oldflags | O_NONBLOCK);
>    }
>  fprintf(fp1,"connect_to_socket(): Before calling connect()\n");
>  fflush(fp1);
>  ret = connect (s, (struct sockaddr *) &ia, sizeof (ia));
>  fprintf(fp1,"connect_to_socket(): After calling connect()\n");
>  fflush(fp1);
>  if (ret < 0 && (blocking || errno != EINPROGRESS))
>    {
>      perror ("connect");
>      exit (77);
>    }
>
>  fprintf(fp1,"connect_to_socket(): After calling listen(), ret=%d, err=%s\n", ret, strerror(errno));
>  fflush(fp1);
>
>  return s;
>}
>
>/* A slightly more convenient interface to poll(2).  */
>static int
>poll1 (int fd, int ev, int time)
>{
>  struct pollfd pfd;
>  int r;
>
>  pfd.fd = fd;
>  pfd.events = ev;
>  pfd.revents = 0;
>  r = poll (&pfd, 1, time);
>  if (r < 0)
>    return r;
>
>  if (pfd.revents & ~(POLLHUP | POLLERR | POLLNVAL | ev))
>    printf ("invalid flag combination (unrequested events)\n");
>
>  return pfd.revents;
>}
>
>/* Test poll(2) for unconnected nonblocking sockets.  */
>static int
>test_connect_first (void)
>{
>  fprintf(fp1,"\ntest-setsockopt.c: test_connect_first()\n");
>  fflush(fp1);
>  int s = open_server_socket ();
>
>  struct sockaddr_in ia;
>  socklen_t addrlen;
>
>  int c1, c2;
>
>  if (poll1 (s, POLLIN | POLLRDNORM | POLLRDBAND, 0) != 0)
>    printf ("can read, socket not connected\n");
>
>  c1 = connect_to_socket (false);
>
>  if (poll1 (s, POLLIN | POLLRDNORM | POLLRDBAND, -1) != (POLLIN | POLLRDNORM))
>    printf ("expecting POLLIN | POLLRDNORM on passive socket\n");
>  if (poll1 (s, POLLIN | POLLRDBAND, 0) != POLLIN)
>    printf ("expecting POLLIN on passive socket\n");
>  if (poll1 (s, POLLRDNORM | POLLRDBAND, 0) != POLLRDNORM)
>    printf ("expecting POLLRDNORM on passive socket\n");
>  addrlen = sizeof (ia);
>  c2 = accept (s, (struct sockaddr *) &ia, &addrlen);
>  close (s);
>  close (c1);
>  close (c2);
>  return 0;
>}
>
>int main ()
>{
>  int result = -1;
>
>  fp1 = fopen ("/tmp/pfinet.log", "a+");
>  fprintf(fp1,"\n********************************************\n");
>  printf ("Unconnected socket test\n");
>  result = test_connect_first();
>  if (!result) printf ("passed\n");
>
>  fprintf(fp1,"********************************************\n");
>  fclose (fp1);
>
>  exit (result);
>}
>

Actions: View

Attachments on bug 69492: 86021 | 86076 | 86077 | 87546 | 87547 | 87548 | 88478

Use of freedesktop.org services, including Bugzilla, is subject to our Code of Conduct. How we collect and use information is described in our Privacy Policy.