Liren Large Software Subsidy 7/07.iso/c/c004/1.ddi/CTSTAT.C

C/C++ Source or Header | 1989-04-18 | 4.5 KB | 209 lines

/*
 *    c-tree Server Status
 *
 *    This program is the CONFIDENTIAL and PROPRIETARY property
 *    of FairCom(R) Corporation. Any unauthorized use, reproduction or
 *    transfer of this program is strictly prohibited.
 *
 *      Copyright (c) 1987, 1988, 1989 FairCom Corporation
 *    (Subject to limited distribution and
 *     restricted disclosure only.)
 *    *** ALL RIGHTS RESERVED ***
 *
 *    4006 West Broadway
 *    Columbia, MO 65203
 *
 *
 *    c-tree(R)    Version 4.3
 *            Release C
 *            February 7, 1989 17:30
 *
 */

#include "ctstdr.h"
#include "ctoptn.h"
#include "cterrc.h"
#include "ctcomm.h"

#define MAXASIZ    512

LOCAL MESSAGE    msg;
LOCAL UCOUNT    cts_mxaln;
LOCAL TEXT     *apxmsg,*apxdat;
COUNT        cts_usrid,uerr_cod,cts_apxsiz,*altseq;
TEXT        ct_buf[CTBUFSIZ];
LOCAL SSTATUS    s;
LOCAL LONG    ffrq[MAX_FUNC] = {0};

COUNT ctrqst(),ctrspn();


VOID status()
{
    printf("\n    Server requests: %ld",s.srqsts);
    printf("\n    Users logged in: %ld (counting status report)",s.susers);
    printf("\nActive transactions: %ld",s.strans);
    printf("\n Shut down attempts: %ld (max required = %d)",
        s.shtdwn,CTS_DOWN);

    printf("\n\n\tWrite locks: %ld\n\t Read locks: %ld\n\t    Unlocks: %ld",
        s.scts_wl,s.scts_rl,s.scts_ul);

    printf("\n\n  Retries w/o block: %ld",s.sredo);

    printf(
"\n      Block history:\tseg ops = %ld\n\t\t\tseg clr = %ld\n\t\t\tusr wak = %ld",
        s.ssets,s.swaks,s.suwaks);
    printf("\nRetries after block: %ld",s.sretry);
}

VOID freq()
{
    int i;

    printf("\n\nServer Function Frequencies:\n");
    for (i = 0; i < MAX_FUNC; i++)
        if (ffrq[i] > 0)
            printf("F%03d %5ld      ",i,ffrq[i]);
    printf("\n");
}

VOID filelist()
{
    TEXT fname[MAX_NAME];
    FAST TEXT *tp;
    COUNT       nusers;

    tp = apxdat;
    while (msg.mvlen--) {
        strcpy(fname,tp);
        tp += (strlen(tp) + 1);
        cpybuf(&nusers,tp,sizeof(COUNT));
        tp += sizeof(COUNT);
        printf("\n%04d    %s",nusers,fname);
    }
}

COUNT ctlogin(papxmsg,cts_apxsiz,pmsg)
TEXT        **papxmsg;
UCOUNT              cts_apxsiz;
MESSAGE                    *pmsg;
{
    TEXT *tpxdat;
    TEXT *getmids();

    /*
     * get server message id, create application id, & get space
     * for msg
     */
    pmsg->mfunc   = TST_SPCLOG;
    if ((*papxmsg = getmids(cts_apxsiz,pmsg)) == NULL)
        return(uerr_cod);
    else
        tpxdat = *papxmsg + sizeof(MESSAGE);

    /*
     * user id determination (pmsg->musrn set by server to
     * actual value)
     */
    pmsg->musrn = cts_usrid = -1;

    /*
     * send a message which: compares application message
     * size with server message size, sends message id
     * (set in getmids and stored in pmsg->mpntr), and
        * compares application MAXLEN with server's
     */
    cts_mxaln   = (pmsg->mvlen = cts_apxsiz) - sizeof(MESSAGE);
    pmsg->mseqn = MAXLEN;
    pmsg->mretc = MAXLEN;
    if (ctrqst(*papxmsg,&msg) || ctrspn(papxmsg,&msg))
        return(uerr_cod);
    return(NO_ERROR);
}

COUNT STPUSR()
{
    msg.mfunc = TST_STPUSR;
    msg.mdlen = msg.mretc = 0;
    ctrqst(apxmsg,&msg);
    ctrspn(&apxmsg,&msg);
    ridmids();
}

main()
{
    FAST TEXT *tp;
    COUNT       i;

    printf("\n\n\t\t\tc-tree(R) Server Status Report\n");

    if (ctlogin(&apxmsg,cts_apxsiz = MAXASIZ,&msg))
        goto err_term;

    /* output status */

    msg.mfunc = FN_STATUS;
    msg.mdlen = msg.mretc = 0;
    msg.mseqn = -1;
    if (ctrqst(apxmsg,&msg) || ctrspn(&apxmsg,&msg))
        goto err_term;
    apxdat = apxmsg + sizeof(MESSAGE);
    cpybuf((TEXT *) &s.srqsts,apxdat,sizeof(SSTATUS));
    status();

    /* output function frequency */

    tp = apxdat + sizeof(SSTATUS);
    for (;;) {
        while (msg.mvlen--) {
            cpybuf(&i,tp,sizeof(COUNT));
            tp += sizeof(COUNT);
            cpybuf(&ffrq[i],tp,sizeof(LONG));
            tp += sizeof(LONG);
        }
        if (msg.mseqn != 0) {
            msg.mfunc = FN_STATUS;
            msg.mdlen = 0;
            if (ctrqst(apxmsg,&msg) || ctrspn(&apxmsg,&msg))
                goto err_term;
            tp = apxmsg + sizeof(MESSAGE);
        } else
            break;
    }
    freq();

    /* File Listing */

    printf("\nPress return to continue with file listing...");
    gets(ct_buf);
    printf("\n\nUsers   File Name");
    msg.mseqn = msg.mretc = 0;
    do {
      msg.mfunc = FN_STFILE;
      msg.mdlen = 0;
      if (ctrqst(apxmsg,&msg) || ctrspn(&apxmsg,&msg))
        goto err_term;

      apxdat = apxmsg + sizeof(MESSAGE);
      filelist();
    } while (msg.mseqn != 0);

    msg.mfunc = TST_STPUSR;
    msg.mdlen = 0;
    if (ctrqst(apxmsg,&msg) || ctrspn(&apxmsg,&msg))
        goto err_term;
    ridmids();

    printf("\nEnd Of Report\n");
    exit(0);

err_term:
    printf("\nCould not continue with status report. Error(%d,%d).\n",
        uerr_cod,msg.merrn);
    ridmids();
    exit(2);
}

/* end of ctstat.c */