gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Switch to send-all-subs when number of RS- gets too big

Browse Source 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
This commit is contained in:
Ivan Kozlovic
2018-11-30 19:08:15 -07:00
parent 54d505201f
commit a23ef5b740
7 changed files with 1215 additions and 457 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/parser.go
View File

@@ -395,7 +395,7 @@ func (c *client) parse(buf []byte) error {
case ROUTER:
err = c.processRemoteSub(arg)
case GATEWAY:
err = c.processGatewaySubjectSub(arg)
err = c.processGatewayRSub(arg)
}
if err != nil {
return err
@@ -487,7 +487,7 @@ func (c *client) parse(buf []byte) error {
case ROUTER:
err = c.processRemoteUnsub(arg)
case GATEWAY:
err = c.processGatewaySubjectUnsub(arg)
err = c.processGatewayRUnsub(arg)
}
if err != nil {
return err