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

15101 commits

This branch
This branch
All branches
Author SHA1 Message Date
Patrik Nordwall
a22b3be9da Merge pull request #18410 from akka/wip-18408-scala-2.11.7-patriknw 
=pro #18408 Update to Scala 2.11.7
 2015-09-10 11:24:04 +02:00
Patrik Nordwall
1de8f05854 Merge pull request #18427 from jamie-allen/update-books 
Updated books page with the book by Vaughn Vernon
 2015-09-10 10:40:14 +02:00
Patrik Nordwall
fd381df392 Merge pull request #18430 from akka/wip-17317-attaching-conductor-patriknw 
=mnt #17317 Harden reconnect when attaching to test conductor
 2015-09-09 19:05:19 +02:00
Patrik Nordwall
0dad493d79 Merge pull request #18424 from akka/wip-18209-doc-remote-ordering-patriknw 
=doc #18209 Clarify remote message ordering
 2015-09-09 19:04:46 +02:00
Patrik Nordwall
013e180e5b Merge pull request #18423 from akka/wip-15399-TestKitBase-doc-patriknw 
=tes #15399 Remove warning from TestKitBase
 2015-09-09 19:04:13 +02:00
Patrik Nordwall
d76cf34487 Merge pull request #18421 from akka/wip-17139-clarify-AtLeastOnceDelivery-patriknw 
=per #17139 Clarify AtLeastOnceDelivery persistent state
 2015-09-09 19:03:45 +02:00
Patrik Nordwall
2c144f74ea Merge pull request #18416 from akka/wip-18415-redeliver-patriknw 
=per #18415 Don't start redelivery during recover
 2015-09-09 19:03:01 +02:00
Patrik Nordwall
3aca98fafc Merge pull request #18435 from johanandren/wip-17556-remote-shutdown-and-back-spec-unstable-johanandren 
=rem #17556 Do not fail if identity or terminated arrives
 2015-09-09 19:01:41 +02:00
Patrik Nordwall
8767997806 Merge pull request #18429 from johanandren/wip-18163-document-akka-behind-nat-johanandren 
=doc #18163 More visible docs about NAT support
 2015-09-09 19:00:40 +02:00
Patrik Nordwall
a0d4cde950 Merge pull request #18420 from johanandren/wip-15678-clarify-slf4j-loglevel-johanandren 
=doc #15678 clarify log level limits events passed to actual logger
 2015-09-09 18:59:49 +02:00
Johan Andrén
97b83fb95b =rem #17556 Do not fail if identity or terminated arrives 
Trying to stabilize RemoteNodeShutdownAndComesBackSpec which fails
intermittently on the test servers by replacing an unecessary check
with receiveWhile which does not fail if it times out.
 2015-09-09 16:02:54 +02:00
drewhk
590f819289 Merge pull request #18419 from johanandren/wip-15001-log-debug-undhandled-docs-johanandren 
=doc #15001 doc logging unhandled messages at debug
 2015-09-09 11:46:42 +02:00
Johan Andrén
e8864fc6da =doc #15001 doc logging unhandled messages at debug 2015-09-09 10:42:43 +02:00
Johan Andrén
32f8c44771 =doc #15678 clarify log level limits events passed to actual logger 2015-09-09 10:37:42 +02:00
Patrik Nordwall
42766b28f1 =mnt #17317 Harden reconnect when attaching to test conductor 
The failing tests showed big variations in startup times, i.e.
JVM1 not started/bound when other JVMs tries to connect to the
test conductor. The reconnect logic was in place but it was
bound to 10 client-reconnects (10 seconds). It's better to let
it by default reconnect until the connect-timeout (20 seconds)
is elapsed.
 2015-09-09 10:37:03 +02:00
Johan Andrén
ca22ae9090 =doc #18163 More visible docs about NAT support 2015-09-09 10:27:40 +02:00
Patrik Nordwall
49558dc415 Merge pull request #18414 from johanandren/wip-16074-remove-returns-johanandren 
=tes #16074 remove return statements from scala sources
 2015-09-09 09:02:41 +02:00
Patrik Nordwall
36e976453b Merge pull request #18413 from johanandren/wip-18226-document-self-stop-johanandren 
=doc #18226 document actor stopping
 2015-09-09 09:01:56 +02:00
Jamie
5cb079fd77 Fixed formatting 2015-09-09 12:04:58 +10:00
Jamie
827bcd68aa Updated books page with the book by Vaughn Vernon 2015-09-09 11:53:43 +10:00
Patrik Nordwall
430751c03f =doc #18209 Clarify remote message ordering 2015-09-08 16:49:02 +02:00
Patrik Nordwall
0105675aec =tes #15399 Remove warning from TestKitBase 2015-09-08 15:59:16 +02:00
Patrik Nordwall
a6d693b8ef =per #17139 Clarify AtLeastOnceDelivery persistent state 2015-09-08 15:07:55 +02:00
Patrik Nordwall
d592914174 Merge pull request #18407 from akka/wip-18404-jmh-dep-patriknw 
=pro #18404 Remove jmh from akka-protobuf
 2015-09-08 14:39:25 +02:00
Patrik Nordwall
cce3690c72 =pro #18408 Update to Scala 2.11.7 2015-09-08 14:38:09 +02:00
Patrik Nordwall
8ce4622783 =per #18415 Don't start redelivery during recover 2015-09-08 13:27:24 +02:00
Johan Andrén
b3c9273be3 =tes #16074 remove return statements from scala sources 2015-09-08 11:23:39 +02:00
Johan Andrén
996ad35495 =doc #18226 document actor stopping 2015-09-08 11:14:18 +02:00
Patrik Nordwall
5481df6c74 =pro #18404 Remove jmh from akka-protobuf 2015-09-07 09:27:27 +02:00
Patrik Nordwall
b25e76e95c Merge pull request #18401 from akka/wip-unidoc-protobuf-patriknw 
=pro workaround for scalaunidoc:doc issues
 2015-09-04 16:02:53 +02:00
Patrik Nordwall
e5644d406e =pro workaround for scalaunidoc:doc issues 2015-09-04 16:01:01 +02:00
Patrik Nordwall
acf0e76244 Merge pull request #18398 from akka/wip-13584-WeaklyUp2-patriknw 
+clu #13584 Accept joining to be WeaklyUp during network split
 2015-09-04 14:10:23 +02:00
Patrik Nordwall
22b8853314 =clu #13584 mark as experimental and some doc clarificiations 2015-09-04 14:09:41 +02:00
Veiga Ortiz, Héctor
c08bc317e2 +clu #13584 Accept joining to be WeaklyUp during network split 
* experimental feature, disabled by default
* Adding documentation to mention weakly up members.
  plus adding new diagram.
 2015-09-04 12:44:47 +02:00
Patrik Nordwall
c9662d8083 Merge pull request #18324 from akka/wip-15646-sharding-initial-watch-patriknw 
=cls #15646 Optimize the initial watch in shard coordinator
 2015-09-04 12:02:17 +02:00
Patrik Nordwall
3a436bb4a3 Merge pull request #18376 from akka/wip-18342-leveldb-config-patriknw 
=per #18342 Improve docs for leveldb plugin config
 2015-09-04 11:49:41 +02:00
Patrik Nordwall
0b1f280739 =per #18342 Improve docs for leveldb plugin config 
* clarify how to enable the plugin
* added empty class property in fallback config in reference
  to have a proper place to document that and throw a more
  specific exception if it is not defined
* also some formatting of reference.conf
 2015-09-04 11:49:00 +02:00
Konrad Malawski
9bf6b65e72 Merge pull request #18395 from akka/wip-fix-persisting-manifest-ktoso 
=per #18394 persist EventAdapter manifest in default proto serializer
 2015-09-04 11:32:37 +02:00
Patrik Nordwall
40936e8333 Merge pull request #18355 from akka/wip-18296-readHighestSequenceNr-patriknw 
=per #18296 Use 0L or snapshot seqNr as asyncReadHighestSequenceNr param
 2015-09-04 11:32:02 +02:00
Patrik Nordwall
e32350c3be Merge pull request #18396 from akka/wip-18345-leave-address-patriknw 
=clu #18345 Support local address in cluster commands
 2015-09-04 11:31:04 +02:00
Patrik Nordwall
4b6382f780 Merge pull request #18363 from akka/wip-13783-embedded-protobuf-patriknw 
=all #13783 replace protobuf dependency by embedded version
 2015-09-04 11:30:01 +02:00
Patrik Nordwall
35f5e28ad3 Merge pull request #18338 from akka/wip-18337-down-removal-margin-patriknw 
=clu #18337 Disable down-removal-margin by default
 2015-09-04 11:29:05 +02:00
Patrik Nordwall
bfde1eff19 =clu #18337 Disable down-removal-margin by default 
For manual downing it is not needed. For auto-down it doesn't add any extra safety, since that
is not handling network partitions anyway.

The setting is still useful if you implement downing strategies that handle network partitions,
e.g. by keeping the larger side of the partition and shutting down the smaller side.
 2015-09-04 11:28:33 +02:00
Konrad Malawski
9e5a2d5c17 =per #18394 persist EventAdapter manifest in default proto serializer 2015-09-04 10:56:56 +02:00
Patrik Nordwall
f8c1671903 =rem #13783 Make ProtobufSerializer independent of protobuf version 
* well, as long as they provide the parseFrom and toByteArray
* it is using reflection to find the `parseFrom` and `toByteArray` methods to avoid
  dependency to `com.google.protobuf`.
* also special case com.google.protobuf when loading serialization binding
* migration guide
* mima filters for the serializers (all types changed)
* add real test for ProtobufSerializer
 2015-09-04 09:12:34 +02:00
Roland Kuhn
c3ecb87a65 =all #13783 replace protobuf dependency by embedded version 
- created new subproject akka-protobuf (and added COPYING and LICENSE)
- renamed com.google.protobuf -> akka.protobuf everywhere
- also added such renaming step to the results of protoc compilation in
  project/Protobuf.scala
- had to include transcriptions of Netty’s ProtobufEncoder/Decoder to
  make multi-node-testkit compile again
 2015-09-04 09:06:50 +02:00
Patrik Nordwall
baa4399521 Merge pull request #18391 from drewhk/wip-17555-forward-port-drewhk 
=rem #17555: Quarantine should clear pending connections (forward port)
 2015-09-04 09:05:08 +02:00
Patrik Nordwall
f98b4c1f5e =clu #18345 Support local address in cluster commands 
* and clarify the doc sample for leave
 2015-09-04 08:53:36 +02:00
Patrik Nordwall
4cbfe3d682 Merge pull request #18332 from akka/wip-17253-cluster-startup-patriknw 
=clu #17253 Improve cluster startup thread usage
 2015-09-03 18:10:22 +02:00
Patrik Nordwall
737a50ebf3 =clu #17253 Improve cluster startup thread usage 
When using a dispatcher (default or separate cluster dispatcher)
with less than 5 threads the Cluster extension initialization
could deadlock.

It was reproducable by adding a sleep before the Await of GetClusterCoreRef
in the Cluster extension constructor. The reason was that other cluster actors were
started too early and they also tried to get the Cluster extension and thereby blocking
dispatcher threads.

Note that the Cluster extension is started via ClusterActorRefProvider before
ActorSystem.apply returns.

The improvement is to start the cluster child actors lazily when the
GetClusterCoreRef is received.
 2015-09-03 18:09:31 +02:00