NotificationsYou must be signed in to change notification settings
Fork425
Star2k

Commita32901b

committed

Add clear resolved cache

1 parent3207f82 commita32901bCopy full SHA for a32901b

File tree

2 files changed

-9

lines changed

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

2 files changed

-9

lines changed

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

Lines changed: 4 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -36,11 +36,11 @@ 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_ =true; }`
	`39`	`+voidclear_resolved_cache() { clear_cache_.store(true); }`
`40`	`40`
`41`	`41`	`protected:`
`42`	`42`	`bool cache_resolved_;`
`43`		`-bool clear_cache_;`
	`43`	`+std::atomic<bool> clear_cache_;`
`44`	`44`	`endpoint_cache endpoint_cache_;`
`45`	`45`	`std::shared_ptr<boost::asio::io_service> service_;`
`46`	`46`	`std::shared_ptr<boost::asio::io_service::strand> resolver_strand_;`
`@@ -50,7 +50,7 @@ struct async_resolver : std::enable_shared_from_this<async_resolver<Tag> > {`
`50`	`50`
`51`	`51`	`voidresolve(resolver_type &resolver_, string_typeconst &host,`
`52`	`52`	`std::uint16_t port, resolve_completion_function once_resolved) {`
`53`		`-if (cache_resolved_ && !clear_cache_) {`
	`53`	`+if (cache_resolved_ && !clear_cache_.load()) {`
`54`	`54`	`typename endpoint_cache::iterator iter =`
`55`	`55`	`endpoint_cache_.find(boost::to_lower_copy(host));`
`56`	`56`	`if (iter != endpoint_cache_.end()) {`
`@@ -77,8 +77,7 @@ struct async_resolver : std::enable_shared_from_this<async_resolver<Tag> > {`
`77`	`77`	`typename endpoint_cache::iterator iter;`
`78`	`78`	`bool inserted =false;`
`79`	`79`	`if (!ec && cache_resolved_) {`
`80`		`-if (clear_cache_) {`
`81`		`- clear_cache_ =false;`
	`80`	`+if (clear_cache_.exchange(false)) {`
`82`	`81`	`endpoint_cache_.clear();`
`83`	`82`	`}`
`84`	`83`	`std::tie(iter, inserted) = endpoint_cache_.insert(std::make_pair(`

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

Lines changed: 3 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -27,15 +27,15 @@ 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_ =true; }`
	`30`	`+voidclear_resolved_cache() { clear_cache_.store(true); }`
`31`	`31`
`32`	`32`	`protected:`
`33`	`33`	`typedeftypename string<Tag>::type string_type;`
`34`	`34`	`typedef std::unordered_map<string_type, resolver_iterator_pair>`
`35`	`35`	`resolved_cache;`
`36`	`36`	`resolved_cache endpoint_cache_;`
`37`	`37`	`bool cache_resolved_;`
`38`		`-bool clear_cache_;`
	`38`	`+std::atomic<bool> clear_cache_;`
`39`	`39`
`40`	`40`	`explicitsync_resolver(bool cache_resolved)`
`41`	`41`	`: cache_resolved_(cache_resolved), clear_cache_(false) {}`
`@@ -44,8 +44,7 @@ struct sync_resolver {`
`44`	`44`	`string_type/unused/const& hostname,`
`45`	`45`	`string_typeconst& port) {`
`46`	`46`	`if (cache_resolved_) {`
`47`		`-if (clear_cache_) {`
`48`		`- clear_cache_ =false;`
	`47`	`+if (clear_cache_.exchange(false)) {`
`49`	`48`	`endpoint_cache_.clear();`
`50`	`49`	`}`
`51`	`50`	`typename resolved_cache::iterator cached_iterator =`

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!

Commita32901b

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