94aa90bb64* fix: recover network requests after Network Service restart * chore: reuse implementation * chore: make linter happy * chore: fix lint --------- Co-authored-by: deepak1556 <hop2deep@gmail.com> Co-authored-by: Charles Kerr <charles@charleskerr.com>
74 lines
2.4 KiB
C++
74 lines
2.4 KiB
C++
// Copyright (c) 2021 Slack Technologies, Inc.
|
|
// Use of this source code is governed by the MIT license that can be
|
|
// found in the LICENSE file.
|
|
|
|
#include "base/command_line.h"
|
|
#include "base/dcheck_is_on.h"
|
|
#include "base/logging.h"
|
|
#include "content/browser/network_service_instance_impl.h" // nogncheck
|
|
#include "content/public/browser/network_service_instance.h"
|
|
#include "content/public/common/content_switches.h"
|
|
#include "shell/common/callback_util.h"
|
|
#include "shell/common/gin_helper/dictionary.h"
|
|
#include "shell/common/gin_helper/promise.h"
|
|
#include "shell/common/node_includes.h"
|
|
#include "v8/include/v8.h"
|
|
|
|
#if DCHECK_IS_ON()
|
|
namespace {
|
|
|
|
void Log(int severity, std::string text) {
|
|
switch (severity) {
|
|
case logging::LOGGING_VERBOSE:
|
|
VLOG(1) << text;
|
|
break;
|
|
case logging::LOGGING_INFO:
|
|
LOG(INFO) << text;
|
|
break;
|
|
case logging::LOGGING_WARNING:
|
|
LOG(WARNING) << text;
|
|
break;
|
|
case logging::LOGGING_ERROR:
|
|
LOG(ERROR) << text;
|
|
break;
|
|
case logging::LOGGING_FATAL:
|
|
LOG(FATAL) << text;
|
|
// break not needed here because LOG(FATAL) is [[noreturn]]
|
|
default:
|
|
LOG(ERROR) << "Unrecognized severity: " << severity;
|
|
break;
|
|
}
|
|
}
|
|
|
|
std::string GetLoggingDestination() {
|
|
const auto* command_line = base::CommandLine::ForCurrentProcess();
|
|
return command_line->GetSwitchValueASCII(switches::kEnableLogging);
|
|
}
|
|
|
|
v8::Local<v8::Promise> SimulateNetworkServiceCrash(v8::Isolate* isolate) {
|
|
gin_helper::Promise<void> promise(isolate);
|
|
v8::Local<v8::Promise> handle = promise.GetHandle();
|
|
auto subscription = content::RegisterNetworkServiceProcessGoneHandler(
|
|
electron::AdaptCallbackForRepeating(
|
|
base::BindOnce([](gin_helper::Promise<void> promise,
|
|
bool crashed) { promise.Resolve(); },
|
|
std::move(promise))));
|
|
content::RestartNetworkService();
|
|
return handle;
|
|
}
|
|
|
|
void Initialize(v8::Local<v8::Object> exports,
|
|
v8::Local<v8::Value> unused,
|
|
v8::Local<v8::Context> context,
|
|
void* priv) {
|
|
v8::Isolate* const isolate = v8::Isolate::GetCurrent();
|
|
gin_helper::Dictionary dict{isolate, exports};
|
|
dict.SetMethod("log", &Log);
|
|
dict.SetMethod("getLoggingDestination", &GetLoggingDestination);
|
|
dict.SetMethod("simulateNetworkServiceCrash", &SimulateNetworkServiceCrash);
|
|
}
|
|
|
|
} // namespace
|
|
|
|
NODE_LINKED_BINDING_CONTEXT_AWARE(electron_common_testing, Initialize)
|
|
#endif
|