Hi Rüdiger, I am doing some testing with akka-http and chunked encoding. I want to > investigate the backpressure behavior, so I am using curl with > --limit-rate 1k on the client side. I should I see backpressure when > using akka-http to send a HttpEntity.Chunked, right? >
Yes, you should. > > One thing I noticed is that all hell breaks loose when the connection > is closed from the client side (e.g. by interrupting curl using > Control-C). See below. Is that going to change with 1.0, or is there a > way to silence this? > It is just the onError signal caused by "connection reset by peer" propagating downwards, and all elements log it (which looks scary and is completely useless). We will remove this logging completely, there is at least one ticket for that: https://github.com/akka/akka/issues/15349 > > Also, is the namespace for the scala dsl going to stay scaladsl**2**? > That would be weird. > No: https://github.com/akka/akka/pull/16154/ -Endre > > cheers, > > Rüdiger > > --- > > FINE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: Closing > connection due to IO error java.io.IOException: Connection reset by > peer, source: akka://Server/system/IO-TCP/selectors/$a/39class: class > akka.io.TcpIncomingConnection > WARNING: 2014/10/28 10:12:16:484: > > satmonjavaservices.server.SatmonJavaServices$$anonfun$1$$anon$4$$anonfun$receive$1: > > DeadLetter(ChannelReadable,Actor[akka://Server/deadLetters],Actor[akka://Server/system/IO-TCP/selectors/$a/39#-1098197434]) > SEVERE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure > during processing, source: > akka://Server/user/IO-HTTP/$a/flow-552-1-rootParserclass: class > akka.stream.impl.TransformProcessorImpl: > akka.stream.io.TcpStreamActor$TcpStreamException: The connection > closed with error Connection reset by peer > > WARNING: 2014/10/28 10:12:16:484: > > satmonjavaservices.server.SatmonJavaServices$$anonfun$1$$anon$4$$anonfun$receive$1: > > DeadLetter(Abort,Actor[akka://Server/system/IO-TCP-STREAM/server-1-%2F0.0.0.0%3A8888/$M#801209365],Actor[akka://Server/system/IO-TCP/selectors/$a/39#-1098197434]) > SEVERE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure > during processing, source: > akka://Server/user/IO-HTTP/$a/flow-552-2-splitWhenclass: class > akka.stream.impl2.SplitWhenProcessorImpl: > akka.stream.io.TcpStreamActor$TcpStreamException: The connection > closed with error Connection reset by peer > > SEVERE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure > during processing, source: > akka://Server/user/IO-HTTP/$a/flow-555-1-prefixAndTailclass: class > akka.stream.impl2.PrefixAndTailImpl: > akka.stream.io.TcpStreamActor$TcpStreamException: The connection > closed with error Connection reset by peer > > WARNING: 2014/10/28 10:12:16:484: > > satmonjavaservices.server.SatmonJavaServices$$anonfun$1$$anon$4$$anonfun$receive$1: > > DeadLetter(Terminate(),Actor[akka://Server/user/IO-HTTP/$a/flow-560-0-iterator#435212900],Actor[akka://Server/user/IO-HTTP/$a/flow-560-0-iterator#435212900]) > SEVERE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure > during processing, source: > akka://Server/user/IO-HTTP/$a/flow-552-3-mapclass: class > akka.stream.impl.TransformProcessorImpl: > akka.stream.io.TcpStreamActor$TcpStreamException: The connection > closed with error Connection reset by peer > > WARNING: 2014/10/28 10:12:16:484: > > satmonjavaservices.server.SatmonJavaServices$$anonfun$1$$anon$4$$anonfun$receive$1: > DeadLetter(Cancel(akka.stream.impl.ActorSubscription@4a9cf35 > ),Actor[akka://Server/deadLetters],Actor[akka://Server/user/IO-HTTP/$a/flow-552-4-concatFlatten#1535190045]) > SEVERE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure > during processing, source: > akka://Server/user/IO-HTTP/$a/flow-552-4-concatFlattenclass: class > akka.stream.impl2.ConcatAllImpl: > akka.stream.io.TcpStreamActor$TcpStreamException: The connection > closed with error Connection reset by peer > > SEVERE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure > during processing, source: > akka://Server/user/IO-HTTP/$a/flow-547-broadcastclass: class > akka.stream.impl2.Broadcast: > akka.stream.io.TcpStreamActor$TcpStreamException: The connection > closed with error Connection reset by peer > > SEVERE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure > during processing, source: > akka://Server/user/IO-HTTP/$a/flow-548-1-collectclass: class > akka.stream.impl.TransformProcessorImpl: > akka.stream.io.TcpStreamActor$TcpStreamException: The connection > closed with error Connection reset by peer > > SEVERE: 2014/10/28 10:12:16:484: > satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure > during processing, source: > akka://Server/user/$b/flow-554-1-mapAsyncUnorderedclass: class > akka.stream.impl2.MapAsyncUnorderedProcessorImpl: > akka.stream.io.TcpStreamActor$TcpStreamException: The connection > closed with error Connection reset by peer > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Search the archives: > https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
