Commit Graph

4127 Commits

Author SHA1 Message Date
Derek Collison
cfe2f448ad Fix for when gateways were dropped and we did not detect interest returning.
Fix for leaked subscription when retrying the source consumers.
Better suppression of old messages from old direct consumers.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-20 08:44:18 -07:00
Derek Collison
04a9d51035 Fix for data race
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-20 07:15:36 -07:00
Derek Collison
61771e88f8 In operator mode with JetStream we want to load accounts that have stable storage.
Also if an account was registered but not JetStream enabled, update it vs error.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-20 06:53:13 -07:00
Derek Collison
f8b14a078e Merge pull request #2023 from nats-io/jsacc
Make sure the jetstream accounts use the name as the key to the map.
2021-03-18 20:13:59 -07:00
Derek Collison
8eefff2b3b Make sure the jetstream accounts use the name as the key to the map.
This prevents possible double adds under reload or restart scenarios.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 17:29:26 -07:00
Derek Collison
ce52ebd9fb Bump to go 1.16
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 12:57:20 -07:00
Derek Collison
a2f1977328 Merge pull request #2021 from nats-io/direct
Direct consumer updates.
2021-03-18 11:51:39 -07:00
Derek Collison
4f2b701eb5 Unlock only on return
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 11:38:04 -07:00
Derek Collison
d32f3ce479 Directs may not show up here anymore
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 11:29:33 -07:00
R.I.Pienaar
52667159e7 Merge pull request #2020 from ripienaar/2019
ensure connect events are always sent
2021-03-18 19:18:02 +01:00
Derek Collison
358ac6a956 Fix for race detector
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 11:09:28 -07:00
R.I.Pienaar
14daf39438 ensure connect events are always sent
Signed-off-by: R.I.Pienaar <rip@devco.net>
2021-03-18 19:04:36 +01:00
Derek Collison
702e17d48f Direct consumer updates.
1. Reduce maximum sliding window for large N->1.
2. Do not create any store for directs.
3. Relax hard requirement for interest at creation for directs.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 10:52:40 -07:00
Derek Collison
4784205c2d Merge pull request #2018 from nats-io/idle_filtered
Fix for filtered consumers and idle heartbeats.
2021-03-18 07:52:51 -07:00
Derek Collison
259cb07284 When a stream was busy but not for a filtered consumer with idle heartbeats they would be suppressed.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 07:46:29 -07:00
Derek Collison
aa0c3e12ac Bump version
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 06:46:28 -07:00
Derek Collison
b60847c532 Merge pull request #2017 from nats-io/mirror_restart
Mirror consumers were not able to restart after initial failure.
2021-03-18 06:28:04 -07:00
Derek Collison
b00b723168 Mirrors were not properly retrying after failures to create their internal consumer.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 06:13:26 -07:00
R.I.Pienaar
11ee71ab8c Merge pull request #2016 from ripienaar/account_failure_logs
improve log line when account registration fails
2021-03-18 13:06:12 +01:00
Derek Collison
b826dd68ae Merge pull request #2015 from nats-io/memp
Updates to memory retention in filestore.
2021-03-18 04:51:14 -07:00
R.I.Pienaar
d6e63cb683 improve log line when account registration fails
Signed-off-by: R.I.Pienaar <rip@devco.net>
2021-03-18 12:19:23 +01:00
Derek Collison
566937a880 Updates to memory pressure.
1. Release cache during heavy writes when we move to a new block if no read activity.
2. If we detect a linear scan reading dump the cache on the last seq read for the mb.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-17 18:51:34 -07:00
Derek Collison
601dbf48c1 Protect against the stream nil'ing out the outq for the consumer
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-17 18:51:18 -07:00
R.I.Pienaar
716c6d60b5 Merge pull request #2014 from ripienaar/banner_update
update banner url
2021-03-17 16:50:42 +01:00
R.I.Pienaar
ac70abdcf3 update banner url
Signed-off-by: R.I.Pienaar <rip@devco.net>
2021-03-17 16:39:24 +01:00
Derek Collison
20b09480e0 Merge pull request #2013 from nats-io/fsubs
When a stream is a mirror or has sources we need to check the upstream streams.
2021-03-17 06:59:31 -07:00
Derek Collison
74cc2b581a When a stream is a mirror or has sources we need to check the upstream streams for filter subject correctness.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-17 06:39:21 -07:00
Derek Collison
9fa16e20c0 Merge pull request #2012 from nats-io/arm32_panic
Fix for #2011 and atomics on 32bit systems.
2021-03-16 14:38:46 -07:00
Derek Collison
2e9ae92bb5 Fix for #2011 and atomics on 32bit systems.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-16 13:57:28 -07:00
Matthias Hanel
d7403ea34d Merge pull request #2009 from nats-io/js-disabled-varz
Suppress varz jetstream output if not enabled
2021-03-15 17:41:09 -04:00
Matthias Hanel
2a2adb76bc Suppress varz jetstream output if not enabled
Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-03-15 16:03:41 -04:00
Derek Collison
cb93955803 Merge pull request #2008 from nats-io/consumer_panic
Don't set to nil on stop to avoid any panics accessing that map.
2021-03-15 09:34:05 -07:00
Derek Collison
7ade99d102 Don't set to nil on stop to avoid any panics accessing that map.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-15 09:13:29 -07:00
Derek Collison
91a63505a6 Re-enable tests post release process
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-15 09:05:24 -07:00
Ivan Kozlovic
0e3c7230e4 Merge pull request #2007 from nats-io/release_2_2_0
Release v2.2.0
v2.2.0
2021-03-14 20:21:29 -06:00
Ivan Kozlovic
0d5b037fc3 Release v2.2.0
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-03-14 19:51:14 -06:00
Derek Collison
67641303cb Merge pull request #2006 from nats-io/li
Avoid lock inversions.
2021-03-14 18:21:29 -07:00
Derek Collison
e84f845afd Avoid lock inversions.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-14 18:17:53 -07:00
Derek Collison
4d15658ec2 Merge pull request #1996 from nats-io/updates
JSC Updates
2021-03-14 17:17:08 -07:00
Derek Collison
e530c98ebe We no longer force remove our peer on out of space.
We also delay restarting JetStream to make sure accounts are enabled.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-14 17:01:38 -07:00
Ivan Kozlovic
423b79440c Merge pull request #2004 from nats-io/jwt-issue
[FIXED] private import issue by pulling in up to date jwt library
2021-03-14 18:00:56 -06:00
Ivan Kozlovic
4f8931e27f Merge pull request #2005 from nats-io/rm-dockerfile-alpine
Delete Dockerfile.alpine
2021-03-14 17:55:50 -06:00
Waldemar Quevedo
e2287c6ce0 Delete Dockerfile.alpine 2021-03-14 16:53:26 -07:00
Matthias Hanel
eb1a91d5b6 [fixed] private import issue by pulling in up to date jwt library
Also prevent nats based account resolver from storing invalid jwt
Updated compress and highwayhash

Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-03-14 19:37:14 -04:00
Derek Collison
a205f8f2de Fix for updating peers and quorum sizes.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-14 15:31:29 -07:00
Waldemar Quevedo
e271042590 Merge pull request #2003 from nats-io/updates-js-reload
Fix for JS reload and exports
2021-03-14 15:22:36 -07:00
Waldemar Quevedo
775afd01e7 Fix for JS reload and exports
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
2021-03-14 15:16:56 -07:00
Ivan Kozlovic
5072649540 Make sure to properly add peer after failure
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-03-14 15:32:12 -06:00
Ivan Kozlovic
b01cdf6108 Merge pull request #2002 from nats-io/gw_interest_only_report
[CHANGED] Move Gateway interest-only mode switch from INF to DBG
2021-03-14 13:58:43 -06:00
Derek Collison
e079d75d8b Fixes for index first from idx file
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-14 12:26:30 -07:00