- int r = SendTo(socket_,peer(),&evb);
- if (r==-1)
- print_error("can't send datagram");
- else
- raw_bytes_up_ += r;
- last_send_time_ = NOW;
- sent_since_recv_++;
- dgrams_sent_++;
- evbuffer_free(evb);
- Reschedule();
+
+ messageQueue.AddBuffer(socket_, evb, peer(), this);
+}
+
+void Channel::Sent(int bytes, evbuffer *evb, bool tofree)
+{
+ raw_bytes_up_ += bytes;
+ if (tofree) {
+ last_send_time_ = NOW;
+ sent_since_recv_++;
+ dgrams_sent_++;
+ evbuffer_free(evb);
+ Reschedule();
+ }