src/ParallelFilesystemCommand.h
branchv_0
changeset 57 c40a241d6e0c
parent 56 81a53e7cf0ab
child 58 4679f67a8324
--- a/src/ParallelFilesystemCommand.h	Mon Jan 20 23:47:54 2020 +0100
+++ b/src/ParallelFilesystemCommand.h	Tue Jan 21 00:19:56 2020 +0100
@@ -18,6 +18,7 @@
 
 #include <mqueue.h>
 #include <limits.h>
+#include <ext/stdio_filebuf.h>
 
 #include "FilesystemCommand.h"
 
@@ -125,7 +126,7 @@
 class ParallelFilesystemCommand : public FilesystemCommand {
 public:
 
-	void process(std::istream& input, std::ostream& output, Configuration& configuration) {
+	void process(int inputFD, int outputFD, Configuration& configuration) {
 		// TODO: ParallelFilesystemCommand
 
 		{ // TODO: demo code – remove:
@@ -146,7 +147,7 @@
 			mqWriter.send(&writeBuffer);
 
 			mqReader.receive(&readBuffer);
-			
+
 			std::string readData(readBuffer.data, readBuffer.dataLength);
 			std::wstring_convert < codecvt_utf8<wchar_t>> convertor;