Skip to content

Commit e229fbe

Browse files
authored
BTS-1845 Revert changes for hasAgent field type (#412)
1 parent 6600b8b commit e229fbe

File tree

2 files changed

+7
-12
lines changed

2 files changed

+7
-12
lines changed

service/peer.go

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
//
22
// DISCLAIMER
33
//
4-
// Copyright 2017-2024 ArangoDB GmbH, Cologne, Germany
4+
// Copyright 2017-2023 ArangoDB GmbH, Cologne, Germany
55
//
66
// Licensed under the Apache License, Version 2.0 (the "License");
77
// you may not use this file except in compliance with the License.
@@ -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
HasResilientSingleFlag bool `json:"HasResilientSingle,omitempty"` // If set, this peer is running a resilient single server
@@ -61,12 +61,8 @@ func preparePeerServers(mode ServiceMode, bsCfg BootstrapConfig, config Config)
6161
if !boolFromRef(bsCfg.StartCoordinator, true) {
6262
hasCoordinator = boolRef(false)
6363
}
64-
var hasAgent *bool
65-
if !boolFromRef(bsCfg.StartAgent, !mode.IsSingleMode()) {
66-
hasAgent = boolRef(false)
67-
}
6864
return peerServers{
69-
HasAgentFlag: hasAgent,
65+
HasAgentFlag: boolFromRef(bsCfg.StartAgent, !mode.IsSingleMode()),
7066
HasDBServerFlag: hasDBServer,
7167
HasCoordinatorFlag: hasCoordinator,
7268
HasResilientSingleFlag: boolFromRef(bsCfg.StartResilientSingle, mode.IsActiveFailoverMode()),
@@ -89,7 +85,7 @@ func newPeer(id, address string, port, portOffset int, dataDir string, servers p
8985
}
9086

9187
// HasAgent returns true if this peer is running an agent
92-
func (p Peer) HasAgent() bool { return p.HasAgentFlag == nil || *p.HasAgentFlag }
88+
func (p Peer) HasAgent() bool { return p.HasAgentFlag }
9389

9490
// HasDBServer returns true if this peer is running a dbserver
9591
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
@@ -914,7 +914,7 @@ func (s *Service) HandleHello(ownAddress, remoteAddress string, req *HelloReques
914914
peer.Port = req.SlavePort
915915
peer.DataDir = req.DataDir
916916

917-
peer.HasAgentFlag = utils.NotNilDefault(req.Agent, peer.HasAgentFlag)
917+
peer.HasAgentFlag = boolFromRef(req.Agent, peer.HasAgentFlag)
918918
peer.HasCoordinatorFlag = utils.NotNilDefault(req.Coordinator, peer.HasCoordinatorFlag)
919919
peer.HasDBServerFlag = utils.NotNilDefault(req.DBServer, peer.HasDBServerFlag)
920920
peer.HasResilientSingleFlag = boolFromRef(req.ResilientSingle, peer.HasResilientSingleFlag)
@@ -932,17 +932,16 @@ func (s *Service) HandleHello(ownAddress, remoteAddress string, req *HelloReques
932932
portOffset := s.myPeers.GetFreePortOffset(slaveAddr, slavePort, s.cfg.AllPortOffsetsUnique)
933933
s.log.Debug().Msgf("Set slave port offset to %d, got slaveAddr=%s, slavePort=%d", portOffset, slaveAddr, slavePort)
934934

935-
hasAgentFlag := !s.myPeers.HaveEnoughAgents()
936935
servers := peerServers{
937-
HasAgentFlag: &hasAgentFlag,
936+
HasAgentFlag: !s.myPeers.HaveEnoughAgents(),
938937
HasDBServerFlag: nil,
939938
HasCoordinatorFlag: nil,
940939
HasResilientSingleFlag: s.mode.IsActiveFailoverMode(),
941940
HasSyncMasterFlag: s.mode.SupportsArangoSync() && s.cfg.SyncEnabled,
942941
HasSyncWorkerFlag: s.mode.SupportsArangoSync() && s.cfg.SyncEnabled,
943942
}
944943
if req.Agent != nil {
945-
servers.HasAgentFlag = req.Agent
944+
servers.HasAgentFlag = *req.Agent
946945
}
947946
if req.DBServer != nil && *req.DBServer != true {
948947
servers.HasDBServerFlag = req.DBServer

0 commit comments

Comments
 (0)