4.3BSD - /usr/src/new/mh/support/pop/mmdfII/pop/qu2po_send.c

   1: #ifndef POP
   2: /* qu2bb_send.c - manager for qu --> bb */
   3: #else   POP
   4: /* qu2po_send.c - manager for qu --> po */
   5: #endif	POP
   6: 
   7: 
   8: #include "util.h"
   9: #include "mmdf.h"
  10: #include "phs.h"
  11: #include "ch.h"
  12: 
  13: /*  */
  14: 
  15: extern LLog *logptr;
  16: extern char *supportaddr;
  17: 
  18: struct rp_construct rp_hend  = { /* end of host list */
  19:     RP_NOOP,
  20:     'e', 'n', 'd', ' ', 'o', 'f', ' ', 'h', 'o', 's', 't', ' ',
  21:     'i', 'g', 'n', 'o', 'r', 'e', 'd',
  22:     NULL
  23: };
  24: 
  25: struct rp_construct rp_aend = { /* end of address list */
  26:     RP_OK,
  27: #ifndef POP
  28:     'b', 'b', 'o', 'a', 'r', 'd', 's', ' ', 'e', 'n', 'd', ' ',
  29: #else   POP
  30:     'p', 'o', 'p', ' ', 'e', 'n', 'd', ' ',
  31: #endif	POP
  32:     'o', 'f', ' ', 'a', 'd', 'd', 'r', ' ', 'l', 'i', 's', 't',
  33:     NULL
  34: };
  35: 
  36: struct rp_construct rp_badr = { /* no such bboard */
  37:     RP_USER,
  38:     'u', 'n', 'k', 'n', 'o', 'w', 'n', ' ',
  39: #ifndef POP
  40:     'b', 'b', 'o', 'a', 'r', 'd',
  41: #else   POP
  42:     'p', 'o', 'p', ' ', 's', 'u', 'b', 's', 'c', 'r', 'i', 'b', 'e', 'r',
  43: #endif	POP
  44:     NULL
  45: };
  46: 
  47: struct rp_construct rp_err = {  /* error, retry later */
  48:     RP_AGN,
  49:     'u', 'n', 'k', 'n', 'o', 'w', 'n', ' ', 'e', 'r', 'r', 'o', 'r',
  50:     NULL
  51: };
  52: 
  53: /*  */
  54: 
  55: qu2bb_send (chanptr)
  56: Chan *chanptr;
  57: {
  58:     short   result;
  59:     char    info[LINESIZE],
  60:             sender[LINESIZE];
  61: 
  62: #ifdef DEBUG
  63:     ll_log (logptr, LLOGBTR, "qu2bb_send()");
  64: #endif
  65: 
  66:     if (rp_isbad (result = qu_pkinit ()))
  67:     return result;
  68:     if (rp_isbad (result = bb_sbinit ()))
  69:     return result;
  70: 
  71:     while (rp_gval ((result =
  72:         qu_rinit (info, sender, chanptr -> ch_apout))) == RP_OK) {
  73: #ifdef  DEBUG
  74:     ll_log (logptr, LLOGGEN, "info=%s sender=%s", info, sender);
  75: #endif
  76:     if (rp_isbad (result = bb_winit (info, sender)))
  77:         return result;
  78:     if (rp_isbad (result = qu2bb_each (sender)))
  79:         return result;
  80:     qu_rend();
  81:     }
  82:     qu_rend();
  83: 
  84:     if (rp_gval (result) != RP_DONE) {
  85:     ll_log (logptr, LLOGTMP, "not DONE [%s]", rp_valstr (result));
  86:     return RP_RPLY;
  87:     }
  88: 
  89:     qu_pkend ();
  90:     bb_sbend ();
  91: 
  92:     return result;
  93: }
  94: 
  95: /*  */
  96: LOCFUN
  97: qu2bb_each (sender)
  98: char   *sender;
  99: {
 100:     short   result;
 101:     char    adr[LINESIZE],
 102:             host[LINESIZE];
 103:     RP_Buf replyval;
 104: 
 105: #ifdef DEBUG
 106:     ll_log (logptr, LLOGBTR, "qu2bb_each(sender='%s')", sender);
 107: #endif
 108: 
 109:     FOREVER {           /* loop through the addresses */
 110:     if (rp_isbad (result = qu_radr (host, adr)))
 111:         return result;
 112: #ifdef  RP_HOK
 113:     if (rp_gval (result) == RP_HOK) {/* no-op the sub-list indication */
 114:         qu_wrply ((struct rp_bufstruct *) &rp_hend, rp_conlen (rp_hend));
 115:         continue;
 116:     }
 117: #endif	RP_HOK
 118:     if (rp_gval (result) == RP_DONE) {
 119:         qu_wrply ((RP_Buf *) &rp_aend, rp_conlen (rp_aend));
 120:         return RP_OK;
 121:     }
 122: 
 123:     switch (replyval.rp_val = bb_wtadr (host, adr)) {
 124:         case RP_AOK:
 125:         case RP_OK:
 126:         switch (replyval.rp_val = bb_txtcpy ()) {
 127:             case RP_MOK:
 128:             replyval.rp_line[0] = NULL;
 129:             break;
 130:             default:
 131:             ll_log (logptr, LLOGFAT, "unknown error [%s]",
 132:                 rp_valstr (replyval.rp_val));
 133:             blt (&rp_err, (char *) &replyval, sizeof rp_err);
 134:             break;
 135:         }
 136:         break;
 137: 
 138:         case RP_USER:
 139: #ifndef POP
 140:         ll_log (logptr, LLOGFAT, "unknown bboard '%s'", adr);
 141: #else   POP
 142:         ll_log (logptr, LLOGFAT, "unknown pop subscriber '%s'", adr);
 143: #endif	POP
 144:         blt (&rp_badr, (char *) &replyval, sizeof rp_badr);
 145:         break;
 146: 
 147:         default:
 148:         ll_log (logptr, LLOGFAT, "unknown error [%s]",
 149:             rp_valstr (replyval.rp_val));
 150:         blt (&rp_err, (char *) &replyval, sizeof rp_err);
 151:         break;
 152:     }
 153: 
 154:     qu_wrply (&replyval,
 155:         (sizeof replyval.rp_val) + strlen (replyval.rp_line));
 156:     }
 157: }

Defined functions

Defined variables