#ifndef APP_RUNNER_H
#define APP_RUNNER_H
#include <stdio.h>
#include <DataIO.h>
#include <Entry.h>
#include <Locker.h>
class AppRunner {
public:
AppRunner(bool requestQuitOnDestruction = false);
~AppRunner();
status_t Run(const char *command, const char *args = NULL,
bool findCommand = true);
bool HasQuitted();
void WaitFor(bool requestQuit = false);
team_id Team();
port_id AppLooperPort();
status_t GetRef(entry_ref *ref);
status_t RequestQuit();
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();
static bool _LockTeamPort();
static void _UnlockTeamPort();
static port_id _ReadPortID(BMessenger &messenger);
private:
BLocker fOutputLock;
port_id fRemotePort;
BMallocIO fOutput;
thread_id fReader;
team_id fTeam;
entry_ref fRef;
BMessenger fMessenger;
bool fRequestQuitOnDestruction;
static port_id fTeamPort;
static BLocker fTeamPortLock;
};
status_t find_test_app(const char *testApp, BString *path);
status_t find_test_app(const char *testApp, entry_ref *ref);
#endif
