gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity
2,886 Commits 30 Branches 48 Tags
07ef71ff98f45f8c2711be4aeaf484610d891dda
Commit Graph

1721 Commits

Author SHA1 Message Date
Derek Collison
07ef71ff98 Avoid parsing large sizes for messages 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-06-01 16:54:41 -07:00
Derek Collison
05e38ae527 Merge branch 'master' into sys-acc 2020-06-01 11:53:14 -07:00
Derek Collison
5f130128ce Read INFO used bufio.Reader 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-06-01 11:46:18 -07:00
Derek Collison
5271be49ee Fix race for snapshots 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-06-01 09:21:22 -07:00
Ivan Kozlovic
c27f717ef6 [FIXED] Log file size limit not honored after re-open signal 
When the logfile_size_limit option is specified, the logfile will
be automatically rotated. However, if user still sends the re-open
signal (SIGUSR1), the log file will then no longer apply the
size limit.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-06-01 09:17:32 -06:00
Derek Collison
4d62a7237d Allow redelivery for AckAll policy, general upgrades to pending beahviors. Fixes #1436 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-31 07:50:50 -07:00
Derek Collison
e584d4efee Merge pull request #1435 from nats-io/js-hdrs 
First pass header support for JetStream
 2020-05-31 06:01:01 -07:00
Derek Collison
dbde2479c2 Add in headers to consumer delivered messages 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-30 15:03:54 -07:00
Derek Collison
9156fa6c03 Merge pull request #1432 from nats-io/snapshot-check 
Allow snapshots to optionally check all message checksums
 2020-05-30 12:53:40 -07:00
Derek Collison
8e407f8db4 Do snapshot setup in go routine as well for checkMsgs 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-30 11:28:43 -07:00
Derek Collison
eca04c6fce First pass header support for JetStream 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-30 10:04:23 -07:00
Derek Collison
2bd7553c71 System Account on by default. 
Most of the changes are to turn it off for tests that were watching subscriptions and such.

Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-29 17:56:45 -07:00
Ivan Kozlovic
44e78a1fb6 Fixed some tests 
- A race test may have consumed a lot of fds going in TIME_WAIT
that could cause some issues for other tests
- Missing defer filestore.Stop() that would leave flushLoop()
routines
- A defer for the from server in a LeafNode test
- Rework [Re]ConnectErrorReports that was failing often for me
locally (probably due to exhaustion of fds - too many TIME_WAIT).

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-29 17:47:08 -06:00
Derek Collison
e12907ffa6 Allow snapshots to optionally check all message checksums 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-29 09:57:33 -07:00
Derek Collison
0a206b4c64 Snapshot performance tweaks 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-29 08:07:31 -07:00
Derek Collison
10e49ca1c4 Fix more flappers 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-28 14:19:11 -07:00
Derek Collison
f6a9d3bc3c Merge pull request #1429 from kingkorf/master 
First check bcrypt '$' prefix before performing rexeg on password
 2020-05-28 14:18:03 -07:00
Jacob
c1848a997c First check $ prefix 2020-05-28 22:54:20 +02:00
Ivan Kozlovic
b0e43b6aa9 Fix flappers 
- TestResponsePermissions: ensure subscription for service is
registered by server before sending requests.
- TestReloadDoesNotWipeAccountsWithOperatorMode: wait for subject
propagation.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-28 13:41:02 -06:00
Derek Collison
f859edaf4f Merge pull request #1428 from nats-io/dl 
Avoid deadlock by releasing consumer lock.
 2020-05-28 12:36:14 -07:00
Derek Collison
8c9a30b8a1 Avoid deadlock by releasing consumer lock 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-28 12:30:12 -07:00
Derek Collison
5bae878719 Merge pull request #1426 from nats-io/max-conns 
Close connections when a remote update exceeds maximum
 2020-05-28 11:36:49 -07:00
Derek Collison
12e353e3ac Close connections when a remote update exceeds maximum 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-28 11:09:00 -07:00
Ivan Kozlovic
5d949bf1ea Merge pull request #1424 from nats-io/fix_1421 
[FIXED] Possible removal of interest on queue subs with leaf nodes
 2020-05-28 11:16:28 -06:00
Derek Collison
11ca6a0bfe Add in snapshot modtime, use PAX format 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-28 10:02:33 -07:00
Ivan Kozlovic
e9805a3109 [FIXED] Possible removal of interest on queue subs with leaf nodes 
Server was incorrectly processing a queue subscription removal
as both a plain sub and queue sub, which may have resulted in
drop of interest even when some queue subs remained.

Resolves #1421

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-28 10:21:51 -06:00
Derek Collison
d3ac95a5e6 Add in a terminate delivery for https://github.com/nats-io/jetstream/issues/189 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-28 08:32:34 -07:00
Derek Collison
18822ab866 Merge pull request #1422 from nats-io/snapshot 
JetStream Snapshots
 2020-05-28 06:59:15 -07:00
Derek Collison
bc0fedbaba Udpates based on PR feedback 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-28 06:08:35 -07:00
Derek Collison
4f0055a603 Fix for checksum hash race 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-27 20:15:25 -07:00
Derek Collison
fa59cff105 Add in snapshot and restore JSApi 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-27 20:01:30 -07:00
Derek Collison
3b1bf16d59 Merge pull request #1420 from kingkorf/master 
Support all bcrypt versions
 2020-05-27 14:18:54 -07:00
Waldemar Quevedo
625dd18974 Add support for SPIFFE x.509 SVIDs for auth 
This can be enabled by using `verify_and_map`.

```
tls {
 cert_file: "server.pem"
 key_file: "server.key"
 ca_file: "ca.pem"
 timeout: 5
 verify_and_map: true
}

authorization {
  users = [
    {
      user = "spiffe://localhost/my-nats-service/user-a"
    },
    {
      user = "spiffe://localhost/my-nats-service/user-b",
      permissions = { subscribe = { deny = ">" }}
    },
  ]
}
```

Signed-off-by: Waldemar Quevedo <wally@synadia.com>
 2020-05-27 13:10:42 -07:00
Jacob
5b5edc4b4b Support all bcrypt versions 2020-05-27 21:38:51 +02:00
R.I.Pienaar
b7c79f66e4 improve consistency between top level and account js options 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2020-05-27 16:22:47 +02:00
Derek Collison
8727315eb9 Updated snapshots, added restore, generic hashes 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-26 19:53:16 -07:00
Ivan Kozlovic
762bc84daf Merge pull request #1408 from nats-io/ldm_send_info 
[FIXED] LameDuckMode sends INFO to clients
 2020-05-26 11:37:59 -06:00
Derek Collison
4c91b69c4f Merge pull request #1413 from nats-io/fix_flappers 
Fix flappers
 2020-05-26 09:01:04 -07:00
Derek Collison
710ef00383 Don't allow JetStream on system account. Warn when accounts configured but no JS 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-25 12:17:18 -07:00
Derek Collison
3caf6265d4 Properly recover ephemeral consumers after restart 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-25 11:06:55 -07:00
Derek Collison
2a829ec34d Force fixed capacity to not allow append to underlying buffer 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-25 08:37:47 -07:00
Derek Collison
f02ec860b6 Fix race when active state has not been updated yet 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-25 07:30:58 -07:00
Derek Collison
57d8cdb1d1 Fix flapper, wait for subs to propagate 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-25 06:58:23 -07:00
Ivan Kozlovic
d20efffccb Fix TestNoRaceRouteCache test 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-25 06:58:23 -07:00
Ivan Kozlovic
f76f0df5ce Remove update of start in readLoop 
That broke sending async INFO in case where there was an update
between accepting the tcp connection and receiving the CONNECT
that indicates that client can receive async INFO.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-25 06:58:23 -07:00
Ivan Kozlovic
c168369afe Prevent TestWSFailureToStartServer from being stuck 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-25 06:58:23 -07:00
Derek Collison
ea31c6638f Fix for flapper 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-25 06:58:23 -07:00
Derek Collison
413884d87f Update start time for readloop started, check RTT on flapper test 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-25 06:58:23 -07:00
Ivan Kozlovic
e976e63099 Fixing some flappers 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-25 06:58:23 -07:00
Derek Collison
f0bfbd176e Merge pull request #1415 from nats-io/consumer_state 
Write consumer state during stop if not deleting
 2020-05-24 21:33:23 -07:00