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

Change , remove T placeholder, 8 to 6 on hash len

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2019-11-16 13:06:56 -08:00
parent 6ad8287bbe
commit 747ba1dc09
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
server/gateway.go
View File

@@ -40,13 +40,12 @@ const (
oldGWReplyPrefixLen = len(oldGWReplyPrefix)
oldGWReplyStart = oldGWReplyPrefixLen + 5 // len of prefix above + len of hash (4) + "."
// The new prefix is "$GNR.<x>.<cluster>.<server>." where <x> is 1 character
// reserved for service imports, <cluster> is 8 characters hash of origin
// cluster name and <server> is 8 characters hash of origin server pub key.
gwReplyPrefix = "$GNR."
// The new prefix is "_GR_.<cluster>.<server>." where <cluster> is 8 characters
// hash of origin cluster name and <server> is 8 characters hash of origin server pub key.
gwReplyPrefix = "_GR_."
gwReplyPrefixLen = len(gwReplyPrefix)
gwHashLen = 8
gwClusterOffset = gwReplyPrefixLen + 2
gwHashLen = 6
gwClusterOffset = gwReplyPrefixLen
gwServerOffset = gwClusterOffset + gwHashLen + 1
gwSubjectOffset = gwServerOffset + gwHashLen + 1
)
@@ -311,7 +310,6 @@ func (s *Server) newGateway(opts *Options) error {
clusterHash := getHash(opts.Gateway.Name)
prefix := make([]byte, 0, gwSubjectOffset)
prefix = append(prefix, gwReplyPrefix...)
prefix = append(prefix, '_', '.')
prefix = append(prefix, clusterHash...)
prefix = append(prefix, '.')
prefix = append(prefix, s.hash...)