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

20028 commits

This branch
This branch
All branches
Author SHA1 Message Date
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
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
Johannes Rudolph
5d03902c5e Add flag to enable mutual certificate authentication for old Akka Remote SSL transport (#21748) 
* =rem #13874 further cleanup of SSLSettings / NettySSLSupport

* +rem #13874 allow requiring mutual authentication for old akka remote ssl transport
 2016-10-28 17:03:07 +02:00
Konrad Malawski
783d961142 reference.conf MUST end with newline (#21755) 2016-10-28 16:46:51 +02:00
Johannes Rudolph
c9854e4350 =pro merge ssl-config-akka from ssl-config project into akka-stream (#21551) 
This will fix the cyclic dependency issue between the ssl-config repo
and akka.

It would have been better if akka-stream would not require
these changes at all but com.typesafe.sslconfig.akka.AkkaSSLConfig is
part of the public interface of akka-stream's TLS stage. So, this
can only be fixed in the next major version.

Source code was copied over from the tree at commit
470fae76f3

See https://github.com/typesafehub/ssl-config/issues/47
 2016-10-28 16:41:26 +02:00
Konrad Malawski
0127d4f424 +str #18793 StageLogging that allows logger access in stages (#21696) 
* +str #18793 StageLogging that allows logger access in stages
Also, non ActorMaterializers can opt-into providing a logger here.

* +str #18794 add javadsl for StageLogging

* fix missing test method on compile only class
 2016-10-28 16:05:56 +02:00
Patrik Nordwall
b775db0be3 Merge pull request #21613 from akka/wip-21194-sharding-min-members-patriknw 
shard coordinator should wait until min-members regions registered, #21194
 2016-10-28 15:50:08 +02:00
Patrik Nordwall
141318e60a shard coordinator should wait until min-members regions registered, #21194 2016-10-28 15:49:21 +02:00
Patrik Nordwall
1ff1f5edee small test changes for Scala 2.12 (#21738) 2016-10-28 14:59:08 +02:00
Konrad Malawski
a0e2286b70 +doc #21668 better docs for configuring ssl (#21730) 
* +doc #21668 better docs for configuring ssl

* address some comments, need to address the rest
 2016-10-28 14:58:32 +02:00
Konrad Malawski
92671e6d98 +act,rem,str add SECURITY marker to logs (#21749) 
* +act,rem,str add SECURITY marker to logs

* Update TlsSpec.scala
 2016-10-28 14:52:17 +02:00
Patrik Nordwall
9be7df1527 send terminationMessage to singleton when leaving last, #21592 (#21654) 
* send terminationMessage to singleton when leaving last, #21592

* When leaving last node, i.e. no newOldestOption, the manager was
  just stopped. The change is to send the terminationMessage also
  in this case and wait until the singleton actor is terminated
  before stopping the manager.
* Also changed so that the singleton is stopped immediately when
  cluster has been terminated when last node is leaving, i.e.
  no newOldestOption. Previously it retried until maxTakeOverRetries
  before stopping.
* More comprehensive test of this scenario in ClusterSingletonManagerLeaveSpec

* increase test timeout
 2016-10-28 14:23:18 +02:00
Roland Kuhn
021c2cbfdd Scala 2.12 does not name mangle private fields (#21742) 
When we can emit a private field, no need to mangle its name

https://github.com/scala/community-builds/pull/317\#issuecomment-254931492
 2016-10-28 13:00:34 +02:00
Patrik Nordwall
84184fe1a2 Merge pull request #21727 from dragos/issue/misplaced-file 
Update package declaration to fit directory.
 2016-10-28 12:06:11 +02:00
Johannes Rudolph
ff78b84233 =rem #13874 cleanup SSLSettings (#21746) 2016-10-28 11:45:48 +02:00
ortigali
f104fea51f Add openLatch.reset to some tests #21719 2016-10-28 11:43:08 +05:00
Iulian Dragos
abf8b1155c Update package declaration to fit directory. 2016-10-27 18:03:34 +02:00
Björn Antonsson
3e55aa5555 Merge pull request #21737 from bantonsson/make-akka-scala-nightly-great-again 
Make the akka-scala-nightly project work as expected
 2016-10-27 17:21:47 +02:00
Johan Andrén
33ece118a8 New EventEnvelope including Offset rather than Long #21722 2016-10-27 15:32:10 +02:00
Konrad Malawski
3951cf4e68 +slf,act #21671 allow using Markers with LoggingAdapter (#21707) 
* +slf,act #21671 allow using Markers with LoggingAdapter

* +slf,act #21671 allow using Markers with LoggingAdapter

* improve compatibility

* add docs

* address review comments

* actually print the marker
 2016-10-27 15:07:59 +02:00