raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
15263 commits 1 branch 31 tags 268 MiB
Commit graph

15263 commits

This branch
This branch
All branches
Author SHA1 Message Date
Jaca777
ed61632bf5 =pro Fix unmaintained scalariform github repo link. 2015-11-14 19:12:45 +01:00
Jaca777
3410e3a615 =doc Fixed typo 2015-11-14 14:41:18 +01:00
Konrad Malawski
b5379632b1 Merge pull request #18915 from kukido/kukido-18899-pr-follow-up 
=doc #18899 code review follow-up, fixed typo
 2015-11-13 09:24:31 +01:00
drewhk
fc75eb361a Merge pull request #18754 from akka/wip-18613-optimize-repointable-patriknw 
=act #18613 Optimize RepointableActorRef for only sys msg
 2015-11-12 10:56:13 +01:00
drewhk
c0054ad662 Merge pull request #18912 from johanandren/wip-18607-no-timeout-ex-waiting-for-future-johanandren 
=act #18607 Test failing on timeout not happening
 2015-11-12 10:22:27 +01:00
kukido
7124b5dddf =doc #18899 code review follow-up, fixed typo 2015-11-11 09:26:00 -08:00
Konrad Malawski
06708f8f57 Merge pull request #18907 from johanandren/wip-18635-migration-guide-terminate-johanandren 
=doc #18635 Added section about `ActorSystem.shutdown` being deprecated
 2015-11-11 16:30:17 +01:00
Konrad Malawski
7161b67a39 Merge pull request #18911 from ktoso/wip-rebased-18805-ktoso 
[rebased] =cls #18762 fix graceful shutdown of empty region
 2015-11-11 16:16:25 +01:00
Patrik Nordwall
7b22aa499d =act #18613 Optimize RepointableActorRef for sys msg 
* Before the cell is started the RepointableActorRef queue the messages
  (both system and non-system messages) into a queue. System messages
  are inserted right before the last non-system message by iterating
  the queue, i.e. becomes slow when there are many system messages already
  enqueued.
* This is a problem for pools with many routees.
* The fix is to keep system messages in a separate queue

JMH benchmark before:

    [info] Benchmark                                 (size)  Mode  Cnt       Score      Error  Units
    [info] RouterPoolCreationBenchmark.testCreation    1000    ss  300   13204.048 ± 3081.576  us/op
    [info] RouterPoolCreationBenchmark.testCreation    2000    ss  300   41939.524 ± 6178.087  us/op
    [info] RouterPoolCreationBenchmark.testCreation    3000    ss  300   70752.881 ± 4344.992  us/op
    [info] RouterPoolCreationBenchmark.testCreation    4000    ss  300  120620.885 ± 3296.342  us/op

JMH benchmark after:

    [info] Benchmark                                 (size)  Mode  Cnt      Score      Error  Units
    [info] RouterPoolCreationBenchmark.testCreation    1000    ss  300   7738.721 ± 1806.297  us/op
    [info] RouterPoolCreationBenchmark.testCreation    2000    ss  300  15497.588 ± 4532.852  us/op
    [info] RouterPoolCreationBenchmark.testCreation    3000    ss  300  28704.005 ± 6322.458  us/op
    [info] RouterPoolCreationBenchmark.testCreation    4000    ss  300  37783.516 ± 6778.437  us/op

fully drain sysmsgQueue when swap cell
 2015-11-11 15:46:01 +01:00
Konrad Malawski
19594c6b94 Merge pull request #18909 from kukido/kukido-javadoc-fixes 
=doc Fixes for genjavadoc
 2015-11-11 14:09:08 +01:00
Johan Andrén
ea22eca7fd =act #18607 Test failing on timeout not happening 
Changed the future to never complete to be sure there is no racing
 2015-11-11 12:35:31 +01:00
Krzysztof Bochenek
5c418efef2 =cls #18762 fix graceful shutdown of empty region 2015-11-11 11:58:43 +01:00
drewhk
712233f725 Merge pull request #18810 from swachter/master 
consider akka.test.timefactor when using akka.test.filter-leeway
 2015-11-11 11:36:57 +01:00
drewhk
48282fc753 Merge pull request #18729 from hseeberger/hseeberger-18575-publish-member-joined 
Publish MemberJoined
 2015-11-11 11:23:04 +01:00
drewhk
11bf8a67d0 Merge pull request #18543 from johanandren/wip-17695-api-for-sharding-state-retrieval-johanandren 
+clu #17695 add a way to inspect the current sharding state
 2015-11-11 11:19:50 +01:00
kukido
3cc3666724 =doc Fixes for genjavadoc 2015-11-11 00:29:44 -08:00
Johan Andrén
4f267d5931 =doc #18635 Added section about ActorSystem.shutdown being deprecated 2015-11-10 16:46:34 +01:00
Konrad Malawski
581829b9b2 Merge pull request #18755 from akka/wip-16522-optimize-stash-config-patriknw 
=act #16522 Optimize Stash creation
 2015-11-09 18:06:17 +01:00
Roland Kuhn
f1abaa1c5e Merge pull request #18875 from ktoso/wip-akka.js-cherries-ktoso 
Akka.js cherries to master
 2015-11-07 18:01:24 +01:00
Roland Kuhn
61c257b2fe Merge pull request #18776 from henrymai/master 
Add TransparentExponentialBackoffSupervisor
 2015-11-07 17:56:02 +01:00
Patrik Nordwall
1e36e5e187 Merge pull request #18746 from akka/wip-18554-singleton-startup-patriknw 
=clu #18554 Make oldest assignment deterministic when joining
 2015-11-06 14:48:57 +01:00
Patrik Nordwall
c7c187f6b7 =clu replace Set -- with diff and ++ with union 
* better performance according to
  https://docs.google.com/presentation/d/1Qjryxoe-fYEM8ZPhM-98LKfbhnRcn5eAEMNlVVnixsA/pub
 2015-11-06 14:48:17 +01:00
Andrea
cd3d68a77c =act switch to java std lib ThreadLocalRandom 2015-11-06 14:04:33 +01:00
Andrea
0511b07f3e =act split Props java api implementation in separate files. 2015-11-06 14:04:27 +01:00
Andrea
74ce3bfb1f =act Scheduler implementation separated from interface. 2015-11-06 14:04:11 +01:00
Andrea
3df34bc21d =act split ReflectiveDynamicAccess implementation in separate file. 2015-11-06 14:01:09 +01:00
Andrea
c3f862d724 =act split FSM java api in a separate file. 2015-11-06 13:55:38 +01:00
Patrik Nordwall
b6ec6009c7 Merge pull request #18769 from akka/wip-ddata-perf-many-nodes-patriknw 
=cdd #18768 Cache serialization of read and write msg
 2015-11-06 13:37:56 +01:00
Patrik Nordwall
1b1ef752fe =act #16522 Optimize Stash creation 
* cache the stash capacity config value

BEFORE

    [info] Result "testCustom":
    [info]   27.607 ±(99.9%) 7.924 us/op [Average]
    [info]   (min, avg, max) = (16.928, 27.607, 760217.600), stdev = 1369.808
    [info]   CI (99.9%): [19.682, 35.531] (assumes normal distribution)
    [info]   Samples, N = 323534
    [info]         mean =     27.607 ±(99.9%) 7.924 us/op
    [info]          min =     16.928 us/op
    [info]   p( 0.0000) =     16.928 us/op
    [info]   p(50.0000) =     21.824 us/op
    [info]   p(90.0000) =     31.680 us/op
    [info]   p(95.0000) =     38.592 us/op
    [info]   p(99.0000) =     57.920 us/op
    [info]   p(99.9000) =    102.144 us/op
    [info]   p(99.9900) =    371.471 us/op
    [info]   p(99.9990) =  85461.364 us/op
    [info]   p(99.9999) = 760217.600 us/op
    [info]          max = 760217.600 us/op

    [info] Result "testDefault":
    [info]   26.465 ±(99.9%) 15.980 us/op [Average]
    [info]   (min, avg, max) = (14.608, 26.465, 1461714.944), stdev = 2900.094
    [info]   CI (99.9%): [10.485, 42.444] (assumes normal distribution)
    [info]   Samples, N = 356626
    [info]         mean =     26.465 ±(99.9%) 15.980 us/op
    [info]          min =     14.608 us/op
    [info]   p( 0.0000) =     14.608 us/op
    [info]   p(50.0000) =     18.304 us/op
    [info]   p(90.0000) =     22.816 us/op
    [info]   p(95.0000) =     26.976 us/op
    [info]   p(99.0000) =     41.647 us/op
    [info]   p(99.9000) =     71.808 us/op
    [info]   p(99.9900) =    139.696 us/op
    [info]   p(99.9990) =  33048.112 us/op
    [info]   p(99.9999) = 1461714.944 us/op
    [info]          max = 1461714.944 us/op

    [info] Benchmark                             Mode     Cnt   Score    Error  Units
    [info] StashCreationBenchmark.testCustom   sample  323534  27.607 ±  7.924  us/op
    [info] StashCreationBenchmark.testDefault  sample  356626  26.465 ± 15.980  us/op

AFTER:

    [info] Result "testCustom":
    [info]   22.710 ±(99.9%) 1.384 us/op [Average]
    [info]   (min, avg, max) = (15.168, 22.710, 110886.912), stdev = 233.744
    [info]   CI (99.9%): [21.326, 24.094] (assumes normal distribution)
    [info]   Samples, N = 308896
    [info]         mean =     22.710 ±(99.9%) 1.384 us/op
    [info]          min =     15.168 us/op
    [info]   p( 0.0000) =     15.168 us/op
    [info]   p(50.0000) =     19.776 us/op
    [info]   p(90.0000) =     28.608 us/op
    [info]   p(95.0000) =     33.344 us/op
    [info]   p(99.0000) =     49.216 us/op
    [info]   p(99.9000) =     90.253 us/op
    [info]   p(99.9900) =    594.334 us/op
    [info]   p(99.9990) =   8350.329 us/op
    [info]   p(99.9999) = 110886.912 us/op
    [info]          max = 110886.912 us/op

    [info] Result "testDefault":
    [info]   19.099 ±(99.9%) 0.424 us/op [Average]
    [info]   (min, avg, max) = (13.120, 19.099, 45940.736), stdev = 77.524
    [info]   CI (99.9%): [18.675, 19.523] (assumes normal distribution)
    [info]   Samples, N = 361741
    [info]         mean =     19.099 ±(99.9%) 0.424 us/op
    [info]          min =     13.120 us/op
    [info]   p( 0.0000) =     13.120 us/op
    [info]   p(50.0000) =     16.368 us/op
    [info]   p(90.0000) =     24.250 us/op
    [info]   p(95.0000) =     31.232 us/op
    [info]   p(99.0000) =     55.680 us/op
    [info]   p(99.9000) =    121.249 us/op
    [info]   p(99.9900) =    402.386 us/op
    [info]   p(99.9990) =   1767.264 us/op
    [info]   p(99.9999) =  45940.736 us/op
    [info]          max =  45940.736 us/op
    [info]
    [info]
    [info] # Run complete. Total time: 00:02:01
    [info]
    [info] Benchmark                             Mode     Cnt   Score   Error  Units
    [info] StashCreationBenchmark.testCustom   sample  308896  22.710 ± 1.384  us/op
    [info] StashCreationBenchmark.testDefault  sample  361741  19.099 ± 0.424  us/op
 2015-11-06 13:34:29 +01:00
Konrad Malawski
18a24c0e50 Merge pull request #18295 from ktoso/wip-docs-warn-about-updated-docs-ktoso 
+doc show warning if browsing outdated docs
 2015-11-05 15:21:46 +01:00
Konrad Malawski
d4dd75cb49 +doc #18295 add close button with 1day delay to reappear 2015-11-05 15:18:51 +01:00
Konrad Malawski
c527987cc3 +doc #18295 show warning if browsing outdated docs 
+doc #18295 include versions.json updation during release
 2015-11-05 13:21:24 +01:00
Konrad Malawski
9f3a489c96 Merge pull request #18851 from 2m/wip-fix-link-ϕ-paper 
=doc fix URL to "The ϕ Accrual Failure Detector" paper
 2015-11-04 19:00:38 +01:00
Martynas Mickevičius
fb664c54a5 =doc fix URL to "The ϕ Accrual Failure Detector" paper 2015-11-04 16:26:45 +02:00
Johan Andrén
4abbc8db50 +clu #17695 add a way to inspect the current sharding state 
Two new message pairs:
`GetShardRegionState`/`CurrentShardRegionState` allows for querying a region for it's current shards and the current `EntityIds` of it
`GetClusterShardingStats`/`ClusterShardingStats` allows for querying the entire cluster for a summary of
the number of entitites alive in each region and shard.
 2015-11-02 08:56:09 +01:00
Henry Mai
a0e9b01aa4 Add TransparentExponentialBackoffSupervisor 2015-11-01 22:25:05 -08:00
Patrik Nordwall
6b935e0c0b =cdd #18768 Cache serialization of read and write msg 
The WriteAggregator and ReadAggregator typically send
the same message to several replicas and by caching the serialized bytes
we avoid doing the same thing for each message

and add a test for WriteAggregator
 2015-10-30 17:03:32 +01:00
Stefan Wachter
cdb229f9b3 consider akka.test.timefactor when using akka.test.filter-leeway 2015-10-29 18:14:33 +01:00
Konrad Malawski
81cba2e580 Merge pull request #18772 from ktoso/wip-persist-nil-ktoso 
=per #18728 allow persistAll(Nil)
 2015-10-26 14:43:15 -07:00
Konrad Malawski
4a3bc59c48 =per #18728 allow persistAll(Nil) 2015-10-26 14:42:33 -07:00
Patrik Nordwall
ac82354077 Merge pull request #18552 from johanandren/wip-18371-warn-about-java-serialization-johanandren 
=act #18371 Warn if the default Java serializer is used
 2015-10-26 08:34:11 +01:00
Patrik Nordwall
97fc493446 Merge pull request #18357 from kailuowang/metrics-based-resizer 
+act #18356 Metrics based resizer for router
 2015-10-23 12:38:14 +02:00
Patrik Nordwall
ee6b3cd8f3 Merge pull request #17761 from 2m/wip-check-all-bc 
=pro verify BC against all binary compatible versions
 2015-10-23 09:40:35 +02:00
Martynas Mickevičius
4ffe267835 =pro verify BC against all binary compatible versions 2015-10-23 09:10:25 +03:00
Kailuo Wang
90cba9ce0d +act #18356 Metrics based resizer for router 2015-10-22 11:14:00 -04:00
Heiko Seeberger
821dc2199b +act #18575 Publish MemberJoined 2015-10-21 17:30:28 +02:00
Patrik Nordwall
a6279b7b3f Merge pull request #18753 from eshepelyuk/emptyEventsStreamForCleanedJournal-18751-eshepelyuk 
+per #18751 Persistence: Return completed current events stream for cleaned journal
 2015-10-21 17:11:28 +02:00
Ievgenii.Shepeliuk
3cc1d0fe8e +per #18751 Persistence: Return completed current events stream for cleaned journal 2015-10-21 14:25:38 +03:00
Roland Kuhn
fb80ac8acb Merge pull request #18705 from akka/wip-18699-typed-death-pact 
=typ #18699 pass Unhandled message to unhandled()
 2015-10-21 10:19:05 +02:00
Johan Andrén
146bb89e23 =act #18371 Warn if the default Java serializer is used 
Unless the message is in akka.* or the configuration setting 'akka.actor.warn-about-java-serializer-usage'
is disabled a warning is logged for each class that the Java serializer is choosen for.
 2015-10-21 10:10:24 +02:00