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

13087 commits

This branch
This branch
All branches
Author SHA1 Message Date
Patrik Nordwall
9b3be181cf Java (Eclipse) compatibility of extensions, see #3469 
* Eclipse JDT showed compilation error
  "The method get(ActorSystem) is ambiguous for the type..."
  for extensions defined with ExtensionKey
 2013-06-24 20:27:23 +02:00
Roland Kuhn
32a37ac96a Merge pull request #1562 from akka/wip-LARS-2.1-∂π 
fix stupid bug in LARS
 2013-06-24 06:40:41 -07:00
Roland Kuhn
57ac1c4385 fix stupid bug in LARS, see #3467 
When switching the enqueueing logic to use the actual time instead of
the current tick number (which had been the purpose of the whole
rewrite) I managed to make the same mistake I did half a year ago again:
enqueueing into the same slot that has just been processed needs to
subtract one round while enqueueing into the slot that is about to be
processed MUST NOT DO THIS.

There was another bug in there related to differences between tick
number and actual time and remaining ticks of the task. I hope that the
code is now clear and simple enough as to be actually correct. As usual,
all tests passing.
 2013-06-24 13:58:24 +02:00
drewhk
c855c164a9 Merge pull request #1561 from drewhk/wip-3460-unreachablejoinsagain-wrong-view-drewhk 
Test was not using the view from the fresh system #3460
 2013-06-24 04:47:08 -07:00
Patrik Nordwall
6541411add Merge pull request #1560 from akka/wip-3468-joinSeedNodes-public-patriknw 
Make Make Cluster.joinSeedNodes public, see #3468
 2013-06-24 04:46:02 -07:00
Patrik Nordwall
59d24e8af8 Merge pull request #1553 from akka/wip-atmos-tracing 
atmos tracing
 2013-06-24 04:45:25 -07:00
drewhk
4c15cd3f9a Merge pull request #1556 from drewhk/wip-tweak-apt-stresstest-drewhk 
Tweaked AkkaProtocolStressSpec drop policies
 2013-06-24 04:42:36 -07:00
Roland Kuhn
f17d6d4cc1 Merge pull request #1557 from akka/wip-3463-actorOf-doc-∂π 
remove obsolete verbiage from ScalaDoc of actorOf, see #3463
 2013-06-24 04:41:40 -07:00
Roland Kuhn
0e931eb51a Merge pull request #1555 from akka/wip-3461-cluster-client-∂π 
replace embedded JMX Client with jmxsh, see #3461
 2013-06-24 04:40:19 -07:00
Patrik Nordwall
30d34e20bf Make Make Cluster.joinSeedNodes public, see #3468 2013-06-24 12:15:22 +02:00
Endre Sándor Varga
bf3180c0f3 Test was not using the view from the fresh system #3460 2013-06-24 11:54:46 +02:00
Endre Sándor Varga
99508e2bf0 Added comment 2013-06-24 09:33:16 +02:00
Peter Vlugter
48fb1a22bd Update atmos test configuration to trace testActors 2013-06-24 16:51:03 +12:00
Patrik Nordwall
5d2f3277eb sbt-multi-jvm 0.3.6 2013-06-24 16:51:03 +12:00
Peter Vlugter
d1f400e11f Setup tests with atmos tracing 2013-06-24 16:50:52 +12:00
Roland Kuhn
b2ca105f6d remove obsolete verbiage from ScalaDoc of actorOf, see #3463 2013-06-22 10:50:40 +02:00
Endre Sándor Varga
b7a34198a4 Tweaked drop policy to be less aggressive on the other system 2013-06-21 15:23:04 +02:00
Björn Antonsson
98afb2bbd2 Merge pull request #1554 from akka/wip-3451-missing-identify-message-ban 
Longer timeout in RemoteDeliverySpec #3451
 2013-06-20 22:21:21 -07:00
Roland Kuhn
72aa5ef171 replace embedded JMX Client with jmxsh, see #3461 
- rewire the akka-cluster shell script to make use of jmxsh-R5.jar
 2013-06-21 00:44:12 +02:00
drewhk
41d8986382 Merge pull request #1552 from drewhk/wip-connection-leak-fix-drewhk 
Bugfixes aplenty -- connection leak and reliable delivery fixes
 2013-06-20 09:30:31 -07:00
Endre Sándor Varga
e6e5be859b Fixes for leaked connection 
- Also introduces reason in the Disassociate message
 - Reliable delivery now transitions from idle to active if there are pending system msgs
 - Minor fix in merging receive buffers (reduces resends)
 - Tweaked WireFormat
 - Removed busy-wait in startup
 - throwing the proper exception type in EndpointReader
 - InvalidAssociationException extends NoStackTrace
 2013-06-20 17:28:26 +02:00
Roland Kuhn
6d8e13c760 Merge pull request #1529 from akka/wip-3429-ActorRef.noSender-∂π 
add ActorRef.noSender() for the Java API, see #3429
 2013-06-20 06:51:54 -07:00
Roland Kuhn
a2a646af4e add ActorRef.noSender() for the Java API, see #3429 
- Actor.noSender is not accessible from Java, but it was in 2.1 so don’t
  remove
- replaced all “null” in doc tests with ActorRef.noSender()
 2013-06-20 15:51:23 +02:00
Roland Kuhn
952e4f0c05 Merge pull request #1531 from akka/wip-3343-scala-2.10.2-√ 
#3343 - Moving to Scala 2.10.2
 2013-06-20 06:32:38 -07:00
Björn Antonsson
e664d4a333 Longer timeout in RemoteDeliverySpec. See #3451 2013-06-20 15:26:12 +02:00
Roland Kuhn
4ac9993c18 Merge pull request #1547 from akka/wip-LARS-2.0-∂π 
rework LARS, see #3428
 2013-06-20 06:23:27 -07:00
Roland Kuhn
e2937dc27f Merge pull request #1541 from mhamrah/master 
Fix grammar typo with Scala/FSM documentation.
 2013-06-20 05:34:07 -07:00
Roland Kuhn
b044b6b5a9 Merge pull request #1548 from spray/wip/io-fix-configured-noacks 
io: fix rare bug in TcpConnection causing the sending of certain `NoAck`...
 2013-06-20 04:57:10 -07:00
Roland Kuhn
e976b13566 Merge pull request #1546 from akka/wip-3449-random-name-in-TestActorRef-for-java-√ 
#3449 - Adding a new factory method for creating TestActorRefs in Java ...
 2013-06-20 04:55:28 -07:00
Roland Kuhn
511393d9a3 Merge pull request #1545 from akka/wip-3438-unbogusify-check-constructors-√ 
#3438 - Adding support for non-static top-level classes in check constr...
 2013-06-20 04:55:04 -07:00
Roland Kuhn
0d3968de59 Merge pull request #1537 from akka/wip-3436-reuse-proper-threadfactory-for-netty-√ 
#3436 - use the ActorSystem's ThreadFactory for Netty threads
 2013-06-20 04:53:52 -07:00
Roland Kuhn
ec2223a69f Merge pull request #1536 from spray/master 
io: tone down error logging a bit more
 2013-06-20 04:51:11 -07:00
Roland Kuhn
223ab49601 Merge pull request #1527 from akka/wip-2809-avoid-copying-for-ByteStrings-in-remoting-if-possible 
#2809 - avoiding unnecessary copying of Byte Arrays for ByteStrings in ...
 2013-06-20 04:49:46 -07:00
Roland Kuhn
359e01b104 revert to 10ms and fix two more things, see #3428 
- one missing tailrec annotation
- and fix the actual bug: instead of enqueueing relative to the current
  wheel position we must enqueue into that bucket which corresponds to
  the correct time
 2013-06-20 13:47:29 +02:00
Roland Kuhn
18f5b8f4ec Merge pull request #1551 from akka/wip-3457-properly-type-TestFSMRef-√ 
#3457 - Adding proper type to TestFsmRef
 2013-06-20 04:05:28 -07:00
Björn Antonsson
46966c25ea Merge pull request #1535 from akka/wip-3441-speed-up-cluster-gossip-processing-ban 
Speed up cluster gossip processing #3441
 2013-06-20 03:56:16 -07:00
Patrik Nordwall
1543c8700a Merge pull request #1549 from akka/wip-3453-log-deadLetters-patriknw 
Log dead letters, see #3453
 2013-06-20 03:09:55 -07:00
Patrik Nordwall
cd2b77157c Log dead letters, see #3453 2013-06-20 12:09:09 +02:00
Björn Antonsson
1adfcb8454 Speed up cluster gossip processing. See #3441 
Check VectorClock for common case first and cache hashCodes. See #3441
Make ClusterDaemon a bit more testable. See #3441
Changing VectorClock and GossipOverview to TreeMaps. See #3441
Make VectorClock private[cluster] and remove unused code. See #3441
 2013-06-20 11:36:24 +02:00
Mathias
b311e9e700 io: change IOException treatment from "fatal error" to "expected during normal operation" 
Up to now IOExceptions during reading, writing or connecting were treated as
fatal actor errors, crashing the connection actor and thus producing ERROR
level log messages. This patch treats such exceptions as "expected" during
normal operation and prevents them from crashing the actor. Rather, they are
logged at DEBUG level and the actor is actively and cleanly stopped.
 2013-06-20 10:22:47 +02:00
Mathias
f2ab463c4d io: fix TcpConnection acking empty writes which carry NoAck(...) markers 2013-06-20 10:11:10 +02:00
Patrik Nordwall
d3a91f9692 Merge pull request #1544 from akka/wip-3450-win-bind-patriknw 
tcp-reuse-addr off on windows, see #3450
 2013-06-20 00:57:30 -07:00
Patrik Nordwall
851cfd87ff Merge pull request #1543 from akka/wip-3452-public-MetricsCollector-patriknw 
Make akka.cluster.MetricsCollector public, see #3452
 2013-06-20 00:57:09 -07:00
Patrik Nordwall
13df99655b Merge pull request #1542 from akka/wip-3445-dispatcher-in-RemoteActorRefProvider-patriknw 
Use dispatcher from config with RARP, see #3445
 2013-06-20 00:56:42 -07:00
Patrik Nordwall
6376db3fcb Merge pull request #1540 from akka/wip-periodic-cluster-stats-patriknw 
Count vclock stats when published, not for each received gossip
 2013-06-20 00:56:09 -07:00
Viktor Klang
f333c7c345 #3457 - Adding proper type to TestFsmRef 2013-06-20 00:04:57 +02:00
Roland Kuhn
e14f22f2e3 rework LARS, see #3428 
- tasks are still enqueued without reading the clock
- in order to be resilient against timer thread over-sleeping the tasks
  are passed to the timer thread using an AbstractNodeQueue and the
  wheel itself is now private to the timer thread
- reuse queue Nodes along the way to minimize allocation costs

The problem with the old implementation was that the timer thread could
sleep too long, then wake up and run multiple buckets in quick
succession. Tasks enqueued just before that event could then get
executed basically immediately, i.e. before their allotted time.
 2013-06-19 15:28:23 +02:00
Viktor Klang
3a394ecda2 #3449 - Adding a new factory method for creating TestActorRefs in Java without having to specify a name. 2013-06-19 03:14:25 +02:00
Viktor Klang
e561999a85 #3438 - Adding support for non-static top-level classes in check constructors 2013-06-19 03:08:38 +02:00
Patrik Nordwall
80a43ff24b tcp-reuse-addr off on windows, see #3450 
* Pretty much a forward port of corresponding setting in Akka 2.1
 2013-06-18 15:52:33 +02:00