1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
#ifndef NEWSBOAT_RELOADER_H_
#define NEWSBOAT_RELOADER_H_
#include <atomic>
#include <functional>
#include <mutex>
#include <vector>
#include "configcontainer.h"
#include "curlhandle.h"
namespace newsboat {
class Cache;
class Controller;
class CurlHandle;
/// \brief Updates feeds (fetches, parses, puts results into Controller).
class Reloader {
public:
Reloader(Controller* c, Cache* cc, ConfigContainer& cfg);
/// \brief Creates detached thread that runs periodic updates.
void spawn_reloadthread();
/// \brief Starts a thread that will reload feeds with specified
/// indexes.
///
/// If \a indexes is empty, all feeds will be reloaded.
void start_reload_all_thread(const std::vector<unsigned int>& indexes = {});
/// \brief Reloads given feed.
///
/// Reloads the feed at position \a pos in the feeds list (as kept by
/// feedscontainer). Only updates status bar if \a unattended is false.
void reload(unsigned int pos, bool unattended = false)
{
CurlHandle easyHandle;
reload(pos, easyHandle, false, unattended);
}
/// \brief Reloads all feeds, spawning threads as necessary.
///
/// Only updates status bar if \a unattended is false. The number of
/// threads spawned is controlled by the user via reload-threads
/// setting.
void reload_all(bool unattended = false);
private:
/// \brief Reloads all feeds with given indexes in feedlist.
///
/// Only updates status bar if \a unattended is false.
void reload_indexes(const std::vector<unsigned int>& indexes,
bool unattended = false);
void reload_indexes_impl(std::vector<unsigned int> indexes,
bool unattended);
/// \brief Reloads given feed.
///
/// Reloads the feed at position \a pos in the feeds list (as kept by
/// feedscontainer). \a show_progress specifies if a progress indicator
/// (`[<progress>/<total_feeds>]`) should be included when updating the status
/// message (at the bottom of the screen). Status messages are only shown
/// if \a unattended is false. All network requests are made through
/// \a easyhandle. If the handle is not provided, this method creates
/// a temporary handle which is destroyed before returning from it.
void reload(unsigned int pos,
CurlHandle& easyhandle,
bool show_progress,
bool unattended);
/// \brief Notify in various ways that there are new unread feeds or
/// articles.
///
/// The type of notification is based on "notify-screen", "notify-xterm",
/// "notify-beep" and "notify-program" settings chosen in Newsboat's config
/// file.
///
/// If "notify-screen", "notify-xterm" or "notify-program" is chosen, the
/// notification will contain \a msg passed.
void notify(const std::string& msg);
void notify_reload_finished(unsigned int unread_feeds_before,
unsigned int unread_articles_before);
void unlock_reload_mutex()
{
reload_mutex.unlock();
}
bool trylock_reload_mutex();
void partition_reload_to_threads(
std::function<void(unsigned int start, unsigned int end)> handle_range,
unsigned int num_feeds);
Controller* ctrl;
Cache* rsscache;
ConfigContainer& cfg;
std::mutex reload_mutex;
std::atomic<unsigned int> reload_progress;
unsigned int reload_progress_max;
};
} // namespace newsboat
#endif /* NEWSBOAT_RELOADER_H_ */
|
