|
|
|
|
@@ -222,16 +222,18 @@ func New(address string, memorySize string, diskSize string, diskPath, upstream,
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
transport := &http.Transport{
|
|
|
|
|
MaxIdleConns: 100,
|
|
|
|
|
MaxIdleConnsPerHost: 10,
|
|
|
|
|
IdleConnTimeout: 90 * time.Second,
|
|
|
|
|
MaxIdleConns: 200, // Increased from 100
|
|
|
|
|
MaxIdleConnsPerHost: 50, // Increased from 10
|
|
|
|
|
IdleConnTimeout: 120 * time.Second, // Increased from 90s
|
|
|
|
|
DialContext: (&net.Dialer{
|
|
|
|
|
Timeout: 30 * time.Second,
|
|
|
|
|
KeepAlive: 30 * time.Second,
|
|
|
|
|
}).DialContext,
|
|
|
|
|
TLSHandshakeTimeout: 10 * time.Second,
|
|
|
|
|
ResponseHeaderTimeout: 10 * time.Second,
|
|
|
|
|
ExpectContinueTimeout: 1 * time.Second,
|
|
|
|
|
TLSHandshakeTimeout: 15 * time.Second, // Increased from 10s
|
|
|
|
|
ResponseHeaderTimeout: 30 * time.Second, // Increased from 10s
|
|
|
|
|
ExpectContinueTimeout: 5 * time.Second, // Increased from 1s
|
|
|
|
|
DisableCompression: true, // Steam doesn't use compression
|
|
|
|
|
ForceAttemptHTTP2: true, // Enable HTTP/2 if available
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
client := &http.Client{
|
|
|
|
|
@@ -453,18 +455,6 @@ func (sc *SteamCache) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
filename := filepath.Base(cacheKey)
|
|
|
|
|
expectedHash, hasHash := extractHashFromFilename(filename)
|
|
|
|
|
|
|
|
|
|
// Debug logging for manifest files
|
|
|
|
|
if strings.Contains(cacheKey, "manifest") {
|
|
|
|
|
logger.Logger.Debug().
|
|
|
|
|
Str("key", cacheKey).
|
|
|
|
|
Str("filename", filename).
|
|
|
|
|
Bool("hasHash", hasHash).
|
|
|
|
|
Str("expectedHash", expectedHash).
|
|
|
|
|
Int64("content_length_header", resp.ContentLength).
|
|
|
|
|
Int("actual_content_length", len(bodyData)).
|
|
|
|
|
Msg("Manifest file hash verification debug")
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Hash verification using Steam's X-Content-Sha header and content length verification
|
|
|
|
|
hashVerified := true
|
|
|
|
|
if hasHash {
|
|
|
|
|
@@ -522,7 +512,6 @@ func (sc *SteamCache) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
Str("key", cacheKey).
|
|
|
|
|
Str("host", r.Host).
|
|
|
|
|
Str("status", "MISS").
|
|
|
|
|
Bool("hash_verified", hasHash).
|
|
|
|
|
Dur("duration", time.Since(tstart)).
|
|
|
|
|
Msg("request")
|
|
|
|
|
|
|
|
|
|
|