OLD | NEW |
| (Empty) |
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_ */ | |
OLD | NEW |