blob: fbfeaecb8e54010d0a9b910119fbe738d56354f8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
package imap
import "github.com/Necoro/feed2imap-go/internal/log"
const maxPipeDepth = 10
type commander struct {
client *Client
pipe chan<- execution
done chan<- struct{}
}
type command interface {
execute(client *Client) error
}
type ErrorHandler func(error) string
type execution struct {
cmd command
done chan<- struct{}
errorHandler ErrorHandler
}
type addCommando struct {
folder Folder
messages []string
}
func (cmd addCommando) execute(client *Client) error {
return client.putMessages(cmd.folder, cmd.messages)
}
type ensureCommando struct {
folder Folder
}
func (cmd ensureCommando) execute(client *Client) error {
return client.ensureFolder(cmd.folder)
}
func (commander *commander) execute(command command, handler ErrorHandler) {
done := make(chan struct{})
commander.pipe <- execution{command, done, handler}
<-done
}
func executioner(client *Client, pipe <-chan execution, done <-chan struct{}) {
for {
select {
case <-done:
return
case execution := <-pipe:
select { // break as soon as done is there
case <-done:
return
default:
}
if err := execution.cmd.execute(client); err != nil {
if execution.errorHandler == nil {
log.Error(err)
} else {
log.Error(execution.errorHandler(err))
}
}
close(execution.done)
}
}
}
func (client *Client) startCommander() {
if client.commander != nil {
return
}
pipe := make(chan execution, maxPipeDepth)
done := make(chan struct{})
client.commander = &commander{client, pipe, done}
go executioner(client, pipe, done)
}
func (client *Client) stopCommander() {
if client.commander == nil {
return
}
close(client.commander.done)
client.commander = nil
}
|
