Derek Collison 4e92b0ed6e When a server was restarting, if a stream had a MaxAge and there were a very large amount of messages to expire, this would take too long. ...

During normal operation and quick restarts the number of expired messages per cycle is manageable and correct.
However if a server is shutdown for quite a long time and many messages have expired this process is too slow.

This commit introduces an optimized expiration tailored for startup vs running state.

Signed-off-by: Derek Collison <derek@nats.io>

2021-07-30 12:48:47 -07:00

..

configs

[fixed] tls timeout now accepts units

2021-07-19 11:42:28 -04:00

pse

Remove external dependency on 'ps' for memory and cpu usage.

2021-06-06 11:13:32 -07:00

sysmem

Fixed Memory() for Windows

2020-05-19 14:15:11 -07:00

accounts_test.go

Review comments

2021-07-22 11:27:34 -04:00

accounts.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

auth_test.go

Run gofmt -s to simplify code

2021-04-09 15:18:06 -07:00

auth.go

[adding] kind and client_type to account connect/disconnect events (#2351)

2021-07-07 17:43:50 -04:00

ciphersuites.go

…

client_test.go

[adding] kind and client_type to account connect/disconnect events (#2351)

2021-07-07 17:43:50 -04:00

client.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

closed_conns_test.go

System Account on by default.

2020-05-29 17:56:45 -07:00

config_check_test.go

ocsp: Add caching staples to disk to store dir

2021-05-26 15:04:05 -07:00

const.go

[changed] default account fetch timeout to be smaller as client timeout

2021-07-19 12:22:07 -04:00

consumer.go

We had a situation where when a stream with interest retention had a clustered consumer it could cause the server to panic when the consumer was being deleted.

2021-07-28 15:10:21 -07:00

dirstore_test.go

[FIXED] MQTT: asset placement in origin cluster

2021-04-28 19:28:00 -06:00

dirstore.go

Move default file and dir perms

2021-05-19 14:46:07 -07:00

disk_avail_windows.go

Separate out disk available for Windows

2020-10-31 12:56:27 -07:00

disk_avail.go

Move default file and dir perms

2021-05-19 14:46:07 -07:00

errors_gen.go

Minor updates to error data

2021-05-28 15:52:22 +02:00

errors_test.go

…

errors.go

richer api errors proposal

2021-05-26 08:04:50 +02:00

errors.json

Add descriptions to JetStream streams and consumers.

2021-07-27 14:05:25 -07:00

events_test.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

events.go

[fixed] jetstream unique server name requirement across domains (#2378)

2021-07-27 18:42:19 -04:00

filestore_test.go

When a server was restarting, if a stream had a MaxAge and there were a very large amount of messages to expire, this would take too long.

2021-07-30 12:48:47 -07:00

filestore.go

When a server was restarting, if a stream had a MaxAge and there were a very large amount of messages to expire, this would take too long.

2021-07-30 12:48:47 -07:00

fuzz.go

Change naming in server fuzzer

2021-07-23 10:19:07 +01:00

gateway_test.go

[FIXED] MQTT fixes and improvements

2021-05-04 20:48:14 -06:00

gateway.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

jetstream_api.go

Add descriptions to JetStream streams and consumers.

2021-07-27 14:05:25 -07:00

jetstream_cluster_test.go

Fix for flapper

2021-07-08 07:42:40 -07:00

jetstream_cluster.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

jetstream_errors_generated.go

Add descriptions to JetStream streams and consumers.

2021-07-27 14:05:25 -07:00

jetstream_errors_test.go

further tagged error confusion cleanups

2021-06-18 20:11:09 +02:00

jetstream_errors.go

Add error codes for all consumer creation errors

2021-07-06 14:51:03 +02:00

jetstream_events.go

add domain in JS advisories

2021-05-07 19:35:46 +02:00

jetstream_test.go

We had a situation where when a stream with interest retention had a clustered consumer it could cause the server to panic when the consumer was being deleted.

2021-07-28 15:10:21 -07:00

jetstream.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

jwt_test.go

Fixed some tests to manually close account resolver

2021-05-06 18:46:32 -06:00

jwt.go

[fixed] header handling in system services

2021-07-01 19:00:52 -04:00

leafnode_test.go

[fixed] jetstream unique server name requirement across domains (#2378)

2021-07-27 18:42:19 -04:00

leafnode.go

[fixed] jetstream unique server name requirement across domains (#2378)

2021-07-27 18:42:19 -04:00

log_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

log.go

JetStream Clustering WIP

2021-01-14 01:14:52 -08:00

memstore_test.go

JetStream Clustering WIP

2021-01-14 01:14:52 -08:00

memstore.go

Improvements to large numbers of JetStream R1 consumers per stream.

2021-06-29 05:45:55 -07:00

monitor_sort_opts.go

…

monitor_test.go

[FIXED] Getting varz from the http endoint saw Subscriptions always double for each fetch.

2021-05-03 18:43:07 -07:00

monitor.go

When checking limits we would check total ask against the server limits if limits were not set.

2021-06-12 10:27:43 -07:00

mqtt_test.go

[FIXED] MQTT: panic when using import/export

2021-06-08 15:03:12 -06:00

mqtt.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

nkey_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

nkey.go

[added] support for StrictSigningKeyUsage and updated jwt library (#1845)

2021-01-26 17:49:58 -05:00

norace_test.go

When a server was restarting, if a stream had a MaxAge and there were a very large amount of messages to expire, this would take too long.

2021-07-30 12:48:47 -07:00

ocsp.go

[adding] kind and client_type to account connect/disconnect events (#2351)

2021-07-07 17:43:50 -04:00

opts_test.go

[FIXED] LeafNode config reload failed without any change made

2021-06-09 16:12:39 -06:00

opts.go

[fixed] tls timeout now accepts units

2021-07-19 11:42:28 -04:00

parser_test.go

[CHANGED] Enforce max_control_line for client connections only

2021-01-26 15:33:39 -07:00

parser.go

[adding] kind and client_type to account connect/disconnect events (#2351)

2021-07-07 17:43:50 -04:00

ping_test.go

Fixed TestPing test

2020-06-12 10:03:47 -06:00

raft.go

Remove the swapping of accounts during processing of service imports.

2021-07-26 07:57:10 -07:00

reload_test.go

[FIXED] Clients disconnected on reload when only $SYS account configured

2021-06-21 14:03:42 -06:00

reload.go

Adds public ReloadOptions api support

2021-07-07 09:57:35 -07:00

ring_test.go

…

ring.go

…

route.go

[fixed] jetstream unique server name requirement across domains (#2378)

2021-07-27 18:42:19 -04:00

routes_test.go

[FIXED] Failed route TLS handshake would leave failed conn's lock, locked

2021-06-22 14:05:43 -06:00

sendq.go

We should not sit in place here, no measurable effect on latency in tests

2021-07-01 14:29:09 -07:00

server_test.go

Force server name to be set if mqtt{} defined

2021-05-05 13:17:53 -06:00

server.go

[fixed] jetstream unique server name requirement across domains (#2378)

2021-07-27 18:42:19 -04:00

service_test.go

Return not ready for connection reason

2021-04-20 11:45:08 -07:00

service_windows.go

…

service.go

…

signal_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

signal_windows.go

…

signal.go

Make SIGTERM exit 1

2021-04-12 10:17:13 -07:00

split_test.go

…

store.go

Improvements to large numbers of JetStream R1 consumers per stream.

2021-06-29 05:45:55 -07:00

stream.go

Add descriptions to JetStream streams and consumers.

2021-07-27 14:05:25 -07:00

sublist_test.go

[FIXED] Return no match result if subject contains empty token

2021-01-28 17:43:22 -07:00

sublist.go

Remove unnecessary lines

2021-07-22 18:53:06 -04:00

test_test.go

richer api errors proposal

2021-05-26 08:04:50 +02:00

trust_test.go

Check errors when removing test directories and files

2021-04-07 11:09:47 -07:00

util_test.go

unexported import of Comma function from humanize

2020-05-19 14:16:03 -07:00

util.go

Inhibit Go's default TCP keepalive settings for NATS (#1562)

2020-08-14 13:37:59 -04:00

websocket_test.go

[FIXED] Websocket compression/decompression issue with continuation frames

2021-06-21 11:09:19 -06:00

websocket.go

[FIXED] Websocket compression/decompression issue with continuation frames

2021-06-21 11:09:19 -06:00