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

20577 commits

This branch
This branch
All branches
Author SHA1 Message Date
Patrik Nordwall
22dedd1ffa Merge pull request #22565 from johanandren/wip-fix-mat-dep-warning-johanandren 
A few warnings fixed
 2017-03-16 20:33:07 +01:00
Maciej Ciołek
f60710b58f Handlers for circuit breaker (#22244) 
* Adding call handlers to CircuitBreaker

* Improvements to docs

* Make System.nanoTIme called as latest as it is possible

* Java naming conversion changed, previous Java methods marked as deprecated

* Code reformated
 2017-03-16 20:05:16 +01:00
Martynas Mickevičius
2a9c0370e0 Add @InternalApi annotations and private markers on internal apis (#22563) 
* #22506 Mark materializer extension as @InternalApi

* #22506 Added missing annotations on internal apis in the fusing package

* #22506 Missing annotations in io package

* #22506 Add internal api annotations in impl package

* #22563 more hiding of the classes in the impl package

* #22563 Formatting fixes

* #22506 Fix private access in stream tcl tests
 2017-03-16 20:04:07 +01:00
Hawstein
6434cbe868 Re-implement javadsl testkit (#22240) 
* re-implement javadsl testkit

* fix mima problem

* rebase master

* move ImplicitSender/DefaultTimeout to scaladsl

* undo the change of moving scala api

* fix return type and add doc

* resolve conflicts and add more comments
 2017-03-16 20:02:47 +01:00
Johan Andrén
3643f18ded Protobuf serializers for remote deployment #22332 2017-03-16 15:12:35 +01:00
Patrik Nordwall
3e4f44765c Merge pull request #22574 from bantonsson/fix-indentation-master 
Fix indentation diffs
 2017-03-16 14:12:29 +01:00
Björn Antonsson
c9518244ce Fix indentation diffs 2017-03-16 11:28:28 +01:00
Patrik Nordwall
6414aaccbc small change in method dispatch that seems to impact bench results (#22564) 2017-03-16 10:27:59 +01:00
Konrad `ktoso` Malawski
addbed15d7 =doc #19661 document purpose and limits of akka scheduler (#22334) 
* =doc #19661 document purpose and limits of akka scheduler

* Update scheduler.rst

* Update scheduler.rst

* Update Scheduler.scala
 2017-03-16 10:21:24 +01:00
Björn Antonsson
2573a02f10 Consolidate various message buffer implementations 2017-03-16 10:00:29 +01:00
Johan Andrén
2eb226ed32 ActorContext.getParent for Java API #22413 2017-03-16 09:30:00 +01:00
Patrik Nordwall
5ff44194a3 Merge pull request #22570 from jrudolph/jr/w/22568-mark-ResumeReading-with-DeadLetterSuppression 
=act #22568 mark ResumeReading with DeadLetterSuppression
 2017-03-15 20:28:56 +01:00
Johan Andrén
d51f7abd63 Give a good error message on unassigned ports #22552 2017-03-15 18:03:52 +01:00
Johannes Rudolph
c4899bda9a =str #22124 enable DEBUG logging for TlsSpec to find cause of failures 2017-03-15 16:49:20 +01:00
Johannes Rudolph
e915a16dbc =act #22568 reduce spurious ResumeReading log messages 
ResumeReading will likely end up in DeadLetters when the connection is
torn down at the same time as the user tries to read more data from the
connection.

For the same reason ResumeReading may arrive in peerSentEOF state. We
ignore it here to get rid of "unhandled message from Actor ... : ResumeReading"
warnings.

This will remove the spurious warnings in these cases.
 2017-03-15 16:48:20 +01:00
Patrik Nordwall
e4a09c207f Merge pull request #22480 from manonthegithub/wip-22446-fix-merge-preferred-ordering 
#22446 fixed corruption of ordering in MergePreferred
 2017-03-15 16:21:30 +01:00
Patrik Nordwall
6b5b819c73 Merge pull request #22378 from akka/wip-delta-in-direct-write-patriknw 
Use delta in direct write also, #22188
 2017-03-15 16:19:29 +01:00
Johannes Rudolph
70253fab3f Merge pull request #22559 from jrudolph/jr/w/22554-fix-CCE-in-SubSink 
=str #22554 fix ClassCastException in SubSink
 2017-03-15 15:26:18 +01:00
Johan Andrén
fca07bb976 Deprecated build symbols replaced 2017-03-15 15:01:53 +01:00
Johan Andrén
39199b877a Fix some build and compile warnings 2017-03-15 14:26:41 +01:00
Johannes Rudolph
5b9295b3f0
=str #22554 fix ClassCastException in SubSink 
Fixes #22554.
 2017-03-15 12:07:52 +01:00
Patrik Nordwall
233e784154 Use delta in direct write also, #22188 
* Follow up on the causal delivery of deltas.
* The first implementation used full state for the direct
  Write messages, i.e. updates with WriteConsistency != LocalWrite
* This is an optimization so that delatas are tried first and if
  they can't be applied it falls back to full state.
* For simultanious updates the messages may be reordered because we
  create separate WriteAggregator actor and such, but normally they
  will be sent in order so the deltas will typically be received in
  order, otherwise we fall back to retrying with full state in the
  second round in the WriteAggregator.
 2017-03-15 11:38:44 +01:00
Johan Andrén
3f0c23e2da Fail framing stage if length field is less than 0 #22367 2017-03-15 11:13:13 +01:00
Johan Andrén
60d918c490 Deprecate auto-fusing setting #22431 2017-03-15 09:15:18 +01:00
Kirill Yankov
5704c72ece fixed corruption of ordering in MergePreferred caused by using emit() with emit in andThen() callback #22446 2017-03-14 23:42:48 +03:00
Johannes Rudolph
c5076a3b9a =str formatting fix 2017-03-14 17:22:48 +01:00
Johan Andrén
740c68873c Scalacheck min max range could become max min and fail the test. (#22400) 2017-03-14 14:55:35 +01:00
Richard Imaoka
cc1312922c Allow multiple Cluster JMX MBeans in the same JVM (#22484) 
* Allow multiple Cluster JMX MBeans in the same JVM (#18772)

* Remove unnecessary whitespace
 2017-03-14 14:31:58 +01:00
Sergey
ba213b7fee GroupedWithin cold emit fix (#22407) 
* groupedWithin cold emit fix

* lowered numbers in tests; removed meaningless assertions
 2017-03-14 13:45:45 +01:00
A Andrievsky
d91fe59566 Suggest using 64bit JVM for Artery in docs (#22553) 
* Suggest using 64bit JVM fo Artery (#1)

* Suggest using 64bit JVM fo Artery

https://github.com/akka/akka/issues/22303

* changed acording to suggestions

* Update scala part of the documentation
 2017-03-14 13:31:54 +01:00
Richard Imaoka
ea9617aa25 Update Persistence Snapshot documentation (#22419) 
* Update Persistence Snapshot documentation (#22233)

* Use copy of ExampleState as it is mutable
 2017-03-14 13:30:32 +01:00
Patrik Nordwall
e77c3c3e8a Merge pull request #22551 from akka/wip-lazy-TraversalBuilder-patriknw 
remove lazy from TraversalBuilder field
 2017-03-14 13:29:49 +01:00
ortigali
db0a473cd5 use CompletionStage instead of Future in java doc classes (#22472) 
* use CompletionStage instead of Future in FactorialBackend.java #22393

* use CompletionStage instead of Future in FactorialBackend.java #22393 2
 2017-03-14 11:51:44 +01:00
Patrik Nordwall
eaf50405ab Merge pull request #22534 from ortigali/wip-22460-actor-selection-spec 
FAILED ActorSelectionSpec
 2017-03-14 11:34:54 +01:00
toaditoad
a569aebc9d Documentation note for large-message-frame-size (#22519) 
* Added to docs that large-message-frame-size is restricted to 1/8th of aeron.term.buffer.length #22257

* Fixed grammar
 2017-03-14 11:22:04 +01:00
Patrik Nordwall
f12594849b Merge pull request #22454 from jlprat/actors-mutable-state-docs-fix 
Move inlined example to its own class #22453
 2017-03-14 11:19:31 +01:00
Patrik Nordwall
eb5262f292 Merge pull request #22408 from athieriot/remove-implicit-in-test 
Remove unecessary implicit in test
 2017-03-14 10:46:01 +01:00
Patrik Nordwall
293c5c0b01 remove lazy from TraversalBuilder field 2017-03-14 07:35:06 +01:00
Aurélien Thieriot
25df5c08e4 Remove unecessary implicit in test 2017-03-13 21:16:04 +00:00
Martynas Mickevičius
11c513fda7 Merge pull request #22542 from 2m/wip-resize-mat-connections-2m 
#22429 Resize connections array when needed
 2017-03-13 19:43:50 +02:00
Johan Andrén
1e6b8ec86b Make sure the hashcode is not negative when selecting key chunk #22487 2017-03-13 17:57:03 +01:00
Johan Andrén
7a0e5b31f8 Avoid Array.ofDim where possible #22516 2017-03-13 17:49:45 +01:00
Martynas Mickevičius
9550e34394 #22429 Use Arrays.copy instead of scala builder 2017-03-13 14:52:56 +02:00
Johan Andrén
5ea2e0536c Remove superflous ownerId fields in interpreter Connection #22447 2017-03-13 12:42:49 +01:00
Konrad `ktoso` Malawski
205a538df3 =act,str Port be-scala-2.13-friendly (#22528) 
* !str #22527 fix SubSource/SubFlow.zip Pair type

* =act don't use conforms, be scala 2.13 friendly

* Update SubFlow.scala
 2017-03-13 12:39:57 +01:00
Patrik Nordwall
5138b8f587 Merge pull request #22544 from johanandren/wip-22543-make-jenkins-your-friend-note-johanandren 
Note that you must be a public member of akka org to trigger builds
 2017-03-13 10:34:37 +01:00
Johan Andrén
4f291d1725 Note that you must be a public member of akka org to trigger builds #22543 2017-03-13 10:19:15 +01:00
Johannes Rudolph
d5660acb64 Merge pull request #22513 from jrudolph/jr/w/remove-most-asInstanceOfs-in-TraversalBuilder 
Small improvements to TraversalBuilder
 2017-03-13 09:43:55 +01:00
Patrik Nordwall
5ec5ad4ae0 Merge pull request #22536 from sebastianharko/master 
Docs: fix some small grammar / usage issues in the Logging section
 2017-03-13 09:08:51 +01:00
Martynas Mickevičius
4bb283b458 #22429 Resize connections array when needed 2017-03-13 09:49:25 +02:00