diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-20 21:24:22 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-20 23:46:18 +0000 |
commit | 1bb2800fb1bf312689115a7230b1d3ead74d4ac6 (patch) | |
tree | 29c84e9a2b9451e0fc4cd8d5e2908c26eb1758fd /fnet | |
parent | 1cfea65b9bc71b472e9dc3370b120cf428b6ece0 (diff) |
Use a common FNET_Transport owned by Proton in both SceduledExecutor and TransactionLogServer.
This reduces the number of Transport object by 1 per document type and netto 1 in Proton.
Each of them contains 2 threads.
In addition it uses a common Transport for the RpcFileAcquirer objects used during config fetching.
This prevents creating 3 temporary Transport objects on every reconfig.
Diffstat (limited to 'fnet')
-rw-r--r-- | fnet/src/vespa/fnet/transport.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/fnet/src/vespa/fnet/transport.cpp b/fnet/src/vespa/fnet/transport.cpp index 8661c8ecace..a695b95bbac 100644 --- a/fnet/src/vespa/fnet/transport.cpp +++ b/fnet/src/vespa/fnet/transport.cpp @@ -6,9 +6,12 @@ #include <vespa/vespalib/util/threadstackexecutor.h> #include <vespa/vespalib/util/size_literals.h> #include <vespa/vespalib/util/rendezvous.h> -#include <chrono> +#include <vespa/vespalib/util/backtrace.h> #include <xxhash.h> +#include <vespa/log/log.h> +LOG_SETUP(".fnet.transport"); + namespace { struct HashState { @@ -130,6 +133,8 @@ FNET_Transport::FNET_Transport(const TransportConfig &cfg) _threads(), _config(cfg.config()) { + // TODO Temporary logging to track down overspend + LOG(debug, "FNET_Transport threads=%d from :%s", cfg.num_threads(), vespalib::getStackTrace(0).c_str()); assert(cfg.num_threads() >= 1); for (size_t i = 0; i < cfg.num_threads(); ++i) { _threads.emplace_back(std::make_unique<FNET_TransportThread>(*this)); |