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
|
#ifndef NEWSBOAT_RELOADER_H_
#define NEWSBOAT_RELOADER_H_
#include <mutex>
#include <vector>
#include "configcontainer.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<int>& indexes = {});
void unlock_reload_mutex()
{
reload_mutex.unlock();
}
bool trylock_reload_mutex();
/// \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
/// (`[<pos>/<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, unless it is a nullptr, in which case this method creates
/// a temporary handle which is destroyed before returning from it.
void reload(unsigned int pos,
bool show_progress = false,
bool unattended = false);
void reload(unsigned int pos,
CurlHandle& easyhandle,
bool show_progress = false,
bool unattended = false);
/// \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);
/// \brief Reloads all feeds with given indexes in feedlist.
///
/// Only updates status bar if \a unattended is false.
void reload_indexes(const std::vector<int>& indexes,
bool unattended = false);
/// \brief Reloads feeds occupying positions from \a start to \a end in
/// feedlist.
///
/// Only updates status bar if \a unattended is false.
void reload_range(unsigned int start,
unsigned int end,
bool unattended = false);
private:
/// \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);
Controller* ctrl;
Cache* rsscache;
ConfigContainer* cfg;
std::mutex reload_mutex;
};
} // namespace newsboat
#endif /* NEWSBOAT_RELOADER_H_ */
|
