Clone of Bael'Zharon's Respite @ https://github.com/boardwalk/bzr

BlobWriter.cpp 1.3KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. /*
  2. * Bael'Zharon's Respite
  3. * Copyright (C) 2014 Daniel Skorupski
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation; either version 2 of the License, or
  8. * (at your option) any later version.
  9. * This program is distributed in the hope that it will be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. * GNU General Public License for more details.
  13. *
  14. * You should have received a copy of the GNU General Public License along
  15. * with this program; if not, write to the Free Software Foundation, Inc.,
  16. * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  17. */
  18. #include "net/BlobWriter.h"
  19. #include "net/SessionManager.h"
  20. #include "Core.h"
  21. BlobWriter::BlobWriter(MessageType messageType, NetQueueId queueId)
  22. {
  23. void* p = malloc(sizeof(Blob) + kMaxFragmentSize);
  24. blob_.reset(reinterpret_cast<Blob*>(p));
  25. blob_->count = 1;
  26. blob_->queueId = static_cast<uint16_t>(queueId);
  27. data_ = blob_.get() + 1;
  28. size_ = kMaxFragmentSize;
  29. writeInt(static_cast<uint32_t>(messageType));
  30. }
  31. BlobWriter::~BlobWriter()
  32. {
  33. blob_->size = position_;
  34. Core::get().sessionManager().sendBlob(move(blob_));
  35. }