*: support incr (apache#112)

neverchanje · Jul 10, 2018 · 961fca2 · 961fca2
1 parent ba5f78b
commit 961fca2
Show file tree

Hide file tree

Showing 37 changed files with 1,117 additions and 209 deletions.
diff --git a/rdsn b/rdsn
diff --git a/src/base/pegasus_rpc_types.h b/src/base/pegasus_rpc_types.h
@@ -17,4 +17,6 @@ using multi_remove_rpc =
 
 using remove_rpc = dsn::rpc_holder<dsn::blob, dsn::apps::update_response>;
 
+using incr_rpc = dsn::rpc_holder<dsn::apps::incr_request, dsn::apps::incr_response>;
+
 } // namespace pegasus
+4 −3		include/dsn/dist/replication/replication.codes.h
+19 −6		include/dsn/tool-api/task_code.h
+3 −1		include/dsn/tool-api/task_spec.h
+2 −2		src/apps/skv/simple_kv.code.definition.h
+4 −3		src/core/core/partition_resolver_simple.cpp
+2 −1		src/core/core/rpc_engine.cpp
+4 −2		src/core/core/task_code.cpp
+4 −1		src/core/core/task_spec.cpp
+6 −0		src/dist/replication/client_lib/replication_common.cpp
+1 −0		src/dist/replication/client_lib/replication_common.h
+6 −0		src/dist/replication/lib/replica_2pc.cpp
+2 −2		src/dist/replication/test/simple_kv/simple_kv.code.definition.h
Original file line number	Diff line number	Diff line change
Expand Up		@@ -17,4 +17,6 @@ using multi_remove_rpc =

		using remove_rpc = dsn::rpc_holder<dsn::blob, dsn::apps::update_response>;

		using incr_rpc = dsn::rpc_holder<dsn::apps::incr_request, dsn::apps::incr_response>;

		} // namespace pegasus