comment (#474)

Signed-off-by: turuslan <[email protected]>

Author: turuslan

core/data_transfer/dt.hpp

@@ -94,8 +94,11 @@ namespace fc::data_transfer {
     std::shared_ptr<Graphsync> gs;
     std::map<std::string, OnPush> on_push;
     std::map<std::string, OnPull> on_pull;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::unordered_map<PeerDtId, OnData> pulling_out;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::unordered_map<PeerDtId, OnData> pulling_in;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::unordered_map<PeerDtId, PushingOut> pushing_out;
     DtId next_dtid;
   };

core/fsm/fsm.hpp

@@ -469,6 +469,7 @@ namespace fc::fsm {
 
     /// a list of entities' current states
     mutable std::shared_mutex states_mutex_;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::unordered_map<EntityPtr, StateEnumType> states_;
 
     /// optional callback called after any transition

core/markets/storage/chain_events/impl/chain_events_impl.hpp

@@ -27,7 +27,9 @@ namespace fc::markets::storage::chain_events {
     using PrecommitCb = std::function<void(outcome::result<SectorNumber>)>;
 
     struct Watch {
+      // TODO(turuslan): FIL-420 check cache memory usage
       std::multimap<DealId, PrecommitCb> precommits;
+      // TODO(turuslan): FIL-420 check cache memory usage
       std::multimap<SectorNumber, CommitCb> commits;
     };
 
@@ -64,6 +66,7 @@ namespace fc::markets::storage::chain_events {
     TipsetCPtr head_;
 
     mutable std::mutex watched_events_mutex_;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::map<Address, Watch> watched_events_;
 
     common::Logger logger_ = common::createLogger("StorageMarketEvents");

core/markets/storage/client/impl/storage_market_client_impl.hpp

@@ -289,10 +289,12 @@ namespace fc::markets::storage::client {
 
     std::mutex waiting_mutex;
     std::shared_ptr<void> waiting_sub;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::vector<std::shared_ptr<ClientDeal>> waiting_deals;
 
     // connection manager
     std::mutex connections_mutex_;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::map<CID, std::shared_ptr<CborStream>> connections_;
 
     /** State machine */

core/markets/storage/provider/impl/provider_impl.hpp

@@ -342,6 +342,7 @@ namespace fc::markets::storage::provider {
 
     // coonnection manager
     std::mutex connections_mutex_;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::map<CID, std::shared_ptr<CborStream>> connections_;
 
     /** State machine */

core/miner/mining.hpp

@@ -61,6 +61,7 @@ namespace fc::mining {
     boost::optional<Tipset> ts;
     BigInt weight;
     size_t skip{};
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::unordered_set<std::pair<TipsetKey, size_t>, pair_hash> mined;
     boost::optional<MiningBaseInfo> info;
   };

core/miner/storage_fsm/impl/events_impl.hpp

@@ -54,9 +54,12 @@ namespace fc::mining {
 
     uint64_t global_id_;
 
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::unordered_map<uint64_t, HeightHandle> height_triggers_;
 
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::map<ChainEpoch, std::set<uint64_t>> height_to_trigger_;  // for apply
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::map<ChainEpoch, std::set<uint64_t>>
         message_height_to_trigger_;  // for revert
 

core/miner/storage_fsm/impl/precommit_batcher_impl.hpp

@@ -52,6 +52,7 @@ namespace fc::mining {
 
     std::mutex mutex_;
     TokenAmount mutual_deposit_;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::map<SectorNumber, PreCommitEntry> batch_storage_;
     std::chrono::milliseconds max_delay_;
     std::shared_ptr<FullNodeApi> api_;
@@ -60,6 +61,7 @@ namespace fc::mining {
     std::chrono::milliseconds closest_cutoff_;
     std::chrono::system_clock::time_point cutoff_start_;
     common::Logger logger_;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::map<SectorNumber, PrecommitCallback> callbacks_;
     std::shared_ptr<FeeConfig> fee_config_;
     AddressSelector address_selector_;

core/miner/storage_fsm/impl/sealing_impl.hpp

@@ -281,6 +281,7 @@ namespace fc::mining {
     SectorId minerSectorId(SectorNumber num) const;
 
     mutable std::mutex sectors_mutex_;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::unordered_map<SectorNumber, std::shared_ptr<SectorInfo>> sectors_;
 
     struct UnsealedSectorInfo {
@@ -290,6 +291,7 @@ namespace fc::mining {
       std::vector<UnpaddedPieceSize> piece_sizes;
     };
 
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::unordered_map<SectorNumber, UnsealedSectorInfo> unsealed_sectors_;
     std::shared_mutex unsealed_mutex_;
 

core/miner/windowpost.hpp

@@ -48,6 +48,7 @@ namespace fc::mining {
     std::shared_ptr<Prover> prover;
     std::shared_ptr<FaultTracker> fault_tracker;
     Address miner, worker;
+    // TODO(turuslan): FIL-420 check cache memory usage
     std::map<ChainEpoch, Cached> cache;
     uint64_t part_size;
     RegisteredPoStProof proof_type;