RemoteGeomProxy.h

Go to the documentation of this file.

 
// Copyright (C) 2002-2022, Open Design Alliance (the "Alliance"). 
// All rights reserved. 
// 
// This software and its documentation and related materials are owned by 
// the Alliance. The software may only be incorporated into application 
// programs owned by members of the Alliance, subject to a signed 
// Membership Agreement and Supplemental Software License Agreement with the
// Alliance. The structure and organization of this software are the valuable  
// trade secrets of the Alliance and its suppliers. The software is also 
// protected by copyright law and international treaty provisions. Application  
// programs incorporating this software must include the following statement 
// with their copyright notices:
//   
//   This application incorporates Open Design Alliance software pursuant to a license 
//   agreement with Open Design Alliance.
//   Open Design Alliance Copyright (C) 2002-2022 by Open Design Alliance. 
//   All rights reserved.
//
// By use of this software, its documentation or related materials, you 
// acknowledge and accept the above terms.
 
 
#ifndef _ODREMOTEGEOMPROXY_INCLUDED_
#define _ODREMOTEGEOMPROXY_INCLUDED_
 
#include "TD_PackPush.h"
 
#include "Gi/GiWorldDraw.h"
#include "DbDatabase.h"
#include "SmartPtr.h"
#include "Ge/GeCircArc2d.h"
#include "UInt8Array.h"
 
DBIO_EXPORT OdSmartPtr<OdGiWorldDraw> oddbBeginProxyGraphics( OdDbDatabase* pDbCtx );
DBIO_EXPORT void oddbEndProxyGraphics( OdGiWorldDraw* pWdSaver, OdUInt8Array& graphics );
 
class OdRemoteGeomProxy {
protected:
  OdDbDatabasePtr           m_pDb;
  OdSmartPtr<OdGiWorldDraw> m_pWd;
public:
 
  // For the internal use.
  enum Opcode {
    kGraphics,
    kStringToExecute
  };
 
  // Constructor.
  OdRemoteGeomProxy();
  ~OdRemoteGeomProxy();
 
  // Initialize reference database that is used for some operations (e.g. font rendering).
  // If you certain that such operations would not be executed you can omit it.
  void setDatabase(OdDbDatabase* pDb);
 
  // Initializes collecting geometry to send.
  void begin();
 
  // Returns OdGiWorldDraw object to output geometry to
  OdGiWorldDraw& wDraw();
 
  // Returns OdGiWorldGeometry object to output geometry to.
  // Shortcut for wDraw().geometry() expression.
  OdGiWorldGeometry& wGeom();
 
  // Returns OdGiSubEntityTraits object to output geometry to.
  // Shortcut for wDraw().subEntityTraits() expression.
  OdGiSubEntityTraits& traits();
 
  // Sends geometry collected since last call of begin() method to
  // Remote Geometry Viewer over the named pipe.
  void end();
 
  // Sends a string for execution to Remote Geometry Viewer.
  // That string will be send to execution to RX command line engine.
  // See OdEdCommandStack for detailes.
  void sendStringToExecute( const OdString& s );
};
 
static const OdString g_strGeomBlockBegin = OD_T("rblock_begin");
static const OdString g_strGeomBlockEnd = OD_T("rblock_end");
 
class OdRemoteGeomProxyAutoBlock
{
  OdRemoteGeomProxy* m_pProxy;
 
public:
  OdRemoteGeomProxyAutoBlock(OdRemoteGeomProxy& proxy) : m_pProxy(&proxy)
  {
    m_pProxy->sendStringToExecute(g_strGeomBlockBegin);
  }
 
  ~OdRemoteGeomProxyAutoBlock()
  {
    m_pProxy->sendStringToExecute(g_strGeomBlockEnd);
  }
 
};
 
inline
OdRemoteGeomProxy::OdRemoteGeomProxy()
{  
}
 
inline
OdRemoteGeomProxy::~OdRemoteGeomProxy()
{  
}
 
inline void
OdRemoteGeomProxy::setDatabase(OdDbDatabase* pDb) {
  m_pDb = pDb;
}
 
inline void OdRemoteGeomProxy::begin() {
  m_pWd = ::oddbBeginProxyGraphics( m_pDb );
}
 
inline OdGiWorldDraw&
OdRemoteGeomProxy::wDraw() {
  return *m_pWd;
}
 
inline OdGiWorldGeometry&
OdRemoteGeomProxy::wGeom() {
  return m_pWd->geometry();
}
 
inline OdGiSubEntityTraits&
OdRemoteGeomProxy::traits() {
  return m_pWd->subEntityTraits();
}
 
inline void
OdRemoteGeomProxy::end() 
{
#if defined(_WIN32) && !defined(_WINRT) && !defined(_WIN32_WCE)
 
  if( m_pWd.get() )
  { 
    HANDLE hBufferWritten = ::OpenEvent(EVENT_MODIFY_STATE | SYNCHRONIZE, FALSE, L"OdaRemoteGeometryBufferWrittenEvent");
    HANDLE hBufferProcessed = ::OpenEvent(EVENT_MODIFY_STATE | SYNCHRONIZE, FALSE, L"OdaRemoteGeometryBufferProcessedEvent");
 
    if(hBufferWritten != NULL && hBufferProcessed != NULL)
    {
      ::WaitForSingleObject(hBufferProcessed, INFINITE);      
      //::ResetEvent(hBufferProcessed);
 
      HANDLE hIPCFile = ::OpenFileMapping(FILE_MAP_READ | FILE_MAP_WRITE, FALSE, L"OdaRemoteGeometryViewerIPCBuffer");
      if(hIPCFile != NULL)
      {
        void* pBuffer = ::MapViewOfFile(hIPCFile, FILE_MAP_READ | FILE_MAP_WRITE, 0, 0, 0);
        if(pBuffer != NULL)
        {
          OdInt8* pIpcFile = reinterpret_cast<OdInt8*>(pBuffer);
 
          OdUInt8Array graphics;
          ::oddbEndProxyGraphics( m_pWd, graphics );
 
          OdUInt32 n = kGraphics;        
          memcpy(pIpcFile, &n, sizeof(n)); 
          pIpcFile += sizeof(n);
 
          n = graphics.size();
          memcpy(pIpcFile, &n, sizeof(n)); 
          pIpcFile += sizeof(n);
 
          memcpy(pIpcFile, graphics.getPtr(), graphics.size());
 
          ::UnmapViewOfFile(pBuffer);
        }
        ::CloseHandle(hIPCFile);        
      }
 
      ::SetEvent(hBufferWritten);
    }
    ::CloseHandle(hBufferWritten);
    ::CloseHandle(hBufferProcessed);
    m_pWd.release();
  }
 
#endif //_WIN32
}
 
inline void
OdRemoteGeomProxy::sendStringToExecute( const OdString& s ) 
{
#if defined(_WIN32) && !defined(_WINRT) && !defined(_WIN32_WCE)
 
  HANDLE hBufferWritten = ::OpenEvent(EVENT_MODIFY_STATE | SYNCHRONIZE, FALSE, L"OdaRemoteGeometryBufferWrittenEvent");
  HANDLE hBufferProcessed = ::OpenEvent(EVENT_MODIFY_STATE | SYNCHRONIZE, FALSE, L"OdaRemoteGeometryBufferProcessedEvent");
 
  if(hBufferWritten != NULL && hBufferProcessed != NULL)
  {
    ::WaitForSingleObject(hBufferProcessed, INFINITE);
 
    HANDLE hIPCFile = ::OpenFileMapping(FILE_MAP_READ | FILE_MAP_WRITE, FALSE, L"OdaRemoteGeometryViewerIPCBuffer");
    if(hIPCFile != NULL)
    {
      void* pBuffer = ::MapViewOfFile(hIPCFile, FILE_MAP_READ | FILE_MAP_WRITE, 0, 0, 0);
      if(pBuffer != NULL)
      {
        OdInt8* pIpcFile = reinterpret_cast<OdInt8*>(pBuffer);
 
        OdUInt32 n = kStringToExecute;        
        memcpy(pIpcFile, &n, sizeof(n)); 
        pIpcFile += sizeof(n);
 
        n = (s.getLength() + 1) * 2;
        memcpy(pIpcFile, &n, sizeof(n)); 
        
        pIpcFile += sizeof(n);
        memcpy(pIpcFile, s.c_str(), n);
 
        ::UnmapViewOfFile(pBuffer);
      }
      ::CloseHandle(hIPCFile);        
    }
 
    ::SetEvent(hBufferWritten);
  }
  
  ::CloseHandle(hBufferWritten);
  ::CloseHandle(hBufferProcessed);
 
#endif //_WIN32
}
 
#include "TD_PackPop.h"
 
#endif //_ODREMOTEGEOMPROXY_INCLUDED_