diff --git a/constants/constants.go b/constants/constants.go index 28ab2e292b6..121d1145c44 100644 --- a/constants/constants.go +++ b/constants/constants.go @@ -23,7 +23,7 @@ import ( ) const ( - VERSION = "0.6.6-2" + VERSION = "0.6.6-3" ENROLLMENT_WELL_KNOWN_FLOW = "E:Enrol" MONITORING_WELL_KNOWN_FLOW = FLOW_PREFIX + "Monitoring" diff --git a/responder/responder.go b/responder/responder.go index 642e5a827a1..8efb06a9538 100644 --- a/responder/responder.go +++ b/responder/responder.go @@ -62,7 +62,7 @@ type Responder struct { request *crypto_proto.VeloMessage logger *logging.LogContext start_time int64 - log_id int64 + log_id int32 // The name of the query we are currently running. Artifact string @@ -193,13 +193,13 @@ func (self *Responder) Log(ctx context.Context, level string, self.AddResponse(ctx, &crypto_proto.VeloMessage{ RequestId: constants.LOG_SINK, LogMessage: &crypto_proto.LogMessage{ - Id: atomic.LoadInt64(&self.log_id), + Id: int64(atomic.LoadInt32(&self.log_id)), Message: fmt.Sprintf(format, v...), Timestamp: uint64(time.Now().UTC().UnixNano() / 1000), Artifact: self.Artifact, Level: level, }}) - atomic.AddInt64(&self.log_id, 1) + atomic.AddInt32(&self.log_id, 1) } func (self *Responder) SessionId() string {