summaryrefslogtreecommitdiff
path: root/src/commodity.h
diff options
context:
space:
mode:
authorJohn Wiegley <johnw@newartisans.com>2010-06-03 05:56:30 -0400
committerJohn Wiegley <johnw@newartisans.com>2010-06-04 05:16:30 -0400
commitf16a5382ed9a9750c69595e5752f80e39cf7a4b8 (patch)
tree8ad1eb94b5706479ff737ff45a68715deddca889 /src/commodity.h
parenta4a45cb4d61e028a19be3fb5be889e62dc83214e (diff)
downloadfork-ledger-f16a5382ed9a9750c69595e5752f80e39cf7a4b8.tar.gz
fork-ledger-f16a5382ed9a9750c69595e5752f80e39cf7a4b8.tar.bz2
fork-ledger-f16a5382ed9a9750c69595e5752f80e39cf7a4b8.zip
commodity_t::find_price now uses memoization
This reduces the slowdown of using -V and -X from 36x in some cases down to around 4-5x (for a debug build).
Diffstat (limited to 'src/commodity.h')
-rw-r--r--src/commodity.h41
1 files changed, 23 insertions, 18 deletions
diff --git a/src/commodity.h b/src/commodity.h
index 483d98b0..d8aad10d 100644
--- a/src/commodity.h
+++ b/src/commodity.h
@@ -59,6 +59,10 @@ struct price_point_t
datetime_t when;
amount_t price;
+ bool operator==(const price_point_t& other) const {
+ return when == other.when && price == other.price;
+ }
+
#if defined(HAVE_BOOST_SERIALIZATION)
private:
/** Serialization. */
@@ -175,6 +179,16 @@ protected:
optional<amount_t> smaller;
optional<amount_t> larger;
+ typedef std::pair<optional<datetime_t>,
+ optional<datetime_t> > optional_time_pair_t;
+ typedef std::pair<optional_time_pair_t,
+ commodity_t *> time_and_commodity_t;
+ typedef std::map<time_and_commodity_t,
+ optional<price_point_t> > memoized_price_map;
+
+ static const std::size_t max_price_map_size = 16;
+ mutable memoized_price_map price_map;
+
mutable bool searched;
public:
@@ -334,37 +348,28 @@ public:
const bool reflexive = true) {
if (! base->varied_history)
base->varied_history = varied_history_t();
-
base->varied_history->add_price(*this, date, price, reflexive);
+ DEBUG("commodity.prices.find", "Price added, clearing price_map");
+ base->price_map.clear(); // a price was added, invalid the map
}
bool remove_price(const datetime_t& date, commodity_t& commodity) {
- if (base->varied_history)
+ if (base->varied_history) {
base->varied_history->remove_price(date, commodity);
+ DEBUG("commodity.prices.find", "Price removed, clearing price_map");
+ base->price_map.clear(); // a price was added, invalid the map
+ }
return false;
}
optional<price_point_t>
find_price(const optional<commodity_t&>& commodity = none,
const optional<datetime_t>& moment = none,
- const optional<datetime_t>& oldest = none
+ const optional<datetime_t>& oldest = none,
+ const bool nested = false
#if defined(DEBUG_ON)
, const int indent = 0
#endif
- ) const {
- if (! has_flags(COMMODITY_WALKED) && base->varied_history &&
- (commodity || ! has_flags(COMMODITY_PRIMARY))) {
- const_cast<commodity_t&>(*this).add_flags(COMMODITY_WALKED);
- optional<price_point_t> point =
- base->varied_history->find_price(*this, commodity, moment, oldest
-#if defined(DEBUG_ON)
- , indent
-#endif
- );
- const_cast<commodity_t&>(*this).drop_flags(COMMODITY_WALKED);
- return point;
- }
- return none;
- }
+ ) const;
optional<price_point_t>
check_for_updated_price(const optional<price_point_t>& point,