Commit c1e7636f authored May 06, 2014 by Andrew Mitchell

Added NoOp to Threadsafe client

parent ea41ac7d

include/kinetic/threadsafe_nonblocking_connection.h

+1 −0

Original line number	Diff line number	Diff line
		@@ -51,6 +51,7 @@ class ThreadsafeNonblockingKineticConnection : public NonblockingKineticConnecti
		/// tells the client the correct cluster version using this method.
		void SetClientClusterVersion(int64_t cluster_version);

		HandlerKey NoOp(const shared_ptr<SimpleCallbackInterface> callback);
		HandlerKey Get(const shared_ptr<const string> key,
		const shared_ptr<GetCallbackInterface> callback);
		HandlerKey GetNext(const shared_ptr<const string> key,

src/main/threadsafe_nonblocking_kinetic_connection.cc

+5 −0

Original line number	Diff line number	Diff line
		@@ -43,6 +43,11 @@ void ThreadsafeNonblockingKineticConnection::SetClientClusterVersion(int64_t clu
		return NonblockingKineticConnection::SetClientClusterVersion(cluster_version);
		}

		HandlerKey ThreadsafeNonblockingKineticConnection::NoOp(const shared_ptr<SimpleCallbackInterface> callback) {
		std::lock_guard<std::mutex> guard(mutex_);
		return NonblockingKineticConnection::NoOp(callback);
		}

		HandlerKey ThreadsafeNonblockingKineticConnection::Get(const shared_ptr<const string> key,
		const shared_ptr<GetCallbackInterface> callback) {
		std::lock_guard<std::mutex> guard(mutex_);