aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rw-r--r--lib/msgstore.go31
1 files changed, 28 insertions, 3 deletions
diff --git a/lib/msgstore.go b/lib/msgstore.go
index a5c0e8f5..908f125e 100644
--- a/lib/msgstore.go
+++ b/lib/msgstore.go
@@ -111,7 +111,15 @@ func (store *MessageStore) FetchHeaders(uids []uint32,
}
}
if len(toFetch) > 0 {
- store.worker.PostAction(&types.FetchMessageHeaders{Uids: toFetch}, nil)
+ store.worker.PostAction(&types.FetchMessageHeaders{Uids: toFetch}, func(msg types.WorkerMessage) {
+ switch msg.(type) {
+ case *types.Error:
+ for _, uid := range toFetch {
+ delete(store.pendingHeaders, uid)
+ delete(store.headerCallbacks, uid)
+ }
+ }
+ })
}
}
@@ -139,6 +147,7 @@ func (store *MessageStore) FetchFull(uids []uint32, cb func(*types.FullMessage))
switch msg.(type) {
case *types.Error:
for _, uid := range toFetch {
+ delete(store.pendingBodies, uid)
delete(store.bodyCallbacks, uid)
}
}
@@ -389,10 +398,25 @@ func (store *MessageStore) Delete(uids []uint32,
store.Deleted[uid] = nil
}
- store.worker.PostAction(&types.DeleteMessages{Uids: uids}, cb)
+ store.worker.PostAction(&types.DeleteMessages{Uids: uids},
+ func(msg types.WorkerMessage) {
+ switch msg.(type) {
+ case *types.Error:
+ store.revertDeleted(uids)
+ }
+ cb(msg)
+ })
store.update()
}
+func (store *MessageStore) revertDeleted(uids []uint32) {
+ for _, uid := range uids {
+ if _, ok := store.Deleted[uid]; ok {
+ delete(store.Deleted, uid)
+ }
+ }
+}
+
func (store *MessageStore) Copy(uids []uint32, dest string, createDest bool,
cb func(msg types.WorkerMessage)) {
@@ -429,9 +453,10 @@ func (store *MessageStore) Move(uids []uint32, dest string, createDest bool,
}, func(msg types.WorkerMessage) {
switch msg.(type) {
case *types.Error:
+ store.revertDeleted(uids)
cb(msg)
case *types.Done:
- store.worker.PostAction(&types.DeleteMessages{Uids: uids}, cb)
+ store.Delete(uids, cb)
}
})