开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 嵌入式/单片机编程 > VxWorks > 查看源码
RpcPduFactory.cpp
资源名称：vxwork_src.rar　[点击查看]
上传用户：nvosite88
上传日期：2007-01-17
资源大小：4983k
文件大小：13k
源码类别：

VxWorks

开发平台：

C/C++

RpcPduFactory.cpp：源码内容
  1. /* RpcPduFactory - create DCOM protocol requests/responses */
  3. /* Copyright (c) 1999 Wind River Systems, Inc. */
  5. /*
  6. modification history
  7. --------------------
  8. 01p,17dec01,nel  Add include symbol for diab build.
  9. 01o,08oct01,nel  SPR#70120. reformat ALTER_CONTEXT_RESP separately from
  10.                  BIND_ACK.
  11. 01n,13jul01,dbs  add pres ctx ID to request pdu
  12. 01m,29mar01,nel  SPR#35873. Add context id parameter to formatBindPdu to allow
  13.                  client side ctxId to be specified.
  14. 01l,16aug00,nel  Win2K patch.
  15. 01k,27jul00,dbs  fix pres-ctx-id returned in FAULT and RESPONSE packets
  16. 01j,26jun00,dbs  explicitly set presCtxId value in BIND msg
  17.                  add 'did not execute' flag to FAULT
  18. 01i,22jun00,dbs  fix handling of alter-context packets
  19. 01h,19aug99,aim  added TraceCall header
  20. 01g,19jul99,dbs  add support for AUTH3 packets
  21. 01f,02jul99,aim  renamed makeBindFormatPdu and makeRequestFormatPdu
  22. 01e,24jun99,dbs  move authn into new class
  23. 01d,23jun99,dbs  fix authn on response packets
  24. 01c,08jun99,aim  rework
  25. 01b,08jun99,aim  now uses NRpcPdu
  26. 01a,03jun99,aim  created
  27. */
  29. #include "RpcPduFactory.h"
  30. #include "dcomProxy.h"
  31. #include "ntlmssp.h"
  32. #include "TraceCall.h"
  34. /* Include symbol for diab */
  35. extern "C" int include_vxdcom_RpcPduFactory (void)
  36.     {
  37.     return 0;
  38.     }
  40. extern IID IID_ISystemActivator;
  42. RpcPduFactory::RpcPduFactory ()
  43.     {
  44.     TRACE_CALL;
  45.     }
  47. RpcPduFactory::~RpcPduFactory ()
  48.     {
  49.     TRACE_CALL;
  50.     }
  52. BYTE
  53. RpcPduFactory::rpcMajorVersion ()
  54.     {
  55.     return 5;
  56.     }
  58. BYTE
  59. RpcPduFactory::rpcMinorVersion ()
  60.     {
  61.     return 0;
  62.     }
  64. void
  65. RpcPduFactory::formatFaultPdu
  66.     (
  67.     const RpcPdu& request,
  68.     RpcPdu& faultPdu,
  69.     HRESULT faultCode,
  70.     bool didNotExecute
  71.     )
  72.     {
  73.     TRACE_CALL;
  75.     RpcPdu& pdu = faultPdu; // shorter, easier!
  77.     pdu.fault ().hdr.rpcVersion      = rpcMajorVersion ();
  78.     pdu.fault ().hdr.rpcMinorVersion = rpcMinorVersion ();
  79.     pdu.fault ().hdr.packetType      = RPC_CN_PKT_FAULT;
  80.     pdu.fault ().hdr.flags           = RPC_CN_FLAGS_FIRST_FRAG |
  81.        RPC_CN_FLAGS_LAST_FRAG;
  83.     if (didNotExecute)
  84. pdu.fault().hdr.flags |= RPC_CN_FLAGS_DID_NOT_EXECUTE;
  85.     
  86.     pdu.fault ().hdr.drep [0]        = VXDCOM_NDR_DATAREP0;
  87.     pdu.fault ().hdr.drep [1]        = VXDCOM_NDR_DATAREP1;
  88.     pdu.fault ().hdr.drep [2]        = VXDCOM_NDR_DATAREP2;
  89.     pdu.fault ().hdr.drep [3]        = VXDCOM_NDR_DATAREP3;
  90.     pdu.fault ().hdr.callId          = request.callId ();
  92.     pdu.fault ().allocHint           = 0; // XXX fix up later
  93.     pdu.fault ().presCtxId           = request.request().presCtxId;
  94.     pdu.fault ().alertCount          = 0;
  95.     pdu.fault ().reserved            = 0;
  96.     pdu.fault ().status              = faultCode;
  97.     pdu.fault ().reserved2           = 0;
  98.     }
  100. void
  101. RpcPduFactory::formatBindAckPdu
  102.     (
  103.     const RpcPdu& request,
  104.     RpcPdu& bindAckPdu,
  105.     ULONG               assocGroupId
  106.     )
  107.     {
  108.     TRACE_CALL;
  110.     // Handle ALTER_CONTEXT response separately now...
  111.     if (request.packetType () == RPC_CN_PKT_ALTER_CONTEXT)
  112. {
  113. formatAlterContextRespPdu (request, bindAckPdu);
  114. return;
  115. }
  117.     // If the input is a BIND PDU then we need to send a BIND_ACK...
  119.     GUID xferSyntax;
  120.     DWORD version;
  121.     RpcPdu& pdu = bindAckPdu; // shorter, easier!
  123.     xferSyntax = request.bind
  124.  ().presCtxList.presCtxElem[0].transferSyntax [0].id;
  126.     version = request.bind
  127.       ().presCtxList.presCtxElem[0].transferSyntax [0].version;
  129.     pdu.bind_ack ().hdr.rpcVersion = rpcMajorVersion ();
  130.     pdu.bind_ack ().hdr.rpcMinorVersion = rpcMinorVersion ();
  132.     pdu.bind_ack ().hdr.packetType = RPC_CN_PKT_BIND_ACK;
  134.     pdu.bind_ack ().hdr.flags =      RPC_CN_FLAGS_FIRST_FRAG |
  135.                                      RPC_CN_FLAGS_LAST_FRAG;
  136.     
  137.     pdu.bind_ack ().hdr.drep [0] = VXDCOM_NDR_DATAREP0;
  138.     pdu.bind_ack ().hdr.drep [1] = VXDCOM_NDR_DATAREP1;
  139.     pdu.bind_ack ().hdr.drep [2] = VXDCOM_NDR_DATAREP2;
  140.     pdu.bind_ack ().hdr.drep [3] = VXDCOM_NDR_DATAREP3;
  142.     pdu.bind_ack ().hdr.callId = request.callId ();
  144.     pdu.bind_ack ().maxTxFrag = RpcPdu::MAXLEN;
  145.     pdu.bind_ack ().maxRxFrag = RpcPdu::MAXLEN;
  147.     // XXX aim
  148.     pdu.bind_ack ().assocGroupId = (ULONG) assocGroupId;
  150.     pdu.bind_ack ().secAddr.len = 4; // ???
  151.     pdu.bind_ack ().secAddr.addr [0] = 0; // ???
  153.     pdu.bind_ack ().resultList.numResults = 1;
  154.     pdu.bind_ack ().resultList.presResult [0].result = 0; // accept
  155.     pdu.bind_ack ().resultList.presResult [0].reason = 0; // not specified
  158.     if (IsEqualGUID(request.bind().presCtxList.presCtxElem[0].abstractSyntax.id, 
  159.                     IID_ISystemActivator))
  160.         {
  161.         // DCE spec lists these codes as network congestion. NT4 returns them
  162.         // when queried for the ISystemActivator interface. This was arrived at
  163.         // by examining the wire protocol.
  164.         pdu.bind_ack ().resultList.presResult [0].result = 0x02;
  165.         pdu.bind_ack ().resultList.presResult [0].reason = 0x01;
  166.         pdu.bind_ack ().resultList.presResult [0].transferSyntax.id = GUID_NULL;
  167.         pdu.bind_ack ().resultList.presResult [0].transferSyntax.version = 0;
  168.         }
  169.     else
  170.         {
  171.         pdu.bind_ack ().resultList.presResult [0].result = 0; // accept
  172.         pdu.bind_ack ().resultList.presResult [0].reason = 0; // not specified
  173.         pdu.bind_ack ().resultList.presResult [0].transferSyntax.id 
  174.                                                                 = xferSyntax;
  175.         pdu.bind_ack ().resultList.presResult [0].transferSyntax.version 
  176.                                                                 = version;
  177.         }
  178.     }
  180. void
  181. RpcPduFactory::formatAlterContextRespPdu
  182.     (
  183.     const RpcPdu& request,
  184.     RpcPdu& alterContextRespPdu
  185.     )
  186.     {
  187.     TRACE_CALL;
  189.     RpcPdu& pdu = alterContextRespPdu; // shorter, easier!
  191.     pdu.alter_context_resp().hdr.rpcVersion = rpcMajorVersion ();
  192.     pdu.alter_context_resp().hdr.rpcMinorVersion = rpcMinorVersion ();
  194.     pdu.alter_context_resp().hdr.packetType = RPC_CN_PKT_ALTER_CONTEXT_RESP;
  195.     pdu.alter_context_resp().hdr.flags = 0;
  197.     pdu.alter_context_resp().hdr.drep [0] = VXDCOM_NDR_DATAREP0;
  198.     pdu.alter_context_resp().hdr.drep [1] = VXDCOM_NDR_DATAREP1;
  199.     pdu.alter_context_resp().hdr.drep [2] = VXDCOM_NDR_DATAREP2;
  200.     pdu.alter_context_resp().hdr.drep [3] = VXDCOM_NDR_DATAREP3;
  202.     pdu.alter_context_resp().hdr.callId = request.callId ();
  204.     pdu.alter_context_resp().maxTxFrag = RpcPdu::MAXLEN;
  205.     pdu.alter_context_resp().maxRxFrag = RpcPdu::MAXLEN;
  207.     pdu.alter_context_resp().assocGroupId = 0;
  209.     pdu.alter_context_resp().secAddr = 0;
  210.     pdu.alter_context_resp().pad = 0;
  212.     pdu.alter_context_resp().resultList.numResults = 1;
  214.     if (IsEqualGUID(request.bind().presCtxList.presCtxElem[0].abstractSyntax.id, 
  215.                     IID_ISystemActivator))
  216.         {
  217.         // DCE spec lists these codes as network congestion. NT4 returns them
  218.         // when queried for the ISystemActivator interface. This was arrived at
  219.         // by examining the wire protocol.
  220.         pdu.alter_context_resp().resultList.presResult [0].result = 0x02;
  221.         pdu.alter_context_resp().resultList.presResult [0].reason = 0x01;
  222.         pdu.alter_context_resp().resultList.presResult [0].transferSyntax.id = GUID_NULL;
  223.         pdu.alter_context_resp().resultList.presResult [0].transferSyntax.version = 0;
  224.         }
  225.     else
  226.         {
  227.         pdu.alter_context_resp().resultList.presResult [0].result = 0; // accept
  228.         pdu.alter_context_resp().resultList.presResult [0].reason = 0; // not specified
  229.         pdu.alter_context_resp().resultList.presResult [0].transferSyntax.id
  230.             = request.bind().presCtxList.presCtxElem[0].transferSyntax [0].id;
  232.         pdu.alter_context_resp().resultList.presResult [0].transferSyntax.version
  233.             = request.bind().presCtxList.presCtxElem[0].transferSyntax [0].version;
  234.         }
  235.     }
  237. void
  238. RpcPduFactory::formatBindNakPdu
  239.     (
  240.     const RpcPdu& request,
  241.     RpcPdu& bindNakPdu
  242.     )
  243.     {
  244.     TRACE_CALL;
  246.     RpcPdu& pdu = bindNakPdu; // shorter, easier!
  248.     pdu.bind_nak ().hdr.rpcVersion = rpcMajorVersion ();
  249.     pdu.bind_nak ().hdr.rpcMinorVersion = rpcMinorVersion ();
  250.     pdu.bind_nak ().hdr.packetType = RPC_CN_PKT_BIND_NAK;
  251.     pdu.bind_nak ().hdr.flags = RPC_CN_FLAGS_FIRST_FRAG |
  252. RPC_CN_FLAGS_LAST_FRAG;
  253.     pdu.bind_nak ().hdr.drep [0] = VXDCOM_NDR_DATAREP0;
  254.     pdu.bind_nak ().hdr.drep [1] = VXDCOM_NDR_DATAREP1;
  255.     pdu.bind_nak ().hdr.drep [2] = VXDCOM_NDR_DATAREP2;
  256.     pdu.bind_nak ().hdr.drep [3] = VXDCOM_NDR_DATAREP3;
  257.     pdu.bind_nak ().hdr.callId = request.callId ();
  259.     pdu.bind_nak ().reason = 0;
  260.     pdu.bind_nak ().numProtocols = 1;
  261.     pdu.bind_nak ().verMajor = rpcMajorVersion ();
  262.     pdu.bind_nak ().verMinor = rpcMinorVersion ();
  263.     }
  265. void
  266. RpcPduFactory::formatResponsePdu
  267.     (
  268.     const RpcPdu& request,
  269.     RpcPdu& responsePdu
  270.     )
  271.     {
  272.     TRACE_CALL;
  274.     // Handle auth info - any outgoing trailer must be appended to the
  275.     // stub-data, and must be 4-byte aligned...
  277.     RpcPdu& pdu = responsePdu; // shorter, easier!
  279.     // Now fill in response fields...
  280.     pdu.response ().hdr.rpcVersion = rpcMajorVersion ();
  281.     pdu.response ().hdr.rpcMinorVersion = rpcMinorVersion ();
  282.     pdu.response ().hdr.packetType = RPC_CN_PKT_RESPONSE;
  283.     pdu.response ().hdr.flags = RPC_CN_FLAGS_FIRST_FRAG |
  284.   RPC_CN_FLAGS_LAST_FRAG;
  285.     pdu.response ().hdr.callId = request.callId ();
  287.     pdu.response ().allocHint  = 0; // XXX fix up later
  288.     pdu.response ().presCtxId  = request.request().presCtxId;
  289.     pdu.response ().alertCount = 0;
  290.     pdu.response ().reserved   = 0;
  291.     }
  293. void
  294. RpcPduFactory::formatBindPdu
  295.     (
  296.     RpcPdu& result,
  297.     REFIID riid,
  298.     ULONG callId,
  299.     ULONG assocGroupId,
  300.     bool alterCtxt,
  301.     USHORT ctxId
  302.     )
  303.     {
  304.     // Build BIND packet
  306.     result.bind().hdr.rpcVersion = rpcMajorVersion ();
  307.     result.bind().hdr.rpcMinorVersion = rpcMinorVersion ();
  309.     if (alterCtxt)
  310.         result.bind().hdr.packetType = RPC_CN_PKT_ALTER_CONTEXT;
  311.     else
  312.         result.bind().hdr.packetType = RPC_CN_PKT_BIND;
  314.     result.bind().hdr.flags = 0;
  316.     result.bind().hdr.drep [0] = VXDCOM_NDR_DATAREP0;
  317.     result.bind().hdr.drep [1] = VXDCOM_NDR_DATAREP1;
  318.     result.bind().hdr.drep [2] = VXDCOM_NDR_DATAREP2;
  319.     result.bind().hdr.drep [3] = VXDCOM_NDR_DATAREP3;
  320.     result.bind().hdr.callId = callId;
  321.     result.bind().maxTxFrag = RpcPdu::MAXLEN;
  322.     result.bind().maxRxFrag = RpcPdu::MAXLEN;
  323.     result.bind().assocGroupId = assocGroupId;
  324.     result.bind().presCtxList.numCtxElems = 1;
  325.     result.bind().presCtxList.presCtxElem [0].abstractSyntax.id = riid;
  326.     result.bind().presCtxList.presCtxElem [0].abstractSyntax.version = 0;
  327.     result.bind().presCtxList.presCtxElem [0].presCtxId = ctxId;
  328.     result.bind().presCtxList.presCtxElem [0].nTransferSyntaxes = 1;
  329.     result.bind().presCtxList.presCtxElem [0].transferSyntax [0].id = DCOM_XFER_SYNTAX;
  330.     result.bind().presCtxList.presCtxElem [0].transferSyntax [0].version = 2;
  331.     }
  333. //////////////////////////////////////////////////////////////////////////
  334. //
  336. void
  337. RpcPduFactory::formatRequestPdu
  338.     (
  339.     RpcPdu& result,
  340.     ULONG callId,
  341.     USHORT opnum,
  342.     const GUID* pObjectUuid,
  343.     USHORT              presCtxId
  344.     )
  345.     {
  346.     result.request().hdr.rpcVersion = rpcMajorVersion ();
  347.     result.request().hdr.rpcMinorVersion = rpcMinorVersion ();
  348.     result.request().hdr.packetType = RPC_CN_PKT_REQUEST;
  349.     result.request().hdr.flags = RPC_CN_FLAGS_FIRST_FRAG |
  350.  RPC_CN_FLAGS_LAST_FRAG;
  351.     if (pObjectUuid)
  352.         {
  353.         result.request().hdr.flags |= RPC_CN_FLAGS_OBJECT_UUID;
  354.         result.request().objectId = *pObjectUuid;
  355.         }
  357.     result.request().hdr.drep [0] = VXDCOM_NDR_DATAREP0;
  358.     result.request().hdr.drep [1] = VXDCOM_NDR_DATAREP1;
  359.     result.request().hdr.drep [2] = VXDCOM_NDR_DATAREP2;
  360.     result.request().hdr.drep [3] = VXDCOM_NDR_DATAREP3;
  361.     result.request().hdr.fragLen = 0; // fix later
  362.     result.request().hdr.authLen = 0;
  363.     result.request().hdr.callId = callId;
  364.     result.request().allocHint = 0; // fixed up later
  365.     result.request().presCtxId = presCtxId;
  366.     result.request().methodNum = opnum;
  367.     }
  369. //////////////////////////////////////////////////////////////////////////
  370. //
  372. void
  373. RpcPduFactory::formatAuth3Pdu
  374.     (
  375.     RpcPdu& pdu,
  376.     ULONG callId
  377.     )
  378.     {
  379.     pdu.auth3().hdr.rpcVersion = rpcMajorVersion ();
  380.     pdu.auth3().hdr.rpcMinorVersion = rpcMinorVersion ();
  381.     pdu.auth3().hdr.packetType = RPC_CN_PKT_AUTH3;
  382.     pdu.auth3().hdr.flags = RPC_CN_FLAGS_FIRST_FRAG |
  383.      RPC_CN_FLAGS_LAST_FRAG;
  384.     pdu.auth3().hdr.drep [0] = VXDCOM_NDR_DATAREP0;
  385.     pdu.auth3().hdr.drep [1] = VXDCOM_NDR_DATAREP1;
  386.     pdu.auth3().hdr.drep [2] = VXDCOM_NDR_DATAREP2;
  387.     pdu.auth3().hdr.drep [3] = VXDCOM_NDR_DATAREP3;
  388.     pdu.auth3().hdr.fragLen = 0; // fix later
  389.     pdu.auth3().hdr.authLen = 0;
  390.     pdu.auth3().hdr.callId = callId;
  391.     pdu.auth3().maxTxFrag = RpcPdu::MAXLEN;
  392.     pdu.auth3().maxRxFrag = RpcPdu::MAXLEN;
  393.     }