Browse Source

Merge branch 'master' into mq-subscribe

mq-subscribe
chrislu 10 months ago
parent
commit
36a3301e0c
  1. 4
      weed/iamapi/iamapi_management_handlers.go
  2. 6
      weed/util/log_buffer/log_read.go

4
weed/iamapi/iamapi_management_handlers.go

@ -3,6 +3,7 @@ package iamapi
import ( import (
"crypto/sha1" "crypto/sha1"
"encoding/json" "encoding/json"
"errors"
"fmt" "fmt"
"math/rand" "math/rand"
"net/http" "net/http"
@ -13,6 +14,7 @@ import (
"time" "time"
"github.com/seaweedfs/seaweedfs/weed/glog" "github.com/seaweedfs/seaweedfs/weed/glog"
"github.com/seaweedfs/seaweedfs/weed/pb/filer_pb"
"github.com/seaweedfs/seaweedfs/weed/pb/iam_pb" "github.com/seaweedfs/seaweedfs/weed/pb/iam_pb"
"github.com/seaweedfs/seaweedfs/weed/s3api/s3_constants" "github.com/seaweedfs/seaweedfs/weed/s3api/s3_constants"
"github.com/seaweedfs/seaweedfs/weed/s3api/s3err" "github.com/seaweedfs/seaweedfs/weed/s3api/s3err"
@ -424,7 +426,7 @@ func (iama *IamApiServer) DoActions(w http.ResponseWriter, r *http.Request) {
} }
values := r.PostForm values := r.PostForm
s3cfg := &iam_pb.S3ApiConfiguration{} s3cfg := &iam_pb.S3ApiConfiguration{}
if err := iama.s3ApiConfig.GetS3ApiConfiguration(s3cfg); err != nil {
if err := iama.s3ApiConfig.GetS3ApiConfiguration(s3cfg); err != nil && !errors.Is(err, filer_pb.ErrNotFound) {
s3err.WriteErrorResponse(w, r, s3err.ErrInternalError) s3err.WriteErrorResponse(w, r, s3err.ErrInternalError)
return return
} }

6
weed/util/log_buffer/log_read.go

@ -40,7 +40,7 @@ func (logBuffer *LogBuffer) LoopProcessLogData(readerName string, startPosition
if bytesBuf != nil { if bytesBuf != nil {
logBuffer.ReleaseMemory(bytesBuf) logBuffer.ReleaseMemory(bytesBuf)
} }
println("LoopProcessLogData", readerName, "sent messages total", entryCounter)
// println("LoopProcessLogData", readerName, "sent messages total", entryCounter)
}() }()
for { for {
@ -105,7 +105,7 @@ func (logBuffer *LogBuffer) LoopProcessLogData(readerName string, startPosition
} }
if stopTsNs != 0 && logEntry.TsNs > stopTsNs { if stopTsNs != 0 && logEntry.TsNs > stopTsNs {
isDone = true isDone = true
println("stopTsNs", stopTsNs, "logEntry.TsNs", logEntry.TsNs)
// println("stopTsNs", stopTsNs, "logEntry.TsNs", logEntry.TsNs)
return return
} }
lastReadPosition = NewMessagePosition(logEntry.TsNs, batchIndex) lastReadPosition = NewMessagePosition(logEntry.TsNs, batchIndex)
@ -125,7 +125,7 @@ func (logBuffer *LogBuffer) LoopProcessLogData(readerName string, startPosition
} }
glog.V(0).Infof("%s sent messages ts[%+v,%+v] size %d\n", readerName, startPosition, lastReadPosition, batchSize)
glog.V(4).Infof("%s sent messages ts[%+v,%+v] size %d\n", readerName, startPosition, lastReadPosition, batchSize)
} }
} }
Loading…
Cancel
Save