Commit96a087a

authored

Add clear_resolved_cache implementation (cpp-netlib#893)

1 parent69d2c11 commit96a087aCopy full SHA for 96a087a

File tree

2 files changed

+16

-3

lines changed

boost/network/protocol/http/policies
- async_resolver.hpp
- sync_resolver.hpp

2 files changed

+16

-3

lines changed

`‎boost/network/protocol/http/policies/async_resolver.hpp‎`

Lines changed: 8 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -36,18 +36,21 @@ struct async_resolver : std::enable_shared_from_this<async_resolver<Tag> > {`
`36`	`36`	`typedef std::function<void(resolver_type &, string_type, std::uint16_t,`
`37`	`37`	`resolve_completion_function)> resolve_function;`
`38`	`38`
	`39`	`+voidclear_resolved_cache() { clear_cache_.store(true); }`
	`40`	`+`
`39`	`41`	`protected:`
`40`	`42`	`bool cache_resolved_;`
	`43`	`+ std::atomic<bool> clear_cache_;`
`41`	`44`	`endpoint_cache endpoint_cache_;`
`42`	`45`	`std::shared_ptr<boost::asio::io_service> service_;`
`43`	`46`	`std::shared_ptr<boost::asio::io_service::strand> resolver_strand_;`
`44`	`47`
`45`	`48`	`explicitasync_resolver(bool cache_resolved)`
`46`		`- : cache_resolved_(cache_resolved), endpoint_cache_() {}`
	`49`	`+ : cache_resolved_(cache_resolved),clear_cache_(false),endpoint_cache_() {}`
`47`	`50`
`48`	`51`	`voidresolve(resolver_type &resolver_, string_typeconst &host,`
`49`	`52`	`std::uint16_t port, resolve_completion_function once_resolved) {`
`50`		`-if (cache_resolved_) {`
	`53`	`+if (cache_resolved_ && !clear_cache_.load()) {`
`51`	`54`	`typename endpoint_cache::iterator iter =`
`52`	`55`	`endpoint_cache_.find(boost::to_lower_copy(host));`
`53`	`56`	`if (iter != endpoint_cache_.end()) {`
`@@ -74,6 +77,9 @@ struct async_resolver : std::enable_shared_from_this<async_resolver<Tag> > {`
`74`	`77`	`typename endpoint_cache::iterator iter;`
`75`	`78`	`bool inserted =false;`
`76`	`79`	`if (!ec && cache_resolved_) {`
	`80`	`+if (clear_cache_.exchange(false)) {`
	`81`	`+ endpoint_cache_.clear();`
	`82`	`+ }`
`77`	`83`	`std::tie(iter, inserted) = endpoint_cache_.insert(std::make_pair(`
`78`	`84`	`host,std::make_pair(endpoint_iterator,resolver_iterator())));`
`79`	`85`	`once_resolved(ec, iter->second);`

`‎boost/network/protocol/http/policies/sync_resolver.hpp‎`

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -27,19 +27,26 @@ struct sync_resolver {`
`27`	`27`	`typedef std::pair<resolver_iterator, resolver_iterator>`
`28`	`28`	`resolver_iterator_pair;`
`29`	`29`
	`30`	`+voidclear_resolved_cache() { clear_cache_.store(true); }`
	`31`	`+`
`30`	`32`	`protected:`
`31`	`33`	`typedeftypename string<Tag>::type string_type;`
`32`	`34`	`typedef std::unordered_map<string_type, resolver_iterator_pair>`
`33`	`35`	`resolved_cache;`
`34`	`36`	`resolved_cache endpoint_cache_;`
`35`	`37`	`bool cache_resolved_;`
	`38`	`+ std::atomic<bool> clear_cache_;`
`36`	`39`
`37`		`-explicitsync_resolver(bool cache_resolved) : cache_resolved_(cache_resolved) {}`
	`40`	`+explicitsync_resolver(bool cache_resolved)`
	`41`	`+ : cache_resolved_(cache_resolved), clear_cache_(false) {}`
`38`	`42`
`39`	`43`	`resolver_iterator_pairresolve(resolver_type& resolver_,`
`40`	`44`	`string_type/unused/const& hostname,`
`41`	`45`	`string_typeconst& port) {`
`42`	`46`	`if (cache_resolved_) {`
	`47`	`+if (clear_cache_.exchange(false)) {`
	`48`	`+ endpoint_cache_.clear();`
	`49`	`+ }`
`43`	`50`	`typename resolved_cache::iterator cached_iterator =`
`44`	`51`	`endpoint_cache_.find(hostname);`
`45`	`52`	`if (cached_iterator == endpoint_cache_.end()) {`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit96a087a

File tree

2 files changed

2 files changed

`‎boost/network/protocol/http/policies/async_resolver.hpp‎`

`‎boost/network/protocol/http/policies/sync_resolver.hpp‎`

0 commit comments