Commit graph

19 commits

Author SHA1 Message Date
Johannes Rudolph
fd05cad103 TcpConnection: use pattern matching 2013-04-09 11:24:55 +02:00
Johannes Rudolph
1b95f65cf4 io: handle half-closed connection when peer closed first
This allows to send data back to the peer even if the peer already has sent
EOF/FIN as specified for TCP. To fully close a connection, the handler has
to close its side of the connection now actively once it is finished with
writing even if it received a `PeerClosed` message before.
2013-04-09 11:24:55 +02:00
Roland Kuhn
7a8dbda95d Merge pull request #1294 from spray/tcp-connection-immediate-Received-message
TcpConnection: forward received data to handler immediately without concatenating buffers
2013-04-08 11:00:39 -07:00
Roland Kuhn
22968a3ab8 Merge pull request #1281 from spray/master
Smaller improvements to TCP side of new akka-io implementation
2013-04-04 02:47:35 -07:00
Mathias
c43ce95bd4 Small simplification in TcpConnection 2013-04-04 11:39:37 +02:00
Mathias
1790bc0e1a TcpOutgoingConnection: Respond with CommandFailed rather than ErrorClosed on failed connect
Before, a Tcp.ErrorClosed event is generated when a connection attempt fails. For symmetry with the Tcp.Bind case and general usability of the API a Tcp.CommandFailed(connect) is the better choice.
2013-04-04 11:39:37 +02:00
Mathias
854d0feef7 Make use of new command.failureMessage 2013-04-04 11:39:37 +02:00
Johannes Rudolph
fc6b7830a9 TcpConnection: forward received data to handler immediately without concatenating buffers
For these reasons:

 - pipeline effect will allow to start processing on the first part of the
   data immediately in parallel
 - data in `Received` messages is now always a simple ByteStrings which will
   improve iteration speed in the next layer
 - code becomes simpler
2013-04-03 16:10:49 +02:00
Viktor Klang
c883705242 #3018 - Enabling -Xlint and dealing with the situation that occurs 2013-03-29 01:43:17 +01:00
Endre Sándor Varga
852afeb565 Set TCPNODELAY as default. 2013-03-13 13:42:04 +01:00
Roland
80825d2433 fix TcpConnection’s PendingWrite.wantsAck 2013-02-15 14:29:37 +01:00
Roland
6d61a59a0f add INTERNAL API markers and explicit return types 2013-02-15 13:11:35 +01:00
Endre Sándor Varga
e9da097621 Fixed according to revew comments 2013-02-10 13:52:52 +01:00
Endre Sándor Varga
91d798cee1 Updated tests to work (or be disabled) on Win 2013-02-06 17:52:49 +01:00
Endre Sándor Varga
98a707bd57 Fixed temporarily disabled StopReading operation 2013-02-05 13:38:27 +01:00
Endre Sándor Varga
1ec065b0cd Factored out common manager code and SocketOptions 2013-02-05 11:48:47 +01:00
Endre Sándor Varga
946fb0eec4 Removed WithByteBuffer and friends 2013-02-04 16:24:34 +01:00
Endre Sándor Varga
8b4a3b0b92 Another LIMBO commit, but TCP now uses the unified selector 2013-02-01 13:11:17 +01:00
Roland
a964843843 move akka-io project into akka-actor’s akka.io package 2013-01-30 09:30:59 +01:00
Renamed from akka-io/src/main/scala/akka/io/TcpConnection.scala (Browse further)