1: /*************************************************************************
2: * (C) 2010 AITNET ltd - Sofia/Bulgaria - <misho@aitbg.com>
3: * by Michael Pounov <misho@openbsd-bg.org>
4: *
5: * $Author: misho $
6: * $Id: builtin.c,v 1.5 2011/11/03 15:32:21 misho Exp $
7: *
8: **************************************************************************
9: The ELWIX and AITNET software is distributed under the following
10: terms:
11:
12: All of the documentation and software included in the ELWIX and AITNET
13: Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>
14:
15: Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011
16: by Michael Pounov <misho@elwix.org>. All rights reserved.
17:
18: Redistribution and use in source and binary forms, with or without
19: modification, are permitted provided that the following conditions
20: are met:
21: 1. Redistributions of source code must retain the above copyright
22: notice, this list of conditions and the following disclaimer.
23: 2. Redistributions in binary form must reproduce the above copyright
24: notice, this list of conditions and the following disclaimer in the
25: documentation and/or other materials provided with the distribution.
26: 3. All advertising materials mentioning features or use of this software
27: must display the following acknowledgement:
28: This product includes software developed by Michael Pounov <misho@elwix.org>
29: ELWIX - Embedded LightWeight unIX and its contributors.
30: 4. Neither the name of AITNET nor the names of its contributors
31: may be used to endorse or promote products derived from this software
32: without specific prior written permission.
33:
34: THIS SOFTWARE IS PROVIDED BY AITNET AND CONTRIBUTORS ``AS IS'' AND
35: ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
36: IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
37: ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
38: FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
39: DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
40: OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
41: HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
42: LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
43: OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
44: SUCH DAMAGE.
45: */
46: #include "global.h"
47:
48:
49: /* builtin RPC server functions */
50:
51: int
52: rpcServerClients(rpc_func_t *call, int ic, array_t *iv)
53: {
54: rpc_srv_t *srv;
55: array_t *vals;
56: rpc_cli_t *cli;
57: register int i;
58: int len;
59: const char *str = NULL;
60: char *val, wrk[INET6_ADDRSTRLEN];
61:
62: RPC_CALLBACK_CHECK_INPUT(call);
63: if (!call->func_parent)
64: return -1;
65: else
66: srv = call->func_parent;
67:
68: rpc_srv_getVars(call, &vals);
69:
70: len = srv->srv_numcli * STRSIZ;
71: if (!(val = malloc(len))) {
72: LOGERR;
73: return -1;
74: } else
75: memset(val, 0, len);
76:
77: for (i = 0, cli = srv->srv_clients; i < srv->srv_numcli; i++, cli++) {
78: if (!cli->cli_sa.sa.sa_family)
79: continue;
80:
81: switch (cli->cli_sa.sa.sa_family) {
82: case AF_INET:
83: str = inet_ntop(cli->cli_sa.sa.sa_family, &cli->cli_sa.sin.sin_addr, wrk, sizeof wrk);
84: break;
85: case AF_INET6:
86: str = inet_ntop(cli->cli_sa.sa.sa_family, &cli->cli_sa.sin6.sin6_addr, wrk, sizeof wrk);
87: break;
88: case AF_LOCAL:
89: str = cli->cli_sa.sun.sun_path;
90: break;
91: }
92: if (str)
93: strlcat(val, (char*) str, len);
94: else
95: strlcat(val, "0.0.0.0", len);
96: strlcat(val, " ", len);
97: }
98:
99: AIT_SET_STR(io_array(vals, 0, ait_val_t*), val);
100: free(val);
101: return 0;
102: }
103:
104: int
105: rpcServerCalls(rpc_func_t *call, int ic, array_t *iv)
106: {
107: rpc_srv_t *srv;
108: array_t *vals;
109: rpc_func_t *f;
110: register int i;
111: int len;
112: char *val, str[MAXPATHLEN];
113:
114: RPC_CALLBACK_CHECK_INPUT(call);
115: if (!call->func_parent)
116: return -1;
117: else
118: srv = call->func_parent;
119:
120: for (i = 0, f = srv->srv_funcs; f; i++, f = f->func_next);
121: len = i * STRSIZ;
122:
123: rpc_srv_getVars(call, &vals);
124:
125: if (!(val = malloc(len))) {
126: LOGERR;
127: return -1;
128: } else
129: memset(val, 0, len);
130:
131: for (f = srv->srv_funcs, i = 0; f; f = f->func_next) {
132: if (*f->func_name) {
133: memset(str, 0, sizeof str);
134: snprintf(str, sizeof str, "/%s/%s(%d); ",
135: *f->func_file ? f->func_file : "*",
136: f->func_name, io_arraySize(f->func_vars));
137: strlcat(val, str, len);
138: }
139: }
140:
141: AIT_SET_STR(io_array(vals, 0, ait_val_t*), val);
142: free(val);
143: return 0;
144: }
145:
146: int
147: rpcServerSessions(rpc_func_t *call, int ic, array_t *iv)
148: {
149: rpc_srv_t *srv;
150: array_t *vals;
151: ait_val_t *v;
152:
153: RPC_CALLBACK_CHECK_INPUT(call);
154: if (!call->func_parent)
155: return -1;
156: else
157: srv = call->func_parent;
158:
159: rpc_srv_getVars(call, &vals);
160:
161: v = io_array(vals, 0, ait_val_t*);
162: AIT_SET_U8(v, srv->srv_session.sess_version);
163: v = io_array(vals, 1, ait_val_t*);
164: AIT_SET_U32(v, srv->srv_session.sess_program);
165: v = io_array(vals, 2, ait_val_t*);
166: AIT_SET_U32(v, srv->srv_session.sess_process);
167: v = io_array(vals, 3, ait_val_t*);
168: AIT_SET_I32(v, srv->srv_numcli);
169:
170: return 0;
171: }
172:
173: int
174: rpcServerShutdown(rpc_func_t *call, int ic, array_t *iv)
175: {
176: rpc_srv_t *srv;
177:
178: RPC_CALLBACK_CHECK_INPUT(call);
179: if (!call->func_parent)
180: return -1;
181: else
182: srv = call->func_parent;
183:
184: pthread_mutex_lock(&srv->srv_mtx);
185: srv->srv_kill = kill;
186: pthread_mutex_unlock(&srv->srv_mtx);
187:
188: return 0;
189: }
190:
191: // ----------------------------------------------------
192:
193: int
194: rpcBLOBServerShutdown(rpc_func_t *call, int ic, array_t *iv)
195: {
196: rpc_srv_t *srv;
197:
198: RPC_CALLBACK_CHECK_INPUT(call);
199: if (!call->func_parent)
200: return -1;
201: else
202: srv = call->func_parent;
203:
204: pthread_mutex_lock(&srv->srv_blob.mtx);
205: srv->srv_blob.state = kill;
206: pthread_mutex_unlock(&srv->srv_blob.mtx);
207:
208: return 0;
209: }
210:
211: int
212: rpcBLOBServerVars(rpc_func_t *call, int ic, array_t *iv)
213: {
214: rpc_srv_t *srv;
215: array_t *vals;
216: rpc_blob_t *b;
217: register int i;
218: char *val, str[64];
219: int len;
220:
221: RPC_CALLBACK_CHECK_INPUT(call);
222: if (!call->func_parent)
223: return -1;
224: else
225: srv = call->func_parent;
226:
227: rpc_srv_getVars(call, &vals);
228:
229: if (srv->srv_blob.state == kill) {
230: AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is killed");
231: return 1;
232: }
233: if (srv->srv_blob.state == disable) {
234: AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is disabled");
235: return 1;
236: }
237:
238: pthread_mutex_lock(&srv->srv_blob.mtx);
239: for (i = 0, b = srv->srv_blob.blobs; b; i++, b = b->blob_next);
240: len = i * sizeof str;
241:
242: if (!len) {
243: AIT_SET_STR(io_array(vals, 0, ait_val_t*), "");
244: pthread_mutex_unlock(&srv->srv_blob.mtx);
245: return 0;
246: }
247:
248: if (!(val = malloc(len))) {
249: LOGERR;
250: pthread_mutex_unlock(&srv->srv_blob.mtx);
251: return -1;
252: } else
253: memset(val, 0, len);
254:
255: for (b = srv->srv_blob.blobs, i = 0; b; i++, b = b->blob_next) {
256: memset(str, 0, sizeof str);
257: snprintf(str, sizeof str, "0x%0X(%lu)=%p ", b->blob_var, (u_long) b->blob_len, b->blob_data);
258: strlcat(val, str, len);
259: }
260:
261: AIT_SET_STR(io_array(vals, 0, ait_val_t*), val);
262: free(val);
263: pthread_mutex_unlock(&srv->srv_blob.mtx);
264: return 0;
265: }
266:
267: int
268: rpcBLOBServerState(rpc_func_t *call, int ic, array_t *iv)
269: {
270: rpc_srv_t *srv;
271:
272: RPC_CALLBACK_CHK_ARGS(call, ic);
273: if (!call->func_parent)
274: return -1;
275: else
276: srv = call->func_parent;
277:
278: if (AIT_TYPE(io_array(iv, 0, ait_val_t*)) != i32)
279: return -1;
280:
281: pthread_mutex_lock(&srv->srv_mtx);
282: srv->srv_blob.state = AIT_GET_I32(io_array(iv, 0, ait_val_t*));
283: pthread_mutex_unlock(&srv->srv_mtx);
284: return 0;
285: }
286:
287: int
288: rpcBLOBServerClients(rpc_func_t *call, int ic, array_t *iv)
289: {
290: rpc_srv_t *srv;
291: array_t *vals;
292: rpc_cli_t *cli;
293: register int i;
294: int len;
295: const char *str = NULL;
296: char *val, wrk[INET6_ADDRSTRLEN];
297:
298: RPC_CALLBACK_CHECK_INPUT(call);
299: if (!call->func_parent)
300: return -1;
301: else
302: srv = call->func_parent;
303:
304: rpc_srv_getVars(call, &vals);
305:
306: if (srv->srv_blob.state == kill) {
307: AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is killed");
308: return 1;
309: }
310: if (srv->srv_blob.state == disable) {
311: AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is disabled");
312: return 1;
313: }
314:
315: len = srv->srv_numcli * STRSIZ;
316: if (!(val = malloc(len))) {
317: LOGERR;
318: return -1;
319: } else
320: memset(val, 0, len);
321:
322: for (i = 0, cli = srv->srv_blob.clients; i < srv->srv_numcli; i++, cli++) {
323: if (!cli->cli_sa.sa.sa_family)
324: continue;
325:
326: switch (cli->cli_sa.sa.sa_family) {
327: case AF_INET:
328: str = inet_ntop(cli->cli_sa.sa.sa_family, &cli->cli_sa.sin.sin_addr, wrk, sizeof wrk);
329: break;
330: case AF_INET6:
331: str = inet_ntop(cli->cli_sa.sa.sa_family, &cli->cli_sa.sin6.sin6_addr, wrk, sizeof wrk);
332: break;
333: case AF_LOCAL:
334: str = cli->cli_sa.sun.sun_path;
335: break;
336: }
337: if (str)
338: strlcat(val, (char*) str, len);
339: else
340: strlcat(val, "0.0.0.0", len);
341: strlcat(val, " ", len);
342: }
343:
344: AIT_SET_STR(io_array(vals, 0, ait_val_t*), val);
345: free(val);
346: return 0;
347: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to builtin.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src