src/builder.cc

   1 ///
   2 /// \file       builder.cc
   3 ///             Virtual protocol packet builder wrapper
   4 ///
   5
   6 /*
   7     Copyright (C) 2005-2011, Net Direct Inc. (http://www.netdirect.ca/)
   8
   9     This program is free software; you can redistribute it and/or modify
  10     it under the terms of the GNU General Public License as published by
  11     the Free Software Foundation; either version 2 of the License, or
  12     (at your option) any later version.
  13
  14     This program is distributed in the hope that it will be useful,
  15     but WITHOUT ANY WARRANTY; without even the implied warranty of
  16     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  17
  18     See the GNU General Public License in the COPYING file at the
  19     root directory of this project for more details.
  20 */
  21
  22 #include "builder.h"
  23 #include <stdexcept>
  24 #include <string.h>
  25
  26 namespace Barry {
  27
  28 //////////////////////////////////////////////////////////////////////////////
  29 // DBDataBuilder class
  30
  31
  32 DBDataBuilder::DBDataBuilder(const DBData &orig)
  33         : m_orig(orig)
  34 {
  35 }
  36
  37 DBDataBuilder::~DBDataBuilder()
  38 {
  39 }
  40
  41 bool DBDataBuilder::BuildRecord(DBData &data, size_t &offset,
  42                                 const IConverter *ic)
  43 {
  44         if( offset == m_orig.GetOffset() ) {
  45                 data = m_orig;
  46         }
  47         else {
  48                 // copy the metadata
  49                 data.CopyMeta(m_orig);
  50
  51                 // copy the buffer, to the new offset
  52                 if( m_orig.GetOffset() > m_orig.GetData().GetSize() )
  53                         throw std::logic_error("DBDataBuilder: offset greater than size");
  54                 size_t actual = m_orig.GetData().GetSize() - m_orig.GetOffset();
  55                 size_t total = offset + actual;
  56                 unsigned char *buf = data.UseData().GetBuffer(total);
  57                 memcpy(buf + offset,
  58                         m_orig.GetData().GetData() + m_orig.GetOffset(),
  59                         actual);
  60                 data.UseData().ReleaseBuffer(total);
  61
  62                 // set the new offset
  63                 data.SetOffset(offset);
  64         }
  65         return true;
  66 }
  67
  68 bool DBDataBuilder::FetchRecord(DBData &data, const IConverter *ic)
  69 {
  70         data = m_orig;
  71         return true;
  72 }
  73
  74 bool DBDataBuilder::EndOfFile() const
  75 {
  76         return true;
  77 }
  78
  79 } // namespace Barry
  80
  81