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

19712 commits

This branch
This branch
All branches
Author SHA1 Message Date
Patrik Nordwall
95328b2882 Merge pull request #21342 from akka/wip-compression-versions-patriknw 
harden receive of messages using wrong compression table
 2016-09-05 14:22:39 +02:00
Patrik Nordwall
e92088119e Merge pull request #21356 from akka/wip-21347-lazy-restart-patriknw 
make restart materialization of outbound streams lazy, #21347
 2016-09-05 14:22:11 +02:00
Patrik Nordwall
32e852596f harden receive of messages using wrong compression table 2016-09-05 13:29:08 +02:00
Patrik Nordwall
9d89810674 make restart materialization of outbound streams lazy, #21347 
* Materialize on first message instead, otherwise handshake attempts
  to non-existing nodes will continue forever

* also fix HandshakeFailureSpec
 2016-09-05 13:27:18 +02:00
Patrik Nordwall
c504258356 Merge pull request #21328 from akka/wip-21207-parallel-lanes-patriknw 
support for parallel lanes, #21207
 2016-09-05 13:15:44 +02:00
Patrik Nordwall
432086b3f4 improve deadLetters and logging when send queue overflow (#21355) 2016-09-05 12:42:46 +02:00
Patrik Nordwall
faf941b4c8 support for parallel lanes, #21207 
* for parallel serialziation/deserialization
* MergeHub for the outbound lanes
* BroadcastHub + filter for the inbound lanes, until we
  have a PartitionHub
* simplify materialization of test stage
* add RemoteSendConsistencyWithThreeLanesSpec
 2016-09-05 12:42:33 +02:00
Johan Andrén
3d3a3528bf Eliminated JVM crashing race on transport stop (#21337) 
* Eliminated JVM crashing race on transport stop

* Fail explicitly if started more than once
 2016-09-02 15:40:38 +01:00
Konrad Malawski
888ffa5f06 +art enable compression for manifests (#21211) (#21333) 2016-09-02 08:52:09 +01:00
Martynas Mickevičius
292face28a #20587 Clean artery configuration (#21279) 
* Move artery settings from remoting settings to dedicated class.
* #20587 Move hardcoded settings to configuration file.
* Copy reused settings from remote to the artery
 2016-09-01 08:07:39 +02:00
Patrik Nordwall
b2eaa854e8 Merge pull request #21327 from akka/wip-update-aeron 
=pro update aeron to 1.0.1
 2016-08-31 12:40:26 +02:00
Konrad Malawski
ed05a77f9c =pro update aeron to 1.0.1 
Changes are https://github.com/real-logic/Aeron/releases/tag/1.0.1 :

> * Adjust incremental cleaning to avoid overwrite of cleaned log in loss scenarios to address Issue #271.
> * Correctly initialise cleaning position for late joining a stream. Issue #268.
> * Make clientLivenessTimeout configurable from Context.
> * Shadow samples into aeron-all JAR.
> * Support creating Agent threads via ThreadFactory to enable pinning.
> * Update to Agrona 0.5.4.
> * Update to ByteBuddy 1.4.20.
 2016-08-31 10:09:07 +01:00
Patrik Nordwall
3c4508d9b5 Merge pull request #21325 from akka/wip-sync-artery-dev-patriknw 
sync artery with latest master (2.4.9++)
 2016-08-31 10:06:19 +02:00
Patrik Nordwall
90cce8579a Merge branch 'master' into wip-sync-artery-dev-patriknw 2016-08-31 08:59:49 +02:00
Patrik Nordwall
2bc25bff17 Merge pull request #21320 from johanandren/wip-21229-persistent-actor-failure-spec-race-johanandren 
Race in PersistentActorFailureSpec removed
 2016-08-30 19:43:39 +02:00
Patrik Nordwall
a95b2d6746 fail fast in mapAsync for completed failed future, #21318 (#21322) 
* fail fast in mapAsync for completed failed future, #21318

* the callback was not run until todo == parallelism or the sync
  event limit was reached, and that can be a problem if upstream
  stages are slow (noticed this for a blocking Kafka producer stage)

* skip callback for completed futures

* fix callback allocation
 2016-08-30 19:30:08 +02:00
Johan Andrén
e20d6f5f36 More generous timeout directive spec timeout #20278 2016-08-30 15:04:21 +02:00
Johan Andrén
b3cfd1c0ed Race in PersistentActorFailureSpec removed #21229 2016-08-30 14:46:51 +02:00
Johan Andrén
012919fdb3 OrElse stage for fallback when no elements emitted #21024 2016-08-30 13:35:59 +02:00
Johan Andrén
fbfc8b4c58 Http internal One2OneBidi pulling closed port #20944 2016-08-30 12:50:12 +02:00
Konrad Malawski
8c98d6cd74 * -htc remove proxy settings because not implemented (#21288) 2016-08-30 10:37:17 +01:00
Richard Imaoka
ec7d6a6998 Expose success and fail methods in CircuitBreaker #18347 2016-08-30 11:09:19 +02:00
Johan Andrén
faf717591b =htc Response rendering spec hardening #21088 (#21245) 
A bit more time between the always-close and the guess-that-the-blueprint-closed timeouts
 2016-08-30 09:38:17 +01:00
drewhk
f062687a0e Merge pull request #21259 from drewhk/wip-20933-recoverWith-nondetached-drewhk 
#20933: Make RecoverWith non-detached (also eliminates race in test)
 2016-08-30 10:38:00 +02:00
Patrik Nordwall
359a087674 Merge pull request #21166 from naferx/sink-graphstage 
=str rewrite Sink internal impl as GraphStage
 2016-08-30 10:37:30 +02:00
Martynas Mickevičius
8f183a04fb Merge pull request #21315 from 2m/wip-scaladex-deps 
Add badge to Scaladex search for projects depending on Akka
 2016-08-30 11:31:11 +03:00
Patrik Nordwall
10e2216ea3 Merge pull request #21280 from akka/wip-21210-compression-patriknw 
Refactoring of outbound compression, #21210
 2016-08-30 10:00:17 +02:00
Martynas Mickevicius
3e43b7fb55 Add badge to Scaladex search for Akka Actor, Stream and Http dependencies. 2016-08-30 01:59:19 +03:00
Johan Andrén
f760b98e8c Use in-memory filesystem for the file sink and source #20726 2016-08-29 16:33:33 +02:00
Johan Andrén
bc09e610f6 =per Log more info when recovery fails #20728 (#21313) 2016-08-29 13:20:48 +01:00
Cédric Chantepie
324a40ba97 =str Refactoring to avoid distinct handler instantiation for stage logics (#21309) 
* Refactoring to avoid distinct handler instantiation for stage logics

* setHandlers
 2016-08-29 13:00:48 +01:00
Konrad Malawski
fb45dd03f3 =act #21237 fix regression in ByteString.slice (#21294) 
* =act #21237 fix regression in ByteString.slice

* Update ByteStringSpec.scala
 2016-08-29 09:38:09 +01:00
2beaucoup
9ef93c6200 =htp change extract to provide (#21302) 2016-08-28 12:57:24 +01:00
dyk
0e302d2236 =htp Extract RemoteAddress.Unknown when cannot find client ip (#21289) 
* handle unknown client ip

* updated doc

* fixed java dsl test
 2016-08-26 15:47:36 +01:00
Patrik Nordwall
3e86c2a44f Merge pull request #21299 from akka/wip-2.12-patriknw 
add `override` for scala/scala#5331
 2016-08-26 15:40:19 +02:00
Patrik Nordwall
0c0e3c5efd Refactoring of outbound compression, #21210 
* outbound compression is now immutable, by simply using
  CompressionTable[ActorRef] and CompressionTable[String]
* immutable outbound compression will make it possible to use
  them from multiple Encoder instances, when we add several lanes
  for parallel serialization
* outbound compression tables not shared via AssociationState
* the advertised tables are sent to the Encoder stage via async
  callback, no need to reference the tables in other places than
  the Encoder stage, no more races via shared mutable state
* when outbound stream is started or restarted it can start out
  without compression, until next advertisement is received
* ensure outbound compression is cleared before handshake is signaled complete
 2016-08-26 15:21:03 +02:00
Johan Andrén
af5eb4c6bf WIP separate prio artery channel (#21278) 
* First incorrect stab - separate prio channel

* Send prio messages over the control stream
 2016-08-26 14:44:33 +02:00
Adriaan Moors
95f43c55cd add override for scala/scala#5331 2016-08-26 13:43:12 +02:00
Jamie Longmuir
440848c741 Add warning to Akka DD docs about freq add/deletes of top-level entit… (#21269) 
* Add warning to Akka DD docs about freq add/deletes of top-level entities - fixes #21249
 2016-08-25 16:47:58 +02:00
Cédric Chantepie
efc87af58a FoldAsync op for Flow #18603 2016-08-24 21:02:32 +02:00
kenji yoshida
9630feb6cc =htc remove unnecessary asInstanceOf (#21275) 2016-08-24 13:55:03 +02:00
drewhk
67d0d2a4e3 Merge pull request #21183 from drewhk/wip-20890-stream-hub-drewhk 
Stream Hubs
 2016-08-24 13:33:02 +02:00
Patrik Nordwall
bcd12f9816 minor cleanup of WildcardIndex 2016-08-24 13:01:09 +02:00
kenji yoshida
4cf9e6969d =doc fix link in CONTRIBUTING.md (#21274) 2016-08-24 12:52:58 +02:00
Endre Sándor Varga
bc358f3188 20890 Added MergeHub and BroadcastHub 2016-08-24 11:43:24 +02:00
Patrik Nordwall
51bb330d2f Merge pull request #21268 from akka/wip-sync-artery-dev-2.4.9-patriknw 
sync artery-dev with master (2.4.9+)
 2016-08-24 11:21:23 +02:00
Bernard Leach
ac8c4dc1b1 +Doc #20192 update http example to always consume response (#21241) 
The single-request-in-actor-example does not consume the response
in where the status code is not OK.  Although this is unlikely
to cause backpressure issues as the response is likely to have
a HttpEntity.Strict entity, the example is confusing as it
does not follow the warning about always consuming the response.
 2016-08-24 11:16:08 +02:00
Paweł Motyl
57fdc758ce +htp Add javadsl Query.create(Iterable) overload #21232 (#21265) 
* Added the Query.create(Iterable) overload using StreamSupport;
* Added a test for the new overload.
 2016-08-24 11:13:05 +02:00
Patrik Nordwall
bc5e62a02c Merge pull request #21266 from akka/wip-areon-1.0-patriknw 
update to Aeron 1.0
 2016-08-23 20:53:11 +02:00
Patrik Nordwall
21a4899054 use the new WildcardIndex 2016-08-23 20:38:39 +02:00