lxrc.h

/*
 *     ____             _________                __                _     
 *    / __ \___  ____ _/ /_  __(_)___ ___  ___  / /   ____  ____ _(_)____
 *   / /_/ / _ \/ __ `/ / / / / / __ `__ \/ _ \/ /   / __ \/ __ `/ / ___/
 *  / _, _/  __/ /_/ / / / / / / / / / / /  __/ /___/ /_/ / /_/ / / /__  
 * /_/ |_|\___/\__,_/_/ /_/ /_/_/ /_/ /_/\___/_____/\____/\__, /_/\___/  
 *                                                       /____/          
 *
 *                  Barracuda Application Server
 *
 ****************************************************************************
 *                            HEADER
 *
 *   $Id: lxrc.h 5568 2024-09-14 14:51:10Z wini $
 *
 *   COPYRIGHT:  Real Time Logic, 2023 - 2024
 *               https://realtimelogic.com
 *
 *   The copyright to the program herein is the property of
 *   Real Time Logic. The program may be used or copied only
 *   with the written permission from Real Time Logic or
 *   in accordance with the terms and conditions stipulated in
 *   the agreement under which the program has been supplied.
 ****************************************************************************
 *
 *
 */
#ifndef __lxrc_h
#define __lxrc_h 
 
#ifndef NO_SHARKSSL
#include <SharkSSL.h>
#endif
#include <balua.h>
#include <SoDispCon.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
void balua_forkpty(lua_State* L);
 
void balua_http(lua_State* L);
 
void balua_luaio(lua_State *L);
 
void balua_sharkssl(lua_State *L);
 
void balua_socket(lua_State* L);
 
void balua_relsocket(lua_State* L);
 
void balua_crypto(lua_State *L);
 
struct ThreadJob;
struct LThreadMgr;
 
void balua_tracelogger(lua_State *L, struct LThreadMgr* tmgr);
 
typedef void (*ThreadJob_Run)(struct ThreadJob* tj, struct LThreadMgr* mgr);
 
typedef void (*ThreadJob_LRun)(
   struct ThreadJob* tj, int msgh, struct LThreadMgr* mgr);
 
typedef struct LThreadMgr
{
   HttpCmdThreadPoolIntf super; /* Inherits from HttpCmdThreadPoolIntf */
   DoubleList idleThreadList; 
   DoubleList runningThreadList;
   DoubleList pendingJobList; /* ThreadJob */
   HttpServer* server; 
   lua_State* Lg; 
   int runningThreads; 
   int pendingJobs; 
   int isDynamic; 
   ThreadPriority priority;
   int stackSize;
   int threads; 
} LThreadMgr;
 
 
typedef struct ThreadJob
{
   DoubleLink super;  /* Inherits from DoubleLink */
   ThreadJob_Run run;
   ThreadJob_LRun lrun;
   lua_State* Lt; 
} ThreadJob;
 
#define LThreadMgr_canRun(o) ! DoubleList_isEmpty(&(o)->idleThreadList)
 
#define LThreadMgr_enableHttpPool(o, server)                            \
   HttpServer_setThreadPoolIntf(server, (HttpCmdThreadPoolIntf*)o)
 
BA_API void LThreadMgr_destructor(LThreadMgr* o);
 
BA_API void LThreadMgr_constructor(LThreadMgr* o, HttpServer* server,
   ThreadPriority priority, int stackSize,
   int threads, lua_State* L, int allowCreate);
 
BA_API ThreadJob* ThreadJob_create(size_t size, ThreadJob_Run run);
 
BA_API ThreadJob* ThreadJob_lcreate(size_t size, ThreadJob_LRun lrun);
 
BA_API int LThreadMgr_run(LThreadMgr* o, ThreadJob* tj);
 /* end of ThreadMgr */  
 /* end of AuxLSP */  
 
#ifdef __cplusplus
}
#endif
 
/************************  Private functions ***************************/
 
int lGetStdSockOptions(lua_State* L, int tabIx, const char** intf,
                       BaBool* ipv6, BaBool* secure);
#ifndef NO_SHARKSSL
void lsharkssl_unlock(lua_State *L,SharkSsl* super);
SharkSsl* lsharkssl_lock(
   lua_State *L,int tabIx,SharkSsl_Role role,SharkSsl* lockedShark);
#endif
int pushCertificate(lua_State *L, SoDispCon* con);
int pushCiphers(lua_State *L, SoDispCon* con);
int calcTabSize(lua_State* L, int ix); /* lhttp.c */
struct HttpClientKeyVal;
char* extractTab(const char* tab, lua_State* L, int ix,
                 char* ud, struct HttpClientKeyVal** pkv); /* lhttp.c */
 
#define HTTPCLIENT "HTTPCLIENT"
struct HttpClient;
#define toHttpClient(L,ix) (struct HttpClient*)luaL_checkudata(L,ix,HTTPCLIENT)
 
#define BACERTSTORE "BACERTSTORE"
/* tocs: To SharkSslCertStore -- Certificate Authority
 */
#define toCertStore(L,ix) (SharkSslCertStore*)luaL_checkudata(L,ix,BACERTSTORE) 
 
 
 
#endif