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

8954 commits

This branch
This branch
All branches
Author SHA1 Message Date
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
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
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
Viktor Klang
3fb62e1d9c Updated to latest jsr166y FJ 2012-01-31 10:01:29 +01:00
Patrik Nordwall
7f684456f2 Rewrite ActorTimeoutSpec not to be iffy. See #1593 2012-01-31 09:27:21 +01:00
patriknw
c9b9a94a9f Merge pull request #279 from jboner/wip-1717-hotswap-patriknw 
Move hotswap stack into Actor trait. See #1717
 2012-01-30 23:35:45 -08:00
Patrik Nordwall
6fbd72591e Review comments. See #1717 2012-01-31 08:34:17 +01:00
Patrik Nordwall
799ab8b482 Fixed import clash when using java7, fj in java.util.concurrent._. See #1728 2012-01-30 20:38:40 +01:00
Patrik Nordwall
1f47e93088 Adjusted performance benchmarks for fjpool. See #1728 2012-01-30 20:37:52 +01:00
Jonas Bonér
e8892eb387 Moved failure detector config from 'remote' to 'cluster' 2012-01-30 19:57:05 +01:00
Jonas Bonér
ad1c84b950 Merged with master. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-30 19:40:28 +01:00
Viktor Klang
32b5e53146 Renaming tests to reflect current APIs 2012-01-30 17:42:50 +01:00
Viktor Klang
1a5e7590ea Adding tests for tryRecover and andThen 2012-01-30 17:32:24 +01:00
Viktor Klang
5d2669769f Making the ExecutionContext protected and adding tryRecover 2012-01-30 17:01:47 +01:00
Patrik Nordwall
269ff0aa96 ZeroMQ module's ConcurrentSocketActorSpec fails. 
* Fixed usage of extension. See #1746
* Clarified usage of load extensions in docs. See #1745
 2012-01-30 16:55:03 +01:00