Return to evrpc-internal.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / libevent

Annotation of embedaddon/libevent/evrpc-internal.h, revision 1.1.1.1

1.1       misho       1: /*
                      2:  * Copyright (c) 2006 Niels Provos <provos@citi.umich.edu>
                      3:  * All rights reserved.
                      4:  *
                      5:  * Redistribution and use in source and binary forms, with or without
                      6:  * modification, are permitted provided that the following conditions
                      7:  * are met:
                      8:  * 1. Redistributions of source code must retain the above copyright
                      9:  *    notice, this list of conditions and the following disclaimer.
                     10:  * 2. Redistributions in binary form must reproduce the above copyright
                     11:  *    notice, this list of conditions and the following disclaimer in the
                     12:  *    documentation and/or other materials provided with the distribution.
                     13:  * 3. The name of the author may not be used to endorse or promote products
                     14:  *    derived from this software without specific prior written permission.
                     15:  *
                     16:  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
                     17:  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
                     18:  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
                     19:  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
                     20:  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
                     21:  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
                     22:  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
                     23:  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
                     24:  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
                     25:  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
                     26:  */
                     27: #ifndef _EVRPC_INTERNAL_H_
                     28: #define _EVRPC_INTERNAL_H_
                     29: 
                     30: #include "http-internal.h"
                     31: 
                     32: struct evrpc;
                     33: 
                     34: #define EVRPC_URI_PREFIX "/.rpc."
                     35: 
                     36: struct evrpc_hook {
                     37:        TAILQ_ENTRY(evrpc_hook) (next);
                     38: 
                     39:        /* returns -1; if the rpc should be aborted, is allowed to rewrite */
                     40:        int (*process)(struct evhttp_request *, struct evbuffer *, void *);
                     41:        void *process_arg;
                     42: };
                     43: 
                     44: TAILQ_HEAD(evrpc_hook_list, evrpc_hook);
                     45: 
                     46: /*
                     47:  * this is shared between the base and the pool, so that we can reuse
                     48:  * the hook adding functions; we alias both evrpc_pool and evrpc_base
                     49:  * to this common structure.
                     50:  */
                     51: struct _evrpc_hooks {
                     52:        /* hooks for processing outbound and inbound rpcs */
                     53:        struct evrpc_hook_list in_hooks;
                     54:        struct evrpc_hook_list out_hooks;
                     55: };
                     56: 
                     57: #define input_hooks common.in_hooks
                     58: #define output_hooks common.out_hooks
                     59: 
                     60: struct evrpc_base {
                     61:        struct _evrpc_hooks common;
                     62: 
                     63:        /* the HTTP server under which we register our RPC calls */
                     64:        struct evhttp* http_server;
                     65: 
                     66:        /* a list of all RPCs registered with us */
                     67:        TAILQ_HEAD(evrpc_list, evrpc) registered_rpcs;
                     68: };
                     69: 
                     70: struct evrpc_req_generic;
                     71: void evrpc_reqstate_free(struct evrpc_req_generic* rpc_state);
                     72: 
                     73: /* A pool for holding evhttp_connection objects */
                     74: struct evrpc_pool {
                     75:        struct _evrpc_hooks common;
                     76: 
                     77:        struct event_base *base;
                     78: 
                     79:        struct evconq connections;
                     80: 
                     81:        int timeout;
                     82: 
                     83:        TAILQ_HEAD(evrpc_requestq, evrpc_request_wrapper) requests;
                     84: };
                     85: 
                     86: 
                     87: #endif /* _EVRPC_INTERNAL_H_ */