com0com-cvs

[Vyacheslav F. <vf...@us...>]

Update of /cvsroot/com0com/hub4com
In directory sc8-pr-cvs4.sourceforge.net:/tmp/cvs-serv7613

Added Files:
	hubmsg.cpp hubmsg.h 
Log Message:
Initial revision









--- NEW FILE: hubmsg.h ---
/*
 * $Id: hubmsg.h,v 1.1 2008/03/26 08:36:03 vfrolov Exp $
 *
 * Copyright (c) 2008 Vyacheslav Frolov
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 *
 * $Log: hubmsg.h,v $
 * Revision 1.1  2008/03/26 08:36:03  vfrolov
 * Initial revision
 *
 *
 */

#ifndef _HUBMSG_H
#define _HUBMSG_H

///////////////////////////////////////////////////////////////
#include "plugins/plugins_api.h"
///////////////////////////////////////////////////////////////
#define MSG_SIGNATURE 'h4cM'
///////////////////////////////////////////////////////////////
class HubMsg : public HUB_MSG
{
  public:
    HubMsg();
    ~HubMsg();

    void Clean();
    void Merge(HubMsg *pMsg);
    HubMsg *Clone() const;

    void Insert(HubMsg *pPrevMsg) {
      _ASSERTE(signature == MSG_SIGNATURE);
      _ASSERTE(pPrevMsg->signature == MSG_SIGNATURE);

      pNext = pPrevMsg->pNext;
      pPrevMsg->pNext = this;
    }

    HubMsg *Next() {
      _ASSERTE(signature == MSG_SIGNATURE);

      return pNext;
    }

  private:
    HubMsg *pNext;

#ifdef _DEBUG
    DWORD signature;
#endif
};
///////////////////////////////////////////////////////////////

#endif /* _HUBMSG_H */

--- NEW FILE: hubmsg.cpp ---
/*
 * $Id: hubmsg.cpp,v 1.1 2008/03/26 08:36:03 vfrolov Exp $
 *
 * Copyright (c) 2008 Vyacheslav Frolov
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 *
 * $Log: hubmsg.cpp,v $
 * Revision 1.1  2008/03/26 08:36:03  vfrolov
 * Initial revision
 *
 *
 */

#include "precomp.h"
#include "hubmsg.h"
#include "bufutils.h"

///////////////////////////////////////////////////////////////
HubMsg::HubMsg()
  : pNext(NULL)
{
#ifdef _DEBUG
  signature = MSG_SIGNATURE;
#endif

  ::memset((HUB_MSG *)this, 0, sizeof(HUB_MSG));
}
///////////////////////////////////////////////////////////////
HubMsg::~HubMsg()
{
  _ASSERTE(signature == MSG_SIGNATURE);

  if (pNext)
    delete pNext;

  Clean();

#ifdef _DEBUG
  signature = 0;
#endif
}
///////////////////////////////////////////////////////////////
HubMsg *HubMsg::Clone() const
{
  _ASSERTE(signature == MSG_SIGNATURE);

  HubMsg *pNewMsg = new HubMsg();

  if (!pNewMsg)
    return NULL;

  if (pNext) {
    pNewMsg->pNext = pNext->Clone();

    if (!pNewMsg->pNext) {
      delete pNewMsg;
      return NULL;
    }
  }

  if ((type & HUB_MSG_UNION_TYPE_MASK) == HUB_MSG_UNION_TYPE_BUF) {
    BufAppend(&pNewMsg->u.buf.pBuf, 0, u.buf.pBuf, u.buf.size);

    if (pNewMsg->u.buf.pBuf || !u.buf.size) {
      pNewMsg->type = type;
      pNewMsg->u.buf.size = u.buf.size;
    } else {
      delete pNewMsg;
      return NULL;
    }
  } else {
    *(HUB_MSG *)pNewMsg = *(const HUB_MSG *)this;
  }

  return pNewMsg;
}
///////////////////////////////////////////////////////////////
void HubMsg::Clean()
{
  _ASSERTE(signature == MSG_SIGNATURE);

  if ((type & HUB_MSG_UNION_TYPE_MASK) == HUB_MSG_UNION_TYPE_BUF)
    BufFree(u.buf.pBuf);

  ::memset((HUB_MSG *)this, 0, sizeof(HUB_MSG));
}
///////////////////////////////////////////////////////////////
void HubMsg::Merge(HubMsg *pMsg)
{
  _ASSERTE(signature == MSG_SIGNATURE);
  _ASSERTE(pMsg == NULL || pMsg->signature == MSG_SIGNATURE);

  HubMsg **ppNext = &pNext;
  while (*ppNext)
    ppNext = &(*ppNext)->pNext;

  *ppNext = pMsg;
}
///////////////////////////////////////////////////////////////