| /third_party/mindspore/tests/ut/cpp/ps/core/ |
| D | tcp_message_handler_test.cc | 39 EXPECT_EQ(meta->ByteSizeLong(), 2); in __anone5e489d30102()
49 EXPECT_EQ(meta.ByteSizeLong(), 2);
53 header.message_meta_length_ = meta.ByteSizeLong();
54 header.message_length_ = data.length() + meta.ByteSizeLong();
60 …memcpy_s(result + kHeaderLen, meta.ByteSizeLong(), meta.SerializeAsString().data(), meta.ByteSizeL…
61 memcpy_s(result + kHeaderLen + meta.ByteSizeLong(), data.length(), data.data(), data.length());
69 EXPECT_EQ(meta->ByteSizeLong(), 2); in __anone5e489d30202()
79 EXPECT_EQ(meta.ByteSizeLong(), 2);
83 header.message_meta_length_ = meta.ByteSizeLong();
84 header.message_length_ = data.length() + meta.ByteSizeLong();
[all …]
|
| D | tcp_pb_server_test.cc | 84 …ssage(message_meta, Protos::RAW, kv_message.SerializeAsString().data(), kv_message.ByteSizeLong()); in TEST_F()
|
| /third_party/protobuf/src/google/protobuf/ |
| D | wire_format_unittest.cc | 222 WireFormat::SerializeWithCachedSizes(source, source.ByteSizeLong(), in TEST()
239 EXPECT_EQ(message.ByteSizeLong(), WireFormat::ByteSize(message)); in TEST()
241 EXPECT_EQ(0, message.ByteSizeLong()); in TEST()
249 EXPECT_EQ(message.ByteSizeLong(), WireFormat::ByteSize(message)); in TEST()
251 EXPECT_EQ(0, message.ByteSizeLong()); in TEST()
259 EXPECT_EQ(message.ByteSizeLong(), WireFormat::ByteSize(message)); in TEST()
261 EXPECT_EQ(0, message.ByteSizeLong()); in TEST()
269 EXPECT_EQ(message.ByteSizeLong(), WireFormat::ByteSize(message)); in TEST()
271 EXPECT_EQ(0, message.ByteSizeLong()); in TEST()
279 EXPECT_EQ(message.ByteSizeLong(), WireFormat::ByteSize(message)); in TEST()
[all …]
|
| D | message_lite.cc | 378 const size_t size = ByteSizeLong(); // Force size to be cached. in SerializePartialToCodedStream()
393 ByteSizeConsistencyError(size, ByteSizeLong(), in SerializePartialToCodedStream()
408 const size_t size = ByteSizeLong(); // Force size to be cached. in SerializePartialToZeroCopyStream()
455 size_t byte_size = ByteSizeLong(); in AppendPartialToString()
485 const size_t byte_size = ByteSizeLong(); in SerializePartialToArray()
|
| D | wrappers.pb.h | 178 size_t ByteSizeLong() const final;
315 size_t ByteSizeLong() const final;
452 size_t ByteSizeLong() const final;
589 size_t ByteSizeLong() const final;
726 size_t ByteSizeLong() const final;
863 size_t ByteSizeLong() const final;
1000 size_t ByteSizeLong() const final;
1137 size_t ByteSizeLong() const final;
1281 size_t ByteSizeLong() const final;
|
| D | message_lite.h | 416 virtual size_t ByteSizeLong() const = 0;
420 int ByteSize() const { return internal::ToIntSize(ByteSizeLong()); } in ByteSize()
|
| D | preserve_unknown_enum_test.cc | 140 EXPECT_EQ(0, message2.ByteSizeLong()); in TEST()
168 EXPECT_EQ(0, message2.ByteSizeLong()); in TEST()
|
| D | wrappers.pb.cc | 421 size_t DoubleValue::ByteSizeLong() const { in ByteSizeLong() function in DoubleValue
616 size_t FloatValue::ByteSizeLong() const { in ByteSizeLong() function in FloatValue
811 size_t Int64Value::ByteSizeLong() const { in ByteSizeLong() function in Int64Value
1008 size_t UInt64Value::ByteSizeLong() const { in ByteSizeLong() function in UInt64Value
1205 size_t Int32Value::ByteSizeLong() const { in ByteSizeLong() function in Int32Value
1402 size_t UInt32Value::ByteSizeLong() const { in ByteSizeLong() function in UInt32Value
1599 size_t BoolValue::ByteSizeLong() const { in ByteSizeLong() function in BoolValue
1806 size_t StringValue::ByteSizeLong() const { in ByteSizeLong() function in StringValue
2010 size_t BytesValue::ByteSizeLong() const { in ByteSizeLong() function in BytesValue
|
| D | struct.pb.cc | 350 size_t Struct::ByteSizeLong() const { in ByteSizeLong() function in Struct
364 total_size += Struct_FieldsEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second); in ByteSizeLong()
745 size_t Value::ByteSizeLong() const { in ByteSizeLong() function in Value
1012 size_t ListValue::ByteSizeLong() const { in ByteSizeLong() function in ListValue
|
| D | implicit_weak_message.h | 81 size_t ByteSizeLong() const override { return data_.size(); } in ByteSizeLong() function
|
| D | empty.pb.h | 146 size_t ByteSizeLong() const final;
|
| D | empty.pb.cc | 176 size_t Empty::ByteSizeLong() const { in ByteSizeLong() function in Empty
|
| D | proto3_arena_unittest.cc | 141 ASSERT_NE(original.ByteSizeLong(), arena_message->ByteSizeLong()); in TEST()
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/ |
| D | leader_scaler.cc | 34 scale_out_message.ByteSizeLong())) { in ScaleOutAsync()
55 scale_in_message.ByteSizeLong())) { in ScaleInAsync()
|
| D | abstract_node.cc | 42 register_message.ByteSizeLong())) { in Register()
119 … scale_out_done_message.SerializeAsString().data(), scale_out_done_message.ByteSizeLong())) { in set_scale_out_done()
139 … scale_in_done_message.SerializeAsString().data(), scale_in_done_message.ByteSizeLong())) { in set_scale_in_done()
159 event_message.ByteSizeLong())) { in BroadcastEvent()
544 heartbeat_message.ByteSizeLong(), kCommTimeoutInSeconds)) { in Heartbeat()
616 fetch_servers.ByteSizeLong())) { in FetchServers()
|
| D | scheduler_node.cc | 73 heartbeat_resp_message.ByteSizeLong())) { in ProcessHeartbeat()
172 register_resp_message.ByteSizeLong())) { in ProcessRegister()
255 fetch_servers_message.ByteSizeLong())) { in ProcessFetchMetadata()
356 send_metadata_message.ByteSizeLong())) { in SendMetadata()
429 event_resp_message.ByteSizeLong())) { in SendEvent()
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/communicator/ |
| D | tcp_client.cc | 279 size_t buf_size = message.ByteSizeLong(); in SendMessage()
280 uint32_t meta_size = SizeToUint(message.pb_meta().ByteSizeLong()); in SendMessage()
311 header.message_meta_length_ = SizeToUint(meta->ByteSizeLong()); in SendMessage()
318 …if (bufferevent_write(buffer_event_, meta->SerializeAsString().data(), meta->ByteSizeLong()) == -1… in SendMessage()
|
| D | tcp_server.cc | 64 size_t buf_size = message->ByteSizeLong(); in SendMessage()
86 header.message_meta_length_ = SizeToUint(meta->ByteSizeLong()); in SendMessage()
93 …if (bufferevent_write(buffer_event_, meta->SerializeAsString().data(), meta->ByteSizeLong()) == -1… in SendMessage()
|
| /third_party/mindspore/mindspore/ccsrc/ps/ |
| D | parameter_server.cc | 647 res->resize(res_data.ByteSizeLong()); in HandlePullReq()
648 size_t dest_size = res_data.ByteSizeLong(); in HandlePullReq()
649 size_t src_size = res_data.ByteSizeLong(); in HandlePullReq()
763 res->resize(res_data.ByteSizeLong()); in HandleCheckReadyForPush()
764 size_t dest_size = res_data.ByteSizeLong(); in HandleCheckReadyForPush()
765 size_t src_size = res_data.ByteSizeLong(); in HandleCheckReadyForPush()
781 res->resize(res_data.ByteSizeLong()); in HandleCheckReadyForPull()
782 size_t dest_size = res_data.ByteSizeLong(); in HandleCheckReadyForPull()
783 size_t src_size = res_data.ByteSizeLong(); in HandleCheckReadyForPull()
802 res->resize(res_data.ByteSizeLong()); in HandleEmbeddingLookup()
[all …]
|
| /third_party/grpc/test/core/util/ |
| D | tsan_suppressions.txt | 12 race:ByteSizeLong
|
| /third_party/protobuf/src/google/protobuf/compiler/cpp/ |
| D | cpp_unittest.cc | 87 EXPECT_EQ(3, message.ByteSizeLong()); in TEST()
|
| D | cpp_unittest.inc | 666 int size = message1.ByteSizeLong();
680 int packed_size = packed_message1.ByteSizeLong();
694 int size = message1.ByteSizeLong();
713 int size = message1.ByteSizeLong();
1847 int size = message1.ByteSizeLong();
1861 int size = message1.ByteSizeLong();
1876 int size = message1.ByteSizeLong();
1890 int size = message1.ByteSizeLong();
1904 int size = message1.ByteSizeLong();
1918 int size = message1.ByteSizeLong();
[all …]
|
| /third_party/protobuf/src/google/protobuf/util/ |
| D | delimited_message_util.cc | 99 size_t size = message.ByteSizeLong(); in SerializeDelimitedToCodedStream()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/perf/ |
| D | cache_pipeline_run.h | 78 auto size_needed = proto->ByteSizeLong(); in SendMessage()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | proto_utils.h | 52 int byte_size = static_cast<int>(msg.ByteSizeLong()); in GenericSerialize()
|