opc_ae_ps.cpp

VXWORKS源代码

    hr=widlUnmarshal (&pdwNumCategories, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&ppdwEventCategories, pus, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.ulong_t (), NDR_SIZEOF(DWORD))))); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&pdwLowSeverity, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&pdwHighSeverity, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&pdwNumAreas, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&ppszAreaList, pus, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.pointer_t(ndrtypes.wstring_t ()), NDR_SIZEOF(LPWSTR))))); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&pdwNumSources, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&ppszSourceList, pus, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.pointer_t(ndrtypes.wstring_t ()), NDR_SIZEOF(LPWSTR))))); if (FAILED(hr)) return hr;
    hr = widlUnmarshal (&hrMethod, pus, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return hrMethod;
    }

HRESULT STDMETHODCALLTYPE IOPCEventSubscriptionMgt_GetFilter_vxstub (IOPCEventSubscriptionMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    DWORD pdwEventType_tmp;
    DWORD* pdwEventType = &pdwEventType_tmp;
    DWORD pdwNumCategories_tmp;
    DWORD* pdwNumCategories = &pdwNumCategories_tmp;
    DWORD* ppdwEventCategories_tmp;
    DWORD** ppdwEventCategories = &ppdwEventCategories_tmp;
    DWORD pdwLowSeverity_tmp;
    DWORD* pdwLowSeverity = &pdwLowSeverity_tmp;
    DWORD pdwHighSeverity_tmp;
    DWORD* pdwHighSeverity = &pdwHighSeverity_tmp;
    DWORD pdwNumAreas_tmp;
    DWORD* pdwNumAreas = &pdwNumAreas_tmp;
    LPWSTR* ppszAreaList_tmp;
    LPWSTR** ppszAreaList = &ppszAreaList_tmp;
    DWORD pdwNumSources_tmp;
    DWORD* pdwNumSources = &pdwNumSources_tmp;
    LPWSTR* ppszSourceList_tmp;
    LPWSTR** ppszSourceList = &ppszSourceList_tmp;
    hrMethod = pitf->GetFilter (pdwEventType, pdwNumCategories, ppdwEventCategories, pdwLowSeverity, pdwHighSeverity, pdwNumAreas, ppszAreaList, pdwNumSources, ppszSourceList);

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&pdwEventType, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pdwNumCategories, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&ppdwEventCategories, pms, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.ulong_t (), NDR_SIZEOF(DWORD), *pdwNumCategories)))); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pdwLowSeverity, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pdwHighSeverity, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pdwNumAreas, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&ppszAreaList, pms, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.pointer_t(ndrtypes.wstring_t ()), NDR_SIZEOF(LPWSTR), *pdwNumAreas)))); if (FAILED(hr)) return hr;
    hr=widlMarshal (&pdwNumSources, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&ppszSourceList, pms, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.pointer_t(ndrtypes.wstring_t ()), NDR_SIZEOF(LPWSTR), *pdwNumSources)))); if (FAILED(hr)) return hr;
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    if ((*ppdwEventCategories)) {CoTaskMemFree ((*ppdwEventCategories));}if ((*ppszAreaList)) {{for (DWORD __ix=0; __ix < *pdwNumAreas; ++__ix) {if (((*ppszAreaList)[__ix])) {CoTaskMemFree (((*ppszAreaList)[__ix]));}}}CoTaskMemFree ((*ppszAreaList));}if ((*ppszSourceList)) {{for (DWORD __ix=0; __ix < *pdwNumSources; ++__ix) {if (((*ppszSourceList)[__ix])) {CoTaskMemFree (((*ppszSourceList)[__ix]));}}}CoTaskMemFree ((*ppszSourceList));};
    return S_OK;
    }

HRESULT STDMETHODCALLTYPE IOPCEventSubscriptionMgt_SelectReturnedAttributes_vxproxy (IOPCEventSubscriptionMgt* pThis, DWORD dwEventCategory, DWORD dwCount, DWORD* dwAttributeIDs)
    {
    RPC_PROXY_MSG	msg (IID_IOPCEventSubscriptionMgt, RpcMode::OBJECT, 5, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&dwEventCategory, pms, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    hr=widlMarshal (&dwCount, pms, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    hr=widlMarshal (&dwAttributeIDs, pms, ndrtypes.refptr_t(ndrtypes.carray_t(ndrtypes.ulong_t (), NDR_SIZEOF(DWORD), dwCount))); 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 IOPCEventSubscriptionMgt_SelectReturnedAttributes_vxstub (IOPCEventSubscriptionMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    DWORD dwEventCategory;
    hr=widlUnmarshal (&dwEventCategory, pus, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    DWORD dwCount;
    hr=widlUnmarshal (&dwCount, pus, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    DWORD* dwAttributeIDs;
    hr=widlUnmarshal (&dwAttributeIDs, pus, ndrtypes.refptr_t(ndrtypes.carray_t(ndrtypes.ulong_t (), NDR_SIZEOF(DWORD)))); if (FAILED(hr)) return hr;
    hrMethod = pitf->SelectReturnedAttributes (dwEventCategory, dwCount, dwAttributeIDs);

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

HRESULT STDMETHODCALLTYPE IOPCEventSubscriptionMgt_GetReturnedAttributes_vxproxy (IOPCEventSubscriptionMgt* pThis, DWORD dwEventCategory, DWORD* pdwCount, DWORD** ppdwAttributeIDs)
    {
    RPC_PROXY_MSG	msg (IID_IOPCEventSubscriptionMgt, RpcMode::OBJECT, 6, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&dwEventCategory, pms, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    hr = msg.SendReceive (); if (FAILED (hr)) return hr;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    hr=widlUnmarshal (&pdwCount, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&ppdwAttributeIDs, pus, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.ulong_t (), NDR_SIZEOF(DWORD))))); if (FAILED(hr)) return hr;
    hr = widlUnmarshal (&hrMethod, pus, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    return hrMethod;
    }

HRESULT STDMETHODCALLTYPE IOPCEventSubscriptionMgt_GetReturnedAttributes_vxstub (IOPCEventSubscriptionMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    DWORD dwEventCategory;
    hr=widlUnmarshal (&dwEventCategory, pus, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    DWORD pdwCount_tmp;
    DWORD* pdwCount = &pdwCount_tmp;
    DWORD* ppdwAttributeIDs_tmp;
    DWORD** ppdwAttributeIDs = &ppdwAttributeIDs_tmp;
    hrMethod = pitf->GetReturnedAttributes (dwEventCategory, pdwCount, ppdwAttributeIDs);

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&pdwCount, pms, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlMarshal (&ppdwAttributeIDs, pms, ndrtypes.refptr_t(ndrtypes.pointer_t(ndrtypes.carray_t(ndrtypes.ulong_t (), NDR_SIZEOF(DWORD), *pdwCount)))); if (FAILED(hr)) return hr;
    hr = widlMarshal (&hrMethod, pms, ndrtypes.hresult_t());
    if (FAILED(hr))
        return hr;
    if ((*ppdwAttributeIDs)) {CoTaskMemFree ((*ppdwAttributeIDs));};
    return S_OK;
    }

HRESULT STDMETHODCALLTYPE IOPCEventSubscriptionMgt_Refresh_vxproxy (IOPCEventSubscriptionMgt* pThis, DWORD dwConnection)
    {
    RPC_PROXY_MSG	msg (IID_IOPCEventSubscriptionMgt, RpcMode::OBJECT, 7, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&dwConnection, pms, ndrtypes.ulong_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 IOPCEventSubscriptionMgt_Refresh_vxstub (IOPCEventSubscriptionMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    DWORD dwConnection;
    hr=widlUnmarshal (&dwConnection, pus, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    hrMethod = pitf->Refresh (dwConnection);

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

HRESULT STDMETHODCALLTYPE IOPCEventSubscriptionMgt_CancelRefresh_vxproxy (IOPCEventSubscriptionMgt* pThis, DWORD dwConnection)
    {
    RPC_PROXY_MSG	msg (IID_IOPCEventSubscriptionMgt, RpcMode::OBJECT, 8, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    NdrMarshalStream* pms = msg.marshalStreamGet ();
    hr=widlMarshal (&dwConnection, pms, ndrtypes.ulong_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 IOPCEventSubscriptionMgt_CancelRefresh_vxstub (IOPCEventSubscriptionMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    DWORD dwConnection;
    hr=widlUnmarshal (&dwConnection, pus, ndrtypes.ulong_t ()); if (FAILED(hr)) return hr;
    hrMethod = pitf->CancelRefresh (dwConnection);

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

HRESULT STDMETHODCALLTYPE IOPCEventSubscriptionMgt_GetState_vxproxy (IOPCEventSubscriptionMgt* pThis, BOOL* pbActive, DWORD* pdwBufferTime, DWORD* pdwMaxSize, OPCHANDLE* phClientSubscription)
    {
    RPC_PROXY_MSG	msg (IID_IOPCEventSubscriptionMgt, RpcMode::OBJECT, 9, pThis);
    NDRTYPES		ndrtypes;
    HRESULT		hrMethod;
    HRESULT		hr;

    hr = msg.SendReceive (); if (FAILED (hr)) return hr;
    NdrUnmarshalStream* pus = msg.unmarshalStreamGet ();
    hr=widlUnmarshal (&pbActive, pus, ndrtypes.refptr_t(ndrtypes.int_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&pdwBufferTime, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&pdwMaxSize, pus, ndrtypes.refptr_t(ndrtypes.ulong_t ())); if (FAILED(hr)) return hr;
    hr=widlUnmarshal (&phClientSubscription, 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 IOPCEventSubscriptionMgt_GetState_vxstub (IOPCEventSubscriptionMgt* pitf, RPC_STUB_MSG& msg)
    {
    NDRTYPES	ndrtypes;
    HRESULT	hr;
    HRESULT	hrMethod;
    BOOL pbActive_tmp;
    BOOL* pbActive = &pbActive_tmp;
    DWORD pdwBufferTime_tmp;
    DWORD* pdwBufferTime = &pdwBufferTime_tmp;
    DWORD pdwMaxSize_tmp