// PipedAppRunner.h

#ifndef PIPED_APP_RUNNER_H
#define PIPED_APP_RUNNER_H

#include <stdio.h>

#include <DataIO.h>
#include <Locker.h>

class PipedAppRunner {
public:
	PipedAppRunner();
	~PipedAppRunner();

	status_t Run(const char *command, const char *args = NULL,
				 bool findCommand = true);
	bool HasQuitted();
	void WaitFor();

	status_t GetOutput(BString *buffer);
	ssize_t ReadOutput(void *buffer, size_t size);
	ssize_t ReadOutputAt(off_t position, void *buffer, size_t size);

private:
	static int32 _ReaderEntry(void *data);
	int32 _ReaderLoop();
	void _ClosePipe();

private:
	BLocker		fOutputLock;
	FILE		*fPipe;
	BMallocIO	fOutput;
	thread_id	fReader;
};

#endif	// PIPED_APP_RUNNER_H