Viewing file:  Config.h (5.65 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
/*
* Phusion Passenger - https://www.phusionpassenger.com/
* Copyright (c) 2014-2017 Phusion Holding B.V.
*
* "Passenger", "Phusion Passenger" and "Union Station" are registered
* trademarks of Phusion Holding B.V.
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
* in the Software without restriction, including without limitation the rights
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
* THE SOFTWARE.
*/
#ifndef _PASSENGER_SERVER_KIT_CONFIG_H_
#define _PASSENGER_SERVER_KIT_CONFIG_H_
// for std::swap()
#if __cplusplus >= 201103L
#include <utility>
#else
#include <algorithm>
#endif
#include <string>
#include <boost/config.hpp>
#include <boost/scoped_ptr.hpp>
#include <ConfigKit/ConfigKit.h>
#include <FileTools/PathManip.h>
#include <Constants.h>
#include <Utils.h>
namespace Passenger {
namespace ServerKit {
using namespace std;
/*
* BEGIN ConfigKit schema: Passenger::ServerKit::Schema
* (do not edit: following text is automatically generated
* by 'rake configkit_schemas_inline_comments')
*
* file_buffered_channel_auto_start_mover boolean - default(true)
* file_buffered_channel_auto_truncate_file boolean - default(true)
* file_buffered_channel_buffer_dir string - default
* file_buffered_channel_delay_in_file_mode_switching unsigned integer - default(0)
* file_buffered_channel_max_disk_chunk_read_size unsigned integer - default(0)
* file_buffered_channel_threshold unsigned integer - default(131072)
* mbuf_block_chunk_size unsigned integer - default(4096),read_only
* secure_mode_password string - secret
*
* END
*/
class Schema: public ConfigKit::Schema {
private:
static Json::Value getDefaultFileBufferedChannelBufferDir(const ConfigKit::Store &config) {
return getSystemTempDir();
}
static Json::Value normalize(const Json::Value &effectiveValues) {
Json::Value updates;
updates["file_buffered_channel_buffer_dir"] = absolutizePath(
effectiveValues["file_buffered_channel_buffer_dir"].asString());
return updates;
}
public:
Schema() {
using namespace ConfigKit;
addWithDynamicDefault("file_buffered_channel_buffer_dir", STRING_TYPE,
OPTIONAL | CACHE_DEFAULT_VALUE, getDefaultFileBufferedChannelBufferDir);
add("file_buffered_channel_threshold", UINT_TYPE, OPTIONAL,
DEFAULT_FILE_BUFFERED_CHANNEL_THRESHOLD);
add("file_buffered_channel_delay_in_file_mode_switching", UINT_TYPE, OPTIONAL, 0);
add("file_buffered_channel_max_disk_chunk_read_size", UINT_TYPE, OPTIONAL, 0);
add("file_buffered_channel_auto_truncate_file", BOOL_TYPE, OPTIONAL, true);
// For unit testing purposes
add("file_buffered_channel_auto_start_mover", BOOL_TYPE, OPTIONAL, true);
add("mbuf_block_chunk_size", UINT_TYPE, OPTIONAL | READ_ONLY,
DEFAULT_MBUF_CHUNK_SIZE);
add("secure_mode_password", STRING_TYPE, OPTIONAL | SECRET);
addNormalizer(normalize);
finalize();
}
};
struct FileBufferedChannelConfig {
string bufferDir;
unsigned int threshold;
unsigned int delayInFileModeSwitching;
unsigned int maxDiskChunkReadSize;
bool autoTruncateFile;
bool autoStartMover;
FileBufferedChannelConfig(const ConfigKit::Store &config)
: bufferDir(config["file_buffered_channel_buffer_dir"].asString()),
threshold(config["file_buffered_channel_threshold"].asUInt()),
delayInFileModeSwitching(config["file_buffered_channel_delay_in_file_mode_switching"].asUInt()),
maxDiskChunkReadSize(config["file_buffered_channel_max_disk_chunk_read_size"].asUInt()),
autoTruncateFile(config["file_buffered_channel_auto_truncate_file"].asBool()),
autoStartMover(config["file_buffered_channel_auto_start_mover"].asBool())
{ }
void swap(FileBufferedChannelConfig &other) BOOST_NOEXCEPT_OR_NOTHROW {
bufferDir.swap(other.bufferDir);
std::swap(threshold, other.threshold);
std::swap(delayInFileModeSwitching, other.delayInFileModeSwitching);
std::swap(maxDiskChunkReadSize, other.maxDiskChunkReadSize);
std::swap(autoTruncateFile, other.autoTruncateFile);
std::swap(autoStartMover, other.autoStartMover);
}
};
struct Config {
string secureModePassword;
FileBufferedChannelConfig fileBufferedChannelConfig;
Config(const ConfigKit::Store &config)
: secureModePassword(config["secure_mode_password"].asString()),
fileBufferedChannelConfig(config)
{ }
void swap(Config &other) BOOST_NOEXCEPT_OR_NOTHROW {
secureModePassword.swap(other.secureModePassword);
fileBufferedChannelConfig.swap(other.fileBufferedChannelConfig);
}
};
struct ConfigChangeRequest {
boost::scoped_ptr<ConfigKit::Store> configStore;
boost::scoped_ptr<Config> config;
};
} // namespace ServerKit
} // namespace Passenger
#endif /* _PASSENGER_SERVER_KIT_CONFIG_H_ */
|