Commit Graph

4688 Commits

Author SHA1 Message Date
Ivan Kozlovic
df3eccbd69 Fix yet another flapper
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-07-06 13:55:28 -06:00
Ivan Kozlovic
710d0c3a1f Fixed another flapper
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-07-06 12:44:08 -06:00
Ivan Kozlovic
d5f5a74438 Fixed some tests
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-07-06 12:20:03 -06:00
Derek Collison
57cfba0964 Make requirement for interest on creation of ephemerals soft vs hard.
Will start the cleanup timer if no interest but allow creation.

Signed-off-by: Derek Collison <derek@nats.io>
2021-07-06 10:48:07 -07:00
Derek Collison
5f7d8be4ed Merge pull request #2344 from nats-io/no-pool
[FIXED] Use of sync.Pool for filestore could cause msg corruption.
2021-07-06 08:48:10 -07:00
Derek Collison
960c45df81 Use of sync.Pool for filestore could cause msg corruption.
Signed-off-by: Derek Collison <derek@nats.io>
2021-07-06 08:41:01 -07:00
R.I.Pienaar
42a17d5532 Merge pull request #2345 from ripienaar/consumer_errors
Add error codes for all consumer creation errors
2021-07-06 16:44:55 +02:00
R.I.Pienaar
709e256d64 Add error codes for all consumer creation errors
I wanted to supress some logging of consumer create
errors that just isn't needed and would be really
annoying on large networks, so I added many constants
and updated all errors.

I think only JSConsumerStoreFailedErrF is worth logging
on large networks else there would be quite a lot of
logs generated that one just cannot act on

Signed-off-by: R.I.Pienaar <rip@devco.net>
2021-07-06 14:51:03 +02:00
Matthias Hanel
dc27c360aa Merge pull request #2338 from nats-io/sys-export
[fixed] header handling in system services
2021-07-01 19:15:24 -04:00
Matthias Hanel
a72ca8a9bf [fixed] header handling in system services
On export/import a header was inserted which broke parsing of the
message.
Fixed unit test broken by .beta in version

Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-07-01 19:00:52 -04:00
Ivan Kozlovic
4e6fe87c06 Fix version
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-07-01 16:55:00 -06:00
Derek Collison
73b2beb2f3 Merge pull request #2337 from nats-io/flush
Should not flush in place for stream loop.
2021-07-01 14:32:08 -07:00
Derek Collison
9b73fae5bd We should not sit in place here, no measurable effect on latency in tests
Signed-off-by: Derek Collison <derek@nats.io>
2021-07-01 14:29:09 -07:00
Waldemar Quevedo
bd5d5d0ff8 Merge pull request #2323 from nats-io/add-ocsp-cert-gen
Add OCSP cert generator script
2021-07-01 11:07:02 -07:00
Jaime Piña
7bbca78ee2 Add OCSP cert generator script 2021-07-01 08:59:37 -07:00
Phil Pennock
25ea93c933 Cleanup references to 'master' and 'gnatsd' (#2336)
* We've renamed our default branch from 'master' to 'main'
* We switched some time ago from 'gnatsd' to 'nats-server' and some temporary
  redirects no longer work, so fix those too
2021-07-01 10:48:30 -04:00
Alberto Ricart
a2480f15b4 adr documenting the idle_heartbeat feature for consumers (#2330)
* adr documenting the idle_heartbeat feature for consumers
[ci skip]
2021-07-01 09:46:35 -05:00
Alberto Ricart
a389e46efb adr documenting purge and options (#2331)
* adr documenting purge and options
[ci skip]
2021-07-01 09:45:51 -05:00
Derek Collison
fd9e9480da Merge pull request #2333 from nats-io/srace
Check not really needed here, so removed
2021-07-01 06:19:46 -07:00
Derek Collison
8794fd7265 Merge pull request #2334 from nats-io/lastupdate
Fix for #2329.
2021-06-30 21:26:59 -07:00
Derek Collison
ad4685c84f Fix for crash in test run
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-30 19:30:37 -07:00
Derek Collison
c2c146c9f2 Fix for #2329.
When we created a filestore we would figure out if we should track by subject based on stream config.
This would cause bad results when a stream was updated to multiple subjects or wildcards.
This change tightens when and what we track but turns it on all the time now.

Signed-off-by: Derek Collison <derek@nats.io>
2021-06-30 19:10:31 -07:00
Derek Collison
617f061084 Check not really needed here, so removed
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-30 15:08:56 -07:00
Ivan Kozlovic
907fef4979 Merge pull request #2327 from nats-io/release_2_3_1
Release v2.3.1
v2.3.1
2021-06-29 14:09:58 -06:00
Ivan Kozlovic
13334c227d Release v2.3.1
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-06-29 13:51:32 -06:00
Ivan Kozlovic
916c6d73b9 Merge pull request #2326 from nats-io/consumer-stop
If dirty flag set always write consumer state.
2021-06-29 13:50:38 -06:00
Derek Collison
35f6be2056 If dirty flag set always write state out
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-29 12:25:28 -07:00
Derek Collison
a78f155733 2.3.1-RC.1
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-29 08:36:00 -07:00
Derek Collison
26e63a14a6 Merge pull request #2324 from nats-io/large-r1
Improvements to large numbers of JetStream R1 consumers per stream.
2021-06-29 08:35:17 -07:00
Derek Collison
280a95b589 Merge pull request #2325 from nats-io/prand-race
Protect account prand, use faster Uint64 variant
2021-06-29 06:50:06 -07:00
Derek Collison
3c16f776dc Protect account prand, use faster Uint64 variant
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-29 06:13:41 -07:00
Derek Collison
99fed910f0 Improvements to large numbers of JetStream R1 consumers per stream.
1. We were holding open FDs longer than we should for consumers causing issues with open FD limits. We now do not hold them open and cap updates a bit better.

2. When doing a stream delete, consumer delete was repeating alot of work that was not necessary, causing longer delays. This has been optimized a bit, still more improvements to be made.

3. We cover all JS under a single export, but that was also trapping GetNext for pull based consumers, and since this was a no-op (is handled at user account level) we were creating alot of garbage service import responses and reverse map entries that had to be garbage collected. We have a fix in to avoind this but still looking for a better one.

4. Still had some lingering references to all exports vs single JS export.

Signed-off-by: Derek Collison <derek@nats.io>
2021-06-29 05:45:55 -07:00
Derek Collison
7be0d28316 Merge pull request #2322 from nats-io/match-seq-subj
Added ability to match based on last expected sequence per subject.
2021-06-28 13:26:25 -07:00
Derek Collison
bb84ef7d91 Added ability to match based on last expected sequence per subject.
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-28 10:57:50 -07:00
R.I.Pienaar
5bd1e8fe4e Merge pull request #2321 from ripienaar/store_error_logging
do not log at Error level for some store failures
2021-06-28 18:07:05 +02:00
R.I.Pienaar
0d71d35e43 do not log at Error level for some store failures
Some of these are quite generic errors that can happen a lot
in normal circumstances so no need to be too noisy about them

Fixes one missed old style Api Error

Signed-off-by: R.I.Pienaar <rip@devco.net>
2021-06-28 10:18:16 +02:00
Derek Collison
cbb97a4f4a Fix for Go client behavior change
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-27 10:52:03 -07:00
Derek Collison
63479ff8fd Bump threshold
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-27 08:33:46 -07:00
Derek Collison
2a96be2fcf Updated Go client and crypto deps
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-26 14:08:16 -07:00
Derek Collison
146c249d55 2.3.1-beta.1
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-25 13:57:16 -07:00
Derek Collison
22b60bdbe6 Merge pull request #2317 from nats-io/dn-bug
FIXED Clustered streams with seq mismatch state on store failures.
2021-06-25 13:56:12 -07:00
Derek Collison
545230bd9e FIXED Clustered streams can become broken with seq mismatch state on low level store failures.
We can account for high level failure properly but were not properly accounting for low level store failures.

Signed-off-by: Derek Collison <derek@nats.io>
2021-06-25 13:46:40 -07:00
Derek Collison
5083b36266 Merge pull request #2316 from nats-io/maxc
FIXED max consumers was not enforced when set on stream.
2021-06-25 12:19:10 -07:00
Derek Collison
08197de9e0 FIXED max consumers was not enforced when set on stream
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-25 11:45:36 -07:00
Derek Collison
e3de25f89e Merge pull request #2315 from nats-io/update-ocsp-ca
Update OCSP CA
2021-06-25 11:02:45 -07:00
Jaime Piña
b13ab18950 Update OCSP CA 2021-06-25 10:26:52 -07:00
Derek Collison
b596eb0a40 Bump to 2.3.1
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-24 14:04:20 -07:00
Derek Collison
16be7e06f0 Merge pull request #2313 from nats-io/kv-get
Added in Stream get last message by subject.
2021-06-24 13:50:43 -07:00
Derek Collison
c0e47966ab Added in Stream get last message by subject.
This is to aid in K/V overlay for simple Get ops vs creating a full blown consumer.

Signed-off-by: Derek Collison <derek@nats.io>
2021-06-24 13:21:39 -07:00
Derek Collison
a27f198b83 Skip for now, covermode blows up memory and latency thresholds
Signed-off-by: Derek Collison <derek@nats.io>
2021-06-23 13:50:14 -07:00