185 		int error = sem_post(handle);

   185 		int error = sem_post(handle);

   186 		if (error) throw RelpipeWriterException(L"Unable to unlock POSIX semaphore.");

   186 		if (error) throw RelpipeWriterException(L"Unable to unlock POSIX semaphore.");

   187 	}

   187 	}

   188 };

   188 };

   189 

   189 

   191 private:

   191 private:

   192 	std::string queueName;

   192 	std::string queueName;

   193 	NamedMutex& stdoutMutex;

   193 	NamedMutex& stdoutMutex;

   194 	string_t relationName;

   194 	string_t relationName;

   195 	std::map<string_t, std::shared_ptr < AttributeFinder>> attributeFinders;

   195 	std::map<string_t, std::shared_ptr < AttributeFinder>> attributeFinders;

   228 				throw RelpipeWriterException(L"ParallelFilesystemWorker recieved message of unsupported type: " + std::to_wstring((int) readBuffer.type)); // TODO: better exception

   228 				throw RelpipeWriterException(L"ParallelFilesystemWorker recieved message of unsupported type: " + std::to_wstring((int) readBuffer.type)); // TODO: better exception

   229 			}

   229 			}

   230 		}

   230 		}

   231 

   231 

   232 	}

   232 	}

   238 };

   233 };

   239 

   234 

   240 class ParallelFilesystemProcess {

   235 class ParallelFilesystemProcess {

   241 private:

   236 private:

   242 	__pid_t subPid;

   237 	__pid_t subPid;