@@ -76,4 +76,3 @@ int main(int argc, char* argv[]) {
LOG(INFO) << "EchoClient is going to quit";
return 0;
}
-
@@ -118,4 +118,3 @@ int main(int argc, char* argv[]) {
@@ -91,4 +91,3 @@ int main(int argc, char* argv[]) {
@@ -90,4 +90,3 @@ int main(int argc, char* argv[]) {
@@ -103,4 +103,3 @@ inline Atomic32 Release_Load(volatile const Atomic32* ptr) {
} // namespace base
#endif // BASE_ATOMICOPS_INTERNALS_GCC_H_
@@ -47,4 +47,3 @@ std::string demangle(const char* name) {
@@ -73,4 +73,3 @@ const char* berror(int error_code) {
const char* berror() {
return berror(errno);
@@ -1848,4 +1848,3 @@ IOBufAppender::IOBufAppender()
void* fast_memcpy(void *__restrict dest, const void *__restrict src, size_t n) {
return base::iobuf::cp(dest, src, n);
@@ -31,4 +31,3 @@ subtle::AtomicWord WaitForInstance(subtle::AtomicWord* instance) {
} // namespace internal
@@ -61,4 +61,3 @@ inline Dst saturated_cast(Src value) {
#endif // BASE_SAFE_CONVERSIONS_H_
@@ -214,4 +214,3 @@ inline RangeConstraint DstRangeRelationToSrcRange(Src value) {
#endif // BASE_SAFE_CONVERSIONS_IMPL_H_
@@ -130,4 +130,3 @@ int string_vprintf(std::string* output, const char* format, va_list args) {
@@ -181,4 +181,3 @@ _xdg_mime_alias_list_dump (XdgAliasList *list)
@@ -180,4 +180,3 @@ _xdg_mime_icon_list_dump (XdgIconList *list)
@@ -216,4 +216,3 @@ _xdg_mime_parent_list_dump (XdgParentList *list)
@@ -131,4 +131,3 @@ __thread int64_t tls_realtime_ns = 0;
__thread int64_t tls_cpuwidetime_ns = 0;
@@ -328,4 +328,3 @@ void Acceptor::BeforeRecycle(Socket* sock) {
} // namespace brpc
@@ -66,4 +66,3 @@ void AdaptiveConnectionType::operator=(const base::StringPiece& name) {
@@ -1205,4 +1205,3 @@ std::ostream& operator<<(std::ostream& os, const AMFArray& arr) {
@@ -85,4 +85,3 @@ inline std::ostream& operator<<(std::ostream& os, const AuthContext& ctx) {
#endif // BRPC_AUTHENTICATOR_H
@@ -61,4 +61,3 @@ void BadMethodService::no_method(::google::protobuf::RpcController* cntl_base,
@@ -33,4 +33,3 @@ public:
#endif // BRPC_BADMETHOD_SERVICE_H
@@ -52,4 +52,3 @@ void BthreadsService::default_method(::google::protobuf::RpcController* cntl_bas
@@ -410,4 +410,3 @@ void Time2GMT(time_t t, char* buf, size_t size) {
@@ -146,4 +146,3 @@ inline std::ostream& operator<<(std::ostream& os, const MinWidth<T>& fw) {
#endif // BRPC_BUILTIN_COMMON_H
@@ -357,4 +357,3 @@ void ConnectionsService::GetTabInfo(TabInfoList* info_list) const {
@@ -123,4 +123,3 @@ void DirService::default_method(::google::protobuf::RpcController* cntl_base,
#endif // BRPC_DIR_SERVICE_H
@@ -251,4 +251,3 @@ void FlagsService::GetTabInfo(TabInfoList* info_list) const {
@@ -40,4 +40,3 @@ private:
#endif // BRPC_FLAGS_SERVICE_H
@@ -43,4 +43,3 @@ const char* flot_min_js() {
@@ -31,4 +31,3 @@ const base::IOBuf& flot_min_js_iobuf_gzip();
#endif // BRPC_BUILTIN_FLOT_MIN_JS_H
@@ -73,4 +73,3 @@ void GetFaviconService::default_method(
@@ -127,4 +127,3 @@ void GetJsService::viz_min(
@@ -39,4 +39,3 @@ void HealthService::default_method(::google::protobuf::RpcController* cntl_base,
@@ -1114,4 +1114,3 @@ void HotspotsService::GetTabInfo(TabInfoList* info_list) const {
@@ -74,4 +74,3 @@ public:
#endif // BRPC_HOTSPOTS_SERVICE_H
@@ -54,4 +54,3 @@ void IdsService::default_method(::google::protobuf::RpcController* cntl_base,
@@ -163,4 +163,3 @@ void IndexService::default_method(::google::protobuf::RpcController* controller,
@@ -45,4 +45,3 @@ const char* jquery_min_js() {
@@ -31,4 +31,3 @@ const base::IOBuf& jquery_min_js_iobuf_gzip();
#endif // BRPC_BUILTIN_JQUERY_MIN_JS_H
@@ -36,4 +36,3 @@ void ListService::default_method(::google::protobuf::RpcController*,
@@ -3526,4 +3526,3 @@ const char* pprof_perl() {
@@ -24,4 +24,3 @@ const char* pprof_perl();
#endif // BRPC_BUILTIN_PPROF_PERL_H
@@ -552,4 +552,3 @@ void PProfService::cmdline(::google::protobuf::RpcController* controller_base,
@@ -109,4 +109,3 @@ void ProtobufsService::default_method(::google::protobuf::RpcController* cntl_ba
@@ -685,4 +685,3 @@ void RpczService::GetTabInfo(TabInfoList* info_list) const {
@@ -50,4 +50,3 @@ void SocketsService::default_method(::google::protobuf::RpcController* cntl_base
@@ -523,4 +523,3 @@ const char* sorttable_js() {
@@ -30,4 +30,3 @@ const base::IOBuf& sorttable_js_iobuf();
#endif // BRPC_BUILTIN_SORTTABLE_JS_H
@@ -220,4 +220,3 @@ void StatusService::GetTabInfo(TabInfoList* info_list) const {
@@ -55,4 +55,3 @@ void ThreadsService::default_method(::google::protobuf::RpcController* cntl_base
@@ -435,4 +435,3 @@ void VarsService::GetTabInfo(TabInfoList* info_list) const {
@@ -35,4 +35,3 @@ void VersionService::default_method(::google::protobuf::RpcController* controlle
@@ -55,4 +55,3 @@ return "function Ub(nr){throw nr}var cc=void 0,wc=!0,xc=null,ee=!1;function bk()
@@ -31,4 +31,3 @@ const base::IOBuf& viz_min_js_iobuf_gzip();
#endif // BRPC_BUILTIN_VIZ_MIN_JS_H
@@ -89,4 +89,3 @@ void VLogService::default_method(::google::protobuf::RpcController* cntl_base,
@@ -455,4 +455,3 @@ int Channel::CheckHealth() {
@@ -203,5 +203,4 @@ enum ChannelOwnership {
#endif // BRPC_CHANNEL_H
@@ -99,4 +99,3 @@ bool SerializeAsCompressedData(const google::protobuf::Message& msg,
@@ -1363,4 +1363,3 @@ google::protobuf::Closure* DoNothing() {
@@ -54,4 +54,3 @@ static unsigned int check_epollrdhup() {
extern const unsigned int has_epollrdhup = check_epollrdhup();
@@ -360,4 +360,3 @@ BAIDU_CASSERT(ARRAY_SIZE(s_huffman_table) == 257u,
const static int32_t HPACK_HUFFMAN_EOS = 256;
@@ -789,4 +789,3 @@ ssize_t HPacker::Decode(base::IOBufBytesIterator& iter, Header* h) {
@@ -2361,4 +2361,3 @@ http_parser_version(void) {
@@ -62,4 +62,3 @@ void LoadBalancerWithNaming::Describe(std::ostream& os,
@@ -45,4 +45,3 @@ private:
#endif // BRPC_LOAD_BALANCER_WITH_NAMING_H
@@ -476,4 +476,3 @@ std::ostream& operator<<(std::ostream& os, const NamingServiceThread& nsthr) {
@@ -54,4 +54,3 @@ int avc_nalu_read_bit(BitStream* stream, int8_t* v) {
@@ -70,4 +70,3 @@ SSLState DetectSSLState(int fd, int* error_code);
#endif // BRPC_SSL_HELPER_H
@@ -177,4 +177,3 @@ void EndRunningUserCodeInPool(void (*fn)(void*), void* arg) {
@@ -273,4 +273,3 @@ EventDispatcher& GetGlobalEventDispatcher(int fd) {
@@ -518,4 +518,3 @@ void GlobalInitializeOrDie() {
@@ -71,4 +71,3 @@ const HttpHeader& DefaultHttpHeader() {
@@ -112,4 +112,3 @@ const char *HttpReasonPhrase(int status_code) {
@@ -496,4 +496,3 @@ Socket* InputMessageBase::ReleaseSocket() {
InputMessageBase::~InputMessageBase() {}
@@ -88,4 +88,3 @@ void SharedLoadBalancer::Describe(std::ostream& os,
@@ -1006,4 +1006,3 @@ bool MemcacheResponse::PopVersion(std::string* version) {
@@ -73,4 +73,3 @@ struct mongo_head_t {
#endif // BRPC_MONGO_HEAD_H
@@ -34,4 +34,3 @@ public:
#endif // BRPC_NAMING_SERVICE_FILTER_H
@@ -231,4 +231,3 @@ void NsheadMessage::Swap(NsheadMessage* other) {
@@ -140,4 +140,3 @@ void NsheadPbServiceAdaptor::ProcessNsheadRequest(
@@ -89,4 +89,3 @@ private:
#endif // BRPC_NSHEAD_PB_SERVICE_ADAPTOR_H
@@ -57,4 +57,3 @@ void NsheadService::Expose(const base::StringPiece& prefix) {
@@ -125,4 +125,3 @@ private:
#endif // BRPC_NSHEAD_SERVICE_H
@@ -720,4 +720,3 @@ const ResponseMerger::Result ResponseMerger::IGNORED;
const ResponseMerger::Result ResponseMerger::CALL_FAILED;
@@ -489,4 +489,3 @@ void DynamicPartitionChannel::CallMethod(
@@ -57,4 +57,3 @@ int PeriodicNamingService::RunNamingService(
@@ -75,4 +75,3 @@ void BaiduNamingService::Destroy() {
} // namespace policy
#endif // BAIDU_INTERNAL
@@ -673,4 +673,3 @@ void PackRpcRequest(base::IOBuf* req_buf,
@@ -289,4 +289,3 @@ void ConsistentHashingLoadBalancer::GetLoads(
@@ -121,4 +121,3 @@ int DHWrapper::do_initialize() {
@@ -134,4 +134,3 @@ void DomainNamingService::Destroy() {
@@ -186,4 +186,3 @@ void DynPartLoadBalancer::Describe(
@@ -44,4 +44,3 @@ const Authenticator* global_esp_authenticator() {
@@ -37,4 +37,3 @@ const Authenticator* global_esp_authenticator();
#endif // BRPC_POLICY_GIANO_AUTHENTICATOR_H
@@ -158,4 +158,3 @@ void ProcessEspResponse(InputMessageBase* msg_base) {
@@ -50,4 +50,3 @@ void ProcessEspResponse(InputMessageBase* msg);
#endif // BRPC_POLICY_ESP_PROTOCOL_H
@@ -162,4 +162,3 @@ void FileNamingService::Destroy() {
@@ -164,4 +164,3 @@ bool ZlibDecompress(const base::IOBuf& data, base::IOBuf* msg) {