Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
05aace294e | ||
|
|
41c7c48825 | ||
|
|
1913181d02 |
@@ -5,7 +5,7 @@ org.gradle.configuration-cache=false
|
|||||||
|
|
||||||
# Mod
|
# Mod
|
||||||
mod_id=video_player
|
mod_id=video_player
|
||||||
mod_version=0.4.19
|
mod_version=0.4.22
|
||||||
maven_group=com.ejclaw.videoplayer
|
maven_group=com.ejclaw.videoplayer
|
||||||
archives_base_name=video_player
|
archives_base_name=video_player
|
||||||
|
|
||||||
|
|||||||
@@ -20,6 +20,7 @@ import net.fabricmc.fabric.api.event.player.AttackBlockCallback;
|
|||||||
import net.minecraft.client.Minecraft;
|
import net.minecraft.client.Minecraft;
|
||||||
import net.minecraft.client.player.LocalPlayer;
|
import net.minecraft.client.player.LocalPlayer;
|
||||||
import net.minecraft.core.BlockPos;
|
import net.minecraft.core.BlockPos;
|
||||||
|
import net.minecraft.sounds.SoundSource;
|
||||||
import net.minecraft.world.InteractionResult;
|
import net.minecraft.world.InteractionResult;
|
||||||
import net.minecraft.world.phys.Vec3;
|
import net.minecraft.world.phys.Vec3;
|
||||||
|
|
||||||
@@ -89,17 +90,26 @@ public class VideoPlayerClient implements ClientModInitializer {
|
|||||||
* Distance is measured from the player's eye to the <em>panel center</em>, not the anchor
|
* Distance is measured from the player's eye to the <em>panel center</em>, not the anchor
|
||||||
* block corner — for a 4×4 panel the corner is ~2 blocks off from where the screen visually
|
* block corner — for a 4×4 panel the corner is ~2 blocks off from where the screen visually
|
||||||
* sits, which made the audio feel like it was off to the side.
|
* sits, which made the audio feel like it was off to the side.
|
||||||
|
*
|
||||||
|
* <p>Gain is also gated by the Minecraft sound options so the in-game sliders work as
|
||||||
|
* expected: vanilla {@code SoundEngine.calculateVolume} multiplies by master × category, so
|
||||||
|
* we do the same with {@link SoundSource#PLAYERS} as the category. Result: dragging the
|
||||||
|
* "Players" slider in Options → Music & Sounds attenuates video audio just like other
|
||||||
|
* player sounds, and "Master" still gates everything.
|
||||||
*/
|
*/
|
||||||
private static void updateDistanceGains(Minecraft client) {
|
private static void updateDistanceGains(Minecraft client) {
|
||||||
LocalPlayer p = client.player;
|
LocalPlayer p = client.player;
|
||||||
if (p == null || client.level == null) return;
|
if (p == null || client.level == null) return;
|
||||||
Vec3 eye = p.getEyePosition();
|
Vec3 eye = p.getEyePosition();
|
||||||
|
float masterVol = client.options.getSoundSourceVolume(SoundSource.MASTER);
|
||||||
|
float playersVol = client.options.getSoundSourceVolume(SoundSource.PLAYERS);
|
||||||
|
float categoryScale = masterVol * playersVol;
|
||||||
for (BlockPos pos : VideoPlayback.activePositions()) {
|
for (BlockPos pos : VideoPlayback.activePositions()) {
|
||||||
if (!(client.level.getBlockEntity(pos) instanceof VideoAnchorBlockEntity be)) continue;
|
if (!(client.level.getBlockEntity(pos) instanceof VideoAnchorBlockEntity be)) continue;
|
||||||
Vec3 center = be.panelCenter();
|
Vec3 center = be.panelCenter();
|
||||||
double d = center.distanceTo(eye);
|
double d = center.distanceTo(eye);
|
||||||
float attenuation = (float) Math.max(0.0, Math.min(1.0, 1.0 - d / 16.0));
|
float attenuation = (float) Math.max(0.0, Math.min(1.0, 1.0 - d / 16.0));
|
||||||
float gain = be.isMuted() ? 0F : be.getVolume() * attenuation;
|
float gain = be.isMuted() ? 0F : be.getVolume() * attenuation * categoryScale;
|
||||||
VideoPlayback.setGain(pos, gain);
|
VideoPlayback.setGain(pos, gain);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -190,7 +190,11 @@ public final class VideoCache {
|
|||||||
public static void preload(String url) {
|
public static void preload(String url) {
|
||||||
if (url == null || url.isEmpty()) return;
|
if (url == null || url.isEmpty()) return;
|
||||||
if (!(url.startsWith("http://") || url.startsWith("https://"))) return;
|
if (!(url.startsWith("http://") || url.startsWith("https://"))) return;
|
||||||
if (READY.containsKey(url)) {
|
// Use lookup() (which also verifies the file exists on disk) instead of
|
||||||
|
// READY.containsKey — defends against READY containing a stale entry whose
|
||||||
|
// backing file was removed by clearAll() / a user-side file delete. Without this,
|
||||||
|
// a stale key would silently block a re-preload.
|
||||||
|
if (lookup(url) != null) {
|
||||||
VideoPlayerMod.LOG.info("[{}] preload: already cached {}", VideoPlayerMod.MOD_ID, url);
|
VideoPlayerMod.LOG.info("[{}] preload: already cached {}", VideoPlayerMod.MOD_ID, url);
|
||||||
notifyChat("[videopreload] 이미 캐시됨: " + url, ChatFormatting.GRAY);
|
notifyChat("[videopreload] 이미 캐시됨: " + url, ChatFormatting.GRAY);
|
||||||
return;
|
return;
|
||||||
@@ -229,6 +233,33 @@ public final class VideoCache {
|
|||||||
|
|
||||||
// -- internals -----------------------------------------------------------------------
|
// -- internals -----------------------------------------------------------------------
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Publish {@code path} into {@link #READY} for {@code url}, but only if the cache
|
||||||
|
* epoch hasn't moved since {@code startEpoch} was captured. Wraps the
|
||||||
|
* pre-check / put / post-check / rollback dance so every publish site uses the
|
||||||
|
* same race-free pattern instead of re-implementing it.
|
||||||
|
*
|
||||||
|
* <p>Race coverage: if {@link #clearAll()} runs at any point between the
|
||||||
|
* pre-check and the post-check, the post-check sees the epoch bump and we
|
||||||
|
* roll back — {@link Map#remove(Object, Object)} is a compareAndRemove so we
|
||||||
|
* don't clobber a legitimate concurrent put under the same key, and we delete
|
||||||
|
* the on-disk file because clearAll's directory scan may have missed it (the
|
||||||
|
* file may not have existed yet when clearAll ran).
|
||||||
|
*
|
||||||
|
* @return {@code true} if the entry is now published; {@code false} if the
|
||||||
|
* caller's work was cancelled and {@code path} has been cleaned up.
|
||||||
|
*/
|
||||||
|
private static boolean publishIfNotCancelled(String url, Path path, long startEpoch) {
|
||||||
|
if (CACHE_EPOCH.get() != startEpoch) return false;
|
||||||
|
READY.put(url, path);
|
||||||
|
if (CACHE_EPOCH.get() != startEpoch) {
|
||||||
|
READY.remove(url, path);
|
||||||
|
try { Files.deleteIfExists(path); } catch (Throwable ignored) {}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
private static void download(String url, long startEpoch) {
|
private static void download(String url, long startEpoch) {
|
||||||
Path cacheDir = cacheDir();
|
Path cacheDir = cacheDir();
|
||||||
Path partPath = null;
|
Path partPath = null;
|
||||||
@@ -255,8 +286,11 @@ public final class VideoCache {
|
|||||||
// Resume-friendly: if the file's already on disk from an earlier session, just
|
// Resume-friendly: if the file's already on disk from an earlier session, just
|
||||||
// index it without re-downloading.
|
// index it without re-downloading.
|
||||||
if (Files.exists(finalPath) && Files.size(finalPath) > 0) {
|
if (Files.exists(finalPath) && Files.size(finalPath) > 0) {
|
||||||
if (CACHE_EPOCH.get() != startEpoch) return;
|
if (!publishIfNotCancelled(url, finalPath, startEpoch)) {
|
||||||
READY.put(url, finalPath);
|
VideoPlayerMod.LOG.info("[{}] preload: reindex cancelled (clearAll ran) — {}",
|
||||||
|
VideoPlayerMod.MOD_ID, url);
|
||||||
|
return;
|
||||||
|
}
|
||||||
VideoPlayerMod.LOG.info("[{}] preload: indexed existing cache {} -> {}",
|
VideoPlayerMod.LOG.info("[{}] preload: indexed existing cache {} -> {}",
|
||||||
VideoPlayerMod.MOD_ID, url, finalPath.getFileName());
|
VideoPlayerMod.MOD_ID, url, finalPath.getFileName());
|
||||||
notifyChat("[videopreload] 기존 캐시 사용: " + url, ChatFormatting.GREEN);
|
notifyChat("[videopreload] 기존 캐시 사용: " + url, ChatFormatting.GREEN);
|
||||||
@@ -352,21 +386,16 @@ public final class VideoCache {
|
|||||||
Files.move(partPath, finalPath, StandardCopyOption.REPLACE_EXISTING,
|
Files.move(partPath, finalPath, StandardCopyOption.REPLACE_EXISTING,
|
||||||
StandardCopyOption.ATOMIC_MOVE);
|
StandardCopyOption.ATOMIC_MOVE);
|
||||||
|
|
||||||
// Post-move cancellation check. clearAll() may have run between the pre-move
|
// Race-safe publish: this covers the window between Files.move and READY.put
|
||||||
// check above and the move itself — in that case clearAll's directory scan
|
// (clearAll deletes the freshly-moved file then we resurrect it in READY) AND
|
||||||
// either missed our file (it didn't exist yet) or saw the .part and skipped /
|
// the window between READY.put and the "완료" notification (clearAll wipes
|
||||||
// failed to delete it. Either way, finalPath now exists on disk but the
|
// READY then we re-publish + emit stale completion chat). publishIfNotCancelled
|
||||||
// user-visible cache state is "cleared", so we must delete the file and skip
|
// rolls back both READY and the on-disk file if the epoch moved at any time.
|
||||||
// both the READY.put and the "완료" chat. Without this check, a clear right at
|
if (!publishIfNotCancelled(url, finalPath, startEpoch)) {
|
||||||
// this window leaves a resurrected file in READY and a stale "완료" message.
|
VideoPlayerMod.LOG.info("[{}] preload: cancelled at publish (clearAll ran) — {}",
|
||||||
if (CACHE_EPOCH.get() != startEpoch) {
|
|
||||||
VideoPlayerMod.LOG.info("[{}] preload: cancelled after move (clearAll ran) — {}",
|
|
||||||
VideoPlayerMod.MOD_ID, url);
|
VideoPlayerMod.MOD_ID, url);
|
||||||
try { Files.deleteIfExists(finalPath); } catch (Throwable ignored) {}
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
READY.put(url, finalPath);
|
|
||||||
VideoPlayerMod.LOG.info("[{}] preload: cached {} ({} bytes) -> {}",
|
VideoPlayerMod.LOG.info("[{}] preload: cached {} ({} bytes) -> {}",
|
||||||
VideoPlayerMod.MOD_ID, url, total, finalPath.getFileName());
|
VideoPlayerMod.MOD_ID, url, total, finalPath.getFileName());
|
||||||
long mb = Math.max(1, total / (1024 * 1024));
|
long mb = Math.max(1, total / (1024 * 1024));
|
||||||
|
|||||||
Reference in New Issue
Block a user