opcda_ps.cpp

VXWORKS源代码

    hr=widlMarshal (&pPercentDeadband, pms, ndrtypes.refptr_t(ndrtypes.float_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pLCID, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&phClientGroup, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&phServerGroup, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    if ((*ppName)) {CoTaskMemFree ((*ppName));};
    return S_OK;
    }

HRESULT STDMETHODCALLTYPE IOPCGroupStateMgt_SetState_vxproxy (IOPCGroupStateMgt* pThis, DWORD* pRequestedUpdateRate, DWORD* pRevisedUpdateRate, BOOL* pActive, LONG* pTimeBias, FLOAT* pPercentDeadband, DWORD* pLCID, OPCHANDLE* phClientGroup)
    {
    RPC_PROXY_MSG	msg (IID_IOPCGroupStateMgt, RpcMode::OBJECT, 4, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&pRequestedUpdateRate, pms, ndrtypes.pointer_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pActive, pms, ndrtypes.pointer_t(ndrtypes.int_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pTimeBias, pms, ndrtypes.pointer_t(ndrtypes.long_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pPercentDeadband, pms, ndrtypes.pointer_t(ndrtypes.float_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pLCID, pms, ndrtypes.pointer_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&phClientGroup, pms, ndrtypes.pointer_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr = msg.SendReceive (); if (FAILED (hr)) return hr;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    hr=widlUnmarshal (&pRevisedUpdateRate, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr = widlUnmarshal (&hrMethod, pus, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return hrMethod;
    }

HRESULT STDMETHODCALLTYPE IOPCGroupStateMgt_SetState_vxstub (IOPCGroupStateMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    DWORD* pRequestedUpdateRate;
    hr=widlUnmarshal (&pRequestedUpdateRate, pus, ndrtypes.pointer_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    BOOL* pActive;
    hr=widlUnmarshal (&pActive, pus, ndrtypes.pointer_t(ndrtypes.int_t ())); if (FAILED(hr)) return hr;
    LONG* pTimeBias;
    hr=widlUnmarshal (&pTimeBias, pus, ndrtypes.pointer_t(ndrtypes.long_t ())); if (FAILED(hr)) return hr;
    FLOAT* pPercentDeadband;
    hr=widlUnmarshal (&pPercentDeadband, pus, ndrtypes.pointer_t(ndrtypes.float_t ())); if (FAILED(hr)) return hr;
    DWORD* pLCID;
    hr=widlUnmarshal (&pLCID, pus, ndrtypes.pointer_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    OPCHANDLE* phClientGroup;
    hr=widlUnmarshal (&phClientGroup, pus, ndrtypes.pointer_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    DWORD pRevisedUpdateRate_tmp;
    DWORD* pRevisedUpdateRate = &pRevisedUpdateRate_tmp;
    hrMethod = pitf->SetState (pRequestedUpdateRate, pRevisedUpdateRate, pActive, pTimeBias, pPercentDeadband, pLCID, phClientGroup);

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&pRevisedUpdateRate, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return S_OK;
    }

HRESULT STDMETHODCALLTYPE IOPCGroupStateMgt_SetName_vxproxy (IOPCGroupStateMgt* pThis, LPCWSTR szName)
    {
    RPC_PROXY_MSG	msg (IID_IOPCGroupStateMgt, RpcMode::OBJECT, 5, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&szName, pms, ndrtypes.refptr_t(ndrtypes.wstring_t ())); if (FAILED(hr)) return hr;
    hr = msg.SendReceive (); if (FAILED (hr)) return hr;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    hr = widlUnmarshal (&hrMethod, pus, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return hrMethod;
    }

HRESULT STDMETHODCALLTYPE IOPCGroupStateMgt_SetName_vxstub (IOPCGroupStateMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    LPCWSTR szName;
    hr=widlUnmarshal (&szName, pus, ndrtypes.refptr_t(ndrtypes.wstring_t ())); if (FAILED(hr)) return hr;
    hrMethod = pitf->SetName (szName);

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return S_OK;
    }

HRESULT STDMETHODCALLTYPE IOPCGroupStateMgt_CloneGroup_vxproxy (IOPCGroupStateMgt* pThis, LPCWSTR szName, REFIID riid, LPUNKNOWN* ppUnk)
    {
    RPC_PROXY_MSG	msg (IID_IOPCGroupStateMgt, RpcMode::OBJECT, 6, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&szName, pms, ndrtypes.refptr_t(ndrtypes.wstring_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&riid, pms, StructDesc__GUID (ndrtypes)); if (FAILED(hr)) return hr;
    hr = msg.SendReceive (); if (FAILED (hr)) return hr;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    hr=widlUnmarshal (&ppUnk, pus, ndrtypes.refptr_t(ndrtypes.interfaceptr_t (IID_IUnknown))); if (FAILED(hr)) return hr;
    hr = widlUnmarshal (&hrMethod, pus, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return hrMethod;
    }

HRESULT STDMETHODCALLTYPE IOPCGroupStateMgt_CloneGroup_vxstub (IOPCGroupStateMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    LPCWSTR szName;
    hr=widlUnmarshal (&szName, pus, ndrtypes.refptr_t(ndrtypes.wstring_t ())); if (FAILED(hr)) return hr;
    IID riid;
    hr=widlUnmarshal (&riid, pus, StructDesc__GUID (ndrtypes)); if (FAILED(hr)) return hr;
    LPUNKNOWN ppUnk_tmp;
    LPUNKNOWN* ppUnk = &ppUnk_tmp;
    hrMethod = pitf->CloneGroup (szName, riid, ppUnk);

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&ppUnk, pms, ndrtypes.refptr_t(ndrtypes.interfaceptr_t (IID_IUnknown))); if (FAILED(hr)) return hr;
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    if ((*ppUnk)) {((*ppUnk))->Release ();};
    return S_OK;
    }

COM_VTABLE(IOPCGroupStateMgt) IOPCGroupStateMgt_vxproxy_vtbl = {
    COM_VTBL_HEADER
    COM_VTBL_METHOD(&IUnknown_QueryInterface_vxproxy),
    COM_VTBL_METHOD(&IUnknown_AddRef_vxproxy),
    COM_VTBL_METHOD(&IUnknown_Release_vxproxy),
    COM_VTBL_METHOD(&IOPCGroupStateMgt_GetState_vxproxy),
    COM_VTBL_METHOD(&IOPCGroupStateMgt_SetState_vxproxy),
    COM_VTBL_METHOD(&IOPCGroupStateMgt_SetName_vxproxy),
    COM_VTBL_METHOD(&IOPCGroupStateMgt_CloneGroup_vxproxy),
    };

const PFN_ORPC_STUB stub_functbl_IOPCGroupStateMgt [] =
    {
    0,0,0,
    (PFN_ORPC_STUB) IOPCGroupStateMgt_GetState_vxstub,
    (PFN_ORPC_STUB) IOPCGroupStateMgt_SetState_vxstub,
    (PFN_ORPC_STUB) IOPCGroupStateMgt_SetName_vxstub,
    (PFN_ORPC_STUB) IOPCGroupStateMgt_CloneGroup_vxstub,
    };

EXTERN_C const VXDCOM_STUB_DISPTBL IOPCGroupStateMgt_vxstub_disptbl =
    {
    7,
    stub_functbl_IOPCGroupStateMgt
    };

VXDCOM_PS_AUTOREGISTER(IOPCGroupStateMgt);

HRESULT STDMETHODCALLTYPE IOPCPublicGroupStateMgt_GetState_vxproxy (IOPCPublicGroupStateMgt* pThis, BOOL* pPublic)
    {
    RPC_PROXY_MSG	msg (IID_IOPCPublicGroupStateMgt, RpcMode::OBJECT, 3, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    hr = msg.SendReceive (); if (FAILED (hr)) return hr;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    hr=widlUnmarshal (&pPublic, pus, ndrtypes.refptr_t(ndrtypes.int_t ())); if (FAILED(hr)) return hr;
    hr = widlUnmarshal (&hrMethod, pus, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return hrMethod;
    }

HRESULT STDMETHODCALLTYPE IOPCPublicGroupStateMgt_GetState_vxstub (IOPCPublicGroupStateMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    BOOL pPublic_tmp;
    BOOL* pPublic = &pPublic_tmp;
    hrMethod = pitf->GetState (pPublic);

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&pPublic, pms, ndrtypes.refptr_t(ndrtypes.int_t ())); if (FAILED(hr)) return hr;
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return S_OK;
    }

HRESULT STDMETHODCALLTYPE IOPCPublicGroupStateMgt_MoveToPublic_vxproxy (IOPCPublicGroupStateMgt* pThis)
    {
    RPC_PROXY_MSG	msg (IID_IOPCPublicGroupStateMgt, RpcMode::OBJECT, 4, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    hr = msg.SendReceive (); if (FAILED (hr)) return hr;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    hr = widlUnmarshal (&hrMethod, pus, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return hrMethod;
    }

HRESULT STDMETHODCALLTYPE IOPCPublicGroupStateMgt_MoveToPublic_vxstub (IOPCPublicGroupStateMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    hrMethod = pitf->MoveToPublic ();

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return S_OK;
    }

COM_VTABLE(IOPCPublicGroupStateMgt) IOPCPublicGroupStateMgt_vxproxy_vtbl = {
    COM_VTBL_HEADER
    COM_VTBL_METHOD(&IUnknown_QueryInterface_vxproxy),
    COM_VTBL_METHOD(&IUnknown_AddRef_vxproxy),
    COM_VTBL_METHOD(&IUnknown_Release_vxproxy),
    COM_VTBL_METHOD(&IOPCPublicGroupStateMgt_GetState_vxproxy),
    COM_VTBL_METHOD(&IOPCPublicGroupStateMgt_MoveToPublic_vxproxy),
    };

const PFN_ORPC_STUB stub_functbl_IOPCPublicGroupStateMgt [] =
    {
    0,0,0,
    (PFN_ORPC_STUB) IOPCPublicGroupStateMgt_GetState_vxstub,
    (PFN_ORPC_STUB) IOPCPublicGroupStateMgt_MoveToPublic_vxstub,
    };

EXTERN_C const VXDCOM_STUB_DISPTBL IOPCPublicGroupStateMgt_vxstub_disptbl =
    {
    5,
    stub_functbl_IOPCPublicGroupStateMgt
    };

VXDCOM_PS_AUTOREGISTER(IOPCPublicGroupStateMgt);

HRESULT STDMETHODCALLTYPE IOPCSyncIO_Read_vxproxy (IOPCSyncIO* pThis, OPCDATASOURCE dwSource, DWORD dwCount, OPCHANDLE* phServer, OPCITEMSTATE** ppItemValues, HRESULT** ppErrors)
    {
    RPC_PROXY_MSG	msg (IID_IOPCSyncIO, RpcMode::OBJECT, 3, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&dwSource, pms, ndrtypes.enum_t ()); if (FAILED(hr)) return hr;
    hr=widlMarshal (&dwCount, pms, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    hr=widlMarshal (&phServer, pms, ndrtypes.refptr_t(ndrtypes.carray_t(ndrtypes.ulong_t (), NDR_SIZEOF(OPCHANDLE), dwCount))); if (FAILED(hr)) return hr;
    hr = msg.SendReceive (); if (FAILED (hr)) return hr;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    hr=widlUnmarshal (&ppItemValues, pus, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(StructDesc_tagOPCITEMSTATE (ndrtypes), NDR_SIZEOF(OPCITEMSTATE))))); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&ppErrors, pus, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.long_t (), NDR_SIZEOF(HRESULT))))); if (FAILED(hr)) return hr;
    hr = widlUnmarshal (&hrMethod, pus, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return hrMethod;
    }

HRESULT STDMETHODCALLTYPE IOPCSyncIO_Read_vxstub (IOPCSyncIO* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    OPCDATASOURCE dwSource;
    hr=widlUnmarshal (&dwSource, pus, ndrtypes.enum_t ()); if (FAILED(hr)) return hr;
    DWORD dwCount;
    hr=widlUnmarshal (&dwCount, pus, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    OPCHANDLE* phServer;
    hr=widlUnmarshal (&phServer, pus, ndrtypes.refptr_t(ndrtypes.carray_t(ndrtypes.ulong_t (), NDR_SIZEOF(OPCHANDLE)))); if (FAILED(hr)) return hr;
    OPCITEMSTATE* ppItemValues_tmp;
    OPCITEMSTATE** ppItemValues = &ppItemValues_tmp;
    HRESULT* ppErrors_tmp;
    HRESULT** ppErrors = &ppErrors_tmp;
    hrMethod = pitf->Read (dwSource, dwCount, phServer, ppItemValues, ppErrors);

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&ppItemValues, pms, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(StructDesc_tagOPCITEMSTATE (ndrtypes), NDR_SIZEOF(OPCITEMSTATE), dwCount)))); if (FAILED(hr)) return hr;
    hr=widlMarshal (&ppErrors, pms, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.long_t (), NDR_SIZEOF(HRESULT), dwCount)))); if (FAILED(hr)) return hr;
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))