Sat, 04 Feb 2017 16:42:11 +0100
refactors kqueue event handler
/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright 2013 Olaf Wintermann. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. */ #include <stdlib.h> #include <ucx/map.h> #include "../public/nsapi.h" #include "../util/pblock.h" #include "func.h" UcxMap *function_map; void func_init() { function_map = ucx_map_new(1337); } void add_function(FuncStruct *func) { struct FuncStruct *f = malloc(sizeof(FuncStruct)); *f = *func; char *name = strdup(func->name); for(int i=0;name[i]!='\0';i++) { if(name[i] == '_') { name[i] = '-'; } } f->name = name; log_ereport(LOG_VERBOSE, "add_function %s", f->name); ucx_map_cstr_put(function_map, (char*)f->name, f); } void add_functions(FuncStruct *funcs) { int i = 0; while(funcs[i].func != NULL) { add_function(&funcs[i]); i++; } } FuncStruct* get_function(char *name) { for(int i=0;name[i]!='\0';i++) { if(name[i] == '_') { name[i] = '-'; } } return ucx_map_cstr_get(function_map, name); } FuncStruct* func_resolve(pblock *pb, Session *sn, Request *rq) { char *name = pblock_findkeyval(pb_key_fn, pb); if(name == NULL) { // TODO: error return NULL; } FuncStruct *func = get_function(name); if(func == NULL) { // TODO: error } return func; } int func_exec(pblock *pb, Session *sn, Request *rq) { FuncStruct *func = func_resolve(pb, sn, rq); if(func == NULL) { return REQ_ABORTED; } return func->func(pb, sn, rq); } // public API struct FuncStruct func_insert(char *name, FuncPtr fn) { struct FuncStruct fc; ZERO(&fc, sizeof(FuncStruct)); fc.func = fn; fc.name = strdup(name); add_function(&fc); return *get_function(name); }