Use correct argument name in log line (#4252)
This commit modifies a log line produced in the WorkerStatusReport function when closing orphaned connections that appears to incorrectly label a worker identifier as a controller identifier. Signed-off-by: David Bond <davidsbond93@gmail.com>
This commit is contained in:
1 parent
43c37ab1d9
commit
422bd6c224
2 files changed
+2
-2
No files matched your search
@@ -391,7 +391,7 @@ func (r *ConnectionRepository) DeleteConnection(ctx context.Context, publicId st
|
||||
return rowsDeleted, nil
|
||||
}
|
||||
|
||||
// closeOrphanedConnections looks for connections that are still active, but where not reported by the worker.
|
||||
// closeOrphanedConnections looks for connections that are still active, but were not reported by the worker.
|
||||
func (r *ConnectionRepository) closeOrphanedConnections(ctx context.Context, workerId string, reportedConnections []string) ([]string, error) {
|
||||
const op = "session.(ConnectionRepository).closeOrphanedConnections"
|
||||
|
||||
|
||||
@@ -60,7 +60,7 @@ func WorkerStatusReport(ctx context.Context, repo *Repository, connRepo *Connect
|
||||
merr = stderrors.Join(merr, errors.New(ctx, errors.Internal, op, fmt.Sprintf("Error closing orphaned connections for worker %s: %v", workerId, err)))
|
||||
}
|
||||
if len(closed) > 0 {
|
||||
event.WriteSysEvent(ctx, op, "marked unclaimed connections as closed", "controller_id", workerId, "count", len(closed))
|
||||
event.WriteSysEvent(ctx, op, "marked unclaimed connections as closed", "worker_id", workerId, "count", len(closed))
|
||||
}
|
||||
|
||||
if merr != nil {
|
||||
|
||||
Reference in new issue
Block a user