inwinstack/kaoliang: pkg/controllers/notification.go; 14 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#L192-L205)

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 queue at line 204 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#L192-L205)

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

```go
for _, queue := range xmlConfig.Queues {
targetResource, err := models.ParseARN(queue.ARN)
if err != nil {
writeErrorResponse(c, cmd.ErrARNNotification)
return
}
db.Where(models.Resource{
AccountID: targetResource.AccountID,
Service: targetResource.Service,
Name: targetResource.Name,
}).First(&targetResource)
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:
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Send, 1) -> (NewRequest, 3) -> (publish, 3) -> (isReconnecting, 0) -> (reconnect, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Send, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Get, 0) -> (NewGetService, 1)
(Save, 1) -> (Lock, 0) -> (lockBlocking, 2) -> (Sub, 1) -> (RLock, 1) -> (Call, 3) -> (Post, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Dial, 2) -> (DialWithConn, 4) -> (connect, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Get, 0) -> (NewGetService, 1) -> (Expand, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Start, 0) -> (Boolean, 1) -> (sniff, 1) -> (updateConns, 1) -> (asyncFlush, 1)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (Open, 2) -> (open, 1) -> (openStart, 1) -> (openTune, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (newBrokerProducer, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (ReadFile, 5) -> (call, 3) -> (Call, 3) -> (Post, 3) -> (initConn, 1) -> (ReadOnly, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Send, 1) -> (NewRequest, 3) -> (publish, 3) -> (isReconnecting, 0) -> (readLoop, 0) -> (processOpErr, 1)
(Save, 1) -> (Lock, 0) -> (lockBlocking, 2) -> (Sub, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (IDKey, 6) -> (deriveKey, 9) -> (extractKey, 4)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0) -> (handleCall, 1) -> (sendMessage, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Do, 1) -> (body, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2) -> (MarkAsAlive, 0) -> (Set, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Decode, 1) -> (IsNil, 0) -> (document, 0) -> (fail, 0) -> (Register, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Run, 0) -> (WaitTimeout, 1) -> (Go, 1) -> (HandlePanic, 2) -> (processResult, 2) -> (openBreaker, 0)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0) -> (StorePointer, 2) -> (LoadLibraryEx, 3) -> (lazyinit, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (Register, 1)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0) -> (StorePointer, 2) -> (LoadLibraryEx, 3) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (WithTimeout, 2) -> (Now, 0) -> (WithCancel, 1) -> (cancel, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newTree, 0) -> (newNonrecursiveTree, 3)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (ReadFile, 5) -> (call, 3) -> (Call, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (watch, 0) -> (run, 0) -> (readyToFlush, 0) -> (empty, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2) -> (IsErrIgnored, 2) -> (GetObjectInfo, 3) -> (getObjectInfo, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Start, 1)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (readFile, 1) -> (Open, 1) -> (sendAndReceiveSASLPlainAuth, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (SendEvent, 4) -> (RemoveRemoteTarget, 2) -> (Post, 3)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0) -> (StorePointer, 2) -> (LoadLibraryEx, 3) -> (GetOrCreate, 1) -> (appendIfNotExists, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Open, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newLogOnceType, 0)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (readFile, 1) -> (Open, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (Get, 1) -> (Get, 2) -> (get, 2) -> (getsockopt, 4) -> (add, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (WithTimeout, 2) -> (Now, 0) -> (Start, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Decode, 1) -> (IsNil, 0) -> (document, 0) -> (fail, 0) -> (NewClient, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (WithContext, 1) -> (copy, 0) -> (copyIP, 1) -> (rrfunc, 0) -> (Register, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newLogOnceType, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3) -> (NewGetService, 1)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 1)
(Save, 1) -> (Unlock, 0) -> (unlock, 4) -> (deleteLockInfoEntryForVolumePath, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (process, 1) -> (file, 3) -> (putInt64Array, 1) -> (run, 2) -> (newClusterNode, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Get, 0) -> (NewGetService, 1) -> (Expand, 0) -> (argExpander, 1) -> (Auth, 1) -> (inWorker, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (Get, 1) -> (Get, 2) -> (get, 2) -> (getsockopt, 4) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (WithTimeout, 2) -> (Now, 0) -> (Start, 0) -> (CFRunLoopWakeUp, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (PerformRequestWithOptions, 2) -> (infof, 5)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (oldRequest, 3) -> (NextMsg, 1)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (watch, 0) -> (run, 0) -> (readyToFlush, 0) -> (empty, 0) -> (newClusterNode, 2) -> (updateLatency, 0) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (Open, 2)
(Save, 1) -> (Lock, 0) -> (lockLoop, 1) -> (Sub, 1) -> (newRetryTimerWithJitter, 4)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (watch, 0) -> (run, 0) -> (readyToFlush, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (sslVerifyCertificateAuthority, 2) -> (Verify, 1) -> (CertificateToDANE, 3) -> (galMulSliceXor, 5)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2) -> (MarkAsAlive, 0) -> (Set, 3)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (ReadFile, 5) -> (call, 3) -> (Call, 3) -> (Post, 3) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0)
(Save, 1) -> (Unlock, 0) -> (unlock, 4) -> (deleteLockInfoEntryForVolumePath, 1) -> (Unlock, 1) -> (Call, 3) -> (Post, 3)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (open, 1) -> (openStart, 1) -> (openTune, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3) -> (NewGetService, 1) -> (Expand, 0) -> (reconnect, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (newPartitionProducer, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Do, 1) -> (body, 0) -> (nTrailingNonStarters, 0)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0) -> (StorePointer, 2) -> (LoadLibraryEx, 3)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (watch, 0) -> (run, 0) -> (readyToFlush, 0) -> (empty, 0) -> (newClusterNode, 2) -> (updateLatency, 0)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (Start, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Do, 1) -> (body, 0)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (String, 0) -> (itoa, 1) -> (uitoa, 1) -> (parseTerm, 1) -> (codeSomeShardsP, 5)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (newBrokerProducer, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Connect, 0) -> (asyncCBDispatcher, 0) -> (pickServer, 0) -> (outboundKeyFromMID, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2) -> (readAllXLMetadata, 4)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Encode, 2) -> (NewEncoder, 1) -> (newEncoderWithWriter, 1) -> (yaml_emitter_set_output_writer, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3) -> (NewGetService, 1) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (IDKey, 6) -> (deriveKey, 9) -> (extractKey, 4)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2) -> (Expand, 0)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (watch, 0) -> (run, 0) -> (readyToFlush, 0) -> (empty, 0) -> (lazyinit, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(Save, 1) -> (Lock, 0) -> (lockLoop, 2) -> (Sub, 1) -> (newRetryTimerWithJitter, 4)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2) -> (IsErrIgnored, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (newBrokerConsumer, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2) -> (Exists, 3) -> (GetObjectInfo, 3) -> (getObjectInfo, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (send, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (process, 1) -> (file, 3) -> (singlewatch, 4) -> (Record, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Send, 1) -> (NewRequest, 3) -> (publish, 3) -> (isReconnecting, 0)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (SetCache, 0) -> (NewClient, 1)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0) -> (StorePointer, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Encode, 2) -> (NewEncoder, 1) -> (newEncoderWithWriter, 1) -> (yaml_emitter_set_output_writer, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (process, 1) -> (file, 3) -> (putInt64Array, 1) -> (run, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (unmarshal, 3) -> (IsNil, 0) -> (document, 0) -> (fail, 0) -> (Register, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (safeAsyncClose, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Send, 1) -> (NewRequest, 3) -> (publish, 3) -> (isReconnecting, 0) -> (NewClient, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Start, 0) -> (Boolean, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (newPartitionProducer, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (inBounds, 3) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (Lock, 0) -> (lockBlocking, 2) -> (Sub, 1) -> (Lock, 1) -> (Call, 3) -> (Post, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Connect, 0) -> (asyncCBDispatcher, 0) -> (pickServer, 0) -> (outboundKeyFromMID, 1) -> (processOpErr, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Start, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Send, 1) -> (NewRequest, 3)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Open, 2) -> (open, 1) -> (openStart, 1) -> (openTune, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (send, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (WithTimeout, 2) -> (Now, 0) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Get, 0) -> (NewGetService, 1) -> (Expand, 0) -> (argExpander, 1) -> (Auth, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Get, 0) -> (NewGetService, 1) -> (Expand, 0) -> (argExpander, 1) -> (Auth, 1) -> (inWorker, 0) -> (handleCall, 1) -> (sendMessage, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (Get, 1) -> (Get, 2) -> (get, 2) -> (getsockopt, 4) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0) -> (handleCall, 1) -> (sendMessage, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (New, 0) -> (Reset, 0) -> (uint32, 1) -> (Remove, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (send, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Remove, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Open, 1) -> (sendAndReceiveSASLPlainAuth, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Request, 3) -> (PublishRequest, 3) -> (publish, 3)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Run, 0) -> (WaitTimeout, 1) -> (Go, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Do, 1) -> (body, 0) -> (bodyNext, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2) -> (readAllXLMetadata, 4)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Start, 0) -> (Boolean, 1) -> (sniff, 1) -> (updateConns, 1) -> (Set, 3)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (SetCache, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (Get, 1) -> (Get, 2) -> (get, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2)
(Save, 1) -> (Unlock, 0) -> (unlock, 4) -> (deleteLockInfoEntryForVolumePath, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (Register, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (Get, 1) -> (Get, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (channel, 0) -> (Dial, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (call, 3) -> (isNetworkDisconnectError, 1) -> (Post, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Unregister, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (WithTimeout, 2) -> (Now, 0) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2) -> (MarkAsAlive, 0) -> (Set, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Get, 0) -> (NewGetService, 1) -> (Expand, 0) -> (argExpander, 1) -> (Auth, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0) -> (StorePointer, 2) -> (LoadLibraryEx, 3) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0) -> (handleCall, 1) -> (sendMessage, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Get, 0) -> (NewGetService, 1)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (WithTimeout, 2) -> (Now, 0) -> (propagateCancel, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Open, 2)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (ReadFile, 5) -> (call, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Do, 1) -> (body, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Connect, 0) -> (asyncCBDispatcher, 0)
(Save, 1) -> (Lock, 0) -> (lockBlocking, 2) -> (Sub, 1) -> (newRetryTimerWithJitter, 4)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Err, 1) -> (AddError, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Start, 0) -> (Boolean, 1) -> (sniff, 1)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2) -> (MarkAsAlive, 0) -> (asyncFlush, 1)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (Register, 1)
(Save, 1) -> (New, 0) -> (Interface, 0) -> (errSyntax, 0) -> (Encode, 2) -> (NewEncoder, 1) -> (newEncoderWithWriter, 1) -> (yaml_emitter_set_output_writer, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (unmarshal, 3) -> (IsNil, 0) -> (document, 0) -> (fail, 0) -> (NewClient, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0) -> (handleCall, 1) -> (sendMessage, 1)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (Unlock, 0) -> (unlock, 4) -> (deleteLockInfoEntryForVolumePath, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (Get, 1) -> (Get, 2) -> (get, 2) -> (getsockopt, 4)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (newPartitionProducer, 2)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0) -> (StorePointer, 2) -> (LoadLibraryEx, 3) -> (initConn, 1) -> (ReadOnly, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (unmarshal, 3) -> (IsNil, 0) -> (document, 0) -> (fail, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Send, 1) -> (NewRequest, 3) -> (publish, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (unmarshal, 3) -> (IsNil, 0) -> (document, 0) -> (fail, 0) -> (NewClient, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2) -> (readAllXLMetadata, 4)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 2)
(Save, 1) -> (Unlock, 0) -> (unlock, 4) -> (deleteLockInfoEntryForVolumePath, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (AsyncGet, 0) -> (GetResult, 1) -> (Ack, 1) -> (Ack, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (getBrokerProducer, 1) -> (newBrokerProducer, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2) -> (Exists, 3) -> (GetObjectInfo, 3) -> (getObjectInfo, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Request, 3) -> (PublishRequest, 3) -> (publish, 3)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (WithContext, 1) -> (copy, 0) -> (copyIP, 1)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (ReadFile, 5) -> (call, 3) -> (Call, 3) -> (Post, 3)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (process, 1) -> (file, 3) -> (singlewatch, 4) -> (Record, 1) -> (newClusterNode, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Start, 0) -> (CFRunLoopWakeUp, 1)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (SetRedis, 0) -> (NewClient, 1)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (MustRegister, 1) -> (Register, 1)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (refBrokerConsumer, 1) -> (newBrokerConsumer, 1)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (watch, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3) -> (NewGetService, 1) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2) -> (MarkAsAlive, 0) -> (asyncFlush, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2) -> (Exists, 3) -> (GetObjectInfo, 3) -> (getObjectInfo, 3)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (AsyncClose, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Connect, 0) -> (asyncCBDispatcher, 0) -> (pickServer, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Stop, 1) -> (Walk, 2) -> (fn, 1) -> (nonStateWatchedLocked, 1)
(Save, 1) -> (Unlock, 0) -> (unlock, 4) -> (deleteLockInfoEntryForVolumePath, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (NewClient, 1)
(Save, 1) -> (New, 0) -> (RandomizePrefix, 0) -> (int, 1) -> (ReadFile, 5) -> (call, 3) -> (Call, 3) -> (Post, 3) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0) -> (handleCall, 1) -> (sendMessage, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (newBrokerConsumer, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (Inf, 1) -> (Register, 1)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Marshal, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (unmarshal, 3) -> (IsNil, 0) -> (document, 0)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (process, 1) -> (file, 3) -> (singlewatch, 4) -> (Record, 1)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (watch, 0) -> (run, 0) -> (readyToFlush, 0) -> (empty, 0) -> (newClusterNode, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3) -> (NewGetService, 1) -> (Expand, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3) -> (NewGetService, 1) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0) -> (handleCall, 1) -> (sendMessage, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2) -> (Expand, 0) -> (initConn, 1) -> (ReadOnly, 0) -> (inWorker, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (safeAsyncClose, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (lockedOpenFile, 4) -> (lockFile, 2) -> (lockFileEx, 5)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Connect, 0) -> (asyncCBDispatcher, 0) -> (pickServer, 0) -> (outboundKeyFromMID, 1) -> (NewClient, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (Get, 1) -> (Get, 2) -> (get, 2) -> (getsockopt, 4) -> (initConn, 1) -> (ReadOnly, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (WithContext, 1) -> (copy, 0) -> (copyIP, 1) -> (rrfunc, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Start, 0)
(Save, 1) -> (Unlock, 0) -> (unlock, 4) -> (deleteLockInfoEntryForVolumePath, 1) -> (ForceUnlock, 1) -> (Call, 3) -> (Post, 3)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Put, 1) -> (Delete, 3) -> (DeleteObject, 3) -> (isObject, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3) -> (NewGetService, 1) -> (Expand, 0) -> (NewClient, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (WithContext, 1) -> (copy, 0) -> (copyIP, 1) -> (rrfunc, 0) -> (NewClient, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 1) -> (NewRequest, 3) -> (NewGetService, 1) -> (Expand, 0) -> (readLoop, 0) -> (processOpErr, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Get, 0) -> (NewGetService, 1) -> (Expand, 0) -> (argExpander, 1) -> (Auth, 1) -> (inWorker, 0)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Connect, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Get, 0) -> (NewGetService, 1) -> (Expand, 0)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1)
(Save, 1) -> (PrimaryKeyZero, 0) -> (PrimaryField, 0) -> (PrimaryFields, 0) -> (Get, 1) -> (Load, 0) -> (StorePointer, 2) -> (LoadLibraryEx, 3) -> (add, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (Start, 0) -> (CFRunLoopWakeUp, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Send, 2) -> (, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Send, 2) -> (send, 3)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (WithTimeout, 2) -> (Now, 0) -> (Start, 0) -> (CFRunLoopWakeUp, 1) -> (healthcheck, 2) -> (MarkAsAlive, 0) -> (asyncFlush, 1)
(Save, 1) -> (New, 0) -> (Interface, 0) -> (errSyntax, 0) -> (Encode, 2) -> (NewEncoder, 1) -> (newEncoderWithWriter, 1) -> (yaml_emitter_set_output_writer, 2) -> (codeSomeShardsP, 5)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (open, 1) -> (openStart, 1) -> (openTune, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Open, 2) -> (open, 1) -> (openStart, 1) -> (openTune, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Open, 1)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (BorrowIterator, 1) -> (ResetBytes, 1) -> (reset, 2) -> (Expand, 0)
(Save, 1) -> (New, 0) -> (New, 1) -> (RegisterValidation, 2) -> (watch, 0) -> (run, 0) -> (readyToFlush, 0) -> (empty, 0) -> (GetOrCreate, 1) -> (appendIfNotExists, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (newTree, 0) -> (newNonrecursiveTree, 3) -> (internal, 1) -> (recFunc, 1) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (inBounds, 3) -> (Render, 2)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (Update, 3) -> (Unmarshal, 2) -> (Do, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (AsyncClose, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (Do, 1) -> (body, 0) -> (nTrailingNonStarters, 0)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (gobEncode, 1) -> (NewEncoder, 1) -> (newEncoderWithWriter, 1) -> (yaml_emitter_set_output_writer, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (updateLeader, 0) -> (Run, 1) -> (storeScratch, 4) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2) -> (Render, 1)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (partitionMessage, 1) -> (Partition, 2) -> (cachedPartitions, 2) -> (inBounds, 3) -> (BashComplete, 1) -> (Render, 2)
(Save, 1) -> (writeFile, 2) -> (Write, 1) -> (lastBoundary, 2) -> (Unregister, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Start, 1) -> (Notify, 2)
(Save, 1) -> (Unlock, 0) -> (unlock, 4) -> (deleteLockInfoEntryForVolumePath, 1) -> (RUnlock, 1) -> (Call, 3) -> (Post, 3)
(Save, 1) -> (writeFile, 2) -> (CreateFile, 1) -> (Remove, 1) -> (, 0) -> (newKafkaVersion, 4) -> (CloseOnExec, 1) -> (SetHandleInformation, 3) -> (newPartitionProducer, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Get, 0) -> (NewGetService, 1) -> (Expand, 0) -> (argExpander, 1) -> (Auth, 1) -> (inWorker, 0) -> (handleCall, 1) -> (sendMessage, 1)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Decode, 1) -> (IsNil, 0) -> (document, 0) -> (fail, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2) -> (SetRedis, 0) -> (NewClient, 1) -> (HasPlugin, 1) -> (Plugins, 0)
(Save, 1) -> (saveFileConfigEtcd, 3) -> (cancel, 0) -> (Copy, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (Decode, 1) -> (IsNil, 0) -> (document, 0)
(Save, 1) -> (New, 0) -> (CriticalIf, 2) -> (Exit, 1) -> (Error, 0) -> (TrimSpace, 1) -> (marshalDoc, 2) -> (yaml_document_end_event_initialize, 2)
(Save, 1) -> (writeFile, 2) -> (Close, 0) -> (handleErr, 1) -> (process, 1) -> (file, 3) -> (singlewatch, 4) -> (Record, 1) -> (newClusterNode, 2)

```

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