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

102 commits

Author SHA1 Message Date
Viktor Klang
474787a81d Renaming createActor to actorOf 2011-10-18 17:56:23 +02:00
Viktor Klang
fa1a2610a7 Removing RemoteActorSystemMessage.Stop in favor of the sexier Terminate message 2011-10-17 19:31:59 +02:00
Peter Vlugter
d9e0088f3c Get remoting working under the remote actor ref provider 2011-10-13 18:08:09 +02:00
Roland
44b94643e5 Merge with Peter's work (i.e. merging master into tame-globals) 2011-10-13 14:17:07 +02:00
Peter Vlugter
317b8bc03b Merge master into tame-globals branch 2011-10-13 13:41:44 +02:00
Roland
85b7accfd4 make EventHandler non-global 
- add Logging trait for nicer interface
- add EventHandlerLogging class for offering the nice interface from
  app.log
- add eventHandler instance to app and use that for all internal logging
  (this means that some places (dispatchers, remoting) were infiltrated
  by app just to do logging, but I think we'll need app in there soon
  enough for other reasons)
 2011-10-13 13:21:59 +02:00
Viktor Klang
fe3c22fe23 #1192 - Removing the 'guaranteed delivery'/message resend in NettyRemoteSupport 2011-10-12 14:45:13 +02:00
Viktor Klang
41029e2f83 Removing pointless Index in the Remoting 2011-10-12 14:12:11 +02:00
Viktor Klang
aa1c636a6b Adding support for giving a Scala function to Index for comparison, and fixed a compilation error in NEttyRemoteSupport 2011-10-12 13:42:54 +02:00
Roland
36ec202d94 rename AkkaConfig values to CamelCase 2011-10-12 11:35:45 +02:00
Roland
14751f7d29 make everything except tutorial-second compile 
someone should look at remoting vs. timeout (i.e. which is sent around),
because I removed that in some places. It might simply be irrelevant
once we remove the Future special-casing.
 2011-10-12 09:10:05 +02:00
Jonas Bonér
4ec050c12e Major refactoring of RemoteActorRefProvider, remote Routing and FailureDetector, including lots of fixes and improvements. 
- Decoupled FailureDetector from Routing by introducing ConnectionManager which uses FailureDetector instead of it being the same thing.
- Added ConnectionManager
- Added LocalConnectionManager
- Added RemoteConnectionManager
- Improved RoutedProps
- Integrated and added configuration for Scatter Gather router
- Added NoOpFailureDetector
-  Misc API and documentation improvements

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-10-07 15:42:55 +02:00
Jonas Bonér
db8a20ea37 Changed all 'def foo(): Unit = { .. }' to 'def foo() { .. }' 2011-09-27 17:41:02 +02:00
Jonas Bonér
00d3b87586 Merge branch 'remote-actorref-provider' 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-09-22 04:38:33 +02:00
Jonas Bonér
af49b99d6f Completed RemoteActorRefProvider and parsing/management of 'remote' section akka.conf, now does provisioning and local instantiation of remote actor on its home node. Also changed command line option 'akka.cluster.port' to 'akka.remote.port'. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-09-22 03:36:59 +02:00
Jonas Bonér
978cbe4437 Change the package name of all classes in remote module to 'akka.remote'. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-09-20 22:08:38 +02:00
Jonas Bonér
8e4bcb304a Moved remoting code into akka-cluster. 
Removed akka-remote.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-23 18:15:47 +02:00
Viktor Klang
0b1174fff9 Fixing mem leak in NettyRemoteSupport.unregister 2011-06-17 12:04:17 +02:00
Jonas Bonér
04bf416ead Merge branch 'master' into pluggable-serializer 2011-06-14 14:41:24 +02:00
Roland
ca592ef1b4 Merge branch 'master' of github.com:jboner/akka 
Conflicts:
	akka-actor/src/main/scala/akka/actor/Actor.scala
	akka-actor/src/main/scala/akka/actor/ActorRef.scala
	akka-actor/src/main/scala/akka/actor/TypedActor.scala
	akka-cluster/src/main/scala/akka/cluster/ClusterActorRef.scala
	akka-cluster/src/main/scala/akka/cluster/ReplicatedClusterRef.scala
	akka-durable-mailboxes/akka-mailboxes-common/src/main/scala/akka/actor/mailbox/DurableDispatcher.scala
	akka-testkit/src/test/scala/akka/testkit/TestActorRefSpec.scala
	akka-tutorials/akka-tutorial-second/src/main/java/akka/tutorial/java/second/Pi.java
 2011-06-14 00:19:54 +02:00
Roland
7712c20620 unify sender/senderFuture into channel (++) 
(squashed merge from the various bits and pieces already part of
release-1.2, everything related to Channel & Future)
 2011-06-13 22:36:46 +02:00
Debasish Ghosh
f27e23bf1d Merged with master 2011-06-13 13:35:39 +05:30
Viktor Klang
54960f7e7d Fixing ticket #916, adding a catch-all logger for exceptions around message processing 2011-06-12 20:29:32 +02:00
Jonas Bonér
5c92a2704d Moved 'akka.remote' config elements into 'akka.cluster' 2011-06-10 20:49:00 +01:00
Debasish Ghosh
40d1ca6da2 Issue #595: Pluggable serializers - basic implementation 2011-06-07 06:36:21 +05:30
Jonas Bonér
e6fa55b3a8 - Changed implementation of Actor.actorOf to work in the the new world of cluster.ref, cluster.use and cluster.store. 
- Changed semantics of replica config. Default replicas is now 0. Replica 1 means one copy of the actor is instantiated on another node.
- Actor.remote.actorFor/Actor.remote.register is now separated and orthogonal from cluster implementation.
- cluster.ref now creates and instantiates its replicas automatically, e.g. it can be created first and will then set up what it needs.
- Added logging everywhere, better warning messages etc.
- Each node now fetches the whole deployment configuration from the cluster on boot.
- Added some config options to cluster

Signed-off-by: Jonas Bonér <jonasremove@jonasboner.com>
 2011-05-25 16:18:35 +02:00
Jonas Bonér
f75dcdbd15 Full clustering circle now works, remote communication. 
Added test for cluster communication.
Refactored deployment parsing.
Added InetSocketAddress to remote protocol.

Signed-off-by: Jonas Bonér <jonasremove@jonasboner.com>
 2011-05-24 19:04:25 +02:00
Viktor Klang
8a790b1ddf Renaming CompletableFuture to Promise, Renaming AlreadyCompletedFuture to KeptPromise, closing ticket #854 2011-05-23 11:31:01 +02:00
Viktor Klang
41a08237d9 Moved secure cookie exchange to on connect established, this means I could remove the synchronization on send, enabling muuuch more throughput, also, since the cookie isn`t sent in each message, message size should drop considerably when secure cookie handshakes are enabled. I do however have no way of testing this since it seems like the clustering stuff is totally not working when it comes to the RemoteSupport 2011-05-20 19:40:11 +02:00
Viktor Klang
236d8e07e9 Removing the old typed actors 2011-05-19 14:29:21 +02:00
Jonas Bonér
a7311c83e6 Added Scalariform sbt plugin which formats code on each compile. Also checking in reformatted code 2011-05-18 17:25:30 +02:00
Viktor Klang
3a255ef083 Fixing typos 2011-05-17 22:22:47 +02:00
Viktor Klang
e2042d003d Resolve merge conflict in cherry-pick 2011-05-17 09:16:16 +02:00
Jonas Bonér
2655d44ee9 Merged wip-2.0 branch with latest master 2011-05-16 12:32:00 +02:00
Viktor Klang
c2486cd52c Fixing ticket 808 2011-04-29 17:15:00 +02:00
Jonas Bonér
517f9a212b Massive refactorings in akka-cluster. Also added ClusterDeployer that manages deployment data in ZooKeeper 2011-04-29 15:47:56 +02:00
Patrik Nordwall
6576cd51e9 Scala style fixes, added parens for side effecting shutdown methods 2011-04-29 10:20:16 +02:00
Jonas Bonér
868ec62ee7 Rebased from master branch 2011-04-27 01:06:08 +02:00
Jonas Bonér
2e7c76dd98 Rebased from master 2011-04-27 00:38:10 +02:00
Patrik Nordwall
a60bbc5f59 Applied patch from bruce.mitchener, with minor adjustment 2011-04-23 08:11:31 +02:00
Viktor Klang
d5c7e12787 Adding possibility to use akka.japi.Option in remote typed actor 2011-04-18 16:26:31 +02:00
Patrik Nordwall
3c8e375f30 Added parens to stop 2011-04-12 10:53:56 +02:00
Patrik Nordwall
087191f19f Added parens to start 2011-04-12 09:56:17 +02:00
Jonas Bonér
3374eef6ce Merged with Viktors work with removing client managed actors. Also removed actor.id, added actor.address 2011-04-08 21:16:05 +02:00
Jonas Bonér
5f918e55bc commit in the middle of address refactoring 2011-04-08 15:29:14 +02:00
Patrik Nordwall
521643782e fixed warnings, asScalaIterable -> collectionAsScalaIterable 2011-04-08 15:12:39 +02:00
Viktor Klang
87069f6e02 Adding TODOs for solving the problem with sender references and senderproxies for remote TypedActor calls 2011-04-07 13:37:17 +02:00
Viktor Klang
b41ecfe09e Removing even more client-managed remote actors residue, damn, this stuff is sticky 2011-04-07 13:14:59 +02:00
Viktor Klang
3f49eadedc Removing more deprecation warnings and more client-managed actors residue 2011-04-07 13:03:23 +02:00
Viktor Klang
0dff50fa52 Removed client-managed actors, a lot of deprecated methods and DataFlowVariable (superceded by Future) 2011-04-07 12:48:30 +02:00