mirror of
https://github.com/ferdzo/fs.git
synced 2026-08-03 05:36:47 +00:00
Compare commits
1 Commits
fix/stream
...
53b359d988
| Author | SHA1 | Date | |
|---|---|---|---|
| 53b359d988 |
20
api/api.go
20
api/api.go
@@ -43,14 +43,8 @@ const (
|
|||||||
maxObjectKeyBytes = 1024
|
maxObjectKeyBytes = 1024
|
||||||
maxAWSChunkedLineBytes = 8 << 10
|
maxAWSChunkedLineBytes = 8 << 10
|
||||||
serverReadHeaderTimeout = 5 * time.Second
|
serverReadHeaderTimeout = 5 * time.Second
|
||||||
// serverReadTimeout and serverWriteTimeout are disabled on purpose: both
|
serverReadTimeout = 60 * time.Second
|
||||||
// cover the full request/response lifetime including streaming bodies, so a
|
serverWriteTimeout = 120 * time.Second
|
||||||
// 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
|
||||||
@@ -277,14 +271,8 @@ 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)
|
||||||
if _, err = io.Copy(w, stream); err != nil && !errors.Is(err, context.Canceled) {
|
_, err = io.Copy(w, stream)
|
||||||
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