Return to pb_write.c CVS log

Up to [CSRG BSD Unix] / 42BSD / ingres / source / ctlmod

Annotation of 42BSD/ingres/source/ctlmod/pb_write.c, revision 1.1.1.1

1.1       root        1: # include      "ctlmod.h"
                      2: # include      "pipes.h"
                      3: # include      <sccs.h>
                      4: 
                      5: SCCSID(@(#)pb_write.c  7.1     2/5/81)
                      6: 
                      7: /*
                      8: **  PB_WRITE -- Write pipe block
                      9: **
                     10: **     Writes the block specified by ppb to the pipe implied by
                     11: **     ppb->pb_proc.  Also handles broadcase messages.
                     12: **
                     13: **     Parameters:
                     14: **             ppb -- a ptr to the pipe block to write.
                     15: **
                     16: **     Returns:
                     17: **             none
                     18: **
                     19: **     Side Effects:
                     20: **             none
                     21: **
                     22: **     Trace Flags:
                     23: **             12.10 - 12.15
                     24: */
                     25: 
                     26: pb_write(ppb)
                     27: register pb_t  *ppb;
                     28: {
                     29:        register int    i;
                     30: 
                     31: # ifdef xCTR1
                     32:        if (tTf(12, 10))
                     33:        {
                     34:                lprintf("pb_write: ");
                     35:                pb_dump(ppb, TRUE);
                     36:        }
                     37: # endif
                     38: 
                     39:        /* handle broadcast messages */
                     40:        if (ppb->pb_proc == PB_WILD)
                     41:        {
                     42:                /* write on all pipes marked as a broadcast pipe */
                     43:                for (i = 0; i < CM_MAXPROC; i++)
                     44:                {
                     45:                        if ((Cm.cm_proc[i].pr_stat & PR_BCAST) != 0)
                     46:                                pb_wphys(ppb, Cm.cm_proc[i].pr_file);
                     47:                }
                     48:        }
                     49:        else
                     50:        {
                     51:                /* normal message */
                     52:                i = ppb->pb_proc;
                     53: # ifdef xCM_DEBUG
                     54:                if (i > CM_MAXPROC || i < 0)
                     55:                        syserr("pb_write: proc %d", i);
                     56: # endif
                     57: # ifdef xCTR1
                     58:                if (tTf(12, 11))
                     59:                        printf("pb_write: proc %d fd=%d\n", i, Cm.cm_proc[i].pr_file);
                     60: # endif
                     61:                pb_wphys(ppb, Cm.cm_proc[i].pr_file);
                     62:        }
                     63: 
                     64:        /* determine the new input */
                     65:        if ((ppb->pb_stat & (PB_INFO|PB_EOF)) == PB_EOF)
                     66:                Cm.cm_input = Cm.cm_proc[ppb->pb_proc].pr_ninput;
                     67: 
                     68:        /* reset some exciting pointers */
                     69:        ppb->pb_xptr = ppb->pb_data;
                     70:        ppb->pb_nleft = PB_DBSIZE;
                     71:        ppb->pb_nused = 0;
                     72: }

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