You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@brpc.apache.org by "caoniaocoder414 (via GitHub)" <gi...@apache.org> on 2023/10/12 12:00:27 UTC
[I] still reachable in loss record (brpc)
caoniaocoder414 opened a new issue, #2412:
URL: https://github.com/apache/brpc/issues/2412
**Describe the bug (描述bug)**
#include <iostream>
#include <gflags/gflags.h>
#include <butil/logging.h>
#include <butil/time.h>
#include <brpc/channel.h>
#include "netcvm.pb.h"
using namespace std;
DEFINE_string(attachment, "", "Carry this along with requests");
DEFINE_string(protocol, "baidu_std", "Protocol type. Defined in src/brpc/options.proto");
DEFINE_string(connection_type, "", "Connection type. Available values: single, pooled, short");
DEFINE_string(server, "127.0.0.1:2365", "IP Address of server");
DEFINE_string(load_balancer, "", "The algorithm for load balancing");
DEFINE_int32(timeout_ms, 100, "RPC timeout in milliseconds");
DEFINE_int32(max_retry, 3, "Max retries(not including the first RPC)");
DEFINE_int32(interval_ms, 1000, "Milliseconds between consecutive requests");
void OLResponse(brpc::Controller* cntl, netcvm::OnlineResponse* response)
{
std::unique_ptr<brpc::Controller> cntl_guard(cntl);
std::unique_ptr<netcvm::OnlineResponse> response_guard(response);
printf("Agent online!\n");
if (cntl->Failed()) {
printf("cntl failed\n");
return;
}
if(response->code() != 0 ) {
printf("Agent register failed!\n");
}
printf("code:%d\n",response->code());
}
int main()
{
// A Channel represents a communication line to a Server. Notice that
// Channel is thread-safe and can be shared by all threads in your program.
brpc::Channel channel;
// Initialize the channel, NULL means using default options.
brpc::ChannelOptions options;
options.protocol = FLAGS_protocol;
options.connection_type = FLAGS_connection_type;
options.timeout_ms = FLAGS_timeout_ms/*milliseconds*/;
options.max_retry = FLAGS_max_retry;
if (channel.Init("10.80.81.107:8998", &options) != 0) {
LOG(ERROR) << "Fail to initialize channel";
printf("init failed!\n");
return -1;
}
printf("init success\n");
netcvm::cvm_data_service_Stub stub(&channel);
netcvm::OnlineRequest request;
request.set_agentserial("aaa");
request.set_paramstr("aaa");
netcvm::OnlineResponse response;
brpc::Controller cntl ;
netcvm::OnlineResponse *newresponse = new (std::nothrow) netcvm::OnlineResponse();
brpc::Controller *newcntl = new (std::nothrow) brpc::Controller();
google::protobuf::Closure *done = brpc::NewCallback(&OLResponse, newcntl, newresponse);
if(done == NULL){
printf("online google::protobuf::Closure malloc failed!\n");
return -1;
}
stub.Online(&cntl, &request, &response, done);
sleep(2);
return 0;
}
使用 valgrind 检查发现 65,792 bytes in 4 blocks are still reachable in loss record 1,424 of 1,449
==00:00:24:07.934 26429== 65,792 bytes in 4 blocks are still reachable in loss record 1,424 of 1,449
==00:00:24:07.934 26429== at 0x4C2A7E6: operator new(unsigned long, std::nothrow_t const&) (vg_replace_malloc.c:387)
==00:00:24:07.934 26429== by 0x6145500: add_block (resource_pool_inl.h:387)
==00:00:24:07.934 26429== by 0x6145500: get (resource_pool_inl.h:210)
==00:00:24:07.934 26429== by 0x6145500: get_resource (resource_pool_inl.h:283)
==00:00:24:07.934 26429== by 0x6145500: get_resource<bthread::TimerThread::Task> (resource_pool.h:97)
==00:00:24:07.934 26429== by 0x6145500: bthread::TimerThread::Bucket::schedule(void (*)(void*), void*, timespec const&) (timer_thread.cpp:187)
==00:00:24:07.934 26429== by 0x6145876: bthread::TimerThread::schedule(void (*)(void*), void*, timespec const&) (timer_thread.cpp:226)
==00:00:24:07.934 26429== by 0x6148DC1: bthread_timer_add (bthread.cpp:335)
==00:00:24:07.934 26429== by 0x621F58B: brpc::Channel::CallMethod(google::protobuf::MethodDescriptor const*, google::protobuf::RpcController*, google::protobuf::Message const*, google::protobuf::Message*, google::protobuf::Closure*) (channel.cpp:520)
==00:00:24:07.934 26429== by 0x52E2C7: Report::Trigger(netcvm::ReportDevPolicyRequest&) (ev_report.cpp:24)
==00:00:24:07.934 26429== by 0x493BCA: DevHBTask::execute(int) (dev_hb_task.cpp:50)
==00:00:24:07.934 26429== by 0x49012F: ThreadPool::runtime(void*) (actuator.cpp:85)
==00:00:24:07.934 26429== by 0x825840E: execute_native_thread_routine (in /opt/csa/csa_lib/lib/libmydtls1.0.so)
==00:00:24:07.934 26429== by 0x9085EA4: start_thread (in /usr/lib64/libpthread-2.17.so)
==00:00:24:07.934 26429== by 0x9BB8B0C: clone (in /usr/lib64/libc-2.17.so)
**To Reproduce (复现方法)**
使用上述代码
**Expected behavior (期望行为)**
是某个函数释放不对吗？
**Versions (各种版本)**
OS:
Compiler:
brpc:
protobuf:
**Additional context/screenshots (更多上下文/截图)**
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@brpc.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@brpc.apache.org
For additional commands, e-mail: dev-help@brpc.apache.org
Re: [I] still reachable in loss record (brpc)
Posted by "zyearn (via GitHub)" <gi...@apache.org>.
zyearn commented on issue #2412:
URL: https://github.com/apache/brpc/issues/2412#issuecomment-1763463758
brpc里面有使用一些全局变量，其中一些是new出来以后一直没有释放的。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@brpc.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@brpc.apache.org
For additional commands, e-mail: dev-help@brpc.apache.org
Re: [I] still reachable in loss record (brpc)
Posted by "zyearn (via GitHub)" <gi...@apache.org>.
zyearn closed issue #2412: still reachable in loss record
URL: https://github.com/apache/brpc/issues/2412
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@brpc.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@brpc.apache.org
For additional commands, e-mail: dev-help@brpc.apache.org