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

12889 commits

This branch
This branch
All branches
Author SHA1 Message Date
Roland
214c29a459 fix one more warning 2013-05-27 08:32:36 +02:00
Roland
3074b0c2f8 split IO docs and mark them EXPERIMENTAL, see #3294 2013-05-26 19:55:35 +02:00
Roland
b6efd467e8 add ScalaDocs and correct UDP docs, see 3268 2013-05-26 18:29:23 +02:00
Roland
ea5b79e562 add BackpressureBuffer, see #3253 
- also make a Write’s “ack” be a Tcp.Event (to suit pipelines)
- add stress test for BackpressureBuffer
- add it to SslTlsSupportSpec
- add it to the docs
 2013-05-26 10:58:55 +02:00
Roland
025a91ecc2 fix some warts in IO 
- remove TcpPipelineHandler’s type parameter
- remove not-accept() failure test (which is completely bogus)
- add comments explaining more about TcpPipelineHandler.Init
- remove the funny “manager” from the Server example
 2013-05-23 16:14:51 +02:00
Roland
f3f55d4972 exclude akkaSbtPlugin from unidoc (does not make sense and fails) 2013-05-22 17:58:38 +02:00
Patrik Nordwall
d3fc338f84 Merge pull request #1460 from akka/wip-3365-config-1.0.1-patriknw 
Config library 1.0.1
 2013-05-22 05:54:57 -07:00
Patrik Nordwall
d5e1f8642a Config library 1.0.1 
* Mention the new syntax for seed-nodes in cluster docs
 2013-05-22 14:51:47 +02:00
Roland Kuhn
f055fafe32 Merge pull request #1461 from akka/wip-scala-2.11-∂π 
2.11.0-M3: make it compile and fix a test
 2013-05-22 05:42:58 -07:00
Patrik Nordwall
37421efe2e Merge pull request #1459 from akka/wip-3368-extra-DeathWatchNotification-patriknw 
Send extra DeathWatchNotification from RemoteWatcher, see #3368
 2013-05-22 05:23:40 -07:00
Roland
0ac9333b50 make it compile with Scala 2.11.0-M3 2013-05-22 11:49:52 +02:00
Roland
479c5170cd fix StashJavaAPI test (i.e. make it test something) 2013-05-22 11:49:30 +02:00
Roland Kuhn
1f4559f364 Merge pull request #1458 from akka/wip-reinstate-deprecations-√ 
Reinstating a couple of deprecation warnings for Props
 2013-05-21 14:03:24 -07:00
Patrik Nordwall
2dd0141bfc Send extra DeathWatchNotification from RemoteWatcher, see #3368 2013-05-21 19:33:06 +02:00
Jonas Bonér
c616fc43a6 Merge pull request #1452 from akka/wip-pubsub-optionally-send-to-sender-node-with-sendall-jboner 
Added optional property (skipSenderNode) to PubSub.SendToAll
 2013-05-21 02:41:03 -07:00
Viktor Klang
f518d3926c Reinstating a couple of deprecation warnings for Props 2013-05-21 10:49:36 +02:00
Jonas Boner
5d524872c7 Minor fixes after review. 2013-05-21 09:05:40 +02:00
Viktor Klang (√)
3b9c05731b Merge pull request #1454 from akka/wip-3370-undeprecate-creator-√ 
#3370 - Undeprecating Props.apply(=> Actor) and Props.withCreator(=> Ac...
 2013-05-20 13:33:43 -07:00
Viktor Klang (√)
628f45aac0 Merge pull request #1456 from akka/wip-3371-bind-exception-in-tcpconnectionspec-√ 
#3371 - using a new port for each of the TcpConnectionSpec tests to avo...
 2013-05-20 12:46:45 -07:00
Viktor Klang
9817b9434a #3370 - Undeprecating Props.apply(=> Actor) and Props.withCreator(=> Actor) 
Also removing the lazy val implementation of Props.constructor and Props.cachedActorClass
 2013-05-20 21:23:05 +02:00
Viktor Klang (√)
b62d5c8e84 Merge pull request #1457 from akka/wip-3345-not-closing-testconductor-on-netty-thread-√ 
#3345 - making sure not to close the Netty Bootstrap on the Netty IO th...
 2013-05-20 12:18:53 -07:00
Viktor Klang (√)
9de503ee51 Merge pull request #1455 from akka/wip-3323-adding-support-for-log-send-√ 
#3323 - Adding support for akka.remote.log-sent-messages
 2013-05-20 12:18:27 -07:00
Viktor Klang
d7658c4ece #3345 - making sure not to close the Netty Bootstrap on the Netty IO thread, and making sure to close the channel and release the external resources. 2013-05-20 15:46:18 +02:00
Viktor Klang
76df8e60d5 #3371 - using a new port for each of the TcpConnectionSpec tests to avoid races with reuse of port numbers 2013-05-20 15:05:44 +02:00
Viktor Klang
1c2909acc1 #3323 - Adding support for akka.remote.log-sent-messages 2013-05-20 14:35:51 +02:00
Jonas Boner
33407e39de Added optional property (skipSenderNode) to PubSub.SendToAll 
if the message should be sent to a matching path on the sender node or not.

Added optional property (skipSenderNode) to PubSub.SendToAll.
Deciding if the SendToAll message should be sent to a matching path on the sender cluster node or not. + Test and Docs.
 2013-05-20 13:45:13 +02:00
drewhk
336fb1b180 Merge pull request #1450 from drewhk/wip-eventstream-for-fd-drewhk 
EventStream is now passed to failure detectors
 2013-05-17 09:40:12 -07:00
Björn Antonsson
e0791419d0 Merge pull request #1446 from akka/wip-3251-callingthreaddispatchermodelspec-failure-ban 
Ensure that dispatcher doesn't get empty during test #3251
 2013-05-17 09:05:55 -07:00
Endre Sándor Varga
44b9ce8db2 Added INTERNAL API marker 2013-05-17 17:57:31 +02:00
Endre Sándor Varga
d094e1bf7f Marked FailureDetectorLoader as akka private 
- also added scaladoc
 2013-05-17 17:31:30 +02:00
Endre Sándor Varga
fd4bc09035 EventStream is now passed to failure detectors 
- Also, dynamic loading is now centralized (DRY)
 2013-05-17 16:35:27 +02:00
Patrik Nordwall
818659ecb0 Merge pull request #1451 from akka/wip-3366-davyJones-patriknw 
davyJones should be sender, see #3366
 2013-05-17 06:34:05 -07:00
Björn Antonsson
bbf9a17e31 Merge pull request #1449 from akka/wip-3269-akka.camel.concurrentactivationtest-failure-ban 
Use a dilated timeout for ConcurrentActivationTest #3269
 2013-05-17 06:33:38 -07:00
Patrik Nordwall
5a292e7fb9 davyJones should be sender, see #3366 2013-05-17 15:32:40 +02:00
Björn Antonsson
130bf293f9 Ensure that dispatcher doesn't get empty during test. See #3251 2013-05-17 15:23:08 +02:00
Patrik Nordwall
7d3398a60e Merge pull request #1448 from akka/wip-3356-netty-3.6.6-patriknw 
Netty 3.6.6, see #3356
 2013-05-17 05:02:04 -07:00
Patrik Nordwall
c640f4a0dd Merge pull request #1447 from akka/wip-3346-netty-defaults-patriknw 
Change defaults for Netty pools, see #3346
 2013-05-17 05:01:11 -07:00
Patrik Nordwall
90a5f0c044 Merge pull request #1445 from akka/wip-3340-RemoteNodeDeathWatchSpec-patriknw 
Missing barrier coordination in RemoteNodeDeathWatchSpec, see #3340
 2013-05-17 05:00:30 -07:00
Patrik Nordwall
6317d81f39 Missing barrier coordination in RemoteNodeDeathWatchSpec, see #3350 2013-05-17 13:59:02 +02:00
Viktor Klang (√)
6d2547b87a Merge pull request #1436 from akka/wip-3340-0-push-timeout-√ 
#3340 - Adding support for 0ms push timeout for blocking mailboxes
 2013-05-17 04:58:38 -07:00
Patrik Nordwall
346d06a57c Merge pull request #1444 from akka/wip-3334-RemoteDeploymentDeathWatchSpec-patriknw 
Shutdown ordering issue in RemoteDeploymentDeathWatchSpec, see #3334
 2013-05-17 04:58:12 -07:00
Patrik Nordwall
8f04b53ac7 Merge pull request #1443 from akka/wip-3359-auto-join-patriknw 
Remove auto-join config, derive from seed-nodes, see #3359
 2013-05-17 04:57:07 -07:00
Patrik Nordwall
c1cbbea1f3 Merge pull request #1432 from akka/wip-3309-exiting-patriknw 
Hardening of cluster member leaving path, see #3309
 2013-05-17 04:55:32 -07:00
Patrik Nordwall
ad1eaa6d4a Remove auto-join config, derive from seed-nodes, see #3359 2013-05-17 13:54:51 +02:00
Björn Antonsson
fbd9d43a9d Use a dilated timeout for ConcurrentActivationTest. See #3269 2013-05-17 13:03:25 +02:00
Patrik Nordwall
c656bb08d2 Netty 3.6.6, see #3356 2013-05-17 12:14:21 +02:00
Patrik Nordwall
3d2db10787 Change defaults for Netty pools, see #3346 
server-socket-worker-pool.pool-size-max = 2
client-socket-worker-pool.pool-size-max = 2
 2013-05-17 12:05:03 +02:00
Björn Antonsson
e6b4e64211 Merge pull request #1441 from akka/wip-3308-actorsystemspec-times-out-ban 
ActorSystemSpec timeout fixes #3308
 2013-05-17 02:46:52 -07:00
Patrik Nordwall
a0a0f39613 Hardening of cluster member leaving path, see #3309 
* Removed leader commands for Shutdown and Exit
* Member shutdown itself  when it sees itself as Exiting
* Singleton cluster with status Exiting will shutdown itself,
  in case the Exiting gossip never arrives
* Exiting member not part convergence check
* Exiting member is removed by leader (on convergence) when the
  exiting member is in the unreachable set, i.e. sucessfully shutdown
* Reverted the change made for #3266, i.e. Exiting is
  detected as unreachable again.
* Adjust ClusterSingletonManager to new Exiting behaviour
* Fix bug in HeartbeatSender, which caused it to continue to
  send heartbeats to removed nodes, instead of rebalancing
* Refactoring of leaderActions method
* Leaving section in docs
 2013-05-17 11:39:49 +02:00
Björn Antonsson
1a63ff7dbd Remove some unnecessary object creation and switch to HashSet for better performance. See #3308 2013-05-17 08:35:34 +02:00