hazelcast::cp::sessionless_semaphore Class Reference

Inheritance diagram for hazelcast::cp::sessionless_semaphore:

Public Member Functions
	sessionless_semaphore (const std::string &proxy_name, client::spi::ClientContext *context, const raft_group_id &group_id, const std::string &object_name, internal::session::proxy_session_manager &session_manager)
boost::future< void >	acquire (int32_t permits) override
boost::future< void >	release (int32_t permits) override
boost::future< int32_t >	drain_permits () override

Protected Member Functions
boost::future< bool >	try_acquire_for_millis (int32_t permits, std::chrono::milliseconds timeout) override
int64_t	get_thread_id () override
boost::future< void >	do_change_permits (int32_t delta) override

Detailed Description

Definition at line 1248 of file cp.h.

Constructor & Destructor Documentation

sessionless_semaphore()

hazelcast::cp::sessionless_semaphore::sessionless_semaphore	(	const std::string &	proxy_name,
		client::spi::ClientContext *	context,
		const raft_group_id &	group_id,
		const std::string &	object_name,
		internal::session::proxy_session_manager &	session_manager )

Definition at line 1050 of file cp.cpp.

  : counting_semaphore(proxy_name,
                       context,
                       group_id,
                       object_name,
                       session_manager)
{}

Member Function Documentation

acquire()

boost::future< void > hazelcast::cp::sessionless_semaphore::acquire ( int32_t permits )

override

Definition at line 1064 of file cp.cpp.

{
    util::Preconditions::check_positive(permits,
                                        "permits must be positive number.");
 
    return to_void_future(
      do_try_acquire(permits, std::chrono::milliseconds(-1)));
}

do_change_permits()

boost::future< void > hazelcast::cp::sessionless_semaphore::do_change_permits ( int32_t delta )

overrideprotected

Definition at line 1155 of file cp.cpp.

{
    auto cluster_wide_threadId = get_thread_id();
    auto invocation_uid =
      get_context().get_hazelcast_client_implementation()->random_uuid();
    auto request = client::protocol::codec::semaphore_change_encode(
      group_id_,
      object_name_,
      internal::session::proxy_session_manager::NO_SESSION_ID,
      cluster_wide_threadId,
      invocation_uid,
      delta);
    return to_void_future(client::spi::impl::ClientInvocation::create(
                            context_, request, object_name_)
                            ->invoke());
}

drain_permits()

boost::future< int32_t > hazelcast::cp::sessionless_semaphore::drain_permits ( )

override

Definition at line 1138 of file cp.cpp.

{
    auto cluster_wide_threadId = get_thread_id();
    auto invocation_uid =
      get_context().get_hazelcast_client_implementation()->random_uuid();
    auto request = client::protocol::codec::semaphore_drain_encode(
      group_id_,
      object_name_,
      internal::session::proxy_session_manager::NO_SESSION_ID,
      cluster_wide_threadId,
      invocation_uid);
    return decode<int32_t>(client::spi::impl::ClientInvocation::create(
                             context_, request, object_name_)
                             ->invoke());
}

get_thread_id()

int64_t hazelcast::cp::sessionless_semaphore::get_thread_id ( )

overrideprotected

Definition at line 1132 of file cp.cpp.

{
    return session_manager_.get_or_create_unique_thread_id(group_id_);
}

release()

boost::future< void > hazelcast::cp::sessionless_semaphore::release ( int32_t permits )

override

Definition at line 1122 of file cp.cpp.

{
    util::Preconditions::check_positive(permits, "Permits must be positive!");
    auto thread_id = get_thread_id();
    return do_release(permits,
                      thread_id,
                      internal::session::proxy_session_manager::NO_SESSION_ID);
}

try_acquire_for_millis()

boost::future< bool > hazelcast::cp::sessionless_semaphore::try_acquire_for_millis ( int32_t permits, std::chrono::milliseconds timeout )

overrideprotected

Definition at line 1110 of file cp.cpp.

{
    util::Preconditions::check_positive(permits, "Permits must be positive!");
 
    return do_try_acquire(permits,
                          timeout > std::chrono::milliseconds::zero()
                            ? timeout
                            : std::chrono::milliseconds::zero());
}

---

The documentation for this class was generated from the following files:

• hazelcast/include/hazelcast/cp/cp.h
• hazelcast/src/hazelcast/cp/cp.cpp