Return to CHenumerate.c CVS log

Up to [CSRG BSD Unix] / 43BSD / contrib / xns / morexnslib / ch

Annotation of 43BSD/contrib/xns/morexnslib/ch/CHenumerate.c, revision 1.1

1.1     ! root        1: #include <stdio.h>
        !             2: /* $Header: CHenumerate.c,v 2.0 85/11/21 07:22:30 jqj Exp $ */
        !             3: 
        !             4: /* contains:
        !             5:  * CH_Enumerate
        !             6:  */
        !             7: 
        !             8: /* $Log:       CHenumerate.c,v $
        !             9:  * Revision 2.0  85/11/21  07:22:30  jqj
        !            10:  * 4.3BSD standard release
        !            11:  * 
        !            12:  * Revision 1.1  85/03/26  06:26:59  jqj
        !            13:  * Initial revision
        !            14:  * 
        !            15:  * Revision 1.1  85/03/26  06:26:59  jqj
        !            16:  * Initial revision
        !            17:  * 
        !            18:  */
        !            19: #include <sys/types.h>
        !            20: #include <netns/ns.h>
        !            21: #include "Clearinghouse2_defs.h"
        !            22: #include <xnscourier/CHEntries.h>
        !            23: #include <xnscourier/except.h>
        !            24: 
        !            25: /*
        !            26:  * This module contains the routine:
        !            27:  * int CH_Enumerate(pattern,property,eachName)
        !            28:  *     ObjectNamePattern pattern;
        !            29:  *     Property property;
        !            30:  *     NameProcedure eachName;
        !            31:  * where NameProcedure is a procedure of the form:
        !            32:  * int eachName(name)
        !            33:  *     Object name;
        !            34:  */
        !            35: #define MAXPACKS 5
        !            36: 
        !            37: static (*ProcEachName)();              /* use:  (*ProcEachName)(arg); */
        !            38: static Cardinal nullhash = 0;
        !            39: static Authenticator nullagent = {{0,{0,(Unspecified*) 0}},
        !            40:                                  {1,&nullhash}};
        !            41: static ObjectName currentname;
        !            42: extern struct ns_addr *LookupCHAddr();
        !            43: 
        !            44: static
        !            45: listObject(name)
        !            46:        ObjectName name;
        !            47: {
        !            48:        printf("%s:%s:%s\n", name.object, name.domain, name.organization);
        !            49: }
        !            50: 
        !            51: static
        !            52: GetObjects(conn)
        !            53:        CourierConnection *conn;
        !            54: {
        !            55:        int count, i;
        !            56:        Unspecified buffer[MAXWORDS*MAXPACKS], *bp, *bufend;
        !            57:        StreamOfObject obnames;
        !            58:        
        !            59:        bufend = buffer;
        !            60:        bp = buffer+((MAXWORDS-1)*MAXPACKS);    /* end of available space */
        !            61:        while (count = BDTread(conn, (char*)bufend, 
        !            62:                                MAXWORDS*sizeof(Unspecified))
        !            63:                ) {
        !            64:                bufend += count/sizeof(Unspecified);
        !            65:                if (bufend > bp) {
        !            66:                        fprintf(stderr,"BDT read too big to fit\n");
        !            67:                        BDTabort(conn);
        !            68:                        /* should clear out stuff here if we knew how much */
        !            69:                }
        !            70:        }
        !            71:        bp = buffer;
        !            72:        while (bp < bufend) {
        !            73:                bp += internalize_StreamOfObject(&obnames,bp);
        !            74:                if (0 == (int) obnames.designator) {
        !            75:                   for (i=0; i < obnames.nextSegment_case.segment.length; i++) {
        !            76:                        currentname.object =
        !            77:                                obnames.nextSegment_case.segment.sequence[i];
        !            78:                        (*ProcEachName)(currentname);
        !            79:                   }
        !            80:                   free(obnames.nextSegment_case.segment.sequence);
        !            81:                } else {
        !            82:                   for (i = 0; i < obnames.lastSegment_case.length; i++) {
        !            83:                        currentname.object =
        !            84:                                obnames.lastSegment_case.sequence[i];
        !            85:                        (*ProcEachName)(currentname);
        !            86:                   }
        !            87:                   free(obnames.lastSegment_case.sequence);
        !            88:                   return;
        !            89:                }
        !            90:        }
        !            91: }
        !            92: 
        !            93: CH_Enumerate(pattern,property,eachName)
        !            94:        ObjectNamePattern pattern;
        !            95:        Property property;
        !            96:        int (*eachName)();
        !            97: {
        !            98:        CourierConnection *conn;
        !            99:        extern CourierConnection *CH_GetFirstCH();
        !           100: 
        !           101:        if (eachName != NULL)
        !           102:                ProcEachName = eachName;
        !           103:        else
        !           104:                ProcEachName = listObject;
        !           105:        if (pattern.object == NULL ||
        !           106:            pattern.domain == NULL ||
        !           107:            pattern.organization == NULL)
        !           108:                return(1);
        !           109:        currentname.domain = pattern.domain;
        !           110:        currentname.organization = pattern.organization;
        !           111: 
        !           112:        if ((conn = CH_GetFirstCH()) == NULL) {
        !           113:                fprintf(stderr,"Can't open connection to local Clearinghouse\n");
        !           114:                return(1);
        !           115:        }
        !           116:        DURING {
        !           117:                ListObjects(conn, GetObjects, pattern, property,
        !           118:                                BulkData1_immediateSink, nullagent);
        !           119:        } HANDLER {
        !           120:                return(Exception.Code); /* some random error */
        !           121:                /* should handle WrongServer here */
        !           122:        } END_HANDLER;
        !           123:        CourierClose(conn);
        !           124:        return(0);
        !           125: }

This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.