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

21675 commits

This branch
This branch
All branches
Author SHA1 Message Date
Konrad `ktoso` Malawski
f6b01f43f1
update jmh plugin (#24131) 
Which now can work on mac and even generate flamegraphs there!
Details: https://twitter.com/ktosopl/status/939532881797439489
 2017-12-15 09:14:01 +01:00
Christopher Batey
3bd05ce67e MultiDcSplitBrainSpec: Turn on gossip loggig; Increase gossip frequency (#24024) 
The last time this failed there was no gossip to or from a node that
didn't see fifth coming back.

Also note that this test doesn't quite test what it says as the split
brain is repaired before starting the second actor system but without
extensions to the multi jvm test kit this can't be improved.

Refs #23306
 2017-12-14 22:26:27 +01:00
Shajahan Palayil
e8ff22e035 Correcting migration guide to configure serialization of messages (#24159) 2017-12-14 16:45:36 +01:00
Ignasi Marimon-Clos
69cf05f917 Specify user-provided hooks are not disabled (#24136) 2017-12-14 16:41:46 +01:00
Ignasi Marimon-Clos
752f380cf6 Formatting: used textile instead of markdown. (#24139) 2017-12-14 16:40:58 +01:00
Philippus Baalman
615094fa5f Remove superfluous 'for' in log message (#24148) 2017-12-14 12:30:22 +01:00
Arnout Engelen
6541d3d19e
Split up 'Networking' docs in 'Networking' and 'Clustering' (#24142) 
We also probably want to add some more wording explaining you probably don't
want to use remoting directly, but either use a 'proper' protocol like
akka-http to loosely couple or akka-cluster for more coupled systems, but that
could be another PR

Move 'networking' below 'streams' as you don't typically have to deal with it directly
 2017-12-14 11:33:41 +01:00
Philippus Baalman
d64f7b2b66 Update Scala 2.11.x version to 2.11.12 (#24033) 2017-12-14 09:58:59 +01:00
Christopher Batey
2a51ea8be2 Fix doc typo in sharding doc (#24151) 2017-12-14 09:50:03 +01:00
Johan Andrén
29bf978fa9
Do not publish typed tests #24125 2017-12-11 11:18:43 +01:00
Johan Andrén
be3766d0ae
Post 2.5.8 fixes (#24128) 
* Update MiMa latest release
* Silence some noise from sbt breaking the relase script
* MiMa excludes we had missed for a couple of releases
 2017-12-08 16:53:47 +01:00
Johan Andrén
582f6a4836
Revert source incompatible sharding changes (#24126) 
* Revert "fix entityPropsFactory id param, #21809"
This reverts commit cd7eae28f6.
* Revert "Merge pull request #24058 from talpr/talpr-24053-add-entity-id-to-sharding-props"
This reverts commit 8417e70460, reversing
changes made to 22e85f869d.
 2017-12-07 17:49:29 +01:00
Patrik Nordwall
cd7eae28f6 fix entityPropsFactory id param, #21809 2017-12-07 13:17:04 +01:00
Konrad `ktoso` Malawski
f96e00ea83 =str use 1.0.2-RC1 TCK, without bumping the API dependency yet (#24108) 2017-12-07 10:25:52 +00:00
Lutz Huehnken
ad57120ec2 Rename AllPersistenceIdsQuery -> PersistenceIdsQuery in docs (#24121) 
* AllPersistenceIdsQuery -> PersistenceIdsQuery
* Replaced additional instances of old name allPersistenceIDs with new persistenceIDs in docs and comments
 2017-12-07 10:24:33 +00:00
Johan Andrén
af8a81f45f
MapAsync and already failed futures #24117 2017-12-07 10:09:15 +01:00
Martynas Mickevičius
2fd9bb736b #24097 Try a few times to get an exception 2017-12-06 14:52:47 +01:00
Johannes Rudolph
f5d28a8e07
Merge pull request #24109 from jrudolph/jr/w/review-async-callback-cleanup 
AsyncCallback speedup / cleanup
 2017-12-06 14:27:00 +01:00
Johannes Rudolph
a98887140c
=str #23953 cleanup ConcurrentAsyncCallback implementation 
The existing implementation had lots of duplication. The Initializing state
could be removed in favor of using `Pending(Nil)` instead which simplified
the state handling logic further. Also, instead of using `OptionVal[Promise[Done]]`
a special marker value, `NoPromise`, was introduced to mark the case when
no promise was supplied.

Fixes #23953.
 2017-12-06 13:29:21 +01:00
Johannes Rudolph
6743d90e52 =str speed up Async callback 
Previously there was quite some contention on adding and removing promises. Now
we only cleanup after a (currently hard-coded) number of 256 executed promises.

A smaller number still showed contention in the SendQueueBenchmark.queue
benchmark.
 2017-12-06 11:51:11 +01:00
Patrik Nordwall
bd576adfc6 fix Typed Cluster Singleton with PersistentActor, #24112 (#24114) 2017-12-06 09:03:50 +00:00
Patrik Nordwall
8417e70460
Merge pull request #24058 from talpr/talpr-24053-add-entity-id-to-sharding-props 
Add entity id to sharding props (#24053)
 2017-12-06 07:35:28 +01:00
ortigali
22e85f869d Calls to stash() inside of persist callbacks should throw exception (#22615) 2017-12-06 07:32:04 +01:00
Patrik Nordwall
b1632c9d2f
Merge pull request #24107 from akka/wip-Done-serialization-patriknw 
adds serializer for akka.Done. #23854
 2017-12-06 07:29:07 +01:00
Johan Andrén
fb689baab8
Do not invoke the supervisor twice for the same MapAsync failure #23888 2017-12-05 18:51:58 +01:00
Johannes Rudolph
f996731c42 =docs use stream compression in recipe (#23823) 
* =docs use stream compression in recipe

* Also use Compression.gzip in scaladsl example
 2017-12-05 16:46:54 +01:00
Tal Pressman
a8e5f48f36 add entity id to sharding props (#24053) 2017-12-05 16:49:05 +02:00
Patrik Nordwall
52f30a8043 ClusterSpec, race between MemberRemoved and MemberExited, #23449 (#24105) 2017-12-05 23:12:19 +09:00
Elijah Rippeth
2837ebba6e adds serializer for akka.Done. #23854 
(cherry picked from commit 53a543788494d7b6457f129b1ad4ff57ff530584)
 2017-12-05 14:38:58 +01:00
Johan Andrén
3dda73c1ea
Async callback memory leak fix #24046 2017-12-05 14:07:10 +01:00
Martynas Mickevičius
fa953e60f7 #24075 Add a buffer to store completion signals 2017-12-05 13:32:57 +01:00
Patrik Nordwall
74b5866f60
Merge pull request #23916 from gosubpl/wip/22974-gc-tombstones 
=ddata Garbage collect valueDeltas tombstones at merge/mergeDelta (#22974)
 2017-12-05 13:19:27 +01:00
Patrik Nordwall
774bfee074
Merge pull request #24049 from akka/wip-24048-coordinated-downing-patriknw 
Run all CoordinatedShutdown phases also when downing, #24048
 2017-12-05 13:01:43 +01:00
Patrik Nordwall
80f1292ac1 make it possible to disable all jvm shutdown hooks, #24077 (#24093) 2017-12-05 11:48:30 +01:00
Arnout Engelen
dbad545803
Nice CONTRIBUTING.md intro text (#24096) 2017-12-05 10:56:47 +01:00
Johan Andrén
ab05ac78d7 FusableProcessorTest failure #22981 (#23994) 2017-12-05 09:13:15 +01:00
Johan Andrén
d52be450f3 ScanAsync did not complete in all scenarios #24036 (#24090) 2017-12-05 08:08:33 +00:00
Konrad `ktoso` Malawski
3eed8e79d0
attempt to stabilize the CompressionIntegrationSpec (#23987) 2017-12-05 15:35:08 +09:00
Konrad `ktoso` Malawski
34f7b319c5
=str convert require calls in GraphStage to ifs to avoid allocs (#24094) 2017-12-05 14:37:57 +09:00
Patrik Nordwall
11d628d27f enforce right order of Timers and PersistentActor trait, #24076 (#24081) 
* the order was also wrong in the AbstractPersistentActorWithTimers
* mima complains about this change for AbstractPersistentActor and
  AbstractPersistentActorWithAtLeastOnceDelivery, but I think it is ok
 2017-12-05 14:24:56 +09:00
mattsu
7452d361cd =str #23929 Fix double push message in sub source (#24083) 
* Fix double push message in sub source

* Add name of pushed port in failure message

* Update GraphStageLogicSpec.scala

* Change substreamEmit to SubstreamEmit
 2017-12-05 13:16:24 +09:00
Johan Andrén
3145ab42c0 Fix multiple potential races in StageActorRefSpec (#24091) 
* Fix multiple potential races in StageActorRefSpec #24087
 2017-12-04 22:42:40 +07:00
Johan Andrén
a380d01337
Test coverage for stages using invokeWithFeedback #23953 2017-12-04 16:34:16 +01:00
Christopher Batey
891cf30348 Harden and turn on debug logging for SystemMessageDeliverySpec (#23989) 
For the failure in #23926 at INFO we get no information about why. This
commit also removes use of deprecated methods in the test.
 2017-12-04 15:28:06 +01:00
Christopher Batey
76b2cfa676 Add common multi jvm config to cluster tests (#23974) 2017-12-04 15:23:55 +01:00
Patrik Nordwall
bdc740bf0a
Merge pull request #24035 from hseeberger/24015-immutableOrIgnore 
Add Actor.immutableOrUnhandled (closes #24015)
 2017-12-04 14:56:32 +01:00
Patrik Nordwall
996cccf890 send crossDcHeartbeatSender over Artery control stream, #24088 (#24089) 
* add crossDcHeartbeatSender to prio wildcard index, otherwise
  HeartbeatRsp will be sent over ordinary message stream
 2017-12-04 22:52:13 +09:00
Patrik Nordwall
c3f39bfe66
Merge pull request #24086 from evis/simplify-future-creations 
Use Future.successful/failed instead of Promise.s/f.future
 2017-12-04 14:46:06 +01:00
Patrik Nordwall
e49acb7daa add Reason to CoordinatedShutdown, #24048 2017-12-04 14:16:06 +01:00
Philippus Baalman
5ef03c4423 Fix some typos/grammar (#24082) 2017-12-04 11:24:21 +01:00