gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

fix some comments

Browse Source 
Signed-off-by: cui fliter <imcusg@gmail.com>
This commit is contained in:
cui fliter
2023-04-25 11:28:59 +08:00
parent b0d98df759
commit f1f5a59e9b
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
conf/lex.go
View File

@@ -681,7 +681,7 @@ func lexMapQuotedKey(lx *lexer) stateFn {
return lexMapQuotedKey
}
// lexMapQuotedKey consumes the text of a key between quotes.
// lexMapDubQuotedKey consumes the text of a key between quotes.
func lexMapDubQuotedKey(lx *lexer) stateFn {
if r := lx.peek(); r == eof {
return lx.errorf("Unexpected EOF processing double quoted map key.")
@@ -1061,7 +1061,7 @@ func lexNegNumberStart(lx *lexer) stateFn {
return lexNegNumber
}
// lexNumber consumes a negative integer or a float after seeing the first digit.
// lexNegNumber consumes a negative integer or a float after seeing the first digit.
func lexNegNumber(lx *lexer) stateFn {
r := lx.next()
switch {

4
server/accounts.go
View File

@@ -1342,7 +1342,7 @@ func (a *Account) sendBackendErrorTrackingLatency(si *serviceImport, reason rsiR
a.sendLatencyResult(si, sl)
}
// sendTrackingMessage will send out the appropriate tracking information for the
// sendTrackingLatency will send out the appropriate tracking information for the
// service request/response latency. This is called when the requestor's server has
// received the response.
// TODO(dlc) - holding locks for RTTs may be too much long term. Should revisit.
@@ -1602,7 +1602,7 @@ func (a *Account) NumPendingAllResponses() int {
return a.NumPendingResponses(_EMPTY_)
}
// NumResponsesPending returns the number of responses outstanding for service exports
// NumPendingResponses returns the number of responses outstanding for service exports
// on this account. An empty filter string returns all responses regardless of which export.
// If you specify the filter we will only return ones that are for that export.
// NOTE this is only for what this server is tracking.

4
server/jetstream.go
View File

@@ -464,7 +464,7 @@ func (s *Server) restartJetStream() error {
return nil
}
// checkStreamExports will check if we have the JS exports setup
// checkJetStreamExports will check if we have the JS exports setup
// on the system account, and if not go ahead and set them up.
func (s *Server) checkJetStreamExports() {
if sacc := s.SystemAccount(); sacc != nil {
@@ -638,7 +638,7 @@ func (a *Account) enableAllJetStreamServiceImportsAndMappings() error {
return nil
}
// enableJetStreamEnabledServiceImportOnly will enable the single service import responder.
// enableJetStreamInfoServiceImportOnly will enable the single service import responder.
// Should we do them all regardless?
func (a *Account) enableJetStreamInfoServiceImportOnly() error {
// Check if this import would be overshadowed. This can happen when accounts