mirrors/ctrl
mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-14 12:37:31 +00:00
Code Activity

update comments

Browse source
This commit is contained in:
postmannen 2022-01-20 07:50:58 +01:00
parent 43bd929b2c
commit 698706b41f
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
server.go
View file

@ -387,6 +387,9 @@ func (s *server) routeMessagesToProcess(dbFileName string) {
// Start reading new fresh messages received on the incomming message // Start reading new fresh messages received on the incomming message
// pipe/file requested, and fill them into the buffer. // pipe/file requested, and fill them into the buffer.
// Since the new messages comming into the system is a []subjectAndMessage
// we loop here, unfold the slice, and put single subjectAndMessages's on
// the channel to the ringbuffer.
go func() { go func() {
for sams := range s.newMessagesCh { for sams := range s.newMessagesCh {
for _, sam := range sams { for _, sam := range sams {