1
// libTorrent - BitTorrent library
2
// Copyright (C) 2005-2007, Jari Sundell
4
// This program is free software; you can redistribute it and/or modify
5
// it under the terms of the GNU General Public License as published by
6
// the Free Software Foundation; either version 2 of the License, or
7
// (at your option) any later version.
9
// This program is distributed in the hope that it will be useful,
10
// but WITHOUT ANY WARRANTY; without even the implied warranty of
11
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12
// GNU General Public License for more details.
14
// You should have received a copy of the GNU General Public License
15
// along with this program; if not, write to the Free Software
16
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
18
// In addition, as a special exception, the copyright holders give
19
// permission to link the code of portions of this program with the
20
// OpenSSL library under certain conditions as described in each
21
// individual source file, and distribute linked combinations
24
// You must obey the GNU General Public License in all respects for
25
// all of the code used other than OpenSSL. If you modify file(s)
26
// with this exception, you may extend this exception to your version
27
// of the file(s), but you are not obligated to do so. If you do not
28
// wish to do so, delete this exception statement from your version.
29
// If you delete this exception statement from all source files in the
30
// program, then also delete it here.
32
// Contact: Jari Sundell <jaris@ifi.uio.no>
35
// 3185 Skoppum, NORWAY
41
#include "data/socket_file.h"
42
#include "torrent/exceptions.h"
45
#include "file_manager.h"
50
FileManager::FileManager() :
52
m_filesOpenedCounter(0),
53
m_filesClosedCounter(0),
54
m_filesFailedCounter(0) {}
56
FileManager::~FileManager() {
58
throw internal_error("FileManager::~FileManager() called but empty() != true.");
62
FileManager::set_max_open_files(size_type s) {
63
if (s < 4 || s > (1 << 16))
64
throw input_error("Max open files must be between 4 and 2^16.");
68
while (size() > m_maxOpenFiles)
73
FileManager::open(value_type file, int prot, int flags) {
77
if (size() > m_maxOpenFiles)
78
throw internal_error("FileManager::open_file(...) m_openSize > m_maxOpenFiles.");
80
if (size() == m_maxOpenFiles)
85
if (!fd.open(file->frozen_path(), prot, flags)) {
86
m_filesFailedCounter++;
90
file->set_protection(prot);
91
file->set_file_descriptor(fd.fd());
92
base_type::push_back(file);
94
// Consider storing the position of the file here.
96
m_filesOpenedCounter++;
101
FileManager::close(value_type file) {
102
if (!file->is_open())
105
SocketFile(file->file_descriptor()).close();
107
file->set_protection(0);
108
file->set_file_descriptor(-1);
110
iterator itr = std::find(begin(), end(), file);
113
throw internal_error("FileManager::close_file(...) itr == end().");
116
base_type::pop_back();
118
m_filesClosedCounter++;
121
struct FileManagerActivity {
122
FileManagerActivity() : m_last(rak::timer::max().usec()), m_file(NULL) {}
124
void operator ()(File* f) {
125
if (f->is_open() && f->last_touched() <= m_last) {
126
m_last = f->last_touched();
136
FileManager::close_least_active() {
137
close(std::for_each(begin(), end(), FileManagerActivity()).m_file);