12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061 |
- /* Copyright (C) 2014 Carlos Aguilar Melchor, Joris Barrier, Marc-Olivier Killijian
- * This file is part of XPIR.
- *
- * XPIR 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 3 of the License, or
- * (at your option) any later version.
- *
- * XPIR 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 XPIR. If not, see <http://www.gnu.org/licenses/>.
- */
- #ifndef DEF_PIRREPLYWRITER
- #define DEF_PIRREPLYWRITER
- #include <iostream>
- #include <boost/signals2.hpp>
- #include <boost/thread.hpp>
- #include <omp.h>
- #include <unistd.h>
- #include "pir/shared_queue.hpp"
- #include "pir/PIRParameters.hpp"
- #include "pir/ClientDefines.hpp"
- #include "pir/GlobalConstant.hpp"
- #include "crypto/PaillierAdapter.hpp"
- #include "pir/events/WriteEvent.hpp"
- #include "pir/events/MessageEvent.hpp"
- #include "apps/client/DESC.hpp"
- class PIRReplyWriter
- {
- private:
- bool dontWrite;
- string filename, filePath;
- PIRParameters& pirParams;
- HomomorphicCrypto* cryptoMethod;
- shared_queue<char*> clearChunks;
- static const std::string kDefaultFolder;
- boost::thread writeThread;
- boost::signals2::signal<void (WriteEvent&)> &writeListeners;
- boost::signals2::signal<void (MessageEvent&)> &messageListeners;
- public:
- PIRReplyWriter(PIRParameters& param, boost::signals2::signal<void ( WriteEvent& )> &writeListeners_, boost::signals2::signal<void (MessageEvent&)> &messageListeners_);
- ~PIRReplyWriter();
- void writeAggregatedFileSecurely(uint64_t chosenElement, DESC catalog);
- void writeFileSecurely(uint64_t element, DESC catalog, uint64_t &skipbytes, WriteEvent &event);
- void startFileWritting(uint64_t chosenElement, DESC catalog);
- void setCryptoMethod(HomomorphicCrypto* crypto_method);
- shared_queue<char*>* getClearDataQueue();
- void join();
- void setdontWrite(bool newvalue);
- };
- #endif
|