test_poll.c File Reference

Poll Tests. More...

#include "asterisk.h"
#include <signal.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <unistd.h>
#include "asterisk/utils.h"
#include "asterisk/module.h"
#include "asterisk/test.h"
#include "asterisk/poll-compat.h"

Include dependency graph for test_poll.c:

Go to the source code of this file.

Macros
#define	FDNO   3
#define	RESET   for (i = 0; i < 4; i++) { pfd[i].revents = 0; }

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
	AST_TEST_DEFINE (poll_test)
static void *	failsafe_cancel (void *vparent)
static int	load_module (void)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Poll test" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_DEFAULT, .support_level = AST_MODULE_SUPPORT_CORE, }
static const struct ast_module_info *	ast_module_info = &__mod_info

Detailed Description

Poll Tests.

Author

Tilghman Lesher <tlesher AT digium DOT com> 

Verify that the various poll implementations work as desired (ast_poll, ast_poll2)

Definition in file test_poll.c.

Macro Definition Documentation

FDNO

#define FDNO   3

Referenced by AST_TEST_DEFINE().

RESET

#define RESET   for (i = 0; i < 4; i++) { pfd[i].revents = 0; }

Definition at line 63 of file test_poll.c.

Referenced by AST_TEST_DEFINE().

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 246 of file test_poll.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 246 of file test_poll.c.

AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM

(

void

)

Definition at line 246 of file test_poll.c.

AST_TEST_DEFINE()

AST_TEST_DEFINE

(

poll_test

)

Definition at line 64 of file test_poll.c.

References ast_poll, ast_poll2(), ast_pthread_create_background, AST_TEST_FAIL, AST_TEST_NOT_RUN, AST_TEST_PASS, ast_test_status_update, errno, failsafe_cancel(), FDNO, sip_to_pjsip::info(), NULL, RESET, TEST_EXECUTE, and TEST_INIT.

{
#define FDNO 3
   int fd[2], res = AST_TEST_PASS, i, res2;
   int rdblocker[2];
#if FDNO > 3
   int wrblocker[2], consec_interrupt = 0;
#endif
   struct pollfd pfd[4] = { { .events = POLLOUT, }, { .events = POLLIN, }, { .events = POLLIN }, { .events = POLLOUT } };
   pthread_t failsafe_tid;
   struct timeval tv = { 0, 0 };
#if FDNO > 3
   char garbage[256] =
      "abcdefghijklmnopqrstuvwxyz0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ@/"
      "abcdefghijklmnopqrstuvwxyz0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ@/"
      "abcdefghijklmnopqrstuvwxyz0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ@/"
      "abcdefghijklmnopqrstuvwxyz0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ@/";
#endif

   switch (cmd) {
   case TEST_INIT:
      info->name = "poll_test";
      info->category = "/main/poll/";
      info->summary = "unit test for the ast_poll() API";
      info->description =
         "Verifies behavior for the ast_poll() API call";
      return AST_TEST_NOT_RUN;
   case TEST_EXECUTE:
      break;
   }

   ast_test_status_update(test, "Creating handle that should NEVER block on write\n");
   if ((fd[0] = open("/dev/null", O_WRONLY)) < 0) {
      ast_test_status_update(test, "Unable to open a writable handle to /dev/null: %s\n", strerror(errno));
      return AST_TEST_FAIL;
   }

   ast_test_status_update(test, "Creating handle that should NEVER block on read\n");
   if ((fd[1] = open("/dev/zero", O_RDONLY)) < 0) {
      ast_test_status_update(test, "Unable to open a readable handle to /dev/zero: %s\n", strerror(errno));
      close(fd[0]);
      return AST_TEST_FAIL;
   }

   ast_test_status_update(test, "Creating handle that should block on read\n");
   if (pipe(rdblocker) < 0) {
      ast_test_status_update(test, "Unable to open a pipe: %s\n", strerror(errno));
      close(fd[0]);
      close(fd[1]);
      return AST_TEST_FAIL;
   }

#if FDNO > 3
   ast_test_status_update(test, "Creating handle that should block on write\n");
   if (pipe(wrblocker) < 0) {
      ast_test_status_update(test, "Unable to open a pipe: %s\n", strerror(errno));
      close(fd[0]);
      close(fd[1]);
      close(rdblocker[0]);
      close(rdblocker[1]);
      return AST_TEST_FAIL;
   }

   ast_test_status_update(test, "Starting thread to ensure we don't block forever\n");
   if (ast_pthread_create_background(&failsafe_tid, NULL, failsafe_cancel, (void *) (long) pthread_self())) {
      ast_test_status_update(test, "Unable to start failsafe thread\n");
      close(fd[0]);
      close(fd[1]);
      close(fd[2]);
      close(rdblocker[0]);
      close(rdblocker[1]);
      close(wrblocker[0]);
      close(wrblocker[1]);
      return AST_TEST_FAIL;
   }

   /* Fill the pipe full of data */
   ast_test_status_update(test, "Making pipe block on write\n");
   for (i = 0; i < 4096; i++) { /* 1MB of data should be more than enough for any pipe */
      errno = 0;
      if (write(wrblocker[1], garbage, sizeof(garbage)) < sizeof(garbage)) {
         ast_test_status_update(test, "Got %d\n", errno);
         if (errno == EINTR && ++consec_interrupt > 1) {
            break;
         }
      } else {
         consec_interrupt = 0;
      }
   }

   ast_test_status_update(test, "Cancelling failsafe thread.\n");
   pthread_cancel(failsafe_tid);
   pthread_kill(failsafe_tid, SIGURG);
   pthread_join(failsafe_tid, NULL);
#endif

   pfd[0].fd = fd[0];
   pfd[1].fd = fd[1];
   pfd[2].fd = rdblocker[0];
#if FDNO > 3
   pfd[3].fd = wrblocker[1];
#endif

   /* Need to ensure the infinite timeout doesn't stall the process */
   ast_test_status_update(test, "Starting thread to ensure we don't block forever\n");
   if (ast_pthread_create_background(&failsafe_tid, NULL, failsafe_cancel, (void *) (long) pthread_self())) {
      ast_test_status_update(test, "Unable to start failsafe thread\n");
      close(fd[0]);
      close(fd[1]);
      close(rdblocker[0]);
      close(rdblocker[1]);
#if FDNO > 3
      close(wrblocker[0]);
      close(wrblocker[1]);
#endif
      return AST_TEST_FAIL;
   }

   RESET;
   if ((res2 = ast_poll(pfd, FDNO, -1)) != 2) {
      ast_test_status_update(test, "ast_poll does not return that only two handles are available (inf timeout): %d, %s\n", res2, res2 == -1 ? strerror(errno) : "");
      res = AST_TEST_FAIL;
   }

   RESET;
   if ((res2 = ast_poll2(pfd, FDNO, NULL)) != 2) {
      ast_test_status_update(test, "ast_poll2 does not return that only two handles are available (inf timeout): %d %s\n", res2, res2 == -1 ? strerror(errno) : "");
      res = AST_TEST_FAIL;
   }

   ast_test_status_update(test, "Cancelling failsafe thread.\n");
   pthread_cancel(failsafe_tid);
   pthread_kill(failsafe_tid, SIGURG);
   pthread_join(failsafe_tid, NULL);

   RESET;
   if (ast_poll(pfd, FDNO, 0) != 2) {
      ast_test_status_update(test, "ast_poll does not return that only two handles are available (0 timeout): %d, %s\n", res2, res2 == -1 ? strerror(errno) : "");
      res = AST_TEST_FAIL;
   }

   RESET;
   if (ast_poll2(pfd, FDNO, &tv) != 2) {
      ast_test_status_update(test, "ast_poll2 does not return that only two handles are available (0 timeout): %d, %s\n", res2, res2 == -1 ? strerror(errno) : "");
      res = AST_TEST_FAIL;
   }

   RESET;
   if (ast_poll(pfd, FDNO, 1) != 2) {
      ast_test_status_update(test, "ast_poll does not return that only two handles are available (1ms timeout): %d, %s\n", res2, res2 == -1 ? strerror(errno) : "");
      res = AST_TEST_FAIL;
   }

   tv.tv_usec = 1000;
   if (ast_poll2(pfd, FDNO, &tv) != 2) {
      ast_test_status_update(test, "ast_poll2 does not return that only two handles are available (1ms timeout): %d, %s\n", res2, res2 == -1 ? strerror(errno) : "");
      res = AST_TEST_FAIL;
   }

   close(fd[0]);
   close(fd[1]);
   close(rdblocker[0]);
   close(rdblocker[1]);
#if FDNO > 3
   close(wrblocker[0]);
   close(wrblocker[1]);
#endif
   return res;
}

failsafe_cancel()

static void* failsafe_cancel ( void *  vparent )

static

Definition at line 47 of file test_poll.c.

References NULL.

Referenced by AST_TEST_DEFINE().

{
   pthread_t parent = (pthread_t) (long) vparent;

   sleep(1);
   pthread_testcancel();
   pthread_kill(parent, SIGURG);
   sleep(1);
   pthread_testcancel();
   pthread_kill(parent, SIGURG);
   sleep(1);
   pthread_testcancel();
   pthread_kill(parent, SIGURG);
   pthread_exit(NULL);
}

load_module()

static int load_module ( void  )

static

Definition at line 240 of file test_poll.c.

References AST_MODULE_LOAD_SUCCESS, and AST_TEST_REGISTER.

{
   AST_TEST_REGISTER(poll_test);
   return AST_MODULE_LOAD_SUCCESS;
}

unload_module()

static int unload_module ( void  )

static

Definition at line 234 of file test_poll.c.

References AST_TEST_UNREGISTER.

{
   AST_TEST_UNREGISTER(poll_test);
   return 0;
}

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Poll test" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_DEFAULT, .support_level = AST_MODULE_SUPPORT_CORE, }

static

Definition at line 246 of file test_poll.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 246 of file test_poll.c.