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

20046 commits

This branch
This branch
All branches
Author SHA1 Message Date
Konrad Malawski
5ca56a56eb =pro update Aeron to 1.0.4 2016-11-17 17:51:04 +01:00
Endre Sándor Varga
d7af58bafa Refactored TopHeavyHitters and added comments. Fixed small bug. 2016-11-17 17:37:01 +01:00
Johannes Rudolph
b4cfc3717f =str #21753 simplify TLSActor configuration by allowing to specify SSLEngine directly (#21822) 
Do all (Akka)SSLConfig magic in one place directly in the TLS API.

Also, introduce new low-level entrypoint in TLS that allows to specify
an SSLEngine constructor directly without relying on SSLContext. This
allows users to use third-party SSLEngine implementations like netty's
OpenSslEngine together with akka-stream.
 2016-11-17 16:07:24 +01:00
Johannes Rudolph
97bada7deb =act #21774 fix ByteString.toString to use fixed stringPrefix for all subclasses (#21775) 
Otherwise, with 2.12,

ByteString().toString == "ByteString.ByteString1C()"

which would expose implementation details in the string representation.
This can lead to failing tests due to test expecting a particular string
representation of a ByteString which might be bad practice, yes, but is also
convenient.

The change is due to a fix in Scala for SI-9019 for which the string representation
of TraversableLike was changed which ByteString inherits.
See https://github.com/scala/scala/pull/5258/files
 2016-11-17 15:51:36 +01:00
Martynas Mickevičius
ef75910872 Remove scalatest from OSGi sample (#21817) 2016-11-17 14:44:47 +01:00
Konrad Malawski
5df1cc52b0 Remove not needed type match in last clause in EventSourced 2016-11-17 14:11:34 +01:00
Nafer Sanabria
80d48ead5a per bugfix #21824 pass the message which cause restart in PersistentActor 2016-11-17 14:11:34 +01:00
Olli Helenius
163f0f9727 Fix formatting of plural ByteStrings in docs (#21792) 2016-11-17 12:31:44 +01:00
Patrik Nordwall
a7eed00948 Merge pull request #21813 from akka/wip-21518-patriknw 
minor cleanup of cluster.subscribe usage
 2016-11-16 21:33:02 +01:00
Patrik Nordwall
a55e84fbd6 Merge pull request #21811 from akka/wip-21718-ClusterShardingSpec-patriknw 
harden ClusterShardingSpec, #21718 and #21535
 2016-11-16 21:31:43 +01:00
Patrik Nordwall
aa142ef83b Merge pull request #21815 from akka/wip-21674-patriknw 
Handle early termination of system when starting logger, #21674
 2016-11-16 21:30:43 +01:00
Hawstein
96a1d2a081 rewrite Buffer as a GraphStage #21528 2016-11-15 18:48:33 +01:00
Patrik Nordwall
88a6bdb059 Cluster singleton testing (#21803) 
* add another singleton restart test

* remove from singleton sorted set with unique address

* because the upNumber used by the Ordering can change
 2016-11-11 15:10:30 -08:00
Patrik Nordwall
9c087d115e fix AgentDocTest (#21814) 2016-11-11 12:05:19 -08:00
Richard Imaoka
693cb6a58b Add resolveOneCS to ActorSelection for Java CompletionStage 21726 2016-11-11 17:21:17 +01:00
drewhk
2dd4ac1ef6 Workaround for #21475 until it is fully fixed. Makes snapshots thread-safe 2016-11-10 15:59:20 +01:00
drewhk
91b522e186 #21743: FlattenMerge should propagate outer attributes 
Added Materializer.materialize() version that takes explicit initial attributes
 2016-11-09 20:14:04 +01:00
Patrik Nordwall
4dd969c0ae remove template pattern in howto docs (#21808) 2016-11-09 20:13:19 +01:00
Patrik Nordwall
4f013a3d1e avoid infinite blocking in TcpConnectionSpec #21375 
* use socket timeout
* additional cleanup of socket utils
 2016-11-09 17:36:04 +01:00
Patrik Nordwall
cbcfbfbccd Handle early termination of system when starting logger, #21674 
* The IntroSpec terminates the system immediately via the root actor
  and when that happens before the logger is started the ask
  can't be scheduled.
 2016-11-08 19:37:08 +01:00
Patrik Nordwall
d9e873644e minor cleanup of cluster.subscribe usage 2016-11-08 15:14:52 +01:00
Patrik Nordwall
48e85953d9 harden ClusterShardingSpec, #21535 2016-11-08 14:01:23 +01:00
Patrik Nordwall
1bb8f1737f increase barrier-timeout in ClusterShardingSpec, #21718 
* In the logs of the failing test we can see that the first node is removed
  as expected and then come back in the membership, which is possible in
  case of conflicting membership state merge. It is supposed to be
  removed again by the auto-down. That doesn't happen within the barrier-timeout.
 2016-11-08 13:37:37 +01:00
Martynas Mickevičius
72925ba392 Publish dining hakkers deps to local maven repo (#21793) 2016-11-07 13:28:34 -08:00
Johan Andrén
519064f40f Added Java API and discoverable factory methods for Offset #21788 2016-11-07 16:37:49 +01:00
drewhk
5eed5d7d7a Merge pull request #21798 from liff/doc-add-RecoveryCompleted-note 
Add a note about RecoveryCompleted for new actors
 2016-11-07 15:37:04 +01:00
drewhk
3f112648f0 Merge pull request #21685 from johanandren/wip-21377-tcpspec-failed-johanandren 
Failing tcp spec fix
 2016-11-07 15:36:16 +01:00
drewhk
2a1e73ea50 Merge pull request #21797 from andy-hw-chung/wip-21794-fold-behaviour-on-supervisor-resume 
Fixed error handling behaviour of Fold and Reduce
 2016-11-07 15:07:45 +01:00
Andy Chung
fff707781e Took grab and pull out of try 2016-11-04 16:13:11 +00:00
Johan Andrén
4c0b66dac9 Bugfix #21770, NoSuchElementException with probe supervisor in TestActorRef (#21776) 2016-11-04 14:53:40 +01:00
Olli Helenius
9390519b09 Add a note about RecoveryCompleted for new actors 2016-11-04 15:32:24 +02:00
Andy Chung
a6a4d1ac7f Fixed error handling behaviour of Fold and Reduce 2016-11-04 10:38:35 +00:00
Alexander Gavrilov
20942b3126 Fix #21760 - Close Tls connection if Inbound closed before receiving peer's close_notify (#21786) 
When application closes inboud using engine.closeInbound the engine can generate an alert message and put it into writer.outboundList. As a result the engine can have a new data packet in outbound and its isOutboundDone will be false. We have to ensure that it will be flushed to the network, that's why we have to update lastHandshakeStatus via the actual status of the engine. Otherwise the actor will transition to the flushingOutbound state but will never flush outbound, since engineNeedsWrap precondition will be false.

Generally speaking whenever we signal something to the SSLEngine, weshould also read getHandshakeStatus afterwards to understand what we need to do next. This was done everywhere but for this engine.closeInbound.
 2016-11-04 11:00:13 +01:00
Johan Andrén
e9253c7c7d Changes needed to build/test/release for 2.12.0 (#21789) 2016-11-03 16:17:36 +01:00
Johan Andrén
8f0d1a3465 New authors-script for releasing (#21783) 2016-11-02 14:45:02 +01:00
Richard Imaoka
56a3718d00 Search box rendering issue in Firefox and IE (Fixes #21779) (#21784) 2016-11-02 11:36:14 +01:00
Patrik Nordwall
9cb7839829 fix enable-additional-serialization-bindings docs (#21769) 
* the config block was not shown
* also fixed several other mistakes
 2016-11-01 18:00:29 +01:00
Johan Andrén
512baeab24 Merge pull request #21778 from bantonsson/make-akka-tests-pass-on-scala-2.12 
* =act Test that serialization works instead of that the bytes match #21771
* =rem Don't try to serializa null file names in stack traces #21772
* =act Ignore some line number tests on Scala 2.12 #21773

* =act,rem Clean up some test serialization issues for Scala 2.12
 2016-11-01 17:53:52 +01:00
Patrik Nordwall
43f3999ca4 Merge pull request #21764 from Silv3rcircl3/patch-2 
fix little typo
 2016-11-01 16:28:06 +01:00
Björn Antonsson
de47178eb5 =act,rem Clean up some test serialization issues for Scala 2.12 2016-11-01 11:55:15 +01:00
Björn Antonsson
53b9a2650c =act Ignore some line number tests on Scala 2.12 #21773 2016-11-01 11:55:15 +01:00
Björn Antonsson
2080c08e36 =rem Don't try to serializa null file names in stack traces #21772 2016-11-01 11:54:51 +01:00
Patrik Nordwall
b233b6a675 Merge pull request #21744 from ortigali/wip-21719-CircuitBreakerSpec 
Add openLatch.reset to some tests
 2016-11-01 07:37:46 +01:00
Cédric Chantepie
d60d68dfa2 Fix #21711 - foldAsync test using mapAsync 2016-10-31 18:22:07 +01:00
Björn Antonsson
d2552128cb =act Test that serialization works instead of that the bytes match #21771 2016-10-31 15:40:47 +01:00
Patrik Nordwall
61dd7f6e35 Merge pull request #21766 from bantonsson/log-warning-should-be-log-warnings 
=act Fix warning log that was published as error #21765
 2016-10-31 12:28:45 +01:00
Björn Antonsson
ca684e9beb =act Fix warning log that was published as error #21765 
Fixes #21765
 2016-10-31 10:26:16 +01:00
Marc Piechura
c09e10337b fix little typo 2016-10-30 20:54:09 +01:00
Konrad Malawski
2a6e62a13b Remove accidentally re-added akka-http files (#21759) 2016-10-28 18:45:44 +02:00
Konrad Malawski
45d53bd520 fix mima warnings (#21756) 2016-10-28 17:22:36 +02:00