Skip to content

Commit

Permalink
bug fix: reuse compression buffer in workspace
Browse files Browse the repository at this point in the history
  • Loading branch information
suiguoxin committed Jun 8, 2022
1 parent 9bf097a commit e1f8052
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion AnnService/SSDServing.vcxproj
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@
<CharacterSet>MultiByte</CharacterSet>
</PropertyGroup>
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Release|x64'" Label="Configuration">
<ConfigurationType>StaticLibrary</ConfigurationType>
<ConfigurationType>Application</ConfigurationType>
<UseDebugLibraries>false</UseDebugLibraries>
<PlatformToolset>v142</PlatformToolset>
<WholeProgramOptimization>true</WholeProgramOptimization>
Expand Down
2 changes: 1 addition & 1 deletion AnnService/inc/Core/SPANN/IExtraSearcher.h
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ namespace SPTAG {
int hashExp = va_arg(arg, int);
int internalResultNum = va_arg(arg, int);
int maxPages = va_arg(arg, int);
int enableDataCompression = va_arg(arg, bool);
bool enableDataCompression = va_arg(arg, bool);
Initialize(maxCheck, hashExp, internalResultNum, maxPages, enableDataCompression);
}

Expand Down
6 changes: 3 additions & 3 deletions AnnService/src/Core/SPANN/SPANNIndex.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ namespace SPTAG

omp_set_num_threads(m_options.m_iSSDNumberOfThreads);
m_workSpacePool.reset(new COMMON::WorkSpacePool<ExtraWorkSpace>());
m_workSpacePool->Init(m_options.m_iSSDNumberOfThreads, m_options.m_maxCheck, m_options.m_hashExp, m_options.m_searchInternalResultNum, max(m_options.m_postingPageLimit, m_options.m_searchPostingPageLimit + 1) << PageSizeEx);
m_workSpacePool->Init(m_options.m_iSSDNumberOfThreads, m_options.m_maxCheck, m_options.m_hashExp, m_options.m_searchInternalResultNum, max(m_options.m_postingPageLimit, m_options.m_searchPostingPageLimit + 1) << PageSizeEx, m_options.m_enableDataCompression);
return ErrorCode::Success;
}

Expand Down Expand Up @@ -707,7 +707,7 @@ namespace SPTAG
}

m_workSpacePool.reset(new COMMON::WorkSpacePool<ExtraWorkSpace>());
m_workSpacePool->Init(m_options.m_iSSDNumberOfThreads, m_options.m_maxCheck, m_options.m_hashExp, m_options.m_searchInternalResultNum, max(m_options.m_postingPageLimit, m_options.m_searchPostingPageLimit + 1) << PageSizeEx);
m_workSpacePool->Init(m_options.m_iSSDNumberOfThreads, m_options.m_maxCheck, m_options.m_hashExp, m_options.m_searchInternalResultNum, max(m_options.m_postingPageLimit, m_options.m_searchPostingPageLimit + 1) << PageSizeEx, m_options.m_enableDataCompression);
m_bReady = true;
return ErrorCode::Success;
}
Expand Down Expand Up @@ -759,7 +759,7 @@ namespace SPTAG
omp_set_num_threads(m_options.m_iSSDNumberOfThreads);
m_index->UpdateIndex();
m_workSpacePool.reset(new COMMON::WorkSpacePool<ExtraWorkSpace>());
m_workSpacePool->Init(m_options.m_iSSDNumberOfThreads, m_options.m_maxCheck, m_options.m_hashExp, m_options.m_searchInternalResultNum, max(m_options.m_postingPageLimit, m_options.m_searchPostingPageLimit + 1) << PageSizeEx);
m_workSpacePool->Init(m_options.m_iSSDNumberOfThreads, m_options.m_maxCheck, m_options.m_hashExp, m_options.m_searchInternalResultNum, max(m_options.m_postingPageLimit, m_options.m_searchPostingPageLimit + 1) << PageSizeEx, m_options.m_enableDataCompression);
return ErrorCode::Success;
}

Expand Down

0 comments on commit e1f8052

Please sign in to comment.