Home | History | Annotate | Download | only in rpc

Lines Matching refs:src

23 bool GrpcByteBufferSource::Init(const grpc::ByteBuffer& src) {
28 bool ok = src.Dump(&slices_).ok();
81 void GrpcMaybeUnparseProto(const protobuf::Message& src,
84 ::grpc::Slice s(src.ByteSizeLong());
85 src.SerializeWithCachedSizesToArray(
93 void GrpcMaybeUnparseProto(const string& src, grpc::ByteBuffer* dst) {
94 ::grpc::Slice s(src.data(), src.size());
99 bool GrpcMaybeParseProto(const grpc::ByteBuffer& src, protobuf::Message* dst) {
101 if (!stream.Init(src)) return false;
108 bool GrpcMaybeParseProto(const ::grpc::ByteBuffer& src, TensorResponse* dst) {
111 GrpcByteBufferSource src;
115 ok = src.Init(*buffer);
116 return &src;
120 bs.buffer = &src;
125 bool GrpcMaybeParseProto(const grpc::ByteBuffer& src, string* dst) {
127 dst->reserve(src.Length());
129 if (!src.Dump(&slices).ok()) {