GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-08-16 19:15:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore: use bytes.Equal instead (#4201)

Browse Source
This commit is contained in:
guangwu 2023-12-11 21:15:47 +08:00 committed by GitHub
parent 6170b2c5dc
commit fb1dbdc05e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/query-service/app/opamp/model/agent.go
View File

@ -259,7 +259,7 @@ func (agent *Agent) processStatusUpdate(
// send the new remote config to the Agent. // send the new remote config to the Agent.
if configChanged || if configChanged ||
(agent.Status.RemoteConfigStatus != nil && (agent.Status.RemoteConfigStatus != nil &&
bytes.Compare(agent.Status.RemoteConfigStatus.LastRemoteConfigHash, agent.remoteConfig.ConfigHash) != 0) { !bytes.Equal(agent.Status.RemoteConfigStatus.LastRemoteConfigHash, agent.remoteConfig.ConfigHash)) {
// The new status resulted in a change in the config of the Agent or the Agent // The new status resulted in a change in the config of the Agent or the Agent
// does not have this config (hash is different). Send the new config the Agent. // does not have this config (hash is different). Send the new config the Agent.
response.RemoteConfig = agent.remoteConfig response.RemoteConfig = agent.remoteConfig
@ -352,7 +352,7 @@ func isEqualConfigFile(f1, f2 *protobufs.AgentConfigFile) bool {
if f1 == nil || f2 == nil { if f1 == nil || f2 == nil {
return false return false
} }
return bytes.Compare(f1.Body, f2.Body) == 0 && f1.ContentType == f2.ContentType return bytes.Equal(f1.Body, f2.Body) && f1.ContentType == f2.ContentType
} }
func (agent *Agent) SendToAgent(msg *protobufs.ServerToAgent) { func (agent *Agent) SendToAgent(msg *protobufs.ServerToAgent) {