mirror of
https://github.com/polserver/polserver
synced 2026-08-13 08:23:08 -04:00
62a252ad3a
* Add libefsw at 3419347 * saving work * some cleanup * move to fs::paths * saving work.. maybe hitting a limit with number of watched dirs? * migrate to watching only ecompile.cfg specified folders, cleanup/doc * Display summary between compilations in watch mode; fix cache reuse * Fix inf loop; some cmake, format changes... * some windows compilation fixes... tweaks to windows cmake? * Update Efsw.cmake for build lib changes * removed debug flag * silence efsw build dont add antlr project if it already exists * Address review comments: - use std::move on efswwatcher add_* * add docs * Add WatchModeByDefault ecompile.cfg option * iniital work on tests * Add CI actions * some changes (passes locally on win, mac, linux) * Fix fixtures dependency; use ecompile verbose mode * Add core-changes * Send ctrl+c instead of killing process * Proper Python file naming * Kill ecompile process on windows, SIGINT otherwise --------- Co-authored-by: turleypol <turley@polserver.com>
101 lines
2.7 KiB
C++
101 lines
2.7 KiB
C++
#include "SourceFileCache.h"
|
|
|
|
#include "bscript/compiler/Profile.h"
|
|
#include "bscript/compiler/file/SourceFile.h"
|
|
#include "bscript/compiler/file/SourceFileIdentifier.h"
|
|
#include "clib/logfacility.h"
|
|
#include "clib/timer.h"
|
|
|
|
namespace Pol::Bscript::Compiler
|
|
{
|
|
void SourceFileCache::configure( unsigned how_many )
|
|
{
|
|
keep = how_many;
|
|
}
|
|
|
|
std::shared_ptr<SourceFile> SourceFileCache::load( const SourceFileIdentifier& ident,
|
|
Report& report )
|
|
{
|
|
const std::string& pathname = ident.pathname;
|
|
|
|
if ( keep > 0 )
|
|
{
|
|
const std::lock_guard<std::mutex> guard( mutex );
|
|
++frequency[pathname];
|
|
|
|
auto itr = files.find( pathname );
|
|
if ( itr != files.end() )
|
|
{
|
|
profile.cache_hits++;
|
|
|
|
// We do not propagate errors here. This happens when the compilation unit
|
|
// or module is obtained, so that the errors occur at the same "time"
|
|
// whether the file was just loaded, or was cached.
|
|
return ( *itr ).second;
|
|
}
|
|
profile.cache_misses++;
|
|
}
|
|
|
|
auto sf = SourceFile::load( ident, profile, report );
|
|
|
|
if ( keep > 0 && sf )
|
|
{
|
|
const std::lock_guard<std::mutex> guard( mutex );
|
|
auto ins = files.insert( { pathname, sf } );
|
|
if ( !ins.second )
|
|
{
|
|
sf = ( *ins.first ).second;
|
|
}
|
|
}
|
|
|
|
return sf;
|
|
}
|
|
|
|
void SourceFileCache::keep_some()
|
|
{
|
|
if ( keep == 0 )
|
|
return;
|
|
|
|
std::unique_lock<std::mutex> lock( mutex, std::try_to_lock_t() );
|
|
if ( !lock.owns_lock() )
|
|
return;
|
|
|
|
if ( files.size() <= keep )
|
|
return;
|
|
|
|
Pol::Tools::HighPerfTimer select_timer;
|
|
|
|
std::vector<std::pair<unsigned, const std::string*>> pathname_frequencies;
|
|
pathname_frequencies.reserve( files.size() );
|
|
for ( auto& kv : files )
|
|
{
|
|
pathname_frequencies.emplace_back( frequency[kv.first], &kv.second->pathname );
|
|
}
|
|
size_t remove = files.size() - keep;
|
|
std::nth_element( pathname_frequencies.begin(), pathname_frequencies.begin() + remove,
|
|
pathname_frequencies.end() );
|
|
|
|
profile.prune_cache_select_micros += select_timer.ellapsed().count();
|
|
|
|
Pol::Tools::HighPerfTimer delete_timer;
|
|
for ( auto itr = pathname_frequencies.begin(), end = itr + remove; itr != end; ++itr )
|
|
{
|
|
const std::string& pathname = *( ( *itr ).second );
|
|
( *itr ).second = nullptr;
|
|
files.erase( pathname );
|
|
}
|
|
profile.prune_cache_delete_micros += delete_timer.ellapsed().count();
|
|
}
|
|
|
|
void SourceFileCache::clear()
|
|
{
|
|
std::unique_lock<std::mutex> lock( mutex, std::try_to_lock_t() );
|
|
if ( !lock.owns_lock() )
|
|
return;
|
|
|
|
Pol::Tools::HighPerfTimer delete_timer;
|
|
files.clear();
|
|
profile.prune_cache_delete_micros += delete_timer.ellapsed().count();
|
|
}
|
|
|
|
} // namespace Pol::Bscript::Compiler
|