diff options
| -rw-r--r-- | btpd/net.c | 43 | ||||
| -rw-r--r-- | btpd/net.h | 2 |
2 files changed, 0 insertions, 45 deletions
diff --git a/btpd/net.c b/btpd/net.c index 493b280..3030ddb 100644 --- a/btpd/net.c +++ b/btpd/net.c @@ -113,34 +113,6 @@ nb_create_set(short type, char *buf, size_t len, nb_hold(nb); return nb; } -#if 0 -void -net_unsend_piece(struct peer *p, struct piece_req *req) -{ - struct nb_link *nl; - struct iob_link *piece; - - BTPDQ_REMOVE(&p->p_reqs, req, entry); - - piece = BTPDQ_NEXT(req->head, entry); - BTPDQ_REMOVE(&p->outq, piece, entry); - piece->kill_buf(&piece->iob); - free(piece); - - BTPDQ_REMOVE(&p->outq, req->head, entry); - req->head->kill_buf(&req->head->iob); - free(req->head); - free(req); - - if (BTPDQ_EMPTY(&p->outq)) { - if (p->flags & PF_ON_WRITEQ) { - BTPDQ_REMOVE(&btpd.writeq, p, wq_entry); - p->flags &= ~PF_ON_WRITEQ; - } else - event_del(&p->out_ev); - } -} -#endif void kill_shake(struct input_reader *reader) @@ -869,21 +841,6 @@ net_connection_cb(int sd, short type, void *arg) } void -net_by_second(void) -{ - struct peer *p; - struct torrent *tp; - int ri = btpd.seconds % RATEHISTORY; - - BTPDQ_FOREACH(tp, &btpd.cm_list, entry) { - BTPDQ_FOREACH(p, &tp->peers, cm_entry) { - p->rate_to_me[ri] = 0; - p->rate_from_me[ri] = 0; - } - } -} - -void net_bw_rate(void) { unsigned sum = 0; diff --git a/btpd/net.h b/btpd/net.h index 2dc377a..25c3c21 100644 --- a/btpd/net.h +++ b/btpd/net.h @@ -128,6 +128,4 @@ void net_write_cb(int sd, short type, void *arg); int net_connect2(struct sockaddr *sa, socklen_t salen, int *sd); int net_connect(const char *ip, int port, int *sd); -void net_unsend_piece(struct peer *p, struct piece_req *req); - #endif |