29th October 2015, 13:41
|
Member
|
|
Join Date: Aug 2009
Posts: 7
|
|
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);
}
}
|