Commit graph

12698 commits

Author SHA1 Message Date
Patrik Nordwall
1cd4d2206c Increase time limits in CircuitBreakerMTSpec, see #3243 2013-04-23 09:49:35 +02:00
drewhk
7094daf313 Merge pull request #1358 from drewhk/wip-3245-udp-temporary-address-drewhk
Udp tests now use ports acquired from a DatagramSocket
2013-04-22 07:32:31 -07:00
Endre Sándor Varga
3b41eaa1f7 Udp tests now use port acquired from a DatagramSocket #3245 2013-04-22 16:31:06 +02:00
drewhk
e4b455da6a Merge pull request #1360 from drewhk/wip-3242-remotenodedeathwatchslow-failed-drewhk
Fixed misnamed barrier
2013-04-22 07:26:53 -07:00
Roland Kuhn
9bdfb51f45 also fix java/io.rst link to EchoServer et al 2013-04-22 17:13:35 +03:00
Roland Kuhn
e96706c7e5 Merge pull request #1357 from etaty/patch-1
Fix links to EchoServer.scala
2013-04-22 07:11:50 -07:00
Endre Sándor Varga
d0cd2be542 Fixed misnamed barrier 2013-04-22 14:00:30 +02:00
Valerian
62037757fa Fix links to EchoServer.scala 2013-04-22 00:33:04 +03:00
Patrik Nordwall
a4b485968c Disable quarantine for RemoteWatcher unit test 2013-04-19 16:40:33 +02:00
drewhk
eeb92e1bfb Merge pull request #1354 from drewhk/wip-fix-outbound-quarantine-drewhk
Fixed bug in outbound quarantine
2013-04-19 06:59:13 -07:00
Endre Sándor Varga
25c75f9e7e Fixed bug in outbound quarantine 2013-04-19 15:31:03 +02:00
drewhk
a694995617 Merge pull request #1352 from drewhk/wip-2594-quarantining-drewhk
Hooked in quarantining
2013-04-19 06:02:08 -07:00
Endre Sándor Varga
fa5ab15450 Ignoring test that relies on actorFor and remote watch 2013-04-19 14:51:21 +02:00
Roland Kuhn
7870bf0cb0 Merge pull request #1353 from akka/wip-structure-docs-∂π
restructure ToC of reST docs
2013-04-19 05:14:52 -07:00
Björn Antonsson
bceef2648c Merge pull request #1343 from akka/wip-2687-per-actor-class-configurable-mailboxes-ban
Allow different types of mailboxes on the same dispatcher #2687
2013-04-19 04:49:40 -07:00
Björn Antonsson
c3eed374f1 Allow different types of mailboxes on the same dispatcher. See #2687 2013-04-19 13:42:58 +02:00
Roland
63c6bc7d88 restructure ToC of reST docs
- completely decouple Java/Scala and remove heading suffixes
- move all images into images/
- move cluster docs into “official” place
2013-04-19 13:40:37 +02:00
Endre Sándor Varga
efbc0a781f Quarantine is in wrong block 2013-04-19 13:36:39 +02:00
Roland Kuhn
d0b7a7f9f1 Merge pull request #1351 from akka/wip-3236-SslTlsSupport-∂π
add SslTlsSupport (ported from spray-io), see #3236
2013-04-19 04:34:00 -07:00
Roland Kuhn
fdd14f0aa5 add link to ticket from FIXME 2013-04-19 14:33:29 +03:00
Endre Sándor Varga
c40d4309cd Fixed require statement for QuarantineDuration 2013-04-19 13:19:45 +02:00
Endre Sándor Varga
444b73bec6 Fixed review comments
- Using Duration.Undefined
 - Quarantine message is actually handled ;)
2013-04-19 12:33:12 +02:00
drewhk
b694981fe5 Merge pull request #1350 from drewhk/wip-3249-newremoteactor-failed-drewhk
NewRemoteActorSpec is racy, but has to work even if the race happens
2013-04-19 03:26:00 -07:00
Patrik Nordwall
c86cc0b8f7 Merge pull request #1347 from akka/wip-3182-fix-SO-in-file-based-mailbox-√
#3182 - Fixing a StackOverflow error in the FileBasedMailbox
2013-04-19 03:06:20 -07:00
Patrik Nordwall
d04d44b184 Merge pull request #1349 from akka/wip-2594-quarantine-removed-member-patriknw
Only quarantine removed member that was unreachable, see #2594
2013-04-19 03:02:32 -07:00
Roland
9ba8b115ec add SslTlsSupport (ported from spray-io), see #3236
- also added TcpPipelineHandler for wrapping a pipeline
- added Java & Scala docs with a complete example
- test verify interop with standard blocking java SSL client and server
- test is placed in akka-remote to benefit from AkkaProvider for
  SecureRandom; should be moved into akka-actor eventually
2013-04-19 12:01:35 +02:00
Endre Sándor Varga
33e2710bf9 Hooked in quarantining 2013-04-19 11:39:28 +02:00
Endre Sándor Varga
a226c2ba2e NewRemoteActorSpec is racy, but has to work even if the race happens
- timeout of the test was small, needs time for FD to trigger
2013-04-19 11:36:36 +02:00
Patrik Nordwall
4ee5cfa483 Merge pull request #1348 from akka/wip-3229-member-prio-patriknw
Change member prio for Joining/Up, see #3239
2013-04-19 01:09:17 -07:00
Patrik Nordwall
49744e0b0f Only quarantine removed member that was unreachable, see #2594
* For graceful leaving and remove it should still be possible to
  communicate with the node after cluster removal.
* Otherwise the hand over in cluster singleton would break, for
  example.
* Also, skip selfAddress to avoid generation of AddressTerminated
  for the own node when removed from cluster.
2013-04-19 08:52:27 +02:00
Patrik Nordwall
a3df775931 Change member prio for Joining/Up, see #3239
* Sometimes caused duplicate MemberUp events, after conflicting gossips
2013-04-19 07:54:23 +02:00
Viktor Klang
a24cf76375 #3182 - Fixing a StackOverflow error in the FileBasedMailbox 2013-04-18 17:38:16 -07:00
Patrik Nordwall
3569886bbe Merge pull request #1345 from akka/wip-3239-cluster-sample-failures-patriknw
Temp workaround in tests for the duplicate MemberUp events, see #3239
2013-04-18 13:13:26 -07:00
Patrik Nordwall
c0e96f55bb Temp workaround in tests for the duplicate MemberUp events, see #3239 2013-04-18 22:07:53 +02:00
Patrik Nordwall
c7db89e9ab Merge pull request #1344 from akka/wip-quarantining-in-ClusterRemoteWatcher-patriknw
Quarantine from ClusterRemoteWatcher also, see #2993
2013-04-18 13:05:06 -07:00
drewhk
98d4bcc9dd Merge pull request #1338 from drewhk/wip-1478-sysmsg-guaranteed-delivery-drewhk
Guaranteed delivery of system messages (and now praying...)
2013-04-18 12:38:28 -07:00
Endre Sándor Varga
7735cb87b9 Adding workaround for UnreachableNodeJoinsAgain
- see #3247
2013-04-18 20:31:31 +02:00
Roland Kuhn
567071be22 Merge pull request #1339 from akka/wip-3200-ResumeWriting-∂π
implement ResumeWriting, see #3200
2013-04-18 08:54:36 -07:00
Patrik Nordwall
58bd0a1460 Quarantine from ClusterRemoteWatcher also, see #2993
* This was an oversight in previous pull request
2013-04-18 16:55:02 +02:00
Patrik Nordwall
09b55a2be3 Merge pull request #1340 from akka/wip-3234-ActorLookupSpec-patriknw
Race between termination and actorFor, see #3234
2013-04-18 07:44:29 -07:00
Patrik Nordwall
be14e62e7b Merge pull request #1342 from akka/wip-props-factory-methods-patriknw
Factory methods for Props
2013-04-18 07:43:59 -07:00
Patrik Nordwall
4293bd7a2d Factory methods for Props
* cleanup of deprecated usage of Props in cluster sample
2013-04-18 16:41:05 +02:00
Endre Sándor Varga
da2a23f3e9 Fixed compile errors 2013-04-18 16:19:41 +02:00
Endre Sándor Varga
2b0a27be9e Added acknowledged delivery of system messages 2013-04-18 16:10:20 +02:00
Roland
0e34edbcb3 implement ResumeWriting, see #3200
also included:
- a complete rewrite of the TCP docs based on real/tested/working code
  samples
- an EchoServer implementation which handles all the edge cases,
  available in Java & Scala
- renamed StopReading to SuspendReading to match up with ResumeReading
- addition of Inbox.watch()
- Inbox RST docs for Java(!) and Scala

not included:
- ScalaDoc / JavaDoc for all IO stuff
2013-04-18 15:05:48 +02:00
Patrik Nordwall
489c00b913 Merge pull request #1341 from akka/wip-UnreachableNodeJoinsSpec-patriknw
Fix failing UnreachableNodeJoinsAgainSpec
2013-04-17 13:24:24 -07:00
Patrik Nordwall
d2939fa39a Fix failing UnreachableNodeJoinsAgainSpec
* Shutting down test conductor controller is never a good idea
2013-04-17 22:22:22 +02:00
Patrik Nordwall
ee1b5879cf Race between termination and actorFor, see #3234 2013-04-17 21:03:16 +02:00
Patrik Nordwall
d6d64b1c1a Merge pull request #1323 from akka/wip-2993-remote-watch-patriknw
Reliable remote supervision and death watch, see #2993
2013-04-17 11:53:13 -07:00
Patrik Nordwall
4606612bd1 Reliable remote supervision and death watch, see #2993
* RemoteWatcher that monitors node failures, with heartbeats
  and failure detector
* Move RemoteDeploymentWatcher from CARP to RARP
* ClusterRemoteWatcher that handles cluster nodes
* Update documentation
* UID in Heartbeat msg to be able to quarantine,
  actual implementation of quarantining will be implemented
  in ticket 2594
2013-04-17 19:42:51 +02:00