Return to builtin.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src

Annotation of libaitrpc/src/builtin.c, revision 1.1

1.1     ! misho       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: aitcli.c,v 1.2.2.17 2010/06/09 09:32:30 misho Exp $
        !             7: *
        !             8: *************************************************************************/
        !             9: #include "global.h"
        !            10: 
        !            11: 
        !            12: /* builtin RPC server functions */
        !            13: 
        !            14: int
        !            15: rpcServerClients(rpc_srv_t * __restrict srv, rpc_func_t *call, int ic, rpc_val_t *iv)
        !            16: {
        !            17:        rpc_val_t *v, *vals = NULL;
        !            18:        rpc_cli_t *cli;
        !            19:        register int i;
        !            20:        const char *str;
        !            21:        char wrk[INET6_ADDRSTRLEN];
        !            22:        struct sockaddr_in *s;
        !            23:        struct sockaddr_in6 *s6;
        !            24: 
        !            25:        if (!srv || !call) {
        !            26:                rpc_SetErr(EINVAL, "Error:: invalid parameters ...\n");
        !            27:                return -1;
        !            28:        }
        !            29:        if (rpc_srv_declValsCall(call, srv->srv_numcli) == -1)
        !            30:                return -1;
        !            31:        else
        !            32:                rpc_srv_delValsCall(call);
        !            33:        if (rpc_srv_getValsCall(call, &vals) == -1)
        !            34:                return -1;
        !            35: 
        !            36:        for (i = 0, cli = srv->srv_clients, v = vals; i < srv->srv_numcli; cli++) {
        !            37:                if (!cli->cli_sa.sa_family)
        !            38:                        continue;
        !            39: 
        !            40:                if (AF_INET == cli->cli_sa.sa_family) {
        !            41:                        s = (struct sockaddr_in*) &cli->cli_sa;
        !            42:                        str = inet_ntop(cli->cli_sa.sa_family, &s->sin_addr, wrk, sizeof wrk);
        !            43:                } else {
        !            44:                        s6 = (struct sockaddr_in6*) &cli->cli_sa;
        !            45:                        str = inet_ntop(cli->cli_sa.sa_family, &s6->sin6_addr, wrk, sizeof wrk);
        !            46:                }
        !            47:                if (str) {
        !            48:                        RPC_SET_STR(v++, (char*) str);
        !            49:                        i++;
        !            50:                }
        !            51:        }
        !            52: 
        !            53:        return 0;
        !            54: }
        !            55: 
        !            56: int
        !            57: rpcServerCalls(rpc_srv_t * __restrict srv, rpc_func_t *call, int ic, rpc_val_t *iv)
        !            58: {
        !            59:        rpc_val_t *v, *vals = NULL;
        !            60:        rpc_func_t *f;
        !            61:        register int i;
        !            62:        char str[MAXPATHLEN];
        !            63: 
        !            64:        if (!srv || !call) {
        !            65:                rpc_SetErr(EINVAL, "Error:: invalid parameters ...\n");
        !            66:                return -1;
        !            67:        }
        !            68: 
        !            69:        for (i = 0, f = srv->srv_funcs; f; i++, f = f->func_next);
        !            70: 
        !            71:        if (rpc_srv_declValsCall(call, i) == -1)
        !            72:                return -1;
        !            73:        else
        !            74:                rpc_srv_delValsCall(call);
        !            75:        if (rpc_srv_getValsCall(call, &vals) == -1)
        !            76:                return -1;
        !            77: 
        !            78:        for (f = srv->srv_funcs, v = vals; f; f = f->func_next) {
        !            79:                if (*f->func_name) {
        !            80:                        memset(str, 0, MAXPATHLEN);
        !            81:                        snprintf(str, MAXPATHLEN, "/%s/%s()", f->func_file, f->func_name);
        !            82:                        RPC_SET_STR(v++, str);
        !            83:                }
        !            84:        }
        !            85: 
        !            86:        return 0;
        !            87: }
        !            88: 
        !            89: int
        !            90: rpcServerSessions(rpc_srv_t * __restrict srv, rpc_func_t *call, int ic, rpc_val_t *iv)
        !            91: {
        !            92:        rpc_val_t *vals = NULL;
        !            93: 
        !            94:        if (!srv || !call) {
        !            95:                rpc_SetErr(EINVAL, "Error:: invalid parameters ...\n");
        !            96:                return -1;
        !            97:        }
        !            98: 
        !            99:        if (rpc_srv_declValsCall(call, 4) == -1)
        !           100:                return -1;
        !           101:        else
        !           102:                rpc_srv_delValsCall(call);
        !           103:        if (rpc_srv_getValsCall(call, &vals) == -1)
        !           104:                return -1;
        !           105: 
        !           106:        RPC_SET_U8(&vals[0], srv->srv_session.sess_version);
        !           107:        RPC_SET_U32(&vals[1], srv->srv_session.sess_program);
        !           108:        RPC_SET_U32(&vals[2], srv->srv_session.sess_process);
        !           109:        RPC_SET_I32(&vals[3], srv->srv_numcli);
        !           110: 
        !           111:        return 0;
        !           112: }