evan/rats-search
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

более редкий вызов обновлений

Browse Source
This commit is contained in:
Alexey Kasyanchuk
2017-01-19 19:52:21 +03:00
parent 671c836e24
commit 354cb5afd4
1 changed files with 21 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/recent-torrents.js
View File

@ -167,9 +167,11 @@ export default class RecentTorrents extends Component {
constructor() {
super()
this.torrents = [];
this.torrentsAssoc = {};
this.displayQueue = [];
this.displayQueueAssoc = {};
this.maxDisplaySize = 1000;
this.maxQueueSize = 1000;
this.maxDisplaySize = 10;
this.state = {
pause: false,
searchingIndicator: false
@ -201,15 +203,26 @@ export default class RecentTorrents extends Component {
let torrent = this.displayQueue.shift();
this.torrents.unshift(torrent);
if(this.torrents.length > 10) {
this.torrentsAssoc[torrent.hash] = torrent;
if(this.torrents.length > this.maxDisplaySize) {
let toDelete = this.torrents.pop()
delete this.torrentsAssoc[toDelete.hash];
delete this.displayQueueAssoc[toDelete.hash];
}
this.displayTorrentCounterValue = this.displayQueue.length;
this.forceUpdate();
setTimeout(this.displayNewTorrent, speed);
}
this.displayNewTorrent();
this.displayTorrentCounterValue = 0;
this.displayTorrentCounter = setInterval(() => {
if(this.displayTorrentCounterValue != this.displayQueue.length) {
this.displayTorrentCounterValue = this.displayQueue.length;
this.forceUpdate();
}
}, 40);
}, () => {
this.setState({
searchingIndicator: true
@ -220,10 +233,9 @@ export default class RecentTorrents extends Component {
});
}));
this.newTorrentFunc = (torrent) => {
if(this.displayQueue.length < this.maxDisplaySize) {
if(this.displayQueue.length < this.maxQueueSize) {
this.displayQueue.push(torrent);
this.displayQueueAssoc[torrent.hash] = torrent;
this.forceUpdate();
}
};
window.torrentSocket.on('newTorrent', this.newTorrentFunc);
@ -232,9 +244,11 @@ export default class RecentTorrents extends Component {
if(statistic.hash in this.displayQueueAssoc)
{
Object.assign(this.displayQueueAssoc[statistic.hash], statistic);
if(statistic.hash in this.torrentsAssoc) {
this.forceUpdate();
}
}
}
window.torrentSocket.on('trackerTorrentUpdate', this.tracketUpdate);
}
pauseAndContinue() {
@ -249,6 +263,8 @@ export default class RecentTorrents extends Component {
window.torrentSocket.off('trackerTorrentUpdate', this.tracketUpdate);
if(this.displayNewTorrent)
delete this.displayNewTorrent;
if(this.displayTorrentCounter)
clearInterval(this.displayTorrentCounter);
}
render() {
const style = {