Fix a bunch of spelling mistakes (1/n) (#1112)
This commit is contained in:
parent
53fcd8ac4d
commit
57fe3463f2
@ -298,7 +298,7 @@ set(ENABLE_JEMALLOC ON)
|
|||||||
if (ASAN)
|
if (ASAN)
|
||||||
message(WARNING "Disabling jemalloc as it doesn't work well with ASAN")
|
message(WARNING "Disabling jemalloc as it doesn't work well with ASAN")
|
||||||
set(ENABLE_JEMALLOC OFF)
|
set(ENABLE_JEMALLOC OFF)
|
||||||
# Enable Addres sanitizer and get nicer stack traces in error messages.
|
# Enable Address sanitizer and get nicer stack traces in error messages.
|
||||||
# NOTE: AddressSanitizer uses llvm-symbolizer binary from the Clang
|
# NOTE: AddressSanitizer uses llvm-symbolizer binary from the Clang
|
||||||
# distribution to symbolize the stack traces (note that ideally the
|
# distribution to symbolize the stack traces (note that ideally the
|
||||||
# llvm-symbolizer version must match the version of ASan runtime library).
|
# llvm-symbolizer version must match the version of ASan runtime library).
|
||||||
|
@ -14,7 +14,7 @@ set(CPACK_PACKAGE_VENDOR "Memgraph Ltd.")
|
|||||||
set(CPACK_PACKAGE_DESCRIPTION_SUMMARY
|
set(CPACK_PACKAGE_DESCRIPTION_SUMMARY
|
||||||
"High performance, in-memory, transactional graph database")
|
"High performance, in-memory, transactional graph database")
|
||||||
|
|
||||||
# Setting arhitecture extension for deb packages
|
# Setting architecture extension for deb packages
|
||||||
set(MG_ARCH_EXTENSION_DEB "all")
|
set(MG_ARCH_EXTENSION_DEB "all")
|
||||||
|
|
||||||
if(${MG_ARCH} STREQUAL "x86_64")
|
if(${MG_ARCH} STREQUAL "x86_64")
|
||||||
@ -50,7 +50,7 @@ set(CPACK_DEBIAN_PACKAGE_DESCRIPTION "${CPACK_PACKAGE_DESCRIPTION_SUMMARY}
|
|||||||
# We also depend on `python3` because we embed it in Memgraph.
|
# We also depend on `python3` because we embed it in Memgraph.
|
||||||
set(CPACK_DEBIAN_PACKAGE_DEPENDS "openssl (>= 1.1.0), python3 (>= 3.5.0)")
|
set(CPACK_DEBIAN_PACKAGE_DEPENDS "openssl (>= 1.1.0), python3 (>= 3.5.0)")
|
||||||
|
|
||||||
# Setting arhitecture extension for rpm packages
|
# Setting architecture extension for rpm packages
|
||||||
set(MG_ARCH_EXTENSION_RPM "noarch")
|
set(MG_ARCH_EXTENSION_RPM "noarch")
|
||||||
|
|
||||||
if(${MG_ARCH} STREQUAL "x86_64")
|
if(${MG_ARCH} STREQUAL "x86_64")
|
||||||
|
@ -27,7 +27,7 @@
|
|||||||
|
|
||||||
///////////////////////////////////////////////////////////
|
///////////////////////////////////////////////////////////
|
||||||
// Our communication layer and query engine don't mix
|
// Our communication layer and query engine don't mix
|
||||||
// very well on Centos because OpenSSL version avaialable
|
// very well on Centos because OpenSSL version available
|
||||||
// on Centos 7 include libkrb5 which has brilliant macros
|
// on Centos 7 include libkrb5 which has brilliant macros
|
||||||
// called TRUE and FALSE. For more detailed explanation go
|
// called TRUE and FALSE. For more detailed explanation go
|
||||||
// to memgraph.cpp.
|
// to memgraph.cpp.
|
||||||
|
@ -1202,7 +1202,7 @@ TypedValue Duration(const TypedValue *args, int64_t nargs, const FunctionContext
|
|||||||
std::function<TypedValue(const TypedValue *, const int64_t, const FunctionContext &)> UserFunction(
|
std::function<TypedValue(const TypedValue *, const int64_t, const FunctionContext &)> UserFunction(
|
||||||
const mgp_func &func, const std::string &fully_qualified_name) {
|
const mgp_func &func, const std::string &fully_qualified_name) {
|
||||||
return [func, fully_qualified_name](const TypedValue *args, int64_t nargs, const FunctionContext &ctx) -> TypedValue {
|
return [func, fully_qualified_name](const TypedValue *args, int64_t nargs, const FunctionContext &ctx) -> TypedValue {
|
||||||
/// Find function is called to aquire the lock on Module pointer while user-defined function is executed
|
/// Find function is called to acquire the lock on Module pointer while user-defined function is executed
|
||||||
const auto &maybe_found =
|
const auto &maybe_found =
|
||||||
procedure::FindFunction(procedure::gModuleRegistry, fully_qualified_name, utils::NewDeleteResource());
|
procedure::FindFunction(procedure::gModuleRegistry, fully_qualified_name, utils::NewDeleteResource());
|
||||||
if (!maybe_found) {
|
if (!maybe_found) {
|
||||||
@ -1210,7 +1210,7 @@ std::function<TypedValue(const TypedValue *, const int64_t, const FunctionContex
|
|||||||
"Function '{}' has been unloaded. Please check query modules to confirm that function is loaded in Memgraph.",
|
"Function '{}' has been unloaded. Please check query modules to confirm that function is loaded in Memgraph.",
|
||||||
fully_qualified_name);
|
fully_qualified_name);
|
||||||
}
|
}
|
||||||
/// Explicit extraction of module pointer, to clearly state that the lock is aquired.
|
/// Explicit extraction of module pointer, to clearly state that the lock is acquired.
|
||||||
// NOLINTNEXTLINE(clang-diagnostic-unused-variable)
|
// NOLINTNEXTLINE(clang-diagnostic-unused-variable)
|
||||||
const auto &module_ptr = (*maybe_found).first;
|
const auto &module_ptr = (*maybe_found).first;
|
||||||
|
|
||||||
|
@ -159,7 +159,7 @@ class Streams final {
|
|||||||
/// nullable parameters map.
|
/// nullable parameters map.
|
||||||
///
|
///
|
||||||
/// @throws StreamsException if the stream doesn't exist
|
/// @throws StreamsException if the stream doesn't exist
|
||||||
/// @throws ConsumerRunningException if the consumer is alredy running
|
/// @throws ConsumerRunningException if the consumer is already running
|
||||||
/// @throws ConsumerCheckFailedException if the transformation function throws any std::exception during processing
|
/// @throws ConsumerCheckFailedException if the transformation function throws any std::exception during processing
|
||||||
TransformationResult Check(const std::string &stream_name,
|
TransformationResult Check(const std::string &stream_name,
|
||||||
std::optional<std::chrono::milliseconds> timeout = std::nullopt,
|
std::optional<std::chrono::milliseconds> timeout = std::nullopt,
|
||||||
|
@ -59,7 +59,7 @@ namespace memgraph::utils {
|
|||||||
* {
|
* {
|
||||||
* // Create accessor to the locker so you can
|
* // Create accessor to the locker so you can
|
||||||
* // add the files which need to be locked.
|
* // add the files which need to be locked.
|
||||||
* // Accesor prevents deletion of any files
|
* // Accessor prevents deletion of any files
|
||||||
* // so you safely add multiple files in atomic way
|
* // so you safely add multiple files in atomic way
|
||||||
* auto accessor = locker.Access();
|
* auto accessor = locker.Access();
|
||||||
* accessor.AddPath(file1);
|
* accessor.AddPath(file1);
|
||||||
|
@ -110,7 +110,7 @@ void MemoryTracker::Alloc(const int64_t size) {
|
|||||||
amount_.fetch_sub(size, std::memory_order_relaxed);
|
amount_.fetch_sub(size, std::memory_order_relaxed);
|
||||||
|
|
||||||
throw OutOfMemoryException(
|
throw OutOfMemoryException(
|
||||||
fmt::format("Memory limit exceeded! Atempting to allocate a chunk of {} which would put the current "
|
fmt::format("Memory limit exceeded! Attempting to allocate a chunk of {} which would put the current "
|
||||||
"use to {}, while the maximum allowed size for allocation is set to {}.",
|
"use to {}, while the maximum allowed size for allocation is set to {}.",
|
||||||
GetReadableSize(size), GetReadableSize(will_be), GetReadableSize(current_hard_limit)));
|
GetReadableSize(size), GetReadableSize(will_be), GetReadableSize(current_hard_limit)));
|
||||||
}
|
}
|
||||||
|
@ -448,7 +448,7 @@ std::pair<DateParameters, LocalTimeParameters> ParseLocalDateTimeParameters(std:
|
|||||||
// https://en.wikipedia.org/wiki/ISO_8601#Combined_date_and_time_representations
|
// https://en.wikipedia.org/wiki/ISO_8601#Combined_date_and_time_representations
|
||||||
// ISO8601 specifies that you cannot mix extended and basic format of date and time
|
// ISO8601 specifies that you cannot mix extended and basic format of date and time
|
||||||
// If the date is in the extended format, same must be true for the time, so we don't send T
|
// If the date is in the extended format, same must be true for the time, so we don't send T
|
||||||
// which denotes the basic format. The opposite case also aplies.
|
// which denotes the basic format. The opposite case also applies.
|
||||||
auto local_time_substring = string.substr(t_position + 1);
|
auto local_time_substring = string.substr(t_position + 1);
|
||||||
if (local_time_substring.empty()) {
|
if (local_time_substring.empty()) {
|
||||||
throw temporal::InvalidArgumentException("Invalid LocalDateTime format. {}",
|
throw temporal::InvalidArgumentException("Invalid LocalDateTime format. {}",
|
||||||
|
@ -12,7 +12,7 @@
|
|||||||
# TODO(gitbuda): Add action to print the context/cluster.
|
# TODO(gitbuda): Add action to print the context/cluster.
|
||||||
# TODO(gitbuda): Add action to print logs of each Memgraph instance.
|
# TODO(gitbuda): Add action to print logs of each Memgraph instance.
|
||||||
# TODO(gitbuda): Polish naming within script.
|
# TODO(gitbuda): Polish naming within script.
|
||||||
# TODO(gitbuda): Consider moving this somewhere higher in the project or even put inside GQLAlchmey.
|
# TODO(gitbuda): Consider moving this somewhere higher in the project or even put inside GQLAlchemy.
|
||||||
|
|
||||||
# The idea here is to implement simple interactive runner of Memgraph instances because:
|
# The idea here is to implement simple interactive runner of Memgraph instances because:
|
||||||
# * it should be possible to manually create new test cases first
|
# * it should be possible to manually create new test cases first
|
||||||
|
@ -492,7 +492,7 @@ void RunInteractivePlanning(memgraph::query::DbAccessor *dba) {
|
|||||||
auto *query = dynamic_cast<memgraph::query::CypherQuery *>(MakeAst(*line, &ast));
|
auto *query = dynamic_cast<memgraph::query::CypherQuery *>(MakeAst(*line, &ast));
|
||||||
if (!query) {
|
if (!query) {
|
||||||
throw memgraph::utils::BasicException(
|
throw memgraph::utils::BasicException(
|
||||||
"Interactive planning is only avaialable for regular openCypher "
|
"Interactive planning is only available for regular openCypher "
|
||||||
"queries.");
|
"queries.");
|
||||||
}
|
}
|
||||||
auto symbol_table = memgraph::query::MakeSymbolTable(query);
|
auto symbol_table = memgraph::query::MakeSymbolTable(query);
|
||||||
|
@ -292,7 +292,7 @@ def mixed_workload(
|
|||||||
function_type = random.choices(population=options, weights=percentage_distribution, k=num_of_queries)
|
function_type = random.choices(population=options, weights=percentage_distribution, k=num_of_queries)
|
||||||
|
|
||||||
for t in function_type:
|
for t in function_type:
|
||||||
# Get the apropropriate functions with same probabilty
|
# Get the appropriate functions with same probabilty
|
||||||
if t == "query":
|
if t == "query":
|
||||||
full_workload.append(base_query())
|
full_workload.append(base_query())
|
||||||
else:
|
else:
|
||||||
|
@ -470,7 +470,7 @@ int main(int argc, char **argv) {
|
|||||||
gflags::ParseCommandLineFlags(&argc, &argv, true);
|
gflags::ParseCommandLineFlags(&argc, &argv, true);
|
||||||
|
|
||||||
spdlog::info("Running a bolt client with following settings:");
|
spdlog::info("Running a bolt client with following settings:");
|
||||||
spdlog::info("Adress: {} ", FLAGS_address);
|
spdlog::info("Address: {} ", FLAGS_address);
|
||||||
spdlog::info("Port: {} ", FLAGS_port);
|
spdlog::info("Port: {} ", FLAGS_port);
|
||||||
spdlog::info("Username: {} ", FLAGS_username);
|
spdlog::info("Username: {} ", FLAGS_username);
|
||||||
spdlog::info("Password: {} ", FLAGS_password);
|
spdlog::info("Password: {} ", FLAGS_password);
|
||||||
|
@ -19,9 +19,9 @@
|
|||||||
#include <vector>
|
#include <vector>
|
||||||
|
|
||||||
//////////////////////////////////////////////////////
|
//////////////////////////////////////////////////////
|
||||||
// "json.hpp" should always come before "antrl4-runtime.h"
|
// "json.hpp" should always come before "antlr4-runtime.h"
|
||||||
// "json.hpp" uses libc's EOF macro while
|
// "json.hpp" uses libc's EOF macro while
|
||||||
// "antrl4-runtime.h" contains a static variable of the
|
// "antlr4-runtime.h" contains a static variable of the
|
||||||
// same name, EOF.
|
// same name, EOF.
|
||||||
// This hides the definition of the macro which causes
|
// This hides the definition of the macro which causes
|
||||||
// the compilation to fail.
|
// the compilation to fail.
|
||||||
|
@ -22,7 +22,7 @@
|
|||||||
/// `TAccessor` supplied must have the functions `NameToLabel`, `LabelToName`,
|
/// `TAccessor` supplied must have the functions `NameToLabel`, `LabelToName`,
|
||||||
/// `NameToProperty`, `PropertyToName`, `NameToEdgeType` and `EdgeTypeToName`.
|
/// `NameToProperty`, `PropertyToName`, `NameToEdgeType` and `EdgeTypeToName`.
|
||||||
/// For example, both `memgraph::storage::Storage` and `Storage::Accessor` will
|
/// For example, both `memgraph::storage::Storage` and `Storage::Accessor` will
|
||||||
/// be apropriate.
|
/// be appropriate.
|
||||||
|
|
||||||
template <class TAccessor>
|
template <class TAccessor>
|
||||||
inline std::string ToString(const memgraph::query::VertexAccessor &vertex, const TAccessor &acc) {
|
inline std::string ToString(const memgraph::query::VertexAccessor &vertex, const TAccessor &acc) {
|
||||||
|
@ -949,7 +949,7 @@ TYPED_TEST(TestPlanner, ListWithAggregationAndGroupBy) {
|
|||||||
CheckPlan<TypeParam>(query, this->storage, aggr, ExpectProduce());
|
CheckPlan<TypeParam>(query, this->storage, aggr, ExpectProduce());
|
||||||
}
|
}
|
||||||
|
|
||||||
TYPED_TEST(TestPlanner, AggregatonWithListWithAggregationAndGroupBy) {
|
TYPED_TEST(TestPlanner, AggregationWithListWithAggregationAndGroupBy) {
|
||||||
// Test RETURN sum(2), [sum(3), 42]
|
// Test RETURN sum(2), [sum(3), 42]
|
||||||
auto sum2 = SUM(LITERAL(2), false);
|
auto sum2 = SUM(LITERAL(2), false);
|
||||||
auto sum3 = SUM(LITERAL(3), false);
|
auto sum3 = SUM(LITERAL(3), false);
|
||||||
|
@ -787,7 +787,7 @@ TEST_F(ReplicationTest, ReplicationReplicaWithExistingEndPoint) {
|
|||||||
.GetError() == memgraph::storage::InMemoryStorage::RegisterReplicaError::END_POINT_EXISTS);
|
.GetError() == memgraph::storage::InMemoryStorage::RegisterReplicaError::END_POINT_EXISTS);
|
||||||
}
|
}
|
||||||
|
|
||||||
TEST_F(ReplicationTest, RestoringReplicationAtStartupAftgerDroppingReplica) {
|
TEST_F(ReplicationTest, RestoringReplicationAtStartupAfterDroppingReplica) {
|
||||||
auto main_config = configuration;
|
auto main_config = configuration;
|
||||||
main_config.durability.restore_replication_state_on_startup = true;
|
main_config.durability.restore_replication_state_on_startup = true;
|
||||||
std::unique_ptr<memgraph::storage::Storage> main_store{new memgraph::storage::InMemoryStorage(main_config)};
|
std::unique_ptr<memgraph::storage::Storage> main_store{new memgraph::storage::InMemoryStorage(main_config)};
|
||||||
|
@ -23,7 +23,7 @@ noExplicitConstructor:src/storage/property_value.hpp
|
|||||||
noExplicitConstructor:src/query/typed_value.hpp
|
noExplicitConstructor:src/query/typed_value.hpp
|
||||||
noExplicitConstructor:src/communication/bolt/v1/decoder/decoded_value.hpp
|
noExplicitConstructor:src/communication/bolt/v1/decoder/decoded_value.hpp
|
||||||
|
|
||||||
// suppress antrl warnings
|
// suppress antlr warnings
|
||||||
variableScope:src/query/frontend/opencypher/generated/CypherParser.h
|
variableScope:src/query/frontend/opencypher/generated/CypherParser.h
|
||||||
variableScope:src/query/frontend/opencypher/generated/CypherLexer.h
|
variableScope:src/query/frontend/opencypher/generated/CypherLexer.h
|
||||||
variableScope:src/query/frontend/opencypher/generated/CypherParser.cpp
|
variableScope:src/query/frontend/opencypher/generated/CypherParser.cpp
|
||||||
|
Loading…
Reference in New Issue
Block a user