aboutsummaryrefslogtreecommitdiffstats
path: root/src/nSocket/nstack/event/select/select_adapt.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/nSocket/nstack/event/select/select_adapt.c')
-rw-r--r--src/nSocket/nstack/event/select/select_adapt.c301
1 files changed, 93 insertions, 208 deletions
diff --git a/src/nSocket/nstack/event/select/select_adapt.c b/src/nSocket/nstack/event/select/select_adapt.c
index a9858e8..f61d7c1 100644
--- a/src/nSocket/nstack/event/select/select_adapt.c
+++ b/src/nSocket/nstack/event/select/select_adapt.c
@@ -26,314 +26,199 @@
/*==============================================*
* project-wide global variables *
*----------------------------------------------*/
-i32 nstack_mod_fd[NSTACK_MAX_MODULE_NUM][NSTACK_SELECT_MAX_FD];
struct select_fd_map_inf g_select_fd_map;
/*==============================================*
* routines' or functions' implementations *
*----------------------------------------------*/
-/*****************************************************************************
-* Prototype : select_alloc
-* Description : select_alloc
-* Input : int size
-* Output : None
-* Return Value : void *
-* Calls :
-* Called By :
-*****************************************************************************/
-void *
-select_alloc (int size)
+void *select_alloc(int size)
{
- char *p;
- if (size <= 0)
+ char *p;
+ if (size <= 0)
{
- return NULL;
+ return NULL;
}
- p = malloc (size);
- if (!p)
+ p = malloc(size);
+ if (!p)
{
- return NULL;
+ return NULL;
}
- if (EOK != MEMSET_S (p, size, 0, size))
+ if (EOK != memset_s(p, size, 0, size))
{
- free (p);
- p = NULL;
+ free(p);
+ p = NULL;
}
- return p;
+ return p;
}
-/*****************************************************************************
-* Prototype : select_free
-* Description : select_free
-* Input : char *p
-* Output : None
-* Return Value : void
-* Calls :
-* Called By :
-*****************************************************************************/
-void
-select_free (char *p)
+/*point is set to NULL because it's freeed */
+void select_free(void *p)
{
- if (p)
+ if (p)
{
- free (p);
- p = NULL;
+ free(p);
+ p = NULL;
}
}
-/*****************************************************************************
-* Prototype : get_select_fdinf
-* Description : get_select_fdinf
-* Input : i32 fd
-* Output : None
-* Return Value : struct select_comm_fd_map *
-* Calls :
-* Called By :
-*****************************************************************************/
-struct select_comm_fd_map *
-get_select_fdinf (i32 fd)
+struct select_comm_fd_map *get_select_fdinf(i32 fd)
{
- if ((fd < 0) || (fd >= NSTACK_SELECT_MAX_FD))
+ if ((fd < 0) || ((u32) fd >= NSTACK_SELECT_MAX_FD))
{
- return NULL;
+ return NULL;
}
- return (&g_select_fd_map.fdinf[fd]);
+ return (&g_select_fd_map.fdinf[fd]);
}
-/*****************************************************************************
-* Prototype : reset_select_fdinf
-* Description : reset_select_fdinf
-* Input : i32 fd
-* Output : None
-* Return Value : void
-* Calls :
-* Called By :
-*****************************************************************************/
-void
-reset_select_fdinf (i32 fd)
+void reset_select_fdinf(i32 fd)
{
- i32 i;
- struct select_comm_fd_map *fdinf = get_select_fdinf (fd);
- if (NULL == fdinf)
+ i32 i;
+ struct select_comm_fd_map *fdinf = get_select_fdinf(fd);
+ /* fdinf is possible is null */
+ if (NULL == fdinf)
{
- return;
+ return;
}
- fdinf->index = -1;
- for (i = 0; i < NSTACK_MAX_MODULE_NUM; i++)
+ fdinf->index = -1;
+ for (i = 0; i < NSTACK_MAX_MODULE_NUM; i++)
{
- fdinf->mod_fd[i] = -1;
+ fdinf->mod_fd[i] = -1;
}
}
-/*****************************************************************************
-* Prototype : select_get_modfd
-* Description : select_get_modfd
-* Input : i32 fd
-* i32 inx
-* Output : None
-* Return Value : i32
-* Calls :
-* Called By :
-*****************************************************************************/
-i32
-select_get_modfd (i32 fd, i32 inx)
+i32 select_get_modfd(i32 fd, i32 inx)
{
- if ((fd < 0) || (fd >= NSTACK_SELECT_MAX_FD))
+ if ((fd < 0) || ((u32) fd >= NSTACK_SELECT_MAX_FD))
{
- return -1;
+ return -1;
}
- if ((inx < 0))
+ if ((inx < 0))
{
- return -1;
+ return -1;
}
- if (!g_select_fd_map.fdinf)
+ if (!g_select_fd_map.fdinf)
{
- return FALSE;
+ return FALSE;
}
- return (g_select_fd_map.fdinf[fd].mod_fd[inx]);
+ return (g_select_fd_map.fdinf[fd].mod_fd[inx]);
}
-/*****************************************************************************
-* Prototype : select_set_modfd
-* Description : select_set_modfd
-* Input : i32 fd
-* i32 inx
-* i32 modfd
-* Output : None
-* Return Value : i32
-* Calls :
-* Called By :
-*****************************************************************************/
-i32
-select_set_modfd (i32 fd, i32 inx, i32 modfd)
+i32 select_set_modfd(i32 fd, i32 inx, i32 modfd)
{
- if ((fd < 0) || (fd >= NSTACK_SELECT_MAX_FD))
+ if ((fd < 0) || ((u32) fd >= NSTACK_SELECT_MAX_FD))
{
- return -1;
+ return -1;
}
- if (!g_select_fd_map.fdinf)
+ if (!g_select_fd_map.fdinf)
{
- return FALSE;
+ return FALSE;
}
- g_select_fd_map.fdinf[fd].mod_fd[inx] = modfd;
+ g_select_fd_map.fdinf[fd].mod_fd[inx] = modfd;
- return TRUE;
+ return TRUE;
}
-/*****************************************************************************
-* Prototype : select_get_modindex
-* Description : select_get_modindex
-* Input : i32 fd
-* Output : None
-* Return Value : i32
-* Calls :
-* Called By :
-*****************************************************************************/
-i32
-select_get_modindex (i32 fd)
+i32 select_get_modindex(i32 fd)
{
- if ((fd < 0) || (fd >= NSTACK_SELECT_MAX_FD))
+ if ((fd < 0) || ((u32) fd >= NSTACK_SELECT_MAX_FD))
{
- return -1;
+ return -1;
}
- return g_select_fd_map.fdinf[fd].index;
+ return g_select_fd_map.fdinf[fd].index;
}
-/*****************************************************************************
-* Prototype : select_get_commfd
-* Description : select_get_commfd
-* Input : i32 modfd
-* i32 inx
-* Output : None
-* Return Value : i32
-* Calls :
-* Called By :
-*****************************************************************************/
-i32
-select_get_commfd (i32 modfd, i32 inx)
+i32 select_get_commfd(i32 modfd, i32 inx)
{
- if ((modfd < 0) || (modfd >= NSTACK_SELECT_MAX_FD))
+ if ((modfd < 0) || ((u32) modfd >= NSTACK_SELECT_MAX_FD))
{
- return -1;
+ return -1;
}
- return g_select_fd_map.modinf[inx].comm_fd[modfd];
+ return g_select_fd_map.modinf[inx].comm_fd[modfd];
}
-/*****************************************************************************
-* Prototype : select_set_commfd
-* Description : select_set_commfd
-* Input : i32 modfd
-* i32 inx
-* i32 fd
-* Output : None
-* Return Value : i32
-* Calls :
-* Called By :
-*****************************************************************************/
-i32
-select_set_commfd (i32 modfd, i32 inx, i32 fd)
+i32 select_set_commfd(i32 modfd, i32 inx, i32 fd)
{
- if ((modfd < 0) || (modfd >= NSTACK_SELECT_MAX_FD))
+ if ((modfd < 0) || ((u32) modfd >= NSTACK_SELECT_MAX_FD))
{
- return -1;
+ return -1;
}
- if (!g_select_fd_map.modinf[inx].comm_fd)
+ if (!g_select_fd_map.modinf[inx].comm_fd)
{
- return FALSE;
+ return FALSE;
}
- g_select_fd_map.modinf[inx].comm_fd[modfd] = fd;
+ g_select_fd_map.modinf[inx].comm_fd[modfd] = fd;
- return TRUE;
+ return TRUE;
}
-/*****************************************************************************
-* Prototype : select_set_index
-* Description : select_set_index
-* Input : i32 fd
-* i32 inx
-* Output : None
-* Return Value : i32
-* Calls :
-* Called By :
-*****************************************************************************/
-i32
-select_set_index (i32 fd, i32 inx)
+i32 select_set_index(i32 fd, i32 inx)
{
- if ((fd < 0) || (fd >= NSTACK_SELECT_MAX_FD))
+ if ((fd < 0) || ((u32) fd >= NSTACK_SELECT_MAX_FD))
{
- return -1;
+ return -1;
}
- if (!g_select_fd_map.fdinf)
+ if (!g_select_fd_map.fdinf)
{
- return FALSE;
+ return FALSE;
}
- g_select_fd_map.fdinf[fd].index = inx;
- return TRUE;
+ g_select_fd_map.fdinf[fd].index = inx;
+ return TRUE;
}
-/*****************************************************************************
-* Prototype : fdmapping_init
-* Description : fdmapping_init
-* Input : void
-* Output : None
-* Return Value : i32
-* Calls :
-* Called By :
-*****************************************************************************/
-i32
-fdmapping_init (void)
+i32 fdmapping_init(void)
{
- int ret = FALSE;
- int i, inx;
+ int ret = FALSE;
+ int i, inx;
- g_select_fd_map.fdinf =
- (struct select_comm_fd_map *)
- select_alloc (sizeof (struct select_comm_fd_map) * NSTACK_SELECT_MAX_FD);
- if (NULL == g_select_fd_map.fdinf)
+ g_select_fd_map.fdinf =
+ (struct select_comm_fd_map *)
+ select_alloc(sizeof(struct select_comm_fd_map) *
+ NSTACK_SELECT_MAX_FD);
+ if (NULL == g_select_fd_map.fdinf)
{
- goto err_return;
+ goto err_return;
}
- for (i = 0; i < get_mode_num (); i++)
+ for (i = 0; i < nstack_get_module_num(); i++)
{
- g_select_fd_map.modinf[i].comm_fd =
- (i32 *) select_alloc (sizeof (i32) * NSTACK_SELECT_MAX_FD);
- if (NULL == g_select_fd_map.modinf[i].comm_fd)
+ g_select_fd_map.modinf[i].comm_fd =
+ (i32 *) select_alloc(sizeof(i32) * NSTACK_SELECT_MAX_FD);
+ if (NULL == g_select_fd_map.modinf[i].comm_fd)
{
- goto err_return;
+ goto err_return;
}
}
- for (i = 0; i < NSTACK_SELECT_MAX_FD; i++)
+ u32 fd_idx = 0;
+ for (fd_idx = 0; fd_idx < NSTACK_SELECT_MAX_FD; fd_idx++)
{
- reset_select_fdinf (i);
+ reset_select_fdinf(fd_idx);
}
- for (inx = 0; inx < get_mode_num (); inx++)
+ for (inx = 0; inx < nstack_get_module_num(); inx++)
{
- for (i = 0; i < NSTACK_SELECT_MAX_FD; i++)
+ for (fd_idx = 0; fd_idx < NSTACK_SELECT_MAX_FD; fd_idx++)
{
- select_set_commfd (i, inx, -1);
-
+ select_set_commfd(fd_idx, inx, -1);
}
}
- ret = TRUE;
- return ret;
-err_return:
+ ret = TRUE;
+ return ret;
+ err_return:
- select_free ((char *) g_select_fd_map.fdinf);
- for (i = 0; i < get_mode_num (); i++)
+ select_free((char *) g_select_fd_map.fdinf);
+ for (i = 0; i < nstack_get_module_num(); i++)
{
- select_free ((char *) g_select_fd_map.modinf[i].comm_fd);
+ select_free((char *) g_select_fd_map.modinf[i].comm_fd);
}
- return ret;
+ return ret;
}