Reset status view when fetch failed.

git-svn-id: file:///srv/svn/repos/haiku/haiku/trunk@40752 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
Clemens Zeidler
2011-03-01 03:19:15 +00:00
parent 9a73627a81
commit 8e4e1a2880
5 changed files with 20 additions and 4 deletions
@@ -61,6 +61,13 @@ DispatcherIMAPListener::NewMessagesToFetch(int32 nMessages)
} }
void
DispatcherIMAPListener::FetchEnd()
{
fProtocol.ResetProgress();
}
const uint32 kMsgStartWatching = '&StW'; const uint32 kMsgStartWatching = '&StW';
@@ -31,6 +31,7 @@ public:
void BodyFetched(int32 uid, BPositionIO* data); void BodyFetched(int32 uid, BPositionIO* data);
void NewMessagesToFetch(int32 nMessages); void NewMessagesToFetch(int32 nMessages);
void FetchEnd();
private: private:
MailProtocol& fProtocol; MailProtocol& fProtocol;
IMAPStorage& fStorage; IMAPStorage& fStorage;
@@ -306,7 +306,7 @@ FetchMessageCommand::FetchMessageCommand(IMAPMailbox& mailbox, int32 message,
fOutData(data), fOutData(data),
fFetchBodyLimit(fetchBodyLimit) fFetchBodyLimit(fetchBodyLimit)
{ {
fIMAPMailbox.Listener().NewMessagesToFetch(fEndMessage - fMessage + 1);
} }
@@ -320,7 +320,13 @@ FetchMessageCommand::FetchMessageCommand(IMAPMailbox& mailbox,
fOutData(NULL), fOutData(NULL),
fFetchBodyLimit(fetchBodyLimit) fFetchBodyLimit(fetchBodyLimit)
{ {
fIMAPMailbox.Listener().NewMessagesToFetch(fEndMessage - fMessage + 1);
}
FetchMessageCommand::~FetchMessageCommand()
{
fIMAPMailbox.Listener().FetchEnd();
} }
@@ -478,6 +484,8 @@ FetchBodyCommand::Handle(const BString& response)
int32 uid = fIMAPMailbox.MessageNumberToUID(message); int32 uid = fIMAPMailbox.MessageNumberToUID(message);
if (uid >= 0) if (uid >= 0)
fIMAPMailbox.Listener().BodyFetched(uid, fOutData); fIMAPMailbox.Listener().BodyFetched(uid, fOutData);
else
fIMAPMailbox.Listener().FetchEnd();
return true; return true;
} }
@@ -615,8 +623,6 @@ ExistsHandler::Handle(const BString& response)
nMessages + 1, exists, &list, NULL); nMessages + 1, exists, &list, NULL);
fIMAPMailbox.AddAfterQuakeCommand(command); fIMAPMailbox.AddAfterQuakeCommand(command);
fIMAPMailbox.Listener().NewMessagesToFetch(exists - nMessages);
command = new FetchMessageCommand(fIMAPMailbox, nMessages + 1, exists, command = new FetchMessageCommand(fIMAPMailbox, nMessages + 1, exists,
fIMAPMailbox.FetchBodyLimit()); fIMAPMailbox.FetchBodyLimit());
fIMAPMailbox.AddAfterQuakeCommand(command); fIMAPMailbox.AddAfterQuakeCommand(command);
@@ -130,6 +130,7 @@ public:
FetchMessageCommand(IMAPMailbox& mailbox, FetchMessageCommand(IMAPMailbox& mailbox,
int32 firstMessage, int32 lastMessage, int32 firstMessage, int32 lastMessage,
int32 fetchBodyLimit = -1); int32 fetchBodyLimit = -1);
~FetchMessageCommand();
BString Command(); BString Command();
bool Handle(const BString& response); bool Handle(const BString& response);
@@ -22,6 +22,7 @@ public:
virtual void BodyFetched(int32 uid, BPositionIO* data) {} virtual void BodyFetched(int32 uid, BPositionIO* data) {}
virtual void NewMessagesToFetch(int32 nMessages) {} virtual void NewMessagesToFetch(int32 nMessages) {}
virtual void FetchEnd() {}
}; };