Enduro/X Master/​libnstd/​sys_epoll.c	Source navigation Diff markup Identifier search General search
	Latest: Master Revert   Change

 /**
  * @brief Epoll Abstraction Layer (EAL)
  *
  * @file sys_epoll.c
  */
 /* -----------------------------------------------------------------------------
  * Enduro/X Middleware Platform for Distributed Transaction Processing
  * Copyright (C) 2009-2016, ATR Baltic, Ltd. All Rights Reserved.
  * Copyright (C) 2017-2023, Mavimax, Ltd. All Rights Reserved.
  * This software is released under one of the following licenses:
  * AGPL (with Java and Go exceptions) or Mavimax's license for commercial use.
  * See LICENSE file for full text.
  * -----------------------------------------------------------------------------
  * AGPL license:
  *
  * This program is free software; you can redistribute it and/or modify it under
  * the terms of the GNU Affero General Public License, version 3 as published
  * by the Free Software Foundation;
  *
  * This program is distributed in the hope that it will be useful, but WITHOUT ANY
  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
  * PARTICULAR PURPOSE. See the GNU Affero General Public License, version 3
  * for more details.
  *
  * You should have received a copy of the GNU Affero General Public License along 
  * with this program; if not, write to the Free Software Foundation, Inc.,
  * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  *
  * -----------------------------------------------------------------------------
  * A commercial use license is available from Mavimax, Ltd
  * contact@mavimax.com
  * -----------------------------------------------------------------------------
  */
 
 /*---------------------------Includes-----------------------------------*/
 #include <stdio.h>
 #include <stdlib.h>
 #include <time.h>
 
 #include <unistd.h>
 #include <stdarg.h>
 #include <ctype.h>
 #include <memory.h>
 #include <errno.h>
 #include <signal.h>
 #include <limits.h>
 #include <pthread.h>
 #include <string.h>
 
 #include <ndrstandard.h>
 #include <ndebug.h>
 #include <nstdutil.h>
 #include <limits.h>
 
 #include <sys_unix.h>
 #include <sys/epoll.h>
 
 
 /*---------------------------Externs------------------------------------*/
 /*---------------------------Macros-------------------------------------*/
 /*---------------------------Enums--------------------------------------*/
 /*---------------------------Typedefs-----------------------------------*/
 /*---------------------------Globals------------------------------------*/
 /*---------------------------Statics------------------------------------*/
 /*---------------------------Prototypes---------------------------------*/
 
 /**
  * not used by Linux epoll()
  * @param idx
  * @return 
  */
 expublic int ndrx_epoll_shallopenq(int idx)
 {
     return EXTRUE;
 }
 /**
  * Not used by Linux epoll()
  * @param qstr
  */
 expublic void ndrx_epoll_mainq_set(char *qstr)
 {
     return;
 }
 /**
  * Nothing to init for epoll()
  */
 expublic int ndrx_epoll_sys_init(void)
 {
     return EXSUCCEED;
 }
 
 /**
  * Not used by Linux epoll
  * @param svcnm
  * @param idx
  * @param mq_exits
  * @return 
  */
 expublic mqd_t ndrx_epoll_service_add(char *svcnm, int idx, mqd_t mq_exits)
 {
     return mq_exits;
 }
 
 /**
  * Not used by linux epoll
  * @return 
  */
 expublic int ndrx_epoll_shmdetach(void)
 {
     return EXSUCCEED;
 }
 
 /**
  * Not used by Linux epoll
  * @param force
  * @return 
  */
 expublic int ndrx_epoll_down(int force)
 {
     return EXSUCCEED;
 }
 
 /**
  * Nothing to un-init for epoll()
  */
 expublic void ndrx_epoll_sys_uninit(void)
 {
     return;
 }
 
 /**
  * Return the compiled poll mode
  * @return 
  */
 expublic char * ndrx_epoll_mode(void)
 {
     static char *mode = "epoll";
     
     return mode;
 }
 
 /**
  * Wrapper for epoll_ctl, for standard file descriptors
  * @param epfd
  * @param op
  * @param fd
  * @param event
  * @return 
  */
 expublic inline int ndrx_epoll_ctl(int epfd, int op, int fd, struct ndrx_epoll_event *event)
 {
     return epoll_ctl(epfd, op, fd, (struct epoll_event *) event);
 }
 
 /**
  * epoll_ctl for Posix queue descriptors
  * @param epfd
  * @param op
  * @param fd
  * @param event
  * @return 
  */
 expublic inline int ndrx_epoll_ctl_mq(int epfd, int op, mqd_t fd, struct ndrx_epoll_event *event)
 {
     return epoll_ctl(epfd, op, fd, (struct epoll_event *) event);
 }
 
 /**
  * Wrapper for epoll_create
  * @param size
  * @return 
  */
 expublic inline int ndrx_epoll_create(int size)
 {
     return epoll_create(size);
 }
 
 /**
  * Close Epoll set.
  */
 expublic inline int ndrx_epoll_close(int fd)
 {
     return close(fd);
 }
 
 /**
  * Wrapper for epoll_wait
  * @param epfd
  * @param events
  * @param maxevents
  * @param timeout
  * @return 
  */
 expublic inline int ndrx_epoll_wait(int epfd, struct ndrx_epoll_event *events, 
         int maxevents, int timeout, char **buf, int *buf_len)
 {
     *buf_len = EXFAIL;
     return epoll_wait(epfd, (struct epoll_event *) events, maxevents, timeout);
 }
 
 /**
  * Return errno for ndrx_poll() operation
  * @return 
  */
 expublic inline int ndrx_epoll_errno(void)
 {
     return errno;
 }
 
 /**
  * Wrapper for strerror
  * @param err
  * @return 
  */
 expublic inline char * ndrx_poll_strerror(int err)
 {
     return strerror(err);
 }
 
 /* vim: set ts=4 sw=4 et smartindent: */

This page was automatically generated by the 2.1.0 LXR engine. The LXR team