Skip to content

Commit fa92ae2

Browse files
authored
BTS-1845 Revert changes for hasAgent field type (#413)
1 parent 81cf547 commit fa92ae2

File tree

2 files changed

+6
-11
lines changed

2 files changed

+6
-11
lines changed

service/peer.go

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ import (
3333

3434
// peerServers
3535
type peerServers struct {
36-
HasAgentFlag *bool `json:"HasAgent,omitempty"` // If set, this peer is running an agent
36+
HasAgentFlag bool `json:"HasAgent"` // If set, this peer is running an agent
3737
HasDBServerFlag *bool `json:"HasDBServer,omitempty"` // If set or is nil, this peer is running a dbserver
3838
HasCoordinatorFlag *bool `json:"HasCoordinator,omitempty"` // If set or is nil, this peer is running a coordinator
3939
}
@@ -58,12 +58,8 @@ func preparePeerServers(mode ServiceMode, bsCfg BootstrapConfig, config Config)
5858
if !boolFromRef(bsCfg.StartCoordinator, true) {
5959
hasCoordinator = boolRef(false)
6060
}
61-
var hasAgent *bool
62-
if !boolFromRef(bsCfg.StartAgent, !mode.IsSingleMode()) {
63-
hasAgent = boolRef(false)
64-
}
6561
return peerServers{
66-
HasAgentFlag: hasAgent,
62+
HasAgentFlag: boolFromRef(bsCfg.StartAgent, !mode.IsSingleMode()),
6763
HasDBServerFlag: hasDBServer,
6864
HasCoordinatorFlag: hasCoordinator,
6965
}
@@ -83,7 +79,7 @@ func newPeer(id, address string, port, portOffset int, dataDir string, servers p
8379
}
8480

8581
// HasAgent returns true if this peer is running an agent
86-
func (p Peer) HasAgent() bool { return p.HasAgentFlag == nil || *p.HasAgentFlag }
82+
func (p Peer) HasAgent() bool { return p.HasAgentFlag }
8783

8884
// HasDBServer returns true if this peer is running a dbserver
8985
func (p Peer) HasDBServer() bool { return p.HasDBServerFlag == nil || *p.HasDBServerFlag }

service/service.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -816,7 +816,7 @@ func (s *Service) HandleHello(ownAddress, remoteAddress string, req *HelloReques
816816
peer.Port = req.SlavePort
817817
peer.DataDir = req.DataDir
818818

819-
peer.HasAgentFlag = utils.NotNilDefault(req.Agent, peer.HasAgentFlag)
819+
peer.HasAgentFlag = boolFromRef(req.Agent, peer.HasAgentFlag)
820820
peer.HasCoordinatorFlag = utils.NotNilDefault(req.Coordinator, peer.HasCoordinatorFlag)
821821
peer.HasDBServerFlag = utils.NotNilDefault(req.DBServer, peer.HasDBServerFlag)
822822
}
@@ -831,14 +831,13 @@ func (s *Service) HandleHello(ownAddress, remoteAddress string, req *HelloReques
831831
portOffset := s.myPeers.GetFreePortOffset(slaveAddr, slavePort, s.cfg.AllPortOffsetsUnique)
832832
s.log.Debug().Msgf("Set slave port offset to %d, got slaveAddr=%s, slavePort=%d", portOffset, slaveAddr, slavePort)
833833

834-
hasAgentFlag := !s.myPeers.HaveEnoughAgents()
835834
servers := peerServers{
836-
HasAgentFlag: &hasAgentFlag,
835+
HasAgentFlag: !s.myPeers.HaveEnoughAgents(),
837836
HasDBServerFlag: nil,
838837
HasCoordinatorFlag: nil,
839838
}
840839
if req.Agent != nil {
841-
servers.HasAgentFlag = req.Agent
840+
servers.HasAgentFlag = *req.Agent
842841
}
843842
if req.DBServer != nil && *req.DBServer != true {
844843
servers.HasDBServerFlag = req.DBServer

0 commit comments

Comments
 (0)