summaryrefslogtreecommitdiff
path: root/src/AbstractCommand.h
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2008-02-08 15:53:45 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2008-02-08 15:53:45 +0000
commit1b7c1982896dba1d38e1fe84ba9660996607f5f9 (patch)
treed12047cb37ded1e18d4d5b97844412538beb19ff /src/AbstractCommand.h
parentd82e183d346375ac8a58a298a58728be615f947e (diff)
2008-02-08 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
Removed "using namespace std;" from all sources. Appended std:: prefix to c++ standard classes. Included string.h where mem* function are used.
Diffstat (limited to 'src/AbstractCommand.h')
-rw-r--r--src/AbstractCommand.h44
1 files changed, 26 insertions, 18 deletions
diff --git a/src/AbstractCommand.h b/src/AbstractCommand.h
index cce0b15d..a92555e1 100644
--- a/src/AbstractCommand.h
+++ b/src/AbstractCommand.h
@@ -36,44 +36,44 @@
#define _D_ABSTRACT_COMMAND_H_
#include "Command.h"
+#include "SharedHandle.h"
#include "TimeA2.h"
#include "RequestGroupAware.h"
-#include "Socket.h"
+
+namespace aria2 {
class Request;
-typedef SharedHandle<Request> RequestHandle;
class DownloadEngine;
+class RequestGroup;
class Segment;
-typedef SharedHandle<Segment> SegmentHandle;
-typedef deque<SegmentHandle> Segments;
class NameResolver;
-typedef SharedHandle<NameResolver> NameResolverHandle;
-class BtProgressInfoFile;
-typedef SharedHandle<BtProgressInfoFile> BtProgressInfoFileHandle;
+class Exception;
+class SocketCore;
class AbstractCommand : public Command, public RequestGroupAware {
private:
Time checkPoint;
int32_t timeout;
protected:
- RequestHandle req;
+ SharedHandle<Request> req;
DownloadEngine* e;
- SocketHandle socket;
- Segments _segments;
+ SharedHandle<SocketCore> socket;
+ std::deque<SharedHandle<Segment> > _segments;
void tryReserved();
virtual bool prepareForRetry(int32_t wait);
virtual void onAbort(Exception* ex);
virtual bool executeInternal() = 0;
- void setReadCheckSocket(const SocketHandle& socket);
- void setWriteCheckSocket(const SocketHandle& socket);
+ void setReadCheckSocket(const SharedHandle<SocketCore>& socket);
+ void setWriteCheckSocket(const SharedHandle<SocketCore>& socket);
void disableReadCheckSocket();
void disableWriteCheckSocket();
- bool resolveHostname(const string& hostname, const NameResolverHandle& nameResolver);
+ bool resolveHostname(const std::string& hostname,
+ const SharedHandle<NameResolver>& nameResolver);
#ifdef ENABLE_ASYNC_DNS
- void setNameResolverCheck(const NameResolverHandle& resolver);
- void disableNameResolverCheck(const NameResolverHandle& resolver);
+ void setNameResolverCheck(const SharedHandle<NameResolver>& resolver);
+ void disableNameResolverCheck(const SharedHandle<NameResolver>& resolver);
virtual bool nameResolveFinished() const;
#endif // ENABLE_ASYNC_DNS
void setTimeout(int32_t timeout) { this->timeout = timeout; }
@@ -83,14 +83,22 @@ protected:
private:
bool checkSocketIsReadable;
bool checkSocketIsWritable;
- SocketHandle readCheckTarget;
- SocketHandle writeCheckTarget;
+ SharedHandle<SocketCore> readCheckTarget;
+ SharedHandle<SocketCore> writeCheckTarget;
bool nameResolverCheck;
public:
- AbstractCommand(int32_t cuid, const RequestHandle& req, RequestGroup* requestGroup, DownloadEngine* e, const SocketHandle& s = SocketHandle());
+ AbstractCommand(int32_t cuid, const SharedHandle<Request>& req,
+ RequestGroup* requestGroup, DownloadEngine* e,
+ const SharedHandle<SocketCore>& s);
+
+ AbstractCommand(int32_t cuid, const SharedHandle<Request>& req,
+ RequestGroup* requestGroup, DownloadEngine* e);
+
virtual ~AbstractCommand();
bool execute();
};
+} // namespace aria2
+
#endif // _D_ABSTRACT_COMMAND_H_