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

8966 commits

This branch
This branch
All branches
Author SHA1 Message Date
Patrik Nordwall
4753f4af02 Remove log warning on reschedule to stopped actor. See #1760 2012-02-01 11:42:27 +01:00
patriknw
f00e38649f Merge pull request #288 from jboner/wip-1761-cp-patriknw 
Config dir first in classpath. See #1761
 2012-02-01 02:29:06 -08:00
patriknw
ed7ff3b02f Merge pull request #283 from jboner/wip-1716-directives-patriknw 
Replaced Action with Directive in SupervisorStrategy. See #1716
 2012-02-01 02:28:42 -08:00
Patrik Nordwall
13fb8df246 DOC: Fixed unclear docs of OneForOneStrategy and AllForOneStrategy. 2012-02-01 11:26:55 +01:00
Viktor Klang
9b43134307 Fixing doc error 2012-02-01 10:22:38 +01:00
Viktor Klang
e57a48e9e2 Merge branch 'master' of github.com:jboner/akka 2012-02-01 10:10:40 +01:00
Viktor Klang
a950fe2d9b Switching to FJP as default in the tests 2012-02-01 10:10:13 +01:00
Roland Kuhn
fd6029ed96 Merge pull request #287 from jboner/wip-1759-FSM-cleanup-∂π 
FSM: remove Ev extractor and move -> into companion object, see #1759
 2012-02-01 00:24:21 -08:00
Patrik Nordwall
aa0b48a43b Config dir first in classpath. See #1761 2012-02-01 08:49:31 +01:00
viktorklang
e7cfb83288 Merge pull request #286 from jboner/wip-1758-fix-testactorref-√ 
Moving the InternalGetActor message to the companion object and verifyin...
 2012-01-31 15:01:26 -08:00
Roland
06b64680e3 doc updates for #1759 2012-01-31 21:58:31 +01:00
Roland
983a6d3ace FSM: remove Ev extractor and move -> into companion object, see #1759 2012-01-31 21:48:24 +01:00
Viktor Klang
dcebd1deb2 Moving the InternalGetActor message to the companion object and verifying that it's possible to call apply from Java 2012-01-31 21:38:20 +01:00
Jonas Bonér
b4d9486e63 Merge pull request #285 from jboner/wip-remove-corba-from-uuid-jboner 
Removed unused classes referencing CORBA from UUID
 2012-01-31 11:56:38 -08:00
Jonas Bonér
f915319e47 Removed unused import 2012-01-31 19:31:56 +01:00
Jonas Bonér
556fc0d19f Removed unused classes referencing CORBA from UUID 2012-01-31 19:30:27 +01:00
Jonas Bonér
fd151d3c95 Removed unused classes referencing CORBA from UUID 2012-01-31 19:28:16 +01:00
Jonas Bonér
e79c22d4ca Removed unused classes referencing CORBA from UUID 2012-01-31 19:25:12 +01:00
Viktor Klang
815245a133 Merging with master 2012-01-31 17:56:49 +01:00
Viktor Klang
92426a82d9 Renaming Future.or to fallbackTo 2012-01-31 17:19:38 +01:00
viktorklang
a0a4a85e49 Merge pull request #270 from jboner/wip-fix-futures-√ 
Wip fix futures √
 2012-01-31 07:10:59 -08:00
Viktor Klang
8cd033bb17 Merge branch 'master' into wip-fix-futures-√ 2012-01-31 16:10:14 +01:00
Patrik Nordwall
2a4418799a Replaced Action with Directive in SupervisorStrategy. See #1716 2012-01-31 16:10:07 +01:00
Viktor Klang
aa1c7ea9b9 Adding java documentation for andThen, recover and tryRecover 2012-01-31 16:00:46 +01:00
Jonas Bonér
5a1c0da8ae converted tabs to spaces 2012-01-31 15:50:06 +01:00
Jonas Bonér
575ae92fb9 Changed line endings from DOS to UNIX 2012-01-31 15:49:24 +01:00
Jonas Bonér
4162372024 Cleaned up AccrualFailureDetectorSpec after changing order of arguments in AccrualFailureDetector 2012-01-31 15:48:01 +01:00
Viktor Klang
e32adebfd9 Adding doc to andThen and tryRecover 2012-01-31 15:23:00 +01:00
Jonas Bonér
7dbb5e9abb Added try-finally blocks for each shutdown step in the Gossipper.shutdown method. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 15:07:15 +01:00
Jonas Bonér
0b59640820 Fixed bunch of stuff based on feedback on pull request. 
Moved all cluster config to akka-cluster (and added test).

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 15:01:06 +01:00
Jonas Bonér
475635fdd0 Merge branch 'wip-gossipping-jboner' of github.com:jboner/akka into wip-gossipping-jboner 2012-01-31 13:34:34 +01:00
Jonas Bonér
0fa184560c Moved Gossiper, FailureDetector and VectorClock (with tests) to the akka-cluster module. Deleted all old unused cluster code (ZooKeeper-based stuff). 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:06 +01:00
Jonas Bonér
64301f5d77 Moved failure detector config from 'remote' to 'cluster' 2012-01-31 13:34:06 +01:00
Jonas Bonér
f914dfe83b Merged with master. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:06 +01:00
Jonas Bonér
c6fb6def13 Enhanced the Gossip state with member status, ring convergence flags etc. 
* Added member status, ring convergence flags etc to Gossip state.
* Updated Gossiper to use Member throughout instead of ParsedTransportAddress.
* Commented out cluster membership updating to be replaced by the one in the cluster specification.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:06 +01:00
Jonas Bonér
56b94227d3 Added some options to the cluster config section. Moved gossip config from remote to cluster section. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:06 +01:00
Jonas Bonér
4b0b985f98 Added test for testing the Failure Detector when used together with Gossiper and a set of remote cluster nodes. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:05 +01:00
Jonas Bonér
135f1e3002 Added logging to AccrualFailureDetector 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:05 +01:00
Jonas Bonér
642be72a6b Added 'Versioned' abstraction which is versioned through a VectorClock (including tests). 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:05 +01:00
Jonas Bonér
04cf3ea7db Added initial join cluster through seed nodes phase to Gossiper plus misc other fixes and additions. 
- Added JoinCluster phase (connect and get initial data from seed nodes) to Gossiper.
- Added '/system/cluster' daemon actor to Gossiper responsible for gossip communication.
- Added various config options to Gossiper.
- Fixed misc bugs in Gossiper.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:05 +01:00
Jonas Bonér
e24238377f Minor code and ScalaDoc formatting changes. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:05 +01:00
Jonas Bonér
6db989ffa3 Fixed ugly logging in NettyRemoteSupport (plus misc minor formatting). 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:05 +01:00
Jonas Bonér
3088201bb8 Changed akka.util.Timer to use nanos and added a 'timeLeft' method. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:05 +01:00
Jonas Bonér
9a7b234ec2 Changed copyright header to Typesafe. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:34:05 +01:00
Jonas Bonér
418ab3f6f6 Moved Gossiper, FailureDetector and VectorClock (with tests) to the akka-cluster module. Deleted all old unused cluster code (ZooKeeper-based stuff). 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 13:33:04 +01:00
Viktor Klang
4c2a44ec7a Removing JMX from akka-actor 2012-01-31 11:02:56 +01:00
viktorklang
2169ce4b76 Merge pull request #280 from jboner/wip-1728-fjpool-√ 
Wip 1728 fjpool √
 2012-01-31 01:22:51 -08:00
Viktor Klang
d0d2bee5c6 Adding correct classloader to executor config 2012-01-31 10:22:20 +01:00
Viktor Klang
30c45c4a8d Merge branch 'wip-1728-fjpool-√' of github.com:jboner/akka into wip-1728-fjpool-√ 2012-01-31 10:14:39 +01:00
Viktor Klang
3d226cb8ef Switching to fork join as default dispatcher and adding tests for it 2012-01-31 10:12:45 +01:00