Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions src/channels/channel_peer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -278,6 +278,9 @@ void channel_peer::handle_read_payload(const code& ec, size_t payload_size,
}
}

LOGX("Recv " << head->command << " from [" << endpoint() << "] ("
<< payload_size << " bytes)");

// Notify subscribers of the new message.
///////////////////////////////////////////////////////////////////////////
// TODO: hack, move into peer::body::reader.
Expand Down Expand Up @@ -310,9 +313,6 @@ void channel_peer::handle_read_payload(const code& ec, size_t payload_size,
payload_buffer_.shrink_to_fit();
}

LOGX("Recv " << head->command << " from [" << endpoint() << "] ("
<< payload_size << " bytes)");

read_heading();
}

Expand Down
18 changes: 0 additions & 18 deletions src/net/proxy.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -328,24 +328,6 @@ void proxy::handle_write(const code& ec, size_t bytes,
// All handlers must be invoked, so continue regardless of error state.
// Handlers are invoked in queued order, after all outstanding complete.
write();

if (ec)
{
// Linux reports error::connect_failed when peer drops here.
if (ec != error::peer_disconnect && ec != error::operation_canceled &&
ec != error::connect_failed)
{
// BUGBUG: payload changed from data_chunk_ptr to const_buffer.
// TODO: messages dependency, move to channel.
////LOGF("Send failure " << heading::get_command(*payload) << " to ["
//// << endpoint() << "] (" << payload->size() << " bytes) "
//// << ec.message());
}

handler(ec, {});
return;
}

handler(ec, bytes);
}

Expand Down
Loading