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

12007 commits

This branch
This branch
All branches
Author SHA1 Message Date
Roland
40a67a4097 disable EPUB build until sbt-site is fixed, see #2938 2013-01-23 21:57:28 +01:00
Roland
b9c0e98d3d Java 6 again; plus forgot one copyright header 2013-01-23 21:02:41 +01:00
Roland Kuhn
7066b37077 Merge pull request #1027 from akka/wip-2904-timer-∂π 
first cut of new AkkaTimer, see #2904
 2013-01-23 11:06:41 -08:00
Roland
8dea20a1f1 LightArrayRevolverScheduler, see #2904 
- based on a wheel (AtomicReferenceArray) from which atomic
  single-linked lists dangle
- no locks
- deterministic tests due to overridable time source
- also bring docs up to date
 2013-01-23 19:57:44 +01:00
Roland Kuhn
9b180a9d87 Merge pull request #1049 from akka/wip-lower-pressure-on-lock-√ 
isProxy is internally using a single, fat, synchronized – yes, astonish...
 2013-01-23 02:33:03 -08:00
Roland Kuhn
f2e9288a4f Merge pull request #1048 from akka/wip-2782-removing-CIHM-√ 
#2782 - Removing ConcurrentIdentityHashMap and shake this all about
 2013-01-23 02:31:02 -08:00
Roland Kuhn
50fb495e56 Merge pull request #1046 from tlockney/feature/epub-support 
added basic support for Epub generation
 2013-01-23 02:20:05 -08:00
Roland Kuhn
205089f7f6 Merge pull request #1041 from RickLatrine/wip-2923-terminated-cascade-ricklatrine 
Prevents Terminated message cascade, see #2923
 2013-01-23 02:01:29 -08:00
Viktor Klang
c16f226d1d isProxy is internally using a single, fat, synchronized – yes, astonishing to say the least, with this we lower the pressure on that lock. 2013-01-22 17:58:37 +01:00
Viktor Klang
4474c34e7c #2782 - Removing ConcurrentIdentityHashMap and shake this all about 2013-01-22 15:11:49 +01:00
Thomas Lockney
bcf81cc12c added basic support for Epub generation 2013-01-21 12:14:46 -08:00
RickLatrine
846e567355 Unwatch watched actors on termination. Fixes: #2923 
unwatchWatchedActors must stay in finishTerminate as an emergency stop might occur at handleInvokeFailure
 2013-01-21 16:02:57 +01:00
Viktor Klang
13b1324509 #2775 - Adding migration guide for waiting on promises 2013-01-21 15:51:49 +01:00
Roland
00a39232cc add debug helper for CallingThreadDispatcherModelSpec, see #2821 
- the problem is that the user guardian gets blocked for more than 3
  seconds, and I have no clue who blocks it where
- therefore print all stack traces two seconds into the test if still
  not finished
 2013-01-20 22:21:02 +01:00
Roland Kuhn
c8779f4e9d Merge pull request #1035 from derekmahar/patch-3 
Update akka-docs/rst/general/actor-systems.rst
 2013-01-20 07:16:30 -08:00
Derek Mahar
3d662f94a0 Update akka-docs/rst/general/actor-systems.rst 
Replace "with respect fault-handling" with "with respect to fault-handling".
 2013-01-18 12:11:05 -05:00
Viktor Klang (√)
6cc4dcb810 Merge pull request #1039 from akka/wip-2838-zeromq-test-shutdown-race-ban 
Terminate zeromq context after actors have terminated
 2013-01-18 07:42:14 -08:00
Björn Antonsson
8f29022ef5 Terminate zeromq context after actors have terminated. See #2838 2013-01-18 15:00:19 +01:00
Björn Antonsson
cd9fae81e5 Making test more DRY. See #2862 2013-01-18 13:58:46 +01:00
Roland Kuhn
fd4624099e Merge pull request #1036 from derekmahar/patch-4 
Update akka-docs/rst/general/actor-systems.rst
 2013-01-18 04:32:18 -08:00
Patrik Nordwall
db5da848c0 Merge pull request #1033 from akka/wip-def-if-patriknw 
Style change of def starting with if
 2013-01-18 04:30:43 -08:00
Patrik Nordwall
5dc108567d Style change of def starting with if 
* When a def starts with if and is not a oneliner the if
  should be on a new line.
* The reason is that it might be easy to miss the if when
  reading the code.
 2013-01-18 13:28:49 +01:00
Viktor Klang (√)
73a1b82869 Merge pull request #1034 from akka/wip-retain-envelope-√ 
Preserving Envelopes in UnstartedActorCell as requested by Mr Pink
 2013-01-18 04:27:48 -08:00
Patrik Nordwall
1557f0c75b Merge pull request #1032 from akka/wip-2905-StressSpec-exercise-supervision-patriknw 
Unique barriers for each round in StressSpec.exerciseSupervision, see #2905
 2013-01-18 04:14:18 -08:00
Patrik Nordwall
bdd69f7cdd Unique barriers for each round in StressSpec.exerciseSupervision, see #2905 
* Looks like the issue was caused by a mixup of barriers and/or name
  of the result aggregator actor
 2013-01-18 13:13:38 +01:00
Patrik Nordwall
06807e73b8 Merge pull request #1029 from akka/wip-2907-heartbeats-patriknw 
Detect failure when no heartbeats sent, see #2907
 2013-01-18 04:10:02 -08:00
Patrik Nordwall
8b4e903e7d Detect failure when no heartbeats sent, see #2907 
* Subscribe to InstantMemberEvent and start heartbeating when
  InstantMemberUp. Same for metrics.
* HeartbeatNodeRing data structure for bidirectional mapping of
  heartbeat sender and receiver. Not using ConsistentHash anymore.
  Node addresses are hashed to ensure that neighbors are spread out.
* HeartbeatRequest when receiver detects that it has not received
  expected heartbeats.
* New test InitialHeartbeatSpec that simulates the problem
* Add/remove some related conf properties
* Add some more logging to be able to diagnose eventual problems
* Explicit config of nr-of-end-heartbeats
 2013-01-18 12:54:09 +01:00
Viktor Klang
c38be1bc4a Preserving Envelopes in UnstartedActorCell as requested by Mr Pink 2013-01-18 12:17:32 +01:00
drewhk
c5685a0855 Merge pull request #1031 from drewhk/wip-2780-removal-of-old-remoting-drewhk 
Removed remaining parts of the old remoting #2780
 2013-01-18 03:10:57 -08:00
Björn Antonsson
398840c204 Merge pull request #1037 from akka/wip-2862-leaking-netty-threads-ban 
Leaking Netty threads causes file handle exhaustion
 2013-01-18 02:19:05 -08:00
Björn Antonsson
a694946f19 Clean up network connections from the test coordinator and player. See #2862 2013-01-18 10:28:21 +01:00
Björn Antonsson
eaff56defe Shut down both client and server channels. See #2862 2013-01-18 08:45:42 +01:00
Derek Mahar
8a47ccf0c6 Update akka-docs/rst/general/actor-systems.rst 2013-01-17 22:26:06 -05:00
Derek Mahar
564ba01434 Update akka-docs/rst/general/actor-systems.rst 2013-01-17 22:14:36 -05:00
Endre Sándor Varga
b08c331577 Fixed problems handling passive connections in Remoting #2878 
- Fixed potential race in EndpointWrite when TakeOff is processed
- Reenabled accidentally disabled gremlin due to changed defaults
- Fixed EndpointRegistry incorrectly handling passive connections
 2013-01-17 14:37:29 +01:00
drewhk
2dd3697b5c Merge pull request #1028 from drewhk/wip-2878-out-of-order-msg-in-stresstest-drewhk 
Fixed problems handling passive connections in Remoting #2878
 2013-01-17 03:41:05 -08:00
Endre Sándor Varga
4f3469ed47 Fixed problems handling passive connections in Remoting #2878 
- Fixed potential race in EndpointWrite when TakeOff is processed
- Reenabled accidentally disabled gremlin due to changed defaults
- Fixed EndpointRegistry incorrectly handling passive connections
 2013-01-17 12:38:26 +01:00
Patrik Nordwall
d983104a7f Merge pull request #1025 from akka/wip-2803-instant-member-events-patriknw 
Publish InstantMemberEvent immediately, see #2803
 2013-01-15 09:23:48 -08:00
drewhk
1b533412b5 Merge pull request #1024 from drewhk/wip-2733-netty-workerpool-shutdown-drew 
Fixed issue with Netty not releasing worker threads properly #2733
 2013-01-15 05:58:17 -08:00
Roland Kuhn
af0906b506 Merge pull request #1020 from akka/wip-2836-ActorRefSpec-∂π 
make ActorRefSpec more deterministic, see #2836
 2013-01-15 01:09:30 -08:00
Patrik Nordwall
8aa6ae868c Merge pull request #1015 from akka/wip-2882-deadletter-null-sender-patriknw 
Replace noSender in DeadLetterActorRef, see #2882
 2013-01-14 10:43:37 -08:00
Patrik Nordwall
79303a1785 Incorparate review comments, see #2803 2013-01-14 19:32:52 +01:00
Patrik Nordwall
d07f331e78 Publish InstantMemberEvent immediately, see #2803 2013-01-14 19:13:48 +01:00
Endre Sándor Varga
5bce8b9430 Fixed issue with Netty not releasing worker threads properly #2733 2013-01-14 16:05:49 +01:00
Roland Kuhn
c321f735f3 Merge pull request #1022 from drewhk/wip-2715-upgrade-netty-3-6-1-drewhk 
Updated Netty to 3.6.1.Final #2715
 2013-01-14 06:34:59 -08:00
Viktor Klang (√)
6b638db65e Merge pull request #1006 from akka/wip-2879-copyright2013-√ 
#2879 - updating copyright info
 2013-01-14 04:59:29 -08:00
Endre Sándor Varga
ba6e977995 Updated Netty to 3.6.1.Final #2715 2013-01-14 09:33:39 +01:00
Roland Kuhn
9f2a0afc05 Merge pull request #1016 from maffoo/wip-2898-hwt-fix-mgn 
Fix HashedWheelTimer to properly handle timeouts that are multiple of wheel period
 2013-01-11 12:39:10 -08:00
Roland
e188699c09 make ActorRefSpec more deterministic, see #2836 2013-01-11 17:40:49 +01:00
Patrik Nordwall
586aa38b62 Merge pull request #1018 from akka/wip-2872-npe-defaultAddress-patriknw 
Throw startup exception from Remoting, see #2872
 2013-01-11 04:09:04 -08:00