Make terminate_threads() less likely to leave _threads containing invalid pointers.
[dcpomatic.git] / src / lib / file_log.cc
1 /*
2     Copyright (C) 2012 Carl Hetherington <cth@carlh.net>
3
4     This file is part of DCP-o-matic.
5
6     DCP-o-matic is free software; you can redistribute it and/or modify
7     it under the terms of the GNU General Public License as published by
8     the Free Software Foundation; either version 2 of the License, or
9     (at your option) any later version.
10
11     DCP-o-matic is distributed in the hope that it will be useful,
12     but WITHOUT ANY WARRANTY; without even the implied warranty of
13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14     GNU General Public License for more details.
15
16     You should have received a copy of the GNU General Public License
17     along with DCP-o-matic.  If not, see <http://www.gnu.org/licenses/>.
18
19 */
20
21 #include "file_log.h"
22 #include "cross.h"
23 #include "config.h"
24 #include <cstdio>
25 #include <iostream>
26
27 using std::cout;
28 using std::string;
29 using std::max;
30 using boost::shared_ptr;
31
32 /** @param file Filename to write log to */
33 FileLog::FileLog (boost::filesystem::path file)
34         : _file (file)
35 {
36         set_types (Config::instance()->log_types());
37 }
38
39 void
40 FileLog::do_log (shared_ptr<const LogEntry> entry)
41 {
42         FILE* f = fopen_boost (_file, "a");
43         if (!f) {
44                 cout << "(could not log to " << _file.string() << "): " << entry.get() << "\n";
45                 return;
46         }
47
48         fprintf (f, "%s\n", entry->get().c_str ());
49         fclose (f);
50 }
51
52 string
53 FileLog::head_and_tail (int amount) const
54 {
55         boost::mutex::scoped_lock lm (_mutex);
56
57         uintmax_t head_amount = amount;
58         uintmax_t tail_amount = amount;
59         uintmax_t size = boost::filesystem::file_size (_file);
60
61         if (size < (head_amount + tail_amount)) {
62                 head_amount = size;
63                 tail_amount = 0;
64         }
65
66         FILE* f = fopen_boost (_file, "r");
67         if (!f) {
68                 return "";
69         }
70
71         string out;
72
73         char* buffer = new char[max(head_amount, tail_amount) + 1];
74
75         int N = fread (buffer, 1, head_amount, f);
76         buffer[N] = '\0';
77         out += string (buffer);
78
79         if (tail_amount > 0) {
80                 out +=  "\n .\n .\n .\n";
81
82                 fseek (f, - tail_amount - 1, SEEK_END);
83
84                 N = fread (buffer, 1, tail_amount, f);
85                 buffer[N] = '\0';
86                 out += string (buffer) + "\n";
87         }
88
89         delete[] buffer;
90         fclose (f);
91
92         return out;
93 }