Skip to content

Commit 8256670

Browse files
committed
fixup! Merge branch 'main' into colin/single-pgcoord
1 parent a1c3acf commit 8256670

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

enterprise/tailnet/pgcoord.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -914,15 +914,12 @@ func (q *querier) newClientSubscription(c agpl.Queue, agentID uuid.UUID) {
914914
q.clientSubscriptions[c.UniqueID()] = map[uuid.UUID]struct{}{}
915915
}
916916

917-
fmt.Println("add sub", c.UniqueID(), agentID)
918-
919917
mk := mKey{
920918
agent: agentID,
921919
kind: agpl.QueueKindClient,
922920
}
923921
cm, ok := q.mappers[mk]
924922
if !ok {
925-
fmt.Println("new mapper")
926923
ctx, cancel := context.WithCancel(q.ctx)
927924
mpr := newMapper(ctx, q.logger, mk, q.heartbeats)
928925
cm = &countedMapper{
@@ -945,8 +942,6 @@ func (q *querier) removeClientSubscription(c agpl.Queue, agentID uuid.UUID) {
945942
q.mu.Lock()
946943
defer q.mu.Unlock()
947944

948-
fmt.Println("remove sub", c.UniqueID(), agentID)
949-
950945
// agentID: uuid.Nil indicates that a client is going away. The querier
951946
// handles that in cleanupConn below instead.
952947
if agentID == uuid.Nil {

0 commit comments

Comments
 (0)