thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

client #1600: add network-bandwidth option

Browse Source
This commit is contained in:
Kirill Shvakov 2017-12-08 17:02:17 +02:00
parent 73d65ec4d4
commit da39514071
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dbms/src/Server/Client.cpp
View File

@ -23,6 +23,7 @@
#include <Common/formatReadable.h>
#include <Common/NetException.h>
#include <common/readline_use.h>
#include <Common/Throttler.h>
#include <Common/typeid_cast.h>
#include <Core/Types.h>
#include <Core/QueryProcessingStage.h>
@ -113,6 +114,7 @@ private:
size_t format_max_block_size = 0; /// Max block size for console output.
String insert_format; /// Format of INSERT data that is read from stdin in batch mode.
size_t insert_format_max_block_size = 0; /// Max block size when reading INSERT data.
size_t network_bandwidth = 0; /// The maximum speed of data exchange over the network for the client in bytes per second.
bool has_vertical_output_suffix = false; /// Is \G present at the end of the query string?
@ -408,6 +410,12 @@ private:
UInt64 server_version_minor = 0;
UInt64 server_revision = 0;
if (network_bandwidth)
{
ThrottlerPtr throttler = std::make_shared<Throttler>(network_bandwidth, 0, "");
connection->setThrottler(throttler);
}
connection->getServerVersion(server_name, server_version_major, server_version_minor, server_revision);
server_version = toString(server_version_major) + "." + toString(server_version_minor) + "." + toString(server_revision);
@ -1266,6 +1274,7 @@ public:
("progress", "print progress even in non-interactive mode")
("version,V", "print version information and exit")
("echo", "in batch mode, print query before execution")
("network-bandwidth", boost::program_options::value<int>(), "the maximum speed of data exchange over the network for the client in bytes per second.")
("compression", boost::program_options::value<bool>(), "enable or disable compression")
APPLY_FOR_SETTINGS(DECLARE_SETTING)
APPLY_FOR_LIMITS(DECLARE_LIMIT)
@ -1375,6 +1384,8 @@ public:
config().setBool("echo", true);
if (options.count("time"))
print_time_to_stderr = true;
if (options.count("network-bandwidth"))
network_bandwidth = options["network-bandwidth"].as<int>();
if (options.count("compression"))
config().setBool("compression", options["compression"].as<bool>());
}