Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
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