mirror of
https://github.com/ferdzo/fs.git
synced 2026-08-03 04:56:47 +00:00
Compare commits
1 Commits
fix/multi-
...
fix/stream
| Author | SHA1 | Date | |
|---|---|---|---|
| c16e9e292f |
20
api/api.go
20
api/api.go
@@ -43,8 +43,14 @@ const (
|
|||||||
maxObjectKeyBytes = 1024
|
maxObjectKeyBytes = 1024
|
||||||
maxAWSChunkedLineBytes = 8 << 10
|
maxAWSChunkedLineBytes = 8 << 10
|
||||||
serverReadHeaderTimeout = 5 * time.Second
|
serverReadHeaderTimeout = 5 * time.Second
|
||||||
serverReadTimeout = 60 * time.Second
|
// serverReadTimeout and serverWriteTimeout are disabled on purpose: both
|
||||||
serverWriteTimeout = 120 * time.Second
|
// cover the full request/response lifetime including streaming bodies, so a
|
||||||
|
// finite value truncates large uploads and downloads mid-flight. Read and
|
||||||
|
// idle liveness are still enforced by serverReadHeaderTimeout (header
|
||||||
|
// phase) and serverIdleTimeout (between keepalive requests), and concurrent
|
||||||
|
// load is bounded by serverMaxConnections.
|
||||||
|
serverReadTimeout = 0
|
||||||
|
serverWriteTimeout = 0
|
||||||
serverIdleTimeout = 120 * time.Second
|
serverIdleTimeout = 120 * time.Second
|
||||||
serverMaxHeaderBytes = 1 << 20
|
serverMaxHeaderBytes = 1 << 20
|
||||||
serverMaxConnections = 1024
|
serverMaxConnections = 1024
|
||||||
@@ -271,8 +277,14 @@ func (h *Handler) handleGetObject(w http.ResponseWriter, r *http.Request) {
|
|||||||
w.Header().Set("Last-Modified", time.Unix(manifest.CreatedAt, 0).UTC().Format(http.TimeFormat))
|
w.Header().Set("Last-Modified", time.Unix(manifest.CreatedAt, 0).UTC().Format(http.TimeFormat))
|
||||||
w.Header().Set("Accept-Ranges", "bytes")
|
w.Header().Set("Accept-Ranges", "bytes")
|
||||||
w.WriteHeader(http.StatusOK)
|
w.WriteHeader(http.StatusOK)
|
||||||
_, err = io.Copy(w, stream)
|
if _, err = io.Copy(w, stream); err != nil && !errors.Is(err, context.Canceled) {
|
||||||
|
h.logger.Warn("get_object_stream_failed",
|
||||||
|
"bucket", bucket,
|
||||||
|
"key", key,
|
||||||
|
"etag", manifest.ETag,
|
||||||
|
"error", err,
|
||||||
|
)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *Handler) handlePostObject(w http.ResponseWriter, r *http.Request) {
|
func (h *Handler) handlePostObject(w http.ResponseWriter, r *http.Request) {
|
||||||
|
|||||||
Reference in New Issue
Block a user