dprintf("%s #%u sent %ib %s:%x\n",
tintstr(),id_,(int)evbuffer_get_length(evb),peer().str(),
peer_channel_id_);
dprintf("%s #%u sent %ib %s:%x\n",
tintstr(),id_,(int)evbuffer_get_length(evb),peer().str(),
peer_channel_id_);
dprintf("%s #%u fsent %ib %s:%x\n",
tintstr(),id_,(int)evbuffer_get_length(evb),peer().str(),
peer_channel_id_);
dprintf("%s #%u fsent %ib %s:%x\n",
tintstr(),id_,(int)evbuffer_get_length(evb),peer().str(),
peer_channel_id_);
size_t evboriglen = evbuffer_get_length(evb);
#define return_log(...) { fprintf(stderr,__VA_ARGS__); evbuffer_free(evb); return; }
if (evbuffer_get_length(evb)<4)
size_t evboriglen = evbuffer_get_length(evb);
#define return_log(...) { fprintf(stderr,__VA_ARGS__); evbuffer_free(evb); return; }
if (evbuffer_get_length(evb)<4)
uint32_t mych = evbuffer_remove_32be(evb);
Sha1Hash hash;
Channel* channel = NULL;
if (mych==0) { // peer initiates handshake
if (evbuffer_get_length(evb)<1+4+1+4+Sha1Hash::SIZE)
return_log ("%s #0 incorrect size %i initial handshake packet %s\n",
uint32_t mych = evbuffer_remove_32be(evb);
Sha1Hash hash;
Channel* channel = NULL;
if (mych==0) { // peer initiates handshake
if (evbuffer_get_length(evb)<1+4+1+4+Sha1Hash::SIZE)
return_log ("%s #0 incorrect size %i initial handshake packet %s\n",
uint8_t hashid = evbuffer_remove_8(evb);
if (hashid!=SWIFT_HASH)
return_log ("%s #0 no hash in the initial handshake %s\n",
uint8_t hashid = evbuffer_remove_8(evb);
if (hashid!=SWIFT_HASH)
return_log ("%s #0 no hash in the initial handshake %s\n",
- return_log ("%s #0 hash %s unknown, requested by %s\n",tintstr(),hash.hex().c_str(),addr.str());
+ return_log ("%s #0 hash %s unknown, requested by %s\n",tintstr(),hash.hex().c_str(),fromi.str());
dprintf("%s #0 -hash ALL %s\n",tintstr(),hash.hex().c_str());
// Arno, 2012-02-27: Check for duplicate channel
dprintf("%s #0 -hash ALL %s\n",tintstr(),hash.hex().c_str());
// Arno, 2012-02-27: Check for duplicate channel
}
//fprintf(stderr,"CHANNEL INCOMING DEF hass %s is id %d\n",hash.hex().c_str(),channel->id());
} else { // peer responds to my handshake (and other messages)
mych = DecodeID(mych);
if (mych>=channels.size())
}
//fprintf(stderr,"CHANNEL INCOMING DEF hass %s is id %d\n",hash.hex().c_str(),channel->id());
} else { // peer responds to my handshake (and other messages)
mych = DecodeID(mych);
if (mych>=channels.size())
- return_log("%s invalid channel #%u, %s\n",tintstr(),mych,addr.str());
+ return_log("%s invalid channel #%u, %s\n",tintstr(),mych,fromi.str());
channel = channels[mych];
if (!channel)
return_log ("%s #%u is already closed\n",tintstr(),mych);
channel = channels[mych];
if (!channel)
return_log ("%s #%u is already closed\n",tintstr(),mych);
//dprintf("recvd %i bytes for %i\n",data.size(),channel->id);
bool wasestablished = channel->is_established();
//dprintf("recvd %i bytes for %i\n",data.size(),channel->id);
bool wasestablished = channel->is_established();
- dprintf("%s #%u peer %s recv_peer %s addr %s\n", tintstr(),mych, channel->peer().str(), channel->recv_peer().str(), addr.str() );
+ dprintf("%s #%u peer %s recv_peer %s addr %s\n", tintstr(),mych, channel->peer().str(), channel->recv_peer().str(), fromi.str() );