wornvirtue
/
premiere-libtorrent
forked from premiere/premiere-libtorrent
1
0
Fork 0
Code Pull Requests Activity

simplify client_test shutdown and make it keep logging as saving resume data

This commit is contained in:
arvidn 2016-03-02 00:53:32 -05:00
parent b9ec183e24
commit 2e7e679eed
1 changed files with 4 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
examples/client_test.cpp
View File

@ -2287,11 +2287,6 @@ int main(int argc, char* argv[])
} }
} }
// keep track of the number of resume data
// alerts to wait for
int num_paused = 0;
int num_failed = 0;
ses.pause(); ses.pause();
printf("saving resume data\n"); printf("saving resume data\n");
std::vector<torrent_status> temp; std::vector<torrent_status> temp;
@ -2334,38 +2329,12 @@ int main(int argc, char* argv[])
for (std::vector<alert*>::iterator i = alerts.begin() for (std::vector<alert*>::iterator i = alerts.begin()
, end(alerts.end()); i != end; ++i) , end(alerts.end()); i != end; ++i)
{ {
torrent_paused_alert* tp = alert_cast<torrent_paused_alert>(*i); if (!::handle_alert(ses, *i, files, non_files))
if (tp)
{ {
++num_paused; // if we didn't handle the alert, print it to the log
printf("\rleft: %d failed: %d pause: %d " std::string event_string;
, num_outstanding_resume_data, num_failed, num_paused); print_alert(*i, event_string);
continue;
} }
if (alert_cast<save_resume_data_failed_alert>(*i))
{
++num_failed;
--num_outstanding_resume_data;
printf("\rleft: %d failed: %d pause: %d "
, num_outstanding_resume_data, num_failed, num_paused);
continue;
}
save_resume_data_alert* rd = alert_cast<save_resume_data_alert>(*i);
if (!rd) continue;
--num_outstanding_resume_data;
printf("\rleft: %d failed: %d pause: %d "
, num_outstanding_resume_data, num_failed, num_paused);
if (!rd->resume_data) continue;
torrent_handle h = rd->handle;
torrent_status st = h.status(torrent_handle::query_save_path);
std::vector<char> out;
bencode(std::back_inserter(out), *rd->resume_data);
save_file(path_append(st.save_path, path_append(".resume"
, leaf_path(hash_to_filename[st.info_hash]) + ".resume")), out);
} }
} }