Nemcio/meanTorrent
1
0
Fork 0
mirror of https://github.com/taobataoma/meanTorrent.git synced 2026-07-07 01:28:55 +02:00
Code Issues Packages Projects Releases Wiki Activity

opt(announce): optimization announce data

Browse Source
This commit is contained in:
OldHawk
2017-12-24 16:05:55 +08:00
parent db95092568
commit b694e1e6c4
2 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
modules/announce/server/controllers/announces.server.controller.js
View File

@@ -437,7 +437,6 @@ exports.announce = function (req, res) {
var lcount = getSelfLeecherCount();
var scount = getSelfSeederCount();
console.log('lcount=' + lcount + ', scount=' + scount);
if (lcount > announceConfig.announceCheck.maxLeechNumberPerUserPerTorrent && !req.seeder) {
mtDebug.debugYellow('getSelfLeecherCount = ' + lcount, 'ANNOUNCE_REQUEST');
removeCurrPeer();
@@ -543,7 +542,11 @@ exports.announce = function (req, res) {
}
}
//write peer last_announce_at time
//write peer data and last_announce_at time
req.currentPeer.peer_uploaded = query.uploaded;
req.currentPeer.peer_downloaded = query.downloaded;
req.currentPeer.peer_left = query.peer_left;
req.currentPeer.last_announce_at = Date.now();
req.currentPeer.update({
$set: {
peer_uploaded: query.uploaded,
@@ -551,7 +554,7 @@ exports.announce = function (req, res) {
peer_left: query.left,
last_announce_at: Date.now()
}
}).exec(function () {
}, function () {
req.currentPeer.globalUpdateMethod();
});
@@ -565,7 +568,7 @@ exports.announce = function (req, res) {
---------------------------------------------------------------*/
function (done) {
if (!req.currentPeer.isNewCreated) {
if (req.completeTorrent && req.completeTorrent.complete) {
if (req.completeTorrent && req.completeTorrent.complete && event(query.event) !== EVENT_COMPLETED) {
req.completeTorrent.total_seed_time += Date.now() - req.currentPeer.last_announce_at;
req.completeTorrent.update({
$inc: {total_seed_time: Date.now() - req.currentPeer.last_announce_at}

6
modules/torrents/server/models/peer.server.model.js
View File

@@ -106,9 +106,11 @@ PeerSchema.pre('save', function (next) {
/**
* globalUpdateMethod
*/
PeerSchema.methods.globalUpdateMethod = function () {
PeerSchema.methods.globalUpdateMethod = function (cb) {
this.refreshat = Date.now();
this.save();
this.save(function (err, p) {
if (cb) cb(p || this);
});
};
/**