From 542d34f452955f79f895691592fba3ea28f888a7 Mon Sep 17 00:00:00 2001 From: Victor Grishchenko Date: Thu, 4 Feb 2010 23:17:04 +0100 Subject: [PATCH] #0 logging --- sendrecv.cpp | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/sendrecv.cpp b/sendrecv.cpp index a174b0f..68784e4 100644 --- a/sendrecv.cpp +++ b/sendrecv.cpp @@ -486,7 +486,7 @@ Channel* Channel::RecvDatagram (int socket) { Datagram data(socket); data.Recv(); const Address& addr = data.address(); -#define return_log(...) { eprintf(__VA_ARGS__); return NULL; } +#define return_log(...) { printf(__VA_ARGS__); return NULL; } if (data.size()<4) return_log("datagram shorter than 4 bytes %s\n",addr.str()); uint32_t mych = data.Pull32(); @@ -494,32 +494,35 @@ Channel* Channel::RecvDatagram (int socket) { Channel* channel = NULL; if (!mych) { // handshake initiated if (data.size()<1+4+1+4+Sha1Hash::SIZE) - return_log ("incorrect size %i initial handshake packet %s\n",data.size(),addr.str()); + return_log ("%s #0 incorrect size %i initial handshake packet %s\n", + tintstr(),data.size(),addr.str()); uint8_t hashid = data.Pull8(); if (hashid!=SWIFT_HASH) - return_log ("no hash in the initial handshake %s\n",addr.str()); + return_log ("%s #0 no hash in the initial handshake %s\n", + tintstr(),addr.str()); bin64_t pos = data.Pull32(); if (pos!=bin64_t::ALL) - return_log ("that is not the root hash %s\n",addr.str()); + return_log ("%s #0 that is not the root hash %s\n",tintstr(),addr.str()); hash = data.PullHash(); FileTransfer* file = FileTransfer::Find(hash); if (!file) - return_log ("hash %s unknown, no such file %s\n",hash.hex().c_str(),addr.str()); + return_log ("%s #0 hash %s unknown, no such file %s\n",tintstr(),hash.hex().c_str(),addr.str()); dprintf("%s #0 -hash ALL %s\n",tintstr(),hash.hex().c_str()); for(binqueue::iterator i=file->hs_in_.begin(); i!=file->hs_in_.end(); i++) if (channels[*i] && channels[*i]->peer_==data.address() && channels[*i]->last_recv_time_>NOW-TINT_SEC*2) - return_log("have a channel already to %s\n",addr.str()); + return_log("%s #0 have a channel already to %s\n",tintstr(),addr.str()); channel = new Channel(file, socket, data.address()); } else { mych = DecodeID(mych); if (mych>=channels.size()) - return_log("invalid channel #%u, %s\n",mych,addr.str()); + return_log("%s invalid channel #%u, %s\n",tintstr(),mych,addr.str()); channel = channels[mych]; if (!channel) - return_log ("channel #%u is already closed\n",mych,addr.str()); + return_log ("%s #%u is already closed\n",tintstr(),mych,addr.str()); if (channel->peer() != addr) - return_log ("invalid peer address #%u %s!=%s\n",mych,channel->peer().str(),addr.str()); + return_log ("%s #%u invalid peer address %s!=%s\n", + tintstr(),mych,channel->peer().str(),addr.str()); channel->own_id_mentioned_ = true; } //dprintf("recvd %i bytes for %i\n",data.size(),channel->id); -- 2.20.1