inwinstack/kaoliang: pkg/controllers/notification.go; 29 LoC

Found a possible issue in [inwinstack/kaoliang](https://www.github.com/inwinstack/kaoliang) at [pkg/controllers/notification.go](https://github.com/inwinstack/kaoliang/blob/a57ce57d9d6e690f48b702329add8820c912954b/pkg/controllers/notification.go#L130-L158)

Below is the message reported by the analyzer for this snippet of code. Beware that the analyzer only reports the first
issue it finds, so please do not limit your consideration to the contents of the below message.

> function call which takes a reference to xmlQueue at line 152 may start a goroutine

[Click here to see the code in its original context.](https://github.com/inwinstack/kaoliang/blob/a57ce57d9d6e690f48b702329add8820c912954b/pkg/controllers/notification.go#L130-L158)

Click here to show the 29 line(s) of Go which triggered the analyzer.

```go
for _, xmlQueue := range xmlConfig.Queues {
targetResource, err := models.ParseARN(xmlQueue.ARN)
if err != nil {
writeErrorResponse(c, cmd.ErrARNNotification)
return
}
if db.Where(models.Resource{
AccountID: targetResource.AccountID,
Service: targetResource.Service,
Name: targetResource.Name,
}).First(&targetResource).RecordNotFound() {
writeErrorResponse(c, cmd.ErrARNNotification)
return
}

queue := models.Queue{}
if db.Where(models.Queue{
QueueIdentifier: xmlQueue.QueueIdentifier,
ConfigID: config.ID,
}).First(&queue).RecordNotFound() {
xmlQueue.ResourceID = targetResource.ID
xmlQueue.ConfigID = config.ID
db.Create(&xmlQueue)
} else {
queue.ARN = targetResource.ARN()
queue.ResourceID = targetResource.ID
db.Save(&queue)
}
}

```

Click here to show extra information the analyzer produced.

```
The following paths through the callgraph could lead to a goroutine:
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (dispatch, 0) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (send, 1) -> (Now, 0) -> (TimeFromUnixNano, 1) -> (file, 3) -> (watch, 3) -> (newWatched, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (send, 1) -> (Now, 0) -> (TimeFromUnixNano, 1) -> (file, 3) -> (Watch, 2) -> (Watch, 1) -> (NewStickyConnPool, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (RefreshMetadata, 1) -> (tryRefreshMetadata, 2) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2) -> (Render, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Lock, 0) -> (lockLoop, 2) -> (Sub, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (startWatcher, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (DialContext, 3) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2) -> (sniff, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (watch, 3) -> (newWatched, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (AddError, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (codeSomeShards, 5) -> (galMulSliceXor, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (SetRedis, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Open, 2) -> (open, 1) -> (openStart, 1) -> (openTune, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (SetCache, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (shutdown, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (WaitTimeout, 1) -> (Go, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Add, 1) -> (Duration, 1) -> (lookupDuration, 2) -> (ParseDuration, 1) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (WaitTimeout, 1) -> (Go, 1) -> (HandlePanic, 2) -> (processResult, 2) -> (openBreaker, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Stop, 0) -> (Write, 2) -> (WriteFile, 4) -> (RaceReadRange, 2) -> (DialWithConn, 4) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2) -> (setVars, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (init, 0) -> (Inf, 1) -> (gccgoXgetbv, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (Go, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1) -> (port_alert, 4) -> (Exists, 3) -> (GetObjectInfo, 3) -> (getObjectInfo, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2) -> (NextLabel, 2)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2) -> (watch, 3) -> (newWatched, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Unregister, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1) -> (port_alert, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (unwatch, 2) -> (Join, 2) -> (singlewatch, 4) -> (Record, 1)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (send, 1) -> (Now, 0) -> (TimeFromUnixNano, 1) -> (file, 3) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2) -> (watch, 3) -> (newWatched, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (watch, 2) -> (InotifyAddWatch, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (setCurrentRoute, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (setCurrentRoute, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (updateStats, 3) -> (With, 1) -> (GetMetricWith, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 2) -> (WriteFile, 4) -> (Addr, 0) -> (mustFind, 0) -> (SetCache, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (startWatcher, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (flush, 1) -> (yaml_emitter_flush, 1) -> (yaml_emitter_set_writer_error, 2) -> (isBinary, 0) -> (WaitTimeout, 1) -> (Go, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (SetCache, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (sniff, 1)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (Interface, 0) -> (errSyntax, 0) -> (errParse, 1) -> (SkipRecursive, 0) -> (codeSomeShards, 5) -> (galMulSliceXor, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 2) -> (WriteFile, 4) -> (Addr, 0) -> (mustFind, 0) -> (SetRedis, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2) -> (Watch, 2) -> (Watch, 1) -> (NewStickyConnPool, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 2) -> (WriteFile, 4) -> (Addr, 0) -> (mustFind, 0) -> (SetCache, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (initConn, 1) -> (ReadOnly, 0) -> (acceptedEnc, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (setVars, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (SetCache, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2) -> (NextLabel, 2) -> (SetCache, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (setVars, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (SetCache, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (Go, 1) -> (HandlePanic, 2) -> (processResult, 2) -> (openBreaker, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (dispatch, 0) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Lock, 0) -> (lockLoop, 2) -> (Sub, 1) -> (Copy, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (processBlocks, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (setVars, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2) -> (setCurrentRoute, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (dispatch, 0) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (start, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1) -> (port_alert, 4) -> (watch, 2) -> (InotifyAddWatch, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (start, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (SetCache, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (Watch, 2) -> (Watch, 1) -> (NewStickyConnPool, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2) -> (start, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (inBounds, 3) -> (Render, 2) -> (Render, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (UTF16PtrFromString, 1) -> (UTF16FromString, 1) -> (Encode, 1) -> (MustEncode, 1) -> (codeSomeShardsP, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2) -> (NextLabel, 2) -> (SetRedis, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (send, 1) -> (Now, 0) -> (TimeFromUnixNano, 1) -> (file, 3) -> (WaitTimeout, 1) -> (Go, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (dispatch, 0) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2) -> (BashComplete, 1) -> (Render, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (sendSimpleMessage, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1) -> (port_alert, 4) -> (Verify, 1) -> (CertificateToDANE, 3) -> (checkSomeShardsP, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Request, 3) -> (delete, 2) -> (Load, 0) -> (StorePointer, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Remove, 1) -> (, 2) -> (CAS, 2) -> (CompareAndSwapInt32, 3) -> (sniff, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (Watch, 2) -> (Watch, 1) -> (NewStickyConnPool, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (putUpstream, 0) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (deleteObject, 3) -> (cleanupDir, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (SetRedis, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Request, 3) -> (delete, 2) -> (Load, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 2) -> (WriteFile, 4) -> (Addr, 0) -> (mustFind, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Rename, 2) -> (MoveFileEx, 3) -> (Addr, 0) -> (mustFind, 0) -> (lazyinit, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (RefreshMetadata, 1) -> (tryRefreshMetadata, 2) -> (resurrectDeadBrokers, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (newPartitionProducer, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (unwatch, 2) -> (Join, 2) -> (singlewatch, 4) -> (Record, 1) -> (DialContext, 3) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (updateStats, 3) -> (With, 1) -> (GetMetricWith, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (setCurrentRoute, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (Watch, 2) -> (Watch, 1) -> (NewStickyConnPool, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (dispatch, 0) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (RefreshMetadata, 1) -> (tryRefreshMetadata, 2) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (unwatch, 2) -> (Join, 2) -> (singlewatch, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Stop, 0) -> (Write, 2) -> (WriteFile, 4) -> (RaceReadRange, 2) -> (lazyinit, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Remove, 1) -> (, 2) -> (CAS, 2) -> (CompareAndSwapInt32, 3) -> (setVars, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (inBounds, 3) -> (Render, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (send, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Open, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (openTune, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Add, 1) -> (Duration, 1) -> (lookupDuration, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (SetRedis, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (discardResults, 0) -> (readResultSetHeaderPacket, 0) -> (readLengthEncodedInteger, 1) -> (readResultOK, 0) -> (startWatcher, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 2) -> (WriteFile, 4) -> (Addr, 0) -> (mustFind, 0) -> (MustRegister, 1) -> (Register, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (dispatch, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Remove, 1) -> (, 2) -> (CAS, 2) -> (CompareAndSwapInt32, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (NewClient, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (putUpstream, 0) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (deleteObject, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Stop, 0) -> (Write, 2) -> (WriteFile, 4) -> (RaceReadRange, 2) -> (DialContext, 3) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Next, 1) -> (ControlMessageSpace, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Remove, 1) -> (, 2) -> (CAS, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (send, 1) -> (Now, 0) -> (TimeFromUnixNano, 1) -> (file, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (shutdown, 1) -> (newAllocator, 2) -> (file, 3) -> (putInt64Array, 1) -> (GetOrCreate, 1) -> (appendIfNotExists, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (safeAsyncClose, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (CreateFile, 7)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (dispatch, 0) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (sendSimpleMessage, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (CreateFile, 7) -> (Addr, 0) -> (mustFind, 0) -> (Find, 0) -> (codeSomeShardsP, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2) -> (NextLabel, 2) -> (WaitTimeout, 1) -> (Go, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Request, 3) -> (delete, 2) -> (Load, 0) -> (StorePointer, 2) -> (DialWithConn, 4) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2) -> (NextLabel, 2) -> (MustRegister, 1) -> (Register, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (watch, 3) -> (newWatched, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Rename, 2) -> (MoveFileEx, 3) -> (Addr, 0) -> (mustFind, 0) -> (GetOrCreate, 1) -> (appendIfNotExists, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (processBlocks, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (reconnect, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1) -> (port_alert, 4) -> (readAllXLMetadata, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (Dial, 2) -> (DialWithConn, 4) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Remove, 1) -> (, 2) -> (CAS, 2) -> (CompareAndSwapInt32, 3) -> (setCurrentRoute, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Next, 1) -> (ControlMessageSpace, 1) -> (roundup, 1) -> (ParseDuration, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (flush, 1) -> (yaml_emitter_flush, 1) -> (yaml_emitter_set_writer_error, 2) -> (isBinary, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2) -> (shutdown, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1) -> (port_alert, 4) -> (watch, 3) -> (newWatched, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Request, 3) -> (delete, 2) -> (Load, 0) -> (StorePointer, 2) -> (DialContext, 3) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (sniff, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (SetCache, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (initConn, 1) -> (ReadOnly, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Request, 3) -> (delete, 2) -> (Load, 0) -> (StorePointer, 2) -> (Consume, 7) -> (add, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (sendSimpleMessage, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (WaitTimeout, 1) -> (Go, 1) -> (HandlePanic, 2) -> (processResult, 2) -> (openBreaker, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1) -> (port_alert, 4) -> (DialWithConn, 4) -> (connect, 3)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2) -> (Watch, 2) -> (Watch, 1) -> (NewStickyConnPool, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (putUpstream, 0) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (getCachedFSLoc, 3) -> (Exists, 3) -> (GetObjectInfo, 3) -> (getObjectInfo, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (sniff, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (flush, 1) -> (yaml_emitter_flush, 1) -> (yaml_emitter_set_writer_error, 2) -> (isBinary, 0) -> (WaitTimeout, 1) -> (Go, 1) -> (HandlePanic, 2) -> (processResult, 2) -> (openBreaker, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (sendSimpleMessage, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (startWatcher, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Next, 1) -> (ControlMessageSpace, 1) -> (roundup, 1) -> (ParseDuration, 1) -> (startWatcher, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Remove, 1) -> (, 2) -> (CAS, 2) -> (CompareAndSwapInt32, 3) -> (start, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Stop, 0) -> (Write, 2) -> (WriteFile, 4) -> (RaceReadRange, 2) -> (Verify, 1) -> (CertificateToDANE, 3) -> (checkSomeShardsP, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (SetRedis, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (codeSomeShardsP, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (dispatch, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (sendSimpleMessage, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (WaitTimeout, 1) -> (Go, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (SetRedis, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (createCall, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (call, 2) -> (ValueOf, 1) -> (NewEncoder, 1) -> (newEncoderWithWriter, 1) -> (codeSomeShardsP, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (flush, 1) -> (yaml_emitter_flush, 1) -> (yaml_emitter_set_writer_error, 2) -> (isBinary, 0) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (discardResults, 0) -> (readResultSetHeaderPacket, 0) -> (readLengthEncodedInteger, 1) -> (readResultOK, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (startWatcher, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (updateStats, 3) -> (With, 1) -> (GetMetricWith, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (initConn, 1) -> (ReadOnly, 0) -> (acceptedEnc, 1) -> (handleCall, 1) -> (sendMessage, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Add, 1) -> (Duration, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (DialWithConn, 4) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (MustRegister, 1) -> (Register, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (removeUpstream, 0) -> (Remove, 1)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (init, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (send, 1) -> (Now, 0) -> (TimeFromUnixNano, 1) -> (file, 3) -> (WaitTimeout, 1) -> (Go, 1) -> (HandlePanic, 2) -> (processResult, 2) -> (openBreaker, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (DialConfig, 1) -> (NewClient, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (watch, 3) -> (newWatched, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 2) -> (WriteFile, 4) -> (Addr, 0) -> (mustFind, 0) -> (SetRedis, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (RefreshMetadata, 1) -> (tryRefreshMetadata, 2) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2) -> (Render, 2) -> (Render, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2) -> (NextLabel, 2) -> (SetCache, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (WaitTimeout, 1) -> (Go, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (Consume, 7) -> (add, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (send, 1) -> (Now, 0) -> (TimeFromUnixNano, 1) -> (file, 3) -> (startWatcher, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (MustRegister, 1) -> (Register, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Rename, 2) -> (MoveFileEx, 3) -> (Addr, 0) -> (mustFind, 0) -> (Watch, 2) -> (Watch, 1) -> (NewStickyConnPool, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (dispatch, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (MustRegister, 1) -> (Register, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (DialContext, 3) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (isInert, 0) -> (DialWithConn, 4) -> (connect, 3)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2) -> (updateStats, 3) -> (With, 1) -> (GetMetricWith, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (inBounds, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Add, 1) -> (Duration, 1) -> (lookupDuration, 2) -> (ParseDuration, 1) -> (Observe, 1) -> (asyncFlush, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (unwatch, 2) -> (Join, 2) -> (singlewatch, 4) -> (Record, 1) -> (DialWithConn, 4) -> (connect, 3)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2) -> (setCurrentRoute, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Remove, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (SetRedis, 0) -> (NewClient, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Remove, 1) -> (, 2) -> (CAS, 2) -> (CompareAndSwapInt32, 3) -> (updateStats, 3) -> (With, 1) -> (GetMetricWith, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (init, 0) -> (Inf, 1) -> (gccgoXgetbv, 2) -> (NewStat, 0) -> (parseCPUStat, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (dispatch, 0) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (start, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (SetElasticsearch, 0) -> (SetSniff, 1)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2) -> (setVars, 2) -> (contextSet, 3) -> (Set, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2) -> (NextLabel, 2) -> (WaitTimeout, 1) -> (Go, 1) -> (HandlePanic, 2) -> (processResult, 2) -> (openBreaker, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (AsyncClose, 0)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2) -> (sniff, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Do, 1) -> (body, 0) -> (HasPrefix, 2) -> (NextLabel, 2) -> (SetRedis, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Next, 1) -> (ControlMessageSpace, 1) -> (roundup, 1) -> (ParseDuration, 1) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2) -> (start, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (flush, 1) -> (yaml_emitter_flush, 1) -> (yaml_emitter_set_writer_error, 2) -> (isBinary, 0) -> (startWatcher, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Flush, 0) -> (compressBlock, 1) -> (ChecksumZero, 1) -> (blockHash, 1) -> (WaitTimeout, 1) -> (Go, 1) -> (HandlePanic, 2) -> (processResult, 2) -> (openBreaker, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (dispatch, 0) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1) -> (resurrectDeadBrokers, 0) -> (setPartitionCache, 2) -> (BashComplete, 1) -> (Render, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (dispatch, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (shutdown, 1) -> (newAllocator, 2) -> (file, 3) -> (putInt64Array, 1) -> (lazyinit, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (dispatch, 0) -> (refBrokerConsumer, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 1) -> (Set, 2) -> (Load, 0) -> (StorePointer, 2) -> (readLoop, 0) -> (parse, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (dispatch, 0) -> (refBrokerConsumer, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Put, 1) -> (Stop, 0) -> (delete, 1) -> (port_alert, 4) -> (DialContext, 3) -> (connect, 3)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (String, 0) -> (itoa, 1) -> (uint, 1) -> (unmarshal, 2) -> (watch, 3) -> (newWatched, 4)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (New, 1) -> (RegisterValidation, 2) -> (ContainsAny, 2) -> (storeInterfaces, 2) -> (updateStats, 3) -> (With, 1) -> (GetMetricWith, 1)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (Watch, 2) -> (Watch, 1) -> (NewStickyConnPool, 2)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (putUpstream, 0) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (sslVerifyCertificateAuthority, 2) -> (Verify, 1) -> (CertificateToDANE, 3) -> (checkSomeShardsP, 5)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Add, 1) -> (Duration, 1) -> (lookupDuration, 2) -> (ParseDuration, 1)
(Create, 1) -> (NewScope, 1) -> (clone, 0) -> (GetName, 0) -> (New, 1) -> (RegisterValidation, 2) -> (panic, 1) -> (storeInterfaces, 2) -> (shutdown, 0)
(Create, 1) -> (LockedOpenFile, 3) -> (lockedOpenFile, 4) -> (Handle, 1) -> (Send, 2) -> (Write, 1) -> (lastBoundary, 2) -> (backwards, 1) -> (startWatcher, 0)

```

Leave a reaction on this issue to contribute to the project by classifying this instance as a **Bug** :-1:, **Mitigated** :+1:, or **Desirable Behavior** :rocket:
See the descriptions of the classifications [here](https://github.com/github-vet/rangeclosure-findings#how-can-i-help) for more information.

commit ID: a57ce57d9d6e690f48b702329add8820c912954b