octoleo/syncthing
1
0
Fork 0
mirror of https://github.com/octoleo/syncthing.git synced 2024-09-19 05:09:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1689 from calmh/nolocks

Browse Source 
events.Subscription.Poll does not seem to require locking
This commit is contained in:
Audrius Butkevicius 2015-04-24 10:26:58 +01:00
commit aece6e8b6c
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/events/events.go
View File

@ -103,7 +103,6 @@ type Subscription struct {
mask EventType
id int
events chan Event
mutex sync.Mutex
}
var Default = NewLogger()
@ -153,7 +152,6 @@ func (l *Logger) Subscribe(mask EventType) *Subscription {
mask: mask,
id: l.nextID,
events: make(chan Event, BufferSize),
mutex: sync.NewMutex(),
}
l.nextID++
l.subs[s.id] = s
@ -172,9 +170,6 @@ func (l *Logger) Unsubscribe(s *Subscription) {
}
func (s *Subscription) Poll(timeout time.Duration) (Event, error) {
s.mutex.Lock()
defer s.mutex.Unlock()
if debug {
dl.Debugln("poll", timeout)
}