fix some problems(json parser/pb lite/connection block) (trpc-group#153)

- fix TransformConfig return true convert not valid json-string to json-object
- complete pb-lite seriazation support
- fix connection block problem when WritingBufferList at high payload

trpc/config/trpc_conf_compatible.cc

@@ -246,6 +246,11 @@ bool TransformConfig(const std::string& from, Json::Value* json_value) {
       TRPC_FMT_ERROR("Json parse error. content:{}, error:{}", from, err_msg);
       return false;
     }
+    // It will cause coredump if str `from` is not json-format.
+    if (!json_value->isArray() && !json_value->isObject()) {
+      TRPC_FMT_ERROR("Json is not array or object. content:{}", from);
+      return false;
+    }
   } catch (std::exception& ex) {
     TRPC_FMT_ERROR("parse string to json ex:{} ", ex.what());
     return false;

trpc/config/trpc_conf_compatible_test.cc

@@ -190,4 +190,11 @@ TEST_F(TrpcConfCompatibleTest, TransformConfig_JSON_Fail_WithIntegerOverflow) {
   ASSERT_FALSE(trpc::config::GetInt64(json_value, "int_overflow", &v));
 }
 
+TEST_F(TrpcConfCompatibleTest, FindValueFromJson_json_string) {
+  std::string from = R"(1)";
+  Json::Value json_value;
+  bool trans_result = trpc::config::TransformConfig(from, &json_value);
+  ASSERT_FALSE(trans_result);
+}
+
 }  // namespace trpc::testing

trpc/runtime/iomodel/reactor/fiber/writing_buffer_list.cc

@@ -117,7 +117,7 @@ ssize_t WritingBufferList::FlushTo(IoHandler* io, ConnectionHandler* conn_handle
   // We did write something out. Remove those buffers and update the result accordingly.
   auto flushed = static_cast<std::size_t>(rc);
   bool drained = false;
-  if (size_.fetch_sub(flushed, std::memory_order_acquire) < max_capacity) {
+  if (size_.fetch_sub(flushed, std::memory_order_acq_rel) - flushed < max_capacity) {
     writable_cv_.notify_one();
   }
 

trpc/server/rpc/unary_rpc_method_handler.h

@@ -200,7 +200,7 @@ class UnaryRpcMethodHandler : public RpcMethodHandlerInterface {
  private:
   bool Serialize(serialization::Serialization* serialization, void* rsp, NoncontiguousBuffer& buff) {
     serialization::DataType type;
-    if constexpr (std::is_convertible_v<RequestType*, google::protobuf::Message*>) {
+    if constexpr (std::is_convertible_v<RequestType*, google::protobuf::MessageLite*>) {
       type = serialization::kPbMessage;
     } else if constexpr (std::is_convertible_v<RequestType*, rapidjson::Document*>) {
       type = serialization::kRapidJson;
@@ -219,7 +219,7 @@ class UnaryRpcMethodHandler : public RpcMethodHandlerInterface {
 
   bool Deserialize(serialization::Serialization* serialization, NoncontiguousBuffer* req_data, void* req) {
     serialization::DataType type;
-    if constexpr (std::is_convertible_v<RequestType*, google::protobuf::Message*>) {
+    if constexpr (std::is_convertible_v<RequestType*, google::protobuf::MessageLite*>) {
       type = serialization::kPbMessage;
     } else if constexpr (std::is_convertible_v<RequestType*, rapidjson::Document*>) {
       type = serialization::kRapidJson;