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

20606 commits

This branch
This branch
All branches
Author SHA1 Message Date
gosubpl
dfbf50538e fixed serialization of RemoveKey 2017-03-21 09:43:33 +02:00
Patrik Nordwall
cc7065601a fix serialization of delta ops, #22604 2017-03-21 09:43:27 +02:00
Patrik Nordwall
45f4727625 Merge pull request #22594 from johanandren/wip-22541-update-docs-johanandren 
Java style accessors for AbstractFSM
 2017-03-17 13:18:20 +01:00
Patrik Nordwall
389dcba314 Merge pull request #22595 from akka/wip-spawnAdapter-2.12-patriknw 
rename spawnAdapter due to Scala 2.12 compilation error
 2017-03-17 13:17:53 +01:00
Patrik Nordwall
191bd0fe41 =str #22584 make subfusing work if diff materialize() is called 
Also: removed unecessary method with wrong name, #22350
 2017-03-17 12:42:13 +01:00
Patrik Nordwall
d871b63990 rename spawnAdapter due to Scala 2.12 compilation error 
* and make scaladoc happy ForkJoinPool.ForkJoinWorkerThreadFactory
 2017-03-17 11:27:13 +01:00
Patrik Nordwall
ef3b0f7444 Merge pull request #22586 from akka/wip-22295-circuit-breaker-improvement2-patriknw 
22295 Allow user define what is failure in terms on circuit breaker
 2017-03-17 10:28:19 +01:00
Patrik Nordwall
edee6ae544 Merge pull request #22508 from gosubpl/wip/22350-delta-crdt-orset-friends 
ORMap and friends are delta-CRDTs (#22350)
 2017-03-17 10:27:52 +01:00
Johan Andrén
07e88300bc Java style accessors for AbstractFSM #22592 2017-03-17 10:26:37 +01:00
ortigali
363ca39f52 AbstractPersistentFSM should have getContext, getSelf, getSender #22541 2017-03-17 09:27:15 +01:00
gosubpl
1f2ef60174 ORMap and friends have deltas (#22350) 2017-03-17 02:47:50 +01:00
Patrik Nordwall
cdc1eddc3b Merge pull request #22577 from akka/wip-typed-IntroSpec-patriknw 
add Akka Typed Java API #22293
 2017-03-16 22:28:22 +01:00
Patrik Nordwall
bece5e3fd0 Merge pull request #22560 from akka/wip-18262-fjp-patriknw 
Embed FJP
 2017-03-16 22:25:39 +01:00
Patrik Nordwall
f485be2bf5 Let typed Stateful optionally handle signals also, #22293 
* and thereby no need for MessageOrSignal
 2017-03-16 20:55:50 +01:00
Patrik Nordwall
ef62a88072 mima filters and note in migration guide 2017-03-16 20:49:01 +01:00
Patrik Nordwall
0904da1a85 Make FJP SPINS configurable with System.property, default 256 2017-03-16 20:49:01 +01:00
Patrik Nordwall
7e3376eb5f scala 2.11 FJP 2017-03-16 20:49:01 +01:00
Patrik Nordwall
569175ac62 Improve ForkJoinActorBenchmark 
* more messages in flight

* additional cleanup
 2017-03-16 20:48:55 +01:00
Johan Andrén
57bce6ad1f Benchmark for actor throughput with FJP #18262 
1-to-1 actor per core bench, avoiding to spend time in string equals
 2017-03-16 20:45:10 +01:00
Patrik Nordwall
c3c058b6bb Merge pull request #22360 from johanandren/wip-21363-future-source-last-bit-johanandren 
Source that flattens a future source and keeps mat val
 2017-03-16 20:36:05 +01:00
Patrik Nordwall
6274af63dd Merge pull request #22580 from johanandren/wip-missed-java-doc-path-updates-johanandren 
Updates to paths in the Java docs missed in #22413
 2017-03-16 20:33:30 +01:00
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
Qingwei
c879c03679 22295 Allow user define what is failure in terms on circuit breaker 
Revert all unnecessary style changes

Add api for java

Make exceptionsAsFailure function private

Exclude changed method api for binary compatibility check

- The changes expand the api by overload, thus is backward compatible
 2017-03-16 20:31:38 +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
Johan Andrén
ad0fd1320f Updates to paths in the Java docs missed in #22413 2017-03-16 15:11:02 +01:00
Patrik Nordwall
b2b4f64d97 convert typed IntroSpec to new API, #22293 2017-03-16 14:51:19 +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
Roland Kuhn
4368bed37a add Akka Typed Java API #22293 
... and matching Scala DSL, to replace the old ScalaDSl._ object.
 2017-03-16 11:52:30 +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