wisplite/distant-horizons-core-sharded
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

re-enable remote timestamp getting

Browse Source
This commit is contained in:
James Seibel
2025-12-22 14:21:12 -06:00
parent 948b4bfd9c
commit fb2dae48e2
1 changed files with 14 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/src/main/java/com/seibel/distanthorizons/core/file/fullDatafile/RemoteFullDataSourceProvider.java
+14 -31
View File
@@ -104,37 +104,20 @@ public class RemoteFullDataSourceProvider extends GeneratedFullDataSourceProvide
Long timestamp = this.getTimestampForPos(pos);
if (timestamp != null)
{
//this.syncOnLoadRequestQueue.submitRequest(pos, timestamp)
// .thenAccept((DataSourceRetrievalResult result) ->
// {
// //if (result.receivedDataSource != null)
// //{
// // result.receivedDataSource.close();
// //}
//
// if (result.state == ERetrievalResultState.SUCCESS)
// {
// FullDataSourceV2 dataSource = result.dataSource;
// if (dataSource != null)
// {
// this.updateDataSourceAsync(dataSource)
// .handle((voidObj, throwable) ->
// {
// dataSource.close();
// return null;
// });
// }
// }
// else
// {
// if (result.dataSource != null)
// {
// int k = 0;
// //result.receivedDataSource.close();
// }
// }
//
// });
this.syncOnLoadRequestQueue.submitRequest(pos, timestamp)
.thenAccept((DataSourceRetrievalResult result) ->
{
if (result.state == ERetrievalResultState.SUCCESS
&& result.dataSource != null)
{
this.updateDataSourceAsync(result.dataSource)
.handle((voidObj, throwable) ->
{
result.dataSource.close();
return null;
});
}
});
}
return super.get(pos);