diff --git a/server/jetstream.go b/server/jetstream.go index 4956d909..d4f642ed 100644 --- a/server/jetstream.go +++ b/server/jetstream.go @@ -2734,7 +2734,7 @@ func canonicalName(name string) string { } // To throttle the out of resources errors. -func (s *Server) resourcesExeededError() { +func (s *Server) resourcesExceededError() { var didAlert bool s.rerrMu.Lock() diff --git a/server/jetstream_api.go b/server/jetstream_api.go index c7ad8b17..831ff972 100644 --- a/server/jetstream_api.go +++ b/server/jetstream_api.go @@ -3360,7 +3360,7 @@ func (s *Server) processStreamRestore(ci *ClientInfo, acc *Account, cfg *StreamC // TODO(dlc) - We could check apriori and cancel initial request if we know it won't fit. total += len(msg) if js.wouldExceedLimits(FileStorage, total) { - s.resourcesExeededError() + s.resourcesExceededError() resultCh <- result{NewJSInsufficientResourcesError(), reply} return } diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index c9d6ec6d..276f3d6a 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -7223,7 +7223,7 @@ func (mset *stream) processClusteredInboundMsg(subject, reply string, hdr, msg [ // Check here pre-emptively if we have exceeded this server limits. if js.limitsExceeded(stype) { - s.resourcesExeededError() + s.resourcesExceededError() if canRespond { b, _ := json.Marshal(&JSPubAckResponse{PubAck: &PubAck{Stream: name}, Error: NewJSInsufficientResourcesError()}) outq.send(newJSPubMsg(reply, _EMPTY_, _EMPTY_, nil, b, nil, 0)) @@ -7769,7 +7769,7 @@ RETRY: } else if err == NewJSInsufficientResourcesError() { notifyLeaderStopCatchup(mrec, err) if mset.js.limitsExceeded(mset.cfg.Storage) { - s.resourcesExeededError() + s.resourcesExceededError() } else { s.Warnf("Catchup for stream '%s > %s' errored, account resources exceeded: %v", mset.account(), mset.name(), err) } diff --git a/server/stream.go b/server/stream.go index 04b6bae0..b343fb9c 100644 --- a/server/stream.go +++ b/server/stream.go @@ -2093,7 +2093,7 @@ func (mset *stream) processInboundMirrorMsg(m *inMsg) bool { var err error if node != nil { if js.limitsExceeded(stype) { - s.resourcesExeededError() + s.resourcesExceededError() err = ApiErrors[JSInsufficientResourcesErr] } else { err = node.Propose(encodeStreamMsg(m.subj, _EMPTY_, m.hdr, m.msg, sseq-1, ts)) @@ -3952,7 +3952,7 @@ func (mset *stream) processJetStreamMsg(subject, reply string, hdr, msg []byte, // Check to see if we have exceeded our limits. if js.limitsExceeded(stype) { - s.resourcesExeededError() + s.resourcesExceededError() mset.clfs++ mset.mu.Unlock() if canRespond {