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

14559 commits

This branch
This branch
All branches
Author SHA1 Message Date
Konrad Malawski
0c659cd923 Merge pull request #17318 from ktoso/wip-fix-reference-conf-ktoso 
=act #17316 fix wrong setting in pinned-disp reference.conf
 2015-05-07 10:08:05 +02:00
Patrik Nordwall
5c7235acbd Merge pull request #17366 from akka/wip-17365-RemoteGatePiercing-patriknw 
=rem #17365 Add missing barrier in RemoteGatePiercingSpec
 2015-05-05 11:29:00 +02:00
Patrik Nordwall
31003ffcb2 =rem #17365 Add missing barrier in RemoteGatePiercingSpec 2015-05-04 09:59:21 +02:00
Konrad Malawski
920dc48109 Merge pull request #17347 from akka/revert-17343-wip-17342-bc-patriknw 
Revert "= #17342 Make 2.4 binary compatible with 2.3"
 2015-04-30 13:11:48 +02:00
Konrad Malawski
6f9b36e3a0 Revert "= #17342 Make 2.4 binary compatible with 2.3" 2015-04-30 13:09:27 +02:00
Konrad Malawski
86ed216ded Merge pull request #17343 from akka/wip-17342-bc-patriknw 
= #17342 Make 2.4 binary compatible with 2.3
 2015-04-30 13:09:23 +02:00
Patrik Nordwall
89af8bdb90 = #17342 Make 2.4 binary compatible with 2.3 2015-04-30 09:27:55 +02:00
Konrad Malawski
251b925375 =act #17316 fix wrong setting in pinned-disp reference.conf 2015-04-27 11:08:56 +02:00
Patrik Nordwall
93d7c0493d Merge pull request #17272 from akka/wip-17240-deadletter-supression-master-patriknw 
= #17240 Use some more DeadLetterSuppression (for validation)
 2015-04-23 07:13:04 +02:00
Patrik Nordwall
573e97c003 Merge pull request #17270 from akka/wip-17213-wrong-assertion-in-endpoint-manager-master-patriknw 
=rem #17213: Remove wrong assertion from EndpointManager (for validation)
 2015-04-23 07:12:28 +02:00
Patrik Nordwall
c1d14f1887 = #17240 Use some more DeadLetterSuppression 
* sysmsg.Terminate, sysmsg.DeathWatchNotification, io.Tcp.Closed
  were needed to silence normal usage of http client/server
* other things based on jenkins logs, but not a complete audit

(cherry picked from commit 270e3b2f49af3c34fd5ea4c3bcfd8257402b5cbe)
 2015-04-22 21:40:23 +02:00
Patrik Nordwall
acd8ea96b6 Merge pull request #17262 from akka/wip-17216-DirectByteBufferPool-locking-master-patriknw 
=act #17216 fix DirectByteBufferPoll locking (for validation)
 2015-04-22 21:37:24 +02:00
Patrik Nordwall
e89d145764 Merge pull request #17260 from akka/wip-17200-stop-when-removed-master-patriknw 
=str #17200 Stop shard region when MemberRemoved (for validation)
 2015-04-22 21:24:04 +02:00
Patrik Nordwall
e0d4230193 Merge pull request #17256 from akka/wip-17255-tmp-disable-broken-workaround-master-patriknw 
=act #17255 Temporary disable windows-connection-abort-workaround (for validation)
 2015-04-22 21:22:14 +02:00
Endre Sándor Varga
1a6f7cc44c =rem #17213: Remove wrong assertion from EndpointManager 
(cherry picked from commit 5b6085664ba2d69cd3f5662c1f4b21c417e4afb1)
 2015-04-22 21:09:49 +02:00
Roland Kuhn
4528ef8c45 =act #17216 fix DirectByteBufferPoll locking 
instead of spinning unboundedly use ReentrantLock.tryLock—it is a best
effort pool anyway and contention shall not lock the whole application

(cherry picked from commit 518fedb33c22c69deae019090d4236c9c5175fb5)
 2015-04-22 12:52:18 +02:00
Patrik Nordwall
c991d5f1d1 =str #17200 Stop shard region when MemberRemoved 
Two issues:

1) ShardRegion actor must stop itself when the node is shutting down,
   ie. when receiving MemberRemoved(selfAddress)
2) ShardCoordinator must not persist anything when the node is shutting
   down. MemberRemoved of other shard regions will trigger Terminated,
   which must not be persisted, because then the next coordinator will
   replay those events and end up in wrong state. This is a problem
   announced itself when using leaving as illustrated in the new test.

To solve the second issue I have added a new ClusterShuttingDown event
that is published before the MemberRemoved events. Note that Terminated
is triggered by MemberRemoved.

(cherry picked from commit 1b272c72597beece9d93f0054f4b58e3d25f9ae2)
 2015-04-22 12:46:30 +02:00
Roland Kuhn
5f08653bb8 Merge pull request #17237 from hepin1989/fix-#13516 
+act #13516 add getByteString and getBytes method with a given length
 2015-04-22 11:05:40 +02:00
Patrik Nordwall
580904a5ae Merge pull request #17205 from akka/wip-16346-socket-leak-patriknw 
=rem #16346 Close connection after refused connection attempt
 2015-04-22 10:51:31 +02:00
Patrik Nordwall
e75f43c53e =act #17255 Temporary disable windows-connection-abort-workaround 
(cherry picked from commit 5d557261082421dda234ad37656d6940252158af)
 2015-04-22 10:30:58 +02:00
hepin
e0f06fdee7 +act #13516 add getByteString and getBytes method with a given length 2015-04-21 14:33:48 +08:00
Roland Kuhn
db8d02ff06 Merge pull request #17201 from hepin1989/fix-#15898 
#15898 change ActorPath to abstract class to make the methods in the com...
 2015-04-20 21:24:43 +02:00
Roland Kuhn
630a80eaad Merge pull request #17215 from hepin1989/fix-17168 
=act #17168 avoid copy in Props for the same mailbox or dispatcher
 2015-04-20 21:08:26 +02:00
hepin
665ad9e424 =act #17168 avoid copy in Props for the same mailbox or dispatcher 2015-04-20 20:15:25 +08:00
Patrik Nordwall
234f9c46cf Merge pull request #17209 from akka/wip-17169-ReliableProxySpec-patriknw 
=con #17169 Add missing barrier in ReliableProxySpec
 2015-04-17 11:35:26 +02:00
hepin
e6aea0b7d1 #15898 change ActorPath to abstract class to make the methods in the companion usable in java 2015-04-17 10:12:20 +08:00
Roland Kuhn
ff6a2c9ef5 switch README from textile to markdown and freshen it up 2015-04-16 22:10:32 +02:00
Roland Kuhn
559ff0eed8 Merge pull request #17207 from akka/wip-17206-document-stop-self-∂π 
=act #17206 properly document semantics of context.stop(self)
 2015-04-16 08:37:26 +02:00
Roland Kuhn
baf63d37f0 =act #17206 properly document semantics of context.stop(self) 2015-04-15 16:35:31 +02:00
Patrik Nordwall
ca526232e1 =con #17169 Add missing barrier in ReliableProxySpec 2015-04-15 14:17:49 +02:00
Patrik Nordwall
0d403311b2 =rem #16346 Close connection after refused connection attempt 2015-04-15 13:46:44 +02:00
Patrik Nordwall
05b841eee5 Merge pull request #17204 from akka/wip-16141-get-subscribers-of-mediator-patriknw 
+con #16141 Add GetTopics message to DistributedPubSubMediator providing list of topics
 2015-04-15 13:08:26 +02:00
Benjamin Poserow
8d6b899be8 +con #16141 Add GetTopics message to DistributedPubSubMediator providing list of topics 2015-04-15 11:29:28 +02:00
Roland Kuhn
2bb208297d Merge pull request #17154 from akka/wip-13869-cluster-singleton-speedup-patriknw 
=con #13869 Speedup startup of Cluster singleton
 2015-04-14 21:24:45 +02:00
Patrik Nordwall
b205800f63 Merge pull request #17180 from akka/wip-doc-singleton-role-patriknw 
=doc Clarify cluster singleton role
 2015-04-14 17:12:57 +02:00
Patrik Nordwall
2ecfa42801 =con #13869 Speedup startup of Cluster singleton 
* avoid the hand-over/take-over attempts when starting the
  ClusterSingletonManager for the normal clase when the cluster is
  in a good shape, i.e. no exiting member that might run previous
  singleton instance
 2015-04-14 16:21:25 +02:00
Patrik Nordwall
a12bca1b15 =doc Clarify cluster singleton role 2015-04-13 10:07:14 +02:00
Patrik Nordwall
a93cce7bf4 Merge pull request #17178 from akka/wip-15914-max-received-message-size-master-patriknw 
=act #15914 Clarify and correct max-received-message-size (for validation)
 2015-04-13 09:57:56 +02:00
Patrik Nordwall
f1437b8754 Merge pull request #17155 from akka/wip-17151-RemoteNodeRestartGateSpec-patriknw 
=rem #17151 Add missing barrier in RemoteNodeRestartGateSpec
 2015-04-13 08:06:40 +02:00
Patrik Nordwall
dc54fa08a2 =act #15914 Clarify and correct max-received-message-size 
(cherry picked from commit c8c07e7a9f8aa4a9b65a9a75e3eb29ea24a99f1f)
 2015-04-13 08:03:10 +02:00
Konrad Malawski
437e64500c Merge pull request #17152 from ktoso/wip-forMaxOverride-FSM-ktoso 
=act #17140 FSM: forMax(Inf) can now override stateTimeout
 2015-04-09 17:34:39 +02:00
Konrad Malawski
bdedb1039f =act #17140 FSM: forMax(Inf) can now override stateTimeout 2015-04-09 17:32:18 +02:00
Roland Kuhn
76717c9e47 Merge pull request #17134 from romusz/150402-romusz-expand-scheduler-doc 
Expand the documentation of Scheduler
 2015-04-09 10:58:51 +02:00
Patrik Nordwall
863920db48 =rem #17151 Add missing barrier in RemoteNodeRestartGate 2015-04-08 15:28:16 +02:00
Patrik Nordwall
ea2219950d Merge pull request #17147 from akka/wip-17080-move-socketutils-master-patriknw 
=tes #17080 Move TestUtils to testkit.SocketUtil (for validation)
 2015-04-08 13:03:56 +02:00
Konrad Malawski
8ad51fba39 Merge pull request #17144 from colinrgodsey/15170-bytestringser-2 
ByteString serialization
 2015-04-08 11:44:03 +02:00
Patrik Nordwall
79e7fe22de =tes #17080 Move TestUtils to testkit.SocketUtil 
(cherry picked from commit 3df2a822efa7e1330d564ceea7506d606359e17c)

Conflicts:
	akka-actor-tests/src/test/scala/akka/actor/ActorPerfSpec.scala
	akka-actor-tests/src/test/scala/akka/io/UdpIntegrationSpec.scala
	akka-durable-mailboxes/akka-file-mailbox/src/main/scala/akka/actor/mailbox/filebased/filequeue/Journal.scala
	akka-testkit/src/main/scala/akka/testkit/SocketUtil.scala
 2015-04-08 08:21:38 +02:00
Colin Godsey
1984a76195 =act #15170 bytestring serialization 2015-04-07 09:34:21 -05:00
Konrad Malawski
8d34880dff Merge pull request #17050 from ktoso/wip-actor-path-errors-impr-ktoso 
+act #17012 improve err msg on invalid actor name/path
 2015-04-07 11:05:38 +02:00
Konrad Malawski
c31469dd29 +act #17012 improve err msg on invalid actor name/path 
Resolves #17012
 2015-04-07 11:04:54 +02:00