View Single Post
  #9  
Old 29th October 2015, 13:41
Zsolti88 Zsolti88 is offline
Member
 
Join Date: Aug 2009
P2P
Posts: 7
Default duplicate peer
Unfortunately, the problem persists esettleg could someone help me?
Image:
http://www.kephost.com/images/2015/10/27/ggggg.png




db.cpp


Code:


void mysql::flush_peers() {
    std::string sql;
    boost::mutex::scoped_lock lock(peer_buffer_lock);
    // because xfu inserts are slow and ram is not infinite we need to
    // limit this queue's size
    if (peer_queue.size() >= 1000) {
        peer_queue.pop();
    }
    if (update_peer_buffer == "") {
        return;
    }
    
    if (peer_queue.size() == 0) {
        sql = "SET session sql_log_bin = 0";
        peer_queue.push(sql);
        sql.clear();
    }
    
    // Added port below to record it into the DB. //Mobbo
    sql = "INSERT INTO xbt_files_users (uid,fid,active,uploaded,downloaded,upspeed,downspeed,remaining," +
        std::string("timespent,announced,ip,port,peer_id,useragent,mtime) VALUES ") + update_peer_buffer + 
                " ON DUPLICATE KEY UPDATE active=VALUES(active), uploaded=VALUES(uploaded), " +
                "downloaded=VALUES(downloaded), upspeed=VALUES(upspeed), " +
                "downspeed=VALUES(downspeed), remaining=VALUES(remaining), " +
                "timespent=VALUES(timespent), announced=VALUES(announced), " + 
                "mtime=VALUES(mtime), port=VALUES(port)";
    peer_queue.push(sql);
    update_peer_buffer.clear();
    if (peer_queue.size() == 2 && p_active == false) {
        boost::thread thread(&mysql::do_flush_peers, this);
    }
}
Reply With Quote