Mercurial > hg > orthanc-transfers
view Framework/DownloadArea.h @ 72:d60d1a3a7357 OrthancTransfers-1.4
fix md5
author | Alain Mazy <am@osimis.io> |
---|---|
date | Tue, 26 Mar 2024 10:16:15 +0100 |
parents | 44a0430d7899 |
children | 1e396fb509ca |
line wrap: on
line source
/** * Transfers accelerator plugin for Orthanc * Copyright (C) 2018-2021 Osimis S.A., Belgium * * This program is free software: you can redistribute it and/or * modify it under the terms of the GNU Affero General Public License * as published by the Free Software Foundation, either version 3 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 * Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>. **/ #pragma once #include "TransferScheduler.h" #include <TemporaryFile.h> namespace OrthancPlugins { class DownloadArea : public boost::noncopyable { private: class Instance : public boost::noncopyable { private: DicomInstanceInfo info_; Orthanc::TemporaryFile file_; class Writer; public: explicit Instance(const DicomInstanceInfo& info); const DicomInstanceInfo& GetInfo() const { return info_; } void WriteChunk(size_t offset, const void* data, size_t size); void Commit(bool simulate) const; }; typedef std::map<std::string, Instance*> Instances; boost::mutex mutex_; Instances instances_; size_t totalSize_; void Clear(); Instance& LookupInstance(const std::string& id); void WriteUncompressedBucket(const TransferBucket& bucket, const void* data, size_t size); void Setup(const std::vector<DicomInstanceInfo>& instances); void CommitInternal(bool simulate); public: explicit DownloadArea(const TransferScheduler& scheduler); explicit DownloadArea(const std::vector<DicomInstanceInfo>& instances) { Setup(instances); } ~DownloadArea() { Clear(); } size_t GetTotalSize() const { return totalSize_; } void WriteBucket(const TransferBucket& bucket, const void* data, size_t size, BucketCompression compression); void WriteInstance(const std::string& instanceId, const void* data, size_t size); void CheckMD5(); void Commit(); }; }