#ifndef __LPSCLIENT_H
#define __LPSCLIENT_H
#include <iostream>
#include <string>
using namespace std;
class Socket;
class LPSException {
public:
LPSException(const string& what)
:
fWhat(what)
{
}
const char * what() const
{
return fWhat.c_str();
}
private:
string fWhat;
};
class LpsClient {
public:
LpsClient(const char* host);
~LpsClient();
void connect();
void close();
void receiveJob(const char* queue);
void receiveControlFile(int cfsize, const char* cfname);
void receiveDataFile(int dfsize, const char* dfname);
void transferData(const char* buffer, int size = -1);
void transferData(istream& is, int size = -1);
void endTransfer();
void checkAck();
private:
bool fConnected;
string fHost;
Socket* fSock;
istream* fInput;
ostream* fOutput;
};
#endif
