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

12137 commits

This branch
This branch
All branches
Author SHA1 Message Date
Roland Kuhn
e06076553c Merge pull request #1097 from akka/wip-channels-∂π 
add Typed Channels, see #2929
 2013-02-01 06:37:41 -08:00
Roland
b127ab0d4f final review comments 
- make it EXPERIMENTAL
- shuffle docs around to be less scary
- reuse sameThreadExecutionContext in CircuitBreaker
- typos
 2013-02-01 15:32:56 +01:00
Björn Antonsson
6440e385f1 Merge pull request #1079 from akka/wip-2954-transport-startup-timeout-patriknw 
Increase remoting startup/shutdown timeouts, see #2954
 2013-02-01 04:48:00 -08:00
Björn Antonsson
f370942c00 Merge pull request #1093 from akka/wip-2880-use-new-scaladoc-features-ban 
Adding implicits and diagrams to scaladoc. See #2880
 2013-02-01 02:56:08 -08:00
Björn Antonsson
c94ef5c66e Adding implicits and diagrams to scaladoc. See #2880 2013-02-01 11:55:08 +01:00
Roland Kuhn
1c11abd230 Merge pull request #1101 from akka/wip-2950-LARS-race-∂π 
fix two bugs in LARS, see #2950
 2013-02-01 02:19:53 -08:00
Patrik Nordwall
abc9471919 Merge pull request #1086 from akka/wip-2690-remote-fd-patriknw 
Failure detector refactoring, see #2690
 2013-02-01 02:04:53 -08:00
Patrik Nordwall
157a25bcde Failure detector refactoring, see #2690 
* Failure detector was previously copied with refactoring to
  akka-remote and this refactoring makes use of that and removes
  the failure detector in akka-cluster
* Adjustments to reference.conf
* Refactoring of FailureDetectorPuppet
 2013-02-01 10:08:39 +01:00
Roland Kuhn
6198480c34 Merge pull request #1091 from jamie-allen/wip-2984-sbt-documentation 
Added libraryDependencies info for sbt users below 0.12.x
 2013-01-31 22:49:24 -08:00
Roland Kuhn
7020b41fce Merge pull request #1099 from akka/wip-2978-non-direct-∂π 
remove old “direct” router references, see #2978
 2013-01-31 22:47:37 -08:00
Roland
2008bab2ba fix two bugs in LARS, see #2950 
- initial setting of the repeated task raced with first execution, when
  the latter won the task would not repeat
- there was a race in task submission which could lead to enqueueing one
  round too late
 2013-02-01 07:33:51 +01:00
Jamie Allen
ad9365e7fc Added libraryDependencies info for sbt users below 0.12.x 
Removed crossString
 2013-01-31 12:57:33 -08:00
Roland
1b331dc547 Merge branch 'master' into wip-channels-∂π 2013-01-31 20:26:01 +01:00
Roland
86ded1fb0b review comments 
- some API docs
- require names for top-level actors
- allow names for children
- flag error when no channels declared
 2013-01-31 20:19:20 +01:00
Roland
ddbde50a14 remove old “direct” router references, see #2978 2013-01-31 16:22:08 +01:00
Viktor Klang (√)
5164e2e08e Merge pull request #1096 from akka/wip-2986-ActorContext-executor-√ 
#2986 - Changing ActorContext and ActorRefFactory's dispatcher to retur...
 2013-01-31 06:42:12 -08:00
Viktor Klang
e519e3dc3b #2986 - Changing ActorContext and ActorRefFactory's dispatcher to return ExecutionContext 2013-01-31 15:41:31 +01:00
Patrik Nordwall
bc9cc3c66e Merge pull request #1076 from akka/wip-2909-rm-workaround-patriknw 
Remove work-around for sending to broken connections, see #2909
 2013-01-31 05:20:23 -08:00
Patrik Nordwall
9dc124dacd Remove work-around for sending to broken connections, see #2909 
* Previous work-around was introduced because Netty blocks when sending
to broken connections. This is supposed to be solved by the non-blocking
new remoting.
* Removed HeartbeatSender and CoreSender in cluster
* Added tests to verify that broken connections don't disturb live connection
 2013-01-31 13:41:02 +01:00
Patrik Nordwall
89b31c995c Merge pull request #1090 from akka/wip-2870-rm-catch-tell-patriknw 
Remove try ... catch constructs around invokations of tell, see #2870
 2013-01-31 04:39:41 -08:00
Patrik Nordwall
f8095587ad Merge pull request #1094 from akka/wip-2983-failing-remote-deployment-patriknw 
Failing remote deployment, see #2983
 2013-01-31 04:38:08 -08:00
Patrik Nordwall
938cf7126b Send ChildTerminated before Terminated when AddressTerminated, see #2983 
* Replaces the previous half-baked removeChildWhenToAddressTerminated
 2013-01-31 13:36:46 +01:00
Roland
c362e8168f update copyright headers 2013-01-31 11:42:39 +01:00
Roland
7ef5ace8d8 add docs on how to create child actors with channels 2013-01-31 11:40:39 +01:00
Patrik Nordwall
85cfa78e92 Generate ChildTerminated from all Terminated in RemoteDeploymentWatcher, see #2983 
* The problem is that we do remote deployment to a node that isn't alive and with ordinary
  remoting that is not detected at all, as we know. With cluster this was taken care of by
  a later AddressTerminated and ChildTerminated generated by RemoteDeploymentWatcher. With
  the new RemoteDeadLetters the additional watch triggers an immediate Terminate which is
  captured by RemoteDeploymentWatcher but not acted upon since it's not an addressTerminated.
  RemoteDeploymentWatcher unwatch and will therefor not act on later AddressTerminated.
* The long term solution is to have reliable system messages and remote supervision without
  explicit watch, so that we know that the remote deployment fails.
* This short term solution is to let RemoteDeploymentWatcher always generate ChildTerminated,
  also for non-addressTerminated.
* It's possibly racy since ChildTerminated is not idempotent.
 2013-01-31 11:28:23 +01:00
Patrik Nordwall
f89dd49954 Share same instance of deadLetters between LARP and RARP, see #2983 2013-01-31 11:28:08 +01:00
Roland
f86fa61613 make all arrows invertible 2013-01-31 11:12:17 +01:00
Roland
5e763bbb38 change synthetic sender’s reply type to UnknownDoNotWriteMeDown 2013-01-31 09:05:49 +01:00
Roland
aec29618e3 require “Actor with Channels” by using self-typing 2013-01-31 08:49:12 +01:00
Roland
6e6e7f7e55 first cut of the docs for typed channels 2013-01-31 00:23:35 +01:00
Roland Kuhn
46a6e34103 Merge pull request #1068 from akka/wip-2950-LARS-∂π 
fix the first of the issues: too strict test requirement, see #2950
 2013-01-29 11:10:10 -08:00
Roland
b881963907 make sure that InterruptExceptions are not swallowed, see #2963 
also remove an old work-around in CallingThreadDispatcherModelSpec and
describe the rules for interrupting in the testing docs
 2013-01-29 17:26:15 +01:00
Roland
afb5740d74 fix the first of the issues: too strict test requirement, see #2950 
LARS may execute recurring tasks a little too early on occasion, which
is a direct consequence of it trying to keep them running more regularly
and also allowing them to run at 1/tick rate.
 2013-01-29 17:25:35 +01:00
Patrik Nordwall
f9611178a3 Remove try ... catch constructs around invokations of tell, see #2870 2013-01-29 16:10:46 +01:00
drewhk
1c9c4ea8f0 Merge pull request #1088 from drewhk/wip-fix-RemoteConfigSpec-discrepancy-drewhk 
Fixed mismatched RemoteConfigSpec with reference.conf
 2013-01-29 05:19:29 -08:00
Endre Sándor Varga
2773b685d1 Fixed mismatched RemoteConfigSpec with reference.conf 2013-01-29 14:17:37 +01:00
Patrik Nordwall
80c5525e7f Merge pull request #1082 from akka/wip-2953-openBreaker-patriknw 
Fix race in CircuitBreakerMTSpec.openBreaker, see #2953
 2013-01-29 04:19:02 -08:00
Roland
33c588d3fc ignore automatically assembled files in akka-osgi resources dir 2013-01-29 12:34:33 +01:00
Viktor Klang (√)
664ab76bf5 Merge pull request #1085 from akka/wip-2974-escalate-uncaught-exceptions-√ 
Making sure that the current Threads' UEH is called when using Akka FJP ...
 2013-01-29 03:21:22 -08:00
drewhk
3e54c347dc Merge pull request #1077 from drewhk/wip-2959-cluster-deathwatch-fix-drewhk 
Dead letters containing remote envelopes handled correctly #2959
 2013-01-29 03:07:51 -08:00
Viktor Klang
1c104c382a Merge branch 'master' into wip-2974-escalate-uncaught-exceptions-√ 2013-01-29 11:42:42 +01:00
Endre Sándor Varga
e0a9dd70ba Dead letters containing remote envelopes handled correctly #2959 
- New DeadLetter class for handling remoting specific envelopes
 - Fixed error handling of name lookups
 - Name lookup is now handled via futures (future refactor opportunity)
 2013-01-29 11:31:53 +01:00
Viktor Klang
ff540d76ec Making sure that the current Threads' UEH is called when using Akka FJP in Dispatcher as ExecutionContext 2013-01-29 11:26:06 +01:00
Patrik Nordwall
cc9c9ce12a Fix race in CircuitBreakerMTSpec.openBreaker, see #2953 
* The problem was that the breaker is asynchronous so it may
  take some extra time to open.
* Was able to reproduce with a sleep in onComplete in
  CircuitBreaker L303
* Added an extra awaitCond in case the normal (quick)
  failing calls don't open the breaker
 2013-01-29 11:24:43 +01:00
Björn Antonsson
3116c7d4c4 Merge pull request #1078 from akka/wip-2919-master-we-get-lingering-dispatchers-ban 
Forward port of #2919 Keep the dispatcher inhabitants count balanced.
 2013-01-29 02:17:25 -08:00
Roland Kuhn
cf97fa0987 Merge pull request #1060 from Crossing-Tech/osgi-user-configuration 
user configuration for OSGi application bundle
 2013-01-29 02:16:34 -08:00
Patrik Nordwall
ca3a978ee1 Merge pull request #1080 from akka/wip-2961-TestActorRefSpec-patriknw 
Stop sending 'timeout' from ReceiveTimeoutActor, see #2961
 2013-01-29 02:13:42 -08:00
Patrik Nordwall
483514ac86 Merge pull request #1074 from akka/wip-cluster-singleton-docs-patriknw 
Clarifications of cluster singleton docs, see #2895
 2013-01-29 02:04:35 -08:00
Patrik Nordwall
c48d9c058e Clarifications of cluster singleton docs, see #2895 2013-01-29 11:03:25 +01:00
Viktor Klang (√)
b0a9b9b9c5 Merge pull request #1084 from akka/wip-hardening-serialization-spec-√ 
Reenabling the SerializationCompatibilitySpec, now with extra bells and ...
 2013-01-29 01:42:49 -08:00