![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to dapwait.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / dsap / net|
Return to dapwait.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / dsap / net |
1.1 ! root 1: /* dapwait.c - DAP: Deal with incoming activity */ ! 2: ! 3: #ifndef lint ! 4: static char *rcsid = "$Header: /f/osi/dsap/net/RCS/dapwait.c,v 7.0 90/07/26 14:45:31 mrose Exp $"; ! 5: #endif ! 6: ! 7: /* ! 8: * $Header: /f/osi/dsap/net/RCS/dapwait.c,v 7.0 90/07/26 14:45:31 mrose Exp $ ! 9: * ! 10: * ! 11: * $Log: dapwait.c,v $ ! 12: * Revision 7.0 90/07/26 14:45:31 mrose ! 13: * *** empty log message *** ! 14: * ! 15: */ ! 16: ! 17: /* ! 18: * NOTICE ! 19: * ! 20: * Acquisition, use, and distribution of this module and related ! 21: * materials are subject to the restrictions of a license agreement. ! 22: * Consult the Preface in the User's Manual for the full terms of ! 23: * this agreement. ! 24: * ! 25: */ ! 26: ! 27: ! 28: /* LINTLIBRARY */ ! 29: ! 30: #include "logger.h" ! 31: #include "quipu/util.h" ! 32: #include "quipu/dap2.h" ! 33: ! 34: ! 35: extern LLog * log_dsap; ! 36: ! 37: #ifdef PDU_DUMP ! 38: #define DUMP_ARG "arg" ! 39: #define DUMP_RES "res" ! 40: #define DUMP_ERR "err" ! 41: #endif ! 42: ! 43: /* ! 44: * Wait routine for a DAP initiator. ! 45: */ ! 46: ! 47: /* ARGSUSED */ ! 48: ! 49: int DapInitWaitRequest (sd, secs, di) ! 50: int sd; ! 51: int secs; ! 52: struct DAPindication * di; ! 53: { ! 54: int result; ! 55: struct RoSAPindication roi_s; ! 56: struct RoSAPindication * roi = &(roi_s); ! 57: ! 58: DLOG (log_dsap,LLOG_TRACE,( "DapInitWaitRequest()")); ! 59: ! 60: result = RoWaitRequest(sd, secs, roi); ! 61: ! 62: if (result == NOTOK) ! 63: { ! 64: return (ros2daplose (di, "RoBindWaitRequest", &(roi->roi_preject))); ! 65: } ! 66: ! 67: switch(roi->roi_type) ! 68: { ! 69: case ROI_INVOKE: ! 70: LLOG (log_dsap, LLOG_EXCEPTIONS, ("DapInitWaitRequest: Invocation received")); ! 71: DRejectRequest (sd, ROS_IP_UNRECOG, roi->roi_invoke.rox_id); ! 72: return (daplose (di, DP_ROS, NULLCP, "DAP initiator cannot accept invokes")); ! 73: ! 74: case ROI_RESULT: ! 75: return (DapDecodeResult (sd, &(roi->roi_result), di)); ! 76: ! 77: case ROI_ERROR: ! 78: return (DapDecodeError (sd, &(roi->roi_error), di)); ! 79: ! 80: case ROI_UREJECT: ! 81: LLOG (log_dsap, LLOG_EXCEPTIONS, ("DapInitWaitRequest: Operation (%d) user rejected (%d)", roi->roi_ureject.rou_id, roi->roi_ureject.rou_reason)); ! 82: return (ros2dapreject(di, "ROI_UREJECT", &(roi->roi_ureject))); ! 83: ! 84: case ROI_PREJECT: ! 85: LLOG (log_dsap, LLOG_EXCEPTIONS, ("DapInitWaitRequest: Operation (%d) provider rejected", roi->roi_preject.rop_id)); ! 86: return (ros2daplose (di, "ROI_PREJECT", &(roi->roi_preject))); ! 87: ! 88: case ROI_FINISH: ! 89: LLOG (log_dsap, LLOG_EXCEPTIONS, ("DapInitWaitRequest: Unbind request received")); ! 90: return (daplose (di, DP_ROS, NULLCP, "DAP initiator cannot accept unbind requests")); ! 91: ! 92: default: ! 93: LLOG (log_dsap,LLOG_EXCEPTIONS,( "Unknown indication type : %d", roi->roi_type)); ! 94: return (daplose (di, DP_ROS, NULLCP, "DapInitWaitRequest(): RoWaitRequest error")); ! 95: } ! 96: /* NOT REACHED */ ! 97: } ! 98: ! 99: int DapDecodeResult (sd, ror, di) ! 100: int sd; ! 101: struct RoSAPresult * ror; ! 102: struct DAPindication * di; ! 103: { ! 104: int success; ! 105: PE pe = ror->ror_result; ! 106: struct DSResult * res = &(di->di_result.dr_res); ! 107: ! 108: di->di_type = DI_RESULT; ! 109: di->di_result.dr_id = ror->ror_id; ! 110: ! 111: #ifdef PDU_DUMP ! 112: pdu_dump (pe,DUMP_RES,ror->ror_op); ! 113: #endif ! 114: ! 115: #ifdef HEAVY_DEBUG ! 116: pdu_res_log (pe, ror->ror_op); ! 117: #endif ! 118: ! 119: switch(res->result_type = ror->ror_op) ! 120: { ! 121: case OP_READ : ! 122: success = decode_DAS_ReadResult(pe,1,NULLIP,NULLVP,&(res->res_rd)); ! 123: break; ! 124: case OP_COMPARE : ! 125: success = decode_DAS_CompareResult(pe,1,NULLIP,NULLVP,&(res->res_cm)); ! 126: break; ! 127: case OP_ABANDON : ! 128: success = decode_DAS_AbandonResult(pe,1,NULLIP,NULLVP,NULLCP); ! 129: break; ! 130: case OP_LIST : ! 131: success = decode_DAS_ListResult(pe,1,NULLIP,NULLVP,&(res->res_ls)); ! 132: break; ! 133: case OP_SEARCH : ! 134: success = decode_DAS_SearchResult(pe,1,NULLIP,NULLVP,&(res->res_sr)); ! 135: break; ! 136: case OP_ADDENTRY : ! 137: success = decode_DAS_AddEntryResult(pe,1,NULLIP,NULLVP,NULLCP); ! 138: break; ! 139: case OP_REMOVEENTRY : ! 140: success = decode_DAS_RemoveEntryResult(pe,1,NULLIP,NULLVP,NULLCP); ! 141: break; ! 142: case OP_MODIFYENTRY : ! 143: success = decode_DAS_ModifyEntryResult(pe,1,NULLIP,NULLVP,NULLCP); ! 144: break; ! 145: case OP_MODIFYRDN : ! 146: success = decode_DAS_ModifyRDNResult(pe,1,NULLIP,NULLVP,NULLCP); ! 147: break; ! 148: ! 149: default: ! 150: LLOG(log_dsap, LLOG_EXCEPTIONS, ("DapDecodeResult: op id %d unknown!", ror->ror_op)); ! 151: DRejectRequest (sd, ROS_RRP_UNRECOG, ror->ror_id); ! 152: return (daplose (di, DP_RESULT, NULLCP, "Unknown operation identifier")); ! 153: } ! 154: ! 155: if (success == NOTOK) ! 156: { ! 157: LLOG (log_dsap, LLOG_EXCEPTIONS, ("DapDecodeResult: Unable to parse argument")); ! 158: DRejectRequest (sd, ROS_RRP_MISTYPED, ror->ror_id); ! 159: return (daplose (di, DP_RESULT, NULLCP, "Undecodable argument")); ! 160: } ! 161: ! 162: return(success); ! 163: } ! 164: ! 165: int DapDecodeError (sd, roe, di) ! 166: int sd; ! 167: struct RoSAPerror * roe; ! 168: struct DAPindication * di; ! 169: { ! 170: int success; ! 171: PE pe = roe->roe_param; ! 172: struct DSError * err = &(di->di_error.de_err); ! 173: ! 174: #ifdef PDU_DUMP ! 175: pdu_dump (pe,DUMP_ERR,roe->roe_id); ! 176: #endif ! 177: ! 178: di->di_type = DI_ERROR; ! 179: di->di_error.de_id = roe->roe_id; ! 180: ! 181: switch(err->dse_type = roe->roe_error) ! 182: { ! 183: case DSE_ABANDON_FAILED : ! 184: success = decode_DAS_AbandonFailedParm(pe,1,NULLIP,NULLVP,&(err->dse_un.dse_un_abandon_fail)); ! 185: break; ! 186: case DSE_ATTRIBUTEERROR : ! 187: success = decode_DAS_AttributeErrorParm(pe,1,NULLIP,NULLVP,&(err->dse_un.dse_un_attribute)); ! 188: break; ! 189: case DSE_NAMEERROR : ! 190: success = decode_DAS_NameErrorParm(pe,1,NULLIP,NULLVP,&(err->dse_un.dse_un_name)); ! 191: break; ! 192: case DSE_REFERRAL : ! 193: success = decode_DAS_ReferralParm(pe,1,NULLIP,NULLVP,&(err->dse_un.dse_un_referral)); ! 194: break; ! 195: case DSE_SECURITYERROR : ! 196: success = decode_DAS_SecurityErrorParm(pe,1,NULLIP,NULLVP,&(err->dse_un.dse_un_security)); ! 197: break; ! 198: case DSE_SERVICEERROR : ! 199: success = decode_DAS_ServiceErrorParm(pe,1,NULLIP,NULLVP,&(err->dse_un.dse_un_service)); ! 200: break; ! 201: case DSE_UPDATEERROR : ! 202: success = decode_DAS_UpdateErrorParm(pe,1,NULLIP,NULLVP,&(err->dse_un.dse_un_update)); ! 203: break; ! 204: case DSE_ABANDONED : ! 205: success = ((pe == NULLPE) ? OK : NOTOK); ! 206: break; ! 207: case DSE_DSAREFERRAL : ! 208: success = decode_DO_DSAReferralParm(pe, 1, NULLIP, NULLVP, &(err->dse_un.dse_un_referral)); ! 209: break; ! 210: ! 211: default: ! 212: LLOG(log_dsap, LLOG_EXCEPTIONS, ("DapDecodeError: op id %d unknown!", roe->roe_error)); ! 213: DRejectRequest (sd, ROS_REP_UNRECOG, roe->roe_id); ! 214: return (daplose (di, DP_ERROR, NULLCP, "Unknown operation identifier")); ! 215: } ! 216: ! 217: if (success == NOTOK) ! 218: { ! 219: LLOG (log_dsap, LLOG_EXCEPTIONS, ("DapDecodeError: Unable to parse argument")); ! 220: DRejectRequest (sd, ROS_RRP_MISTYPED, roe->roe_id); ! 221: return (daplose (di, DP_ERROR, NULLCP, "Undecodable argument")); ! 222: } ! 223: ! 224: return(success); ! 225: } ! 226:
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.