mirror of
https://github.com/go-micro/go-micro.git
synced 2024-11-30 08:06:40 +02:00
Merge pull request #737 from milosgajdos83/buffered-advertchan
Lets make advert channel buffered so we don't lose adverts
This commit is contained in:
commit
df5657dcd1
@ -10,6 +10,7 @@ import (
|
|||||||
|
|
||||||
"github.com/google/uuid"
|
"github.com/google/uuid"
|
||||||
"github.com/micro/go-micro/registry"
|
"github.com/micro/go-micro/registry"
|
||||||
|
"github.com/micro/go-micro/util/log"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@ -289,6 +290,7 @@ func (r *router) publishAdvert(advType AdvertType, events []*Event) {
|
|||||||
Events: events,
|
Events: events,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
log.Debugf("Router publishing advert; %+v", a)
|
||||||
r.RLock()
|
r.RLock()
|
||||||
for _, sub := range r.subscribers {
|
for _, sub := range r.subscribers {
|
||||||
// check the exit chan first
|
// check the exit chan first
|
||||||
@ -601,7 +603,7 @@ func (r *router) Advertise() (<-chan *Advert, error) {
|
|||||||
|
|
||||||
switch r.status.Code {
|
switch r.status.Code {
|
||||||
case Advertising:
|
case Advertising:
|
||||||
advertChan := make(chan *Advert)
|
advertChan := make(chan *Advert, 128)
|
||||||
r.subscribers[uuid.New().String()] = advertChan
|
r.subscribers[uuid.New().String()] = advertChan
|
||||||
return advertChan, nil
|
return advertChan, nil
|
||||||
case Running:
|
case Running:
|
||||||
@ -641,7 +643,7 @@ func (r *router) Advertise() (<-chan *Advert, error) {
|
|||||||
r.status = Status{Code: Advertising, Error: nil}
|
r.status = Status{Code: Advertising, Error: nil}
|
||||||
|
|
||||||
// create advert channel
|
// create advert channel
|
||||||
advertChan := make(chan *Advert)
|
advertChan := make(chan *Advert, 128)
|
||||||
r.subscribers[uuid.New().String()] = advertChan
|
r.subscribers[uuid.New().String()] = advertChan
|
||||||
|
|
||||||
return advertChan, nil
|
return advertChan, nil
|
||||||
|
Loading…
Reference in New Issue
Block a user