Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion examples/distributed-map/entry-processor/employee.h
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,8 @@ struct hz_serializer<employee_raise_entry_processor>
static void write_data(
const employee_raise_entry_processor& object,
hazelcast::client::serialization::object_data_output& out)
{}
{
}

employee_raise_entry_processor read_data(
hazelcast::client::serialization::object_data_input& in)
Expand Down
3 changes: 2 additions & 1 deletion examples/distributed-map/map-interceptor/main.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,8 @@ struct hz_serializer<MapInterceptor> : identified_data_serializer
static void write_data(
const MapInterceptor& object,
hazelcast::client::serialization::object_data_output& out)
{}
{
}

static MapInterceptor read_data(
hazelcast::client::serialization::object_data_input& in)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,8 @@ struct PartitionAwareString
{
PartitionAwareString(const std::string& actual_key)
: actual_key(actual_key)
{}
{
}

const std::string* get_partition_key() const override
{
Expand Down
3 changes: 2 additions & 1 deletion examples/distributed-map/query/employee.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -269,7 +269,8 @@ void
hz_serializer<examples::employee_entry_comparator>::write_data(
const examples::employee_entry_comparator& object,
object_data_output& writer)
{}
{
}

examples::employee_entry_comparator
hz_serializer<examples::employee_entry_comparator>::read_data(
Expand Down
3 changes: 2 additions & 1 deletion examples/pipeline/PipeliningDemo.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,8 @@ class PipeliningDemo
: client_(hazelcast::new_client().get())
, map_(client_.get_map("map").get())
, gen_(rd_())
{}
{
}

void init()
{
Expand Down
7 changes: 4 additions & 3 deletions examples/sql/sql_query_with_portable.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -104,8 +104,8 @@ main()
)")
.get();

std::cout << "Mapping created. Affected row count:" << result->update_count()
<< std::endl;
std::cout << "Mapping created. Affected row count:"
<< result->update_count() << std::endl;

// One can select all rows of the table with *.
result = sql.execute("SELECT * FROM person_table").get();
Expand All @@ -114,7 +114,8 @@ main()

// Fetch people older than 38
result = sql.execute("SELECT * FROM person_table WHERE age > ?", 38).get();
std::cout << "Query(SELECT * FROM person_table WHERE age > 38) result:" << std::endl;
std::cout << "Query(SELECT * FROM person_table WHERE age > 38) result:"
<< std::endl;
print_result(*result);

std::cout << "Finished" << std::endl;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,8 @@
namespace hazelcast {
namespace client {

namespace serialization {}
namespace serialization {
}
namespace spi {
class ClientContext;
}
Expand Down
3 changes: 2 additions & 1 deletion hazelcast/include/hazelcast/client/entry_view.h
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,8 @@ class entry_view
, last_stored_time(lastStoredTime)
, last_update_time(lastUpdateTime)
, version(version)
{}
{
}

/**
* key
Expand Down
3 changes: 2 additions & 1 deletion hazelcast/include/hazelcast/client/exception/iexception.h
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,8 @@ class exception_builder
public:
explicit exception_builder(const std::string& source)
: source_(source)
{}
{
}

template<typename T>
exception_builder& operator<<(const T& message)
Expand Down
4 changes: 2 additions & 2 deletions hazelcast/include/hazelcast/client/hazelcast_client.h
Original file line number Diff line number Diff line change
Expand Up @@ -71,8 +71,8 @@ namespace client {
* Our C++ client is completely open source and the source code is freely
* available at https://github.com/hazelcast/hazelcast-cpp-client . Please feel
* free to contribute. You can join our community at
* https://hazelcastcommunity.slack.com/channels/cpp-client where you can find answers
* to your questions.
* https://hazelcastcommunity.slack.com/channels/cpp-client where you can find
* answers to your questions.
*/
class HAZELCAST_API hazelcast_client
{
Expand Down
6 changes: 4 additions & 2 deletions hazelcast/include/hazelcast/client/iexecutor_service.h
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,8 @@ class HAZELCAST_API iexecutor_service : public proxy::ProxyImpl
public:
executor_promise(spi::ClientContext& context)
: context_(context)
{}
{
}

executor_promise(
boost::future<boost::optional<T>>& future,
Expand All @@ -75,7 +76,8 @@ class HAZELCAST_API iexecutor_service : public proxy::ProxyImpl
, member_uuid_(member)
, context_(context)
, invocation_(invocation)
{}
{
}

bool cancel(bool may_interrupt_if_running)
{
Expand Down
3 changes: 2 additions & 1 deletion hazelcast/include/hazelcast/client/ilist.h
Original file line number Diff line number Diff line change
Expand Up @@ -274,7 +274,8 @@ class ilist : public proxy::IListImpl
private:
ilist(const std::string& instance_name, spi::ClientContext* context)
: proxy::IListImpl(instance_name, context)
{}
{
}
};
} // namespace client
} // namespace hazelcast
3 changes: 2 additions & 1 deletion hazelcast/include/hazelcast/client/imap.h
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,8 @@ class HAZELCAST_API imap : public proxy::IMapImpl

imap(const std::string& instance_name, spi::ClientContext* context)
: proxy::IMapImpl(instance_name, context)
{}
{
}

/**
* check if this map contains key.
Expand Down
6 changes: 3 additions & 3 deletions hazelcast/include/hazelcast/client/impl/BaseEventHandler.h
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ class HAZELCAST_API BaseEventHandler
: public spi::EventHandler<protocol::ClientMessage>
{
public:
BaseEventHandler(logger &logger);
BaseEventHandler(logger& logger);

~BaseEventHandler() override;

Expand All @@ -61,10 +61,10 @@ class HAZELCAST_API BaseEventHandler
*/
void on_listener_register() override {}

logger &get_logger() const;
logger& get_logger() const;

protected:
logger &logger_;
logger& logger_;
};
} // namespace impl
} // namespace client
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,8 @@ class EntryEventHandler : public BaseType
, listener_(std::move(listener))
, include_value_(include_value)
, logger_(lg)
{}
{
}

void handle_entry(
const boost::optional<serialization::pimpl::data>& key,
Expand Down
4 changes: 2 additions & 2 deletions hazelcast/include/hazelcast/client/impl/ItemEventHandler.h
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ class item_event_handler : public BaseType
public:
item_event_handler(
std::string instance_name,
logger &logger,
logger& logger,
spi::impl::ClientClusterServiceImpl& cluster_service,
serialization::pimpl::SerializationService& serialization_service,
item_listener&& listener,
Expand All @@ -41,7 +41,7 @@ class item_event_handler : public BaseType
, cluster_service_(cluster_service)
, serialization_service_(serialization_service)
, listener_(std::move(listener))
, include_value_(include_value){};
, include_value_(include_value) {};

void handle_item(const boost::optional<serialization::pimpl::data>& item,
boost::uuids::uuid uuid,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ class EvictableStore
*/
virtual int evict(
std::vector<std::shared_ptr<EvictionCandidate<MAPKEY, MAPVALUE, A, E>>>*
/* eviction_candidates */,
/* eviction_candidates */,
EvictionListener<A, E>* /* eviction_listener */)
{
assert(0);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,9 +54,10 @@ class EvictionListener
* @param wasExpired {@code true} if the entry was evicted due to
* expiration, {@code false} otherwise
*/
virtual void on_evict(const std::shared_ptr<A>& /* evicted_entry_accessor */,
const std::shared_ptr<E>& /* evicted_entry */,
bool /* was_expired */)
virtual void on_evict(
const std::shared_ptr<A>& /* evicted_entry_accessor */,
const std::shared_ptr<E>& /* evicted_entry */,
bool /* was_expired */)
{
assert(0);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ class EvictionPolicyEvaluator
virtual std::unique_ptr<std::vector<
std::shared_ptr<eviction::EvictionCandidate<MAPKEY, MAPVALUE, A, E>>>>
evaluate(util::Iterable<EvictionCandidate<MAPKEY, MAPVALUE, A, E>>&
/* eviction_candidates */) const
/* eviction_candidates */) const
{
assert(0);
return std::unique_ptr<std::vector<std::shared_ptr<
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ class EvictionStrategy
*/
virtual int evict(S* /* evictable_store*/,
EvictionPolicyEvaluator<MAPKEY, MAPVALUE, A, E>*
/* eviction_policy_evaluator*/,
/* eviction_policy_evaluator*/,
EvictionChecker* /* eviction_checker*/,
EvictionListener<A, E>* /* eviction_listener */)
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,8 @@ class DefaultEvictionPolicyEvaluator
const std::shared_ptr<EvictionPolicyComparator<MAPKEY, MAPVALUE>>&
comparator)
: eviction_policy_comparator_(comparator)
{}
{
}

const std::shared_ptr<EvictionPolicyComparator<MAPKEY, MAPVALUE>>
get_eviction_policy_comparator() const override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ class AbstractEvictionStrategy
protected:
virtual int evict_internal(S* /* evictable_store */,
EvictionPolicyEvaluator<MAPKEY, MAPVALUE, A, E>*
/* eviction_policy_evaluator */,
/* eviction_policy_evaluator */,
EvictionListener<A, E>* /* eviction_listener */)
{
assert(0);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,8 @@ class NearCacheRecord
* @param now current time in milliseconds
* @return {@code true} if exceeds max idle seconds, otherwise {@code false}
*/
virtual bool is_idle_at(int64_t /* max_idle_milli_seconds */, int64_t /* now */) = 0;
virtual bool is_idle_at(int64_t /* max_idle_milli_seconds */,
int64_t /* now */) = 0;

/**
* @return last known invalidation sequence at time of this records'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,8 @@ class DefaultNearCache : public NearCache<KS, V>
, execution_service_(es)
, serialization_service_(ss)
, logger_(lg)
{}
{
}

~DefaultNearCache() override = default;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,8 @@ class EntryCountNearCacheMaxSizeChecker : public eviction::MaxSizeChecker
const store::HeapNearCacheRecordMap<K, V, KS, R>& record_map)
: near_cache_record_map_(record_map)
, max_size_(size)
{}
{
}

bool is_reached_to_max_size() const override
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,8 @@ class AbstractNearCacheRecord : public NearCacheRecord<V>
, expiration_time_(expiry_time)
, access_time_(NearCacheRecord<V>::TIME_NOT_SET)
, access_hit_(0)
{}
{
}

std::shared_ptr<V> get_value() const override { return value_; }

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,8 @@ class NearCacheObjectRecord : public AbstractNearCacheRecord<V>
int64_t creation_time,
int64_t expiry_time)
: AbstractNearCacheRecord<V>(value, creation_time, expiry_time)
{}
{
}
};
} // namespace record
} // namespace impl
Expand Down
Loading
Loading