lint: simplify code (gosimple)
Replaces infinite for loops containing a select on a channel with a single case with a range over the channel. Removes redundant assignments to blank identifiers. Remove unnecessary guard clause around delete(). Remove `if condition { return true } return false` with return condition Signed-off-by: Moritz Poldrack <moritz@poldrack.dev> Acked-by: Robin Jarry <robin@jarry.cc>
This commit is contained in:
parent
03f9f4c3ab
commit
ef599aa8fc
6 changed files with 28 additions and 39 deletions
|
@ -19,8 +19,5 @@ func NoQuitDone() {
|
|||
// QuitAllowed checks if aerc can exit normally (only when all goroutines that
|
||||
// requested a no-quit mode were done and called the NoQuitDone() function)
|
||||
func QuitAllowed() bool {
|
||||
if atomic.LoadInt32(&noquit) > 0 {
|
||||
return false
|
||||
}
|
||||
return true
|
||||
return atomic.LoadInt32(&noquit) <= 0
|
||||
}
|
||||
|
|
|
@ -452,9 +452,7 @@ func (store *MessageStore) Delete(uids []uint32,
|
|||
|
||||
func (store *MessageStore) revertDeleted(uids []uint32) {
|
||||
for _, uid := range uids {
|
||||
if _, ok := store.Deleted[uid]; ok {
|
||||
delete(store.Deleted, uid)
|
||||
}
|
||||
delete(store.Deleted, uid)
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -194,7 +194,7 @@ func NewAccountWizard(conf *config.AercConfig, aerc *Aerc) *AccountWizard {
|
|||
}
|
||||
wizard.imapUri()
|
||||
}
|
||||
hostport, srv = getSRV(server, []string{"submission"})
|
||||
hostport, _ = getSRV(server, []string{"submission"})
|
||||
if hostport != "" {
|
||||
wizard.smtpServer.Set(hostport)
|
||||
wizard.smtpMode = SMTP_STARTTLS
|
||||
|
|
|
@ -385,7 +385,7 @@ func buildTree(node *types.Thread, stree [][]string, defaultUid uint32) {
|
|||
}
|
||||
sort.Strings(keys)
|
||||
for _, key := range keys {
|
||||
next, _ := m[key]
|
||||
next := m[key]
|
||||
var uid uint32 = defaultUid
|
||||
for _, testStr := range next {
|
||||
if len(testStr) == 1 {
|
||||
|
|
|
@ -134,23 +134,20 @@ func (i *idler) waitOnIdle() {
|
|||
i.log("wait for idle in background")
|
||||
go func() {
|
||||
defer logging.PanicHandler()
|
||||
select {
|
||||
case err := <-i.done:
|
||||
if err == nil {
|
||||
i.log("<=(idle) waited")
|
||||
i.log("connect done->")
|
||||
i.worker.PostMessage(&types.Done{
|
||||
Message: types.RespondTo(&types.Connect{}),
|
||||
}, nil)
|
||||
} else {
|
||||
i.log("<=(idle) waited; with err: %v", err)
|
||||
}
|
||||
i.setWaiting(false)
|
||||
i.stop = make(chan struct{})
|
||||
i.log("restart")
|
||||
i.Start()
|
||||
return
|
||||
err := <-i.done
|
||||
if err == nil {
|
||||
i.log("<=(idle) waited")
|
||||
i.log("connect done->")
|
||||
i.worker.PostMessage(&types.Done{
|
||||
Message: types.RespondTo(&types.Connect{}),
|
||||
}, nil)
|
||||
} else {
|
||||
i.log("<=(idle) waited; with err: %v", err)
|
||||
}
|
||||
i.setWaiting(false)
|
||||
i.stop = make(chan struct{})
|
||||
i.log("restart")
|
||||
i.Start()
|
||||
}()
|
||||
}
|
||||
|
||||
|
|
|
@ -363,20 +363,17 @@ func (w *mboxWorker) handleMessage(msg types.WorkerMessage) error {
|
|||
}
|
||||
|
||||
func (w *mboxWorker) Run() {
|
||||
for {
|
||||
select {
|
||||
case msg := <-w.worker.Actions:
|
||||
msg = w.worker.ProcessAction(msg)
|
||||
if err := w.handleMessage(msg); err == errUnsupported {
|
||||
w.worker.PostMessage(&types.Unsupported{
|
||||
Message: types.RespondTo(msg),
|
||||
}, nil)
|
||||
} else if err != nil {
|
||||
w.worker.PostMessage(&types.Error{
|
||||
Message: types.RespondTo(msg),
|
||||
Error: err,
|
||||
}, nil)
|
||||
}
|
||||
for msg := range w.worker.Actions {
|
||||
msg = w.worker.ProcessAction(msg)
|
||||
if err := w.handleMessage(msg); err == errUnsupported {
|
||||
w.worker.PostMessage(&types.Unsupported{
|
||||
Message: types.RespondTo(msg),
|
||||
}, nil)
|
||||
} else if err != nil {
|
||||
w.worker.PostMessage(&types.Error{
|
||||
Message: types.RespondTo(msg),
|
||||
Error: err,
|
||||
}, nil)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue