Skip to content

Commit

Permalink
chore: fix function names in comment
Browse files Browse the repository at this point in the history
Signed-off-by: needsure <[email protected]>
  • Loading branch information
needsure committed Apr 9, 2024
1 parent dbf8e26 commit 1239702
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion internal/fastrand/fastrand.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ func Uint32() uint32
//go:linkname Uint32n runtime.fastrandn
func Uint32n(n uint32) uint32

// Uint32 returns a lock free uint64 value.
// Uint64 returns a lock free uint64 value.
func Uint64() uint64 {
v := uint64(Uint32())
return v<<32 | uint64(Uint32())
Expand Down
2 changes: 1 addition & 1 deletion logger/syslog_windows_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ func TestSysLoggerWithDebugAndTrace(t *testing.T) {
}
}

// TestSysLoggerWithDebugAndTrace tests remote event logging
// TestRemoteSysLoggerWithDebugAndTrace tests remote event logging
func TestRemoteSysLoggerWithDebugAndTrace(t *testing.T) {
checkPrivledges(t)
logger := NewRemoteSysLogger("", true, true)
Expand Down
2 changes: 1 addition & 1 deletion server/events.go
Original file line number Diff line number Diff line change
Expand Up @@ -1450,7 +1450,7 @@ func (s *Server) sameDomain(domain string) bool {
return domain == _EMPTY_ || s.info.Domain == _EMPTY_ || domain == s.info.Domain
}

// remoteServerShutdownEvent is called when we get an event from another server shutting down.
// remoteServerShutdown is called when we get an event from another server shutting down.
func (s *Server) remoteServerShutdown(sub *subscription, c *client, _ *Account, subject, reply string, hdr, msg []byte) {
s.mu.Lock()
defer s.mu.Unlock()
Expand Down
2 changes: 1 addition & 1 deletion server/jetstream_cluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -551,7 +551,7 @@ func (js *jetStream) isStreamHealthy(acc *Account, sa *streamAssignment) bool {
return false
}

// isConsumerCurrent will determine if the consumer is up to date.
// isConsumerHealthy will determine if the consumer is up to date.
// For R1 it will make sure the consunmer is present on this server.
func (js *jetStream) isConsumerHealthy(mset *stream, consumer string, ca *consumerAssignment) bool {
if mset == nil {
Expand Down

0 comments on commit 1239702

Please sign in to comment.