[Enhencement](Broker reader)Use smart Pointer instead of native Pointers in broker reader
This commit is contained in:
@ -77,8 +77,7 @@ Status BrokerReader::open() {
|
||||
request.__set_clientId(client_id(_env, broker_addr));
|
||||
request.__set_properties(_properties);
|
||||
|
||||
TBrokerOpenReaderResponse* response = new TBrokerOpenReaderResponse();
|
||||
Defer del_reponse {[&] { delete response; }};
|
||||
std::unique_ptr<TBrokerOpenReaderResponse> response(new TBrokerOpenReaderResponse());
|
||||
try {
|
||||
Status status;
|
||||
BrokerServiceConnection client(client_cache(_env), broker_addr,
|
||||
|
||||
@ -94,8 +94,7 @@ Status BrokerFileSystem::open_file(const Path& path, FileReaderSPtr* reader,
|
||||
request.__set_clientId(client_id(_broker_addr));
|
||||
request.__set_properties(_broker_prop);
|
||||
|
||||
TBrokerOpenReaderResponse* response = new TBrokerOpenReaderResponse();
|
||||
Defer del_reponse {[&] { delete response; }};
|
||||
std::unique_ptr<TBrokerOpenReaderResponse> response(new TBrokerOpenReaderResponse());
|
||||
try {
|
||||
Status status;
|
||||
try {
|
||||
|
||||
Reference in New Issue
Block a user