X-Git-Url: http://p2p-next.cs.pub.ro/gitweb/?a=blobdiff_plain;f=src%2Flibswift%2Fswift.h;h=1c5634a7b269fa2557b7a9a65fb731b7094d7108;hb=88fbecb49ce37e1003f51c87d5ac41f110ac5167;hp=3fac3904ed94e262d96e1963d90d8b7f7031d5f7;hpb=41816c4e73a12147ee2e83cdb869c9c76cf876ca;p=swifty.git diff --git a/src/libswift/swift.h b/src/libswift/swift.h index 3fac390..1c5634a 100644 --- a/src/libswift/swift.h +++ b/src/libswift/swift.h @@ -525,7 +525,7 @@ namespace swift { void OnHandshake (struct evbuffer *evb); void OnRandomize (struct evbuffer *evb); //FRAGRAND void AddHandshake (struct evbuffer *evb); - bin_t AddData (struct evbuffer *evb); + bin_t AddData (struct evbuffer **evb); void AddAck (struct evbuffer *evb); void AddHave (struct evbuffer *evb); void AddHint (struct evbuffer *evb); @@ -791,7 +791,7 @@ namespace swift { // Arno: Save transfer's binmap for zero-hashcheck restart void Checkpoint(int fdes); -#define MAX_QUEUE_LENGTH 10 +#define MAX_QUEUE_LENGTH 1 #define TIMER_USEC 100000 class MessageQueue @@ -845,13 +845,10 @@ namespace swift { } int r = Channel::SendTo(sock, addr, evbs); - printf("Sent %d buffers\n", list.size()); if (r > 0) { i = 0; - for (EntryList::iterator it = list.begin(); it != list.end(); ++it, ++i) { + for (EntryList::iterator it = list.begin(); it != list.end(); ++it, ++i) (*it).channel->Sent(evbuffer_get_length((*it).evb), (*it).evb, (*it).tofree); - printf("Sent %d bytes\n", addr.addr->dests[i].bytes); - } } list.clear(); }