Skip to content
This repository has been archived by the owner on Nov 10, 2020. It is now read-only.

change Session.Cmsg to Session.cmsg and provide wrapper functions #37

Open
wants to merge 8 commits into
base: master
Choose a base branch
from
Open

change Session.Cmsg to Session.cmsg and provide wrapper functions #37

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
ab45444
Update memtopics.go
shamork Mar 17, 2016
533da4c
make cmsg private and provide wrapper functions
shamork Mar 17, 2016
83610c9
Update service.go
shamork Mar 17, 2016
9070b45
Update process.go
shamork Mar 17, 2016
016e172
Merge pull request #1 from shamork/patch-2
shamork Mar 17, 2016
7b3ac7c
Merge pull request #2 from shamork/patch-4
shamork Mar 17, 2016
04e94e2
Merge pull request #3 from shamork/patch-3
shamork Mar 17, 2016
0539990
Merge pull request #4 from shamork/patch-1
shamork Jun 17, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
Update memtopics.go 
writing smu and rmu should get lock
  • Loading branch information
@shamork
shamork committed Mar 17, 2016
commit ab45444a27bd80ca2db77da8e1b082e2be0bdd60
4 changes: 4 additions & 0 deletions topics/memtopics.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -125,8 +125,12 @@ func (this *memTopics) Retained(topic []byte, msgs *[]*message.PublishMessage) e
}

func (this *memTopics) Close() error {
this.smu.Lock()
this.sroot = nil
this.smu.Unlock()
this.rmu.Lock()
this.rroot = nil
this.rmu.Unlock()
return nil
}

Expand Down