Commit graph

20217 commits

Author SHA1 Message Date
Patrik Nordwall
fcddd5fa72 Merge pull request #22144 from jgordijn/22140-test-failure-ReplicatedDataSerializer-jgordijn
#22140 fixed ReplicatedDataSerializerSpec error with artery serializers
2017-01-17 10:51:29 +01:00
Patrik Nordwall
4b6a650f56 Merge pull request #21930 from akka/wip-21537-coordinated-patriknw
add CoordinatedShutdown, #21537
2017-01-16 09:59:49 +01:00
Patrik Nordwall
84ade6fdc3 add CoordinatedShutdown, #21537
* CoordinatedShutdown that can run tasks for configured phases in order (DAG)
* coordinate handover/shutdown of singleton with cluster exiting/shutdown
* phase config obj with depends-on list
* integrate graceful leaving of sharding in coordinated shutdown
* add timeout and recover
* add some missing artery ports to tests
* leave via CoordinatedShutdown.run
* optionally exit-jvm in last phase
* run via jvm shutdown hook
* send ExitingConfirmed to leader before shutdown of Exiting
  to not have to wait for failure detector to mark it as
  unreachable before removing
* the unreachable signal is still kept as a safe guard if
  message is lost or leader dies
* PhaseClusterExiting vs MemberExited in ClusterSingletonManager
* terminate ActorSystem when cluster shutdown (via Down)
* add more predefined and custom phases
* reference documentation
* migration guide
* problem when the leader order was sys2, sys1, sys3,
  then sys3 could not perform it's duties and move Leving sys1 to
  Exiting because it was observing sys1 as unreachable
* exclude Leaving with exitingConfirmed from convergence condidtion
2017-01-16 09:01:57 +01:00
Jeroen Gordijn
55a1532e56 #22140 fixed ReplicatedDataSerializerSpec error with artery serializers 2017-01-16 08:51:40 +01:00
Patrik Nordwall
4a9c753710 Merge pull request #22063 from jgordijn/21648-Prefer_reachable_nodes_in_consistency-jgordijn
#21648 Prefer reachable nodes in consistency writes/reads
2017-01-13 12:32:41 +01:00
Konrad `ktoso` Malawski
dcd8cea32e #21475 moving compressions ownership to Decoder (#22047)
* WIP early preview of moving compressions ownership to Decoder

* Compression table created in transport, but owned by Decoder
Added test for restart of inbound stream

* =art snapshot not needed in HeavyHitters since owned by Decoder
2017-01-13 10:33:55 +01:00
gosubpl
c80c3e16c4 remove org.uncommons.maths dependency (#12636)
Also
* add InternalApi annotation to AESCounterBuiltinRNG
* add setDaemon(true) to re-seeder thread
2017-01-13 10:23:06 +01:00
Patrik Nordwall
a8f9ad4775 Merge branch 'master' into 21648-Prefer_reachable_nodes_in_consistency-jgordijn 2017-01-13 10:21:09 +01:00
Patrik Nordwall
956676d0bc Merge pull request #22089 from VEINHORN/master
Remove redundant new modifier
2017-01-12 15:34:59 +01:00
Patrik Nordwall
98d6907960 Merge pull request #22060 from jgordijn/22035-Change_ORMap_to_more_generic_type-jgordijn
#22035  Make it possible to use anything as the key in a map
2017-01-12 15:32:32 +01:00
Jeroen Gordijn
8499ff6faf #22035 Make it possible to use anything as the key in a map
- All Map types are now generic in their key: ORMap, ORMultiMap, LWWMap,
  PNCounterMap
- test for binary compatibility with previous version for serialization
- entries are sorted for deterministic SHA-1 on same value
2017-01-11 21:20:39 +01:00
Konrad `ktoso` Malawski
bbb2d2b92a Update CONTRIBUTING.md 2017-01-11 20:09:55 +01:00
Konrad `ktoso` Malawski
ebc6bc1d50 Merge pull request #22013 from gosubpl/wip/12636-aes-ctr-prng-alternative-random
AES-CTR with re-seeding (#21740)
2017-01-11 16:09:29 +01:00
gosubpl
1f20c86d99 AES-CTR with re-seeding, review remarks included (#21740) 2017-01-11 04:31:09 +01:00
Patrik Nordwall
1eba8656cd Merge pull request #22094 from akka/wip-22093-ClusterClient-ask-patriknw
stop ClusterClient ResponseTunnel after first reply when ask is used, #22093
2017-01-10 10:34:41 +01:00
Jeroen Gordijn
81f081b33c #21648 Prefer reachable nodes in consistency writes/reads 2017-01-09 20:36:54 +01:00
Patrik Nordwall
180361868c Merge pull request #22054 from akka/wip-22053-log-join-retry-patriknw
log join retries, #22053
2017-01-09 14:18:40 +01:00
Konrad Malawski
5c79b81e92 +doc document DoNotInherit and ApiMayChange 2017-01-06 15:12:53 +01:00
Konrad Malawski
6fffeceb0d +act #22109 add documentation annotations in akka.annotation 2017-01-06 13:55:15 +01:00
Patrik Nordwall
b213a7af20 stop ClusterClient ResponseTunnel after first reply when ask is used, #22093 2017-01-05 17:13:24 +01:00
Patrik Nordwall
9d2bec7f23 Merge pull request #22104 from Philippus/license-2017-22102
extended copyright into 2017 #22102
2017-01-05 16:58:38 +01:00
Philippus Baalman
6c7085252a extended copyright into 2017 2017-01-04 17:37:15 +01:00
Patrik Nordwall
4c426b4e05 Merge pull request #22099 from akka/wip-fork-stream-tck-patriknw
fork stream TCK tests
2017-01-04 11:52:51 +01:00
Patrik Nordwall
345929fb4f fork stream TCK tests
The TCK tests are using System.gc(), which
is causing long GC pauses when running with G1 on
the CI build servers. Therefore we fork these tests
to run with small heap without G1.
2017-01-04 08:30:07 +01:00
Johannes Rudolph
2fab199142 Merge pull request #22048 from jrudolph/jr/w/21365-improve-inbound-lanes-performance
Improve performance of inbound lanes by making spinning loops in AeronSource configurable
2017-01-03 17:51:10 +01:00
Konrad `ktoso` Malawski
d1cc07c7e7 Merge pull request #22009 from ktoso/wip-query-2.5
=peq #21724 #19174 unify naming of query methods, un-experimentalize Query
2017-01-03 17:05:53 +01:00
Konrad `ktoso` Malawski
067b569f85 Merge branch 'master' into wip-query-2.5 2017-01-03 17:04:48 +01:00
Johannes Rudolph
d1e255f42f Merge pull request #22086 from jrudolph/jr/w/22073-enable-mutual-auth-by-default
!rem #22073 enable mutual TLS authentication by default
2017-01-03 15:43:43 +01:00
Johannes Rudolph
bbb5ccb8ed !rem #22073 enable mutual TLS authentication by default 2017-01-03 15:43:02 +01:00
Johannes Rudolph
e07ad0d068 =doc reorder migration guide a bit based on generality of subprojects 2017-01-03 15:43:02 +01:00
Konrad `ktoso` Malawski
bdcf703c22 Merge pull request #22091 from akka/wip-22085-ActorModelSpec-allocations-patriknw
reduce allocations in ActorModelSpec, #22085
2017-01-03 15:40:49 +01:00
gosubpl
83bafb48a2
removing deprecated AESCounterInetRNGs, fixes #22014 (#22015) 2017-01-03 15:39:52 +01:00
Patrik Nordwall
deef184cdd reduce allocations in ActorModelSpec, #22085
* this reduces the number of allocated AtomicLong instances when running
  BalancingDispatcherModelSpec from 4.2 million to 200 thousand.
2017-01-03 14:40:33 +01:00
VEINHORN
29612565eb removed redundant new modifier 2017-01-03 11:59:42 +03:00
Johannes Rudolph
af377790b0
=rem #21365 less aggressive busy spinning in AeronSource
Benchmarks revealed that busy spinning directly in the graph stage can
lead to an excessive increase in latency when multiple inbound lanes are
active (i.e. the inbound flow has an asynchronous boundary driving the
multiple lanes).

The new strategy is therefore:

For inbound-lanes > 1 or idle-cpu-level < 5: no spinning in the graph stage
For inbound-lanes = 1 and idle-cpu-level >= 6: 50 * settings.Advanced.IdleCpuLevel - 240

which means in general much less or no spinning at all.

Fixes #21365.
2017-01-02 16:27:52 +01:00
Patrik Nordwall
7646506af0 Merge pull request #22020 from akka/wip-catch-deserialization-patriknw
catch NotSerializableException from deserialization, #20641
2017-01-02 16:00:06 +01:00
Patrik Nordwall
df3d19f052 Merge pull request #22078 from Philippus/improve-contributing-section
More consistent naming and style, fixed typos and mistakes #22077
2017-01-02 15:59:12 +01:00
Konrad `ktoso` Malawski
2334320f22 Merge pull request #22072 from akka/aeron-update
Update Aeron to 1.0.5
2017-01-02 14:54:54 +01:00
Philippus Baalman
f319dec711 more consistent naming and style, fixed typos and mistakes #22077 2016-12-30 20:24:29 +01:00
Johannes Rudolph
e66cb028b0 =rem #21365 enable multiple lanes in MaxThroughputSpec
This needed the other change for each sender to send to all of the target
actors. Otherwise, large batches of messages to the same target actor would
limit the potential of actually doing work in parallel with multiple lanes due
to head-of-line blocking.
2016-12-30 12:52:42 +01:00
Johannes Rudolph
35feef8d01 =rem log results of MaxThroughputSpec and LatencySpec to result file 2016-12-30 12:50:24 +01:00
Johannes Rudolph
73ff3e1dc9 =rem #21365 cleanup multiple lane creation slightly 2016-12-30 12:46:15 +01:00
Johannes Rudolph
2f5f93daa2 =rem #21365 use default directory for shared media driver to /dev/shm
It was reported that shared media driver performance can depend on the
kind of file-system where the files are contained. /dev/shm is an in-memory
filesystem that was reported to work well with the shared aeron media driver.
2016-12-30 12:32:12 +01:00
Johannes Rudolph
8349a6a25a =pro fix typo 2016-12-30 12:32:12 +01:00
Konrad `ktoso` Malawski
17c4352382 Update Aeron to 1.0.5 2016-12-29 12:48:46 +01:00
Konrad `ktoso` Malawski
b1e146c836 Merge pull request #22056 from akka/ktoso-typo-1
=str fix typo in GraphStage port validations
2016-12-22 13:42:40 +01:00
Konrad `ktoso` Malawski
f3422f8d96 Merge pull request #22058 from jlprat/patch-1
Fix release date of Akka in Action
2016-12-22 10:55:55 +01:00
Patrik Nordwall
d36aa3118f Merge pull request #22055 from akka/wip-22037-DurableDataSpec-patriknw
harden DurableDataSpec, #22037
2016-12-21 21:45:36 +01:00
Josep Prat
f397d26738 Fix release date of Akka in Action
Issue: #22057
Akka in Action was released in September.
2016-12-21 21:23:54 +01:00
Konrad `ktoso` Malawski
0ce1ed2c67 =str fix typo in GraphStage port validations
It should be can not `push` instead "pull" closed port
2016-12-21 17:57:44 +01:00