list_for_each(pos, &ps->conn_list) {
conn = list_entry(pos, struct p2pkp_conn_info, list);
- err = p2pkp_msgsend(ps->net_sock,
- &conn->sin, ps->buffer, ps->buffer_len);
+ err = p2pkp_msgsend(ps->net_sock, &conn->sin,
+ ps->buffer, bytes_read);
if (err < 0) {
ERROR("can't send first message");
goto out_conn;
lock_sock(sk);
/* TODO keep connections */
bytes_read = p2pkp_msgrecv(ps->net_sock, sin, ps->buffer, ps->buffer_len);
+ DEBUG("XXX: received %d bytes\n", bytes_read);
if (bytes_read > 0) {
bytes_written = p2pkp_write_in_file(file, ps->buffer, bytes_read);
err = 0;