| Index: trunk/willow/src/willow/flowio.cc |
| — | — | @@ -193,7 +193,7 @@ |
| 194 | 194 | socket_sink::data_ready(char const *buf, size_t len, ssize_t &discard) |
| 195 | 195 | { |
| 196 | 196 | ssize_t wrote; |
| 197 | | - if ((wrote = _socket->write(buf + off, len - off)) == -1) { |
| | 197 | + if ((wrote = _socket->write(buf, len)) == -1) { |
| 198 | 198 | if (errno == EAGAIN) { |
| 199 | 199 | _sink_spigot->sp_cork(); |
| 200 | 200 | if (!_reg) { |
| — | — | @@ -239,7 +239,6 @@ |
| 240 | 240 | } |
| 241 | 241 | _sink_spigot->sp_cork(); |
| 242 | 242 | return sink_result_error; |
| 243 | | - break; |
| 244 | 243 | } |
| 245 | 244 | discard += wrote; |
| 246 | 245 | _counter += wrote; |