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

18667 commits

This branch
This branch
All branches
Author SHA1 Message Date
Jonas Bonér
bd244a4fd4 Fixed typo 2016-02-19 12:38:35 +01:00
Jonas Bonér
08d886f530 Added Learning Akka book 2016-02-19 12:37:54 +01:00
Konrad Malawski
f0a4805b03 Merge pull request #19812 from akka/wip-19774-implement-readN-√ 
=str - #19774 - Implements GSL.readN properly, with tests
 2016-02-18 12:52:00 +01:00
Konrad Malawski
b48b069fbd Merge pull request #19820 from 2m/wip-cross-full-custom-scala-version-2m 
Make CrossVersion.full work with custom scala versions
 2016-02-18 12:46:44 +01:00
Martynas Mickevičius
bd215f2844 Make CrossVersion.full work with custom scala versions 2016-02-18 11:15:24 +02:00
Viktor Klang
771111f40d =str - #19774 - Implements GSL.readN properly, with tests 2016-02-17 17:44:58 +01:00
drewhk
1200ff2df3 Merge pull request #19813 from akka/wip-unbreak-master-√ 
Unbreak master by fixing StreamFileDocSpec to import scaladsl._ iso io._
 2016-02-17 14:42:57 +01:00
Viktor Klang
b5516f6b93 Unbreak master by fixing StreamFileDocSpec to import scaladsl._ iso io._ 2016-02-17 14:03:20 +01:00
Bojan Petrovic
0bc04f3466 = str #19803 fix 1 element buffer handling 
* Sink.queue and Sink.actorRefWithAck can now handle one element input
  buffers
* Sink.queue now buffers as much upstream elements as declared in its
  InputBuffer attribute, instead of one less.
* Tests for streaming with full buffer now do not depend on default
  input buffer size (16); instead, they set sink input buffer size
  explicitly.
 2016-02-16 21:59:56 +01:00
Roland Kuhn
c91fa3545e Merge branch 'tmp' 2016-02-16 21:51:04 +01:00
Endre Sándor Varga
4ba4c27b0f splitting up TLS APIs 2016-02-16 21:49:35 +01:00
Roland Kuhn
fd800fe1ac Merge pull request #19807 from akka/wip-FixedSizeBuffer-wrap-RK 
Wip fixed size buffer wrap rk
 2016-02-16 21:31:21 +01:00
Roland Kuhn
03d0bce08a fix Balance internal buffer wrap-around, see #19806 2016-02-16 21:25:44 +01:00
Roland Kuhn
a1e7e87f38 fix Merge internal buffer wrap-around, fixes #19806 2016-02-16 21:25:44 +01:00
Roland Kuhn
bfe8d3bb31 fix FixedSizeBuffer wrap-around 2016-02-16 21:25:38 +01:00
Konrad Malawski
650e94ba30 Merge pull request #19802 from ktoso/wip-framing-made-proper-ktoso 
!str split Framing into javadsl and scaladsl
 2016-02-16 20:53:34 +01:00
Konrad Malawski
c24cac2b04 +doc add missing migration parts to java documentation 2016-02-16 19:57:03 +01:00
Roland Kuhn
8e5fabae0c Merge pull request #19800 from akka/wip-misc-doc-fixes-RK 
add new Streams Quick Start
 2016-02-16 19:27:18 +01:00
Konrad Malawski
c25e0abab6 !str split Framing into javadsl and scaladsl 2016-02-16 18:53:49 +01:00
Roland Kuhn
125c996fae add new Streams Quick Start 
also move IOResult to akka.stream package
 2016-02-16 18:14:32 +01:00
Konrad Malawski
5d3a8256c1 Merge pull request #19784 from akka/wip-bump-ssl-config-2.12.0-M3 
Prepare build for Scala 2.12.0-M3 release
 2016-02-16 16:31:54 +01:00
Konrad Malawski
a4e884503a Merge pull request #19797 from ktoso/wip-entity-raw-json-ktoso 
+doc #19796 explain how to obtain a JsValue using entity(as)
 2016-02-16 16:30:21 +01:00
Konrad Malawski
1143b27b89 +doc #19796 explain how to obtain a JsValue using entity(as) 2016-02-16 16:29:43 +01:00
Konrad Malawski
3c94805666 Merge pull request #19788 from ktoso/wip-connect-to-ktoso 
-htp #19577 replace overloads of bind with HttpConnect
 2016-02-16 15:07:09 +01:00
Roland Kuhn
d11d461805 Merge pull request #19753 from pvlugter/generate-versions 
Generate version files
 2016-02-16 13:56:54 +01:00
Roland Kuhn
2f9cc7d04f Merge pull request #19626 from MQ-EL/master 
=per #19551 support stash overflow strategy
 2016-02-16 13:50:40 +01:00
Konrad Malawski
00c64e5409 Prepare build for Scala 2.12.0-M3 release 
By bumping ssl-config to version released also for this version of Scala
 2016-02-16 13:42:18 +01:00
Konrad Malawski
ef827e6ef1 -htp #19577 replace overloads of bind with HttpConnect 2016-02-16 13:01:05 +01:00
Roland Kuhn
61a86556c6 Merge pull request #19794 from akka/wip-misc-doc-fixes-RK 
Wip misc doc fixes rk
 2016-02-16 12:58:04 +01:00
Roland Kuhn
67d5cc1471 remove requirement for module tag in commit message, fixes #19413 2016-02-16 11:56:29 +01:00
Roland Kuhn
f820d90061 document that GraphStage is a blueprint, fixes #19471 2016-02-16 11:50:56 +01:00
Roland Kuhn
0b77b0f853 add section about Java 8 APIs #19655 
This is not a complete documentation rewrite to put CompletionStage in
everywhere, that is some that is impossible to slot in right now.

fixes #19655
 2016-02-16 11:42:48 +01:00
Roland Kuhn
a25a0f0aa8 document that StreamConverters close their streams #19773 
fixes #19773
 2016-02-16 11:10:54 +01:00
prettynatty
5a5f52c047 expose file open options in FileIO.toFile #19635 2016-02-16 10:47:13 +01:00
Roland Kuhn
2bb45ce211 Merge pull request #19783 from ALPHA-60/fix-ignore-zero-sized-buffer 
=str #19781 Use overriden `InputBuffer` attribute
 2016-02-16 10:31:17 +01:00
Roland Kuhn
2b878be1c1 Merge branch 'wip-fixups-RK' 2016-02-16 10:19:38 +01:00
Roland Kuhn
73034d72ed Merge pull request #19778 from akka/wip-tidying-√ 
= - Minor cleanups, will get an appropriate commit message soon
 2016-02-16 09:59:20 +01:00
Roland Kuhn
6bd3b4effe Merge pull request #19768 from johanandren/wip-19735-do-not-use-push-pull-stage-in-examples-johanandren 
Documentation improvements
 2016-02-16 09:54:50 +01:00
Bojan Petrovic
b4f507cdd6 =str #19781 Use overriden InputBuffer attribute 
* Sink.{queue, actorRefWithAck} and StreamConverters.{asInputStream,
  asOutputStream} now use overriden/inherited `InputBuffer` attribute
* They now use their default attributes as initial attributes.
 2016-02-15 21:31:13 +01:00
Viktor Klang
365e6243b3 = - Minor cleanups, will get an appropriate commit message soon 2016-02-15 21:01:28 +01:00
Roland Kuhn
e1afb62cab Merge pull request #19779 from kazuhiro/issue-19775-filepublisher-multiple-eof-messages-in-logs 
=str #19775 FilePublisher should not report EOF multiple times
 2016-02-15 20:37:17 +01:00
Roland Kuhn
e202ea8c40 clean up dependencies #19755 and other fixes 
* remove inter-project dependencies between streamTestkit -> peristence -> remote
* make PartitionOutOfBoundsException extend IndexOutOfBoundsException
* some weird formatting
* remove -experimental from HTTP Testkit/Tests
* split out shared LevelDb journal tests into new subproject (not to be
  published)
 2016-02-15 20:35:37 +01:00
Johan Andrén
737991c01c Documentation improvements 
* Re enabling Java tests in akka-docs (they were not run before)
* Fixed bug #19764
* #19735 Rewrote every sample using the deprecated PushPullStage and friends
  using GraphStage
* Pruned old unused graph images
* Added missing graffle file for new graph images
 2016-02-15 19:33:05 +01:00
Roland Kuhn
8f3c5aa17f Merge pull request #19785 from 412b/fix-19766-gzip-streams-leak-412b 
GZipInputStream leaking off-heap memory
 2016-02-15 18:41:41 +01:00
Roland Kuhn
815dc2aa70 Merge pull request #19786 from akka/wip-docs-RK 
add statefulMapConcat to overview and fix links
 2016-02-15 18:39:30 +01:00
Roland Kuhn
d1b35e441e add statefulMapConcat to overview and fix links 2016-02-15 16:51:58 +01:00
Kirill Plyashkevich
35ffc49226 GZIPInputStream is not closed at all at places, where it's instantiated, which leads to off-heap memory leak with every deserialized message. 
GZIPInputStream uses Inflater internally (so also native zlib). Inflater frees up memory only on explicit call to end() or during finalization (finalize() contains only call to end()), so GZIPInputStream should always be explicitly closed.

As native libraries are used a non-scalaish try-finally is used to avoid off-heap memory leak for GZIPInputStream and GZIPOutputStream in case of exceptions.
 2016-02-15 16:15:05 +01:00
Konrad Malawski
10d3af1478 Merge pull request #19584 from cmbaxter/feature/xff-avoid-dns-cmbaxter 
!htt #19388 Removing use of InetAddress.getByName
 2016-02-15 13:29:50 +01:00
Piotr Jarzemski
d5f8186f05 =str #19775 FilePublisher should not report EOF multiple times 2016-02-15 10:05:36 +01:00
qian miao
952d768693 =per #19551 support stash overflow strategy 2016-02-15 15:27:15 +08:00