src/StreamletAttributeFinder.h
branchv_0
changeset 60 bb7ca5891755
parent 51 841845ccf06d
child 61 640ba8948d69
--- a/src/StreamletAttributeFinder.h	Fri Jan 24 21:05:10 2020 +0100
+++ b/src/StreamletAttributeFinder.h	Sat Jan 25 16:37:20 2020 +0100
@@ -95,7 +95,6 @@
 	}
 
 	virtual void writeFieldOfExistingFile(RelationalWriter* writer, const string_t& relationName, const RequestedField & field) override {
-		// TODO: paralelize also over records → fork multiple processes and distribute records across them; then collect results (with a lock)
 		if (field.group == RequestedField::GROUP_STREAMLET) {
 			for (auto metadata : cachedMetadata[field.id]) {
 				SubProcess::Message m = subProcesses[field.id]->read();
@@ -105,7 +104,7 @@
 
 			SubProcess::Message m = subProcesses[field.id]->read();
 			if (m.code != StreamletMsg::WAITING_FOR_INPUT_ATTRIBUTES) throw RelpipeWriterException(L"Protocol violation from exec sub-process. Expected WAITING_FOR_INPUT_ATTRIBUTES but got: " + m.toString());
-			// TODO: generic protocol violation error messages / method for checking responses
+			// FIXME: generic protocol violation error messages / method for checking responses
 		}
 	}