| 213 | } |
| 214 | |
| 215 | void SerializePublicPbrpcRequest(butil::IOBuf* buf, Controller* cntl, |
| 216 | const google::protobuf::Message* request) { |
| 217 | CompressType type = cntl->request_compress_type(); |
| 218 | if (type != COMPRESS_TYPE_NONE && type != COMPRESS_TYPE_SNAPPY) { |
| 219 | cntl->SetFailed(EREQUEST, "public_pbrpc doesn't support " |
| 220 | "compress type=%d", type); |
| 221 | return; |
| 222 | } |
| 223 | return SerializeRequestDefault(buf, cntl, request); |
| 224 | } |
| 225 | |
| 226 | void PackPublicPbrpcRequest(butil::IOBuf* buf, |
| 227 | SocketMessage**, |