2 files changed, 14 insertions, 14 deletions

diff --git a/weed/s3api/s3err/audit_fluent.go b/weed/s3api/s3err/audit_fluent.go
index ef2459eac..5e7e2487c 100644
--- a/weed/s3api/s3err/audit_fluent.go
+++ b/weed/s3api/s3err/audit_fluent.go
@@ -8,8 +8,8 @@ import (
 	"time"
 
 	"github.com/fluent/fluent-logger-golang/fluent"
-	"github.com/seaweedfs/seaweedfs/weed/glog"
 	"github.com/seaweedfs/seaweedfs/weed/s3api/s3_constants"
+	"github.com/seaweedfs/seaweedfs/weed/util/log"
 )
 
 type AccessLogExtend struct {
@@ -57,12 +57,12 @@ var (
 func InitAuditLog(config string) {
 	configContent, readErr := os.ReadFile(config)
 	if readErr != nil {
-		glog.Errorf("fail to read fluent config %s : %v", config, readErr)
+		log.Errorf("fail to read fluent config %s : %v", config, readErr)
 		return
 	}
 	fluentConfig := &fluent.Config{}
 	if err := json.Unmarshal(configContent, fluentConfig); err != nil {
-		glog.Errorf("fail to parse fluent config %s : %v", string(configContent), err)
+		log.Errorf("fail to parse fluent config %s : %v", string(configContent), err)
 		return
 	}
 	if len(fluentConfig.TagPrefix) == 0 && len(environment) > 0 {
@@ -71,13 +71,13 @@ func InitAuditLog(config string) {
 	fluentConfig.Async = true
 	fluentConfig.AsyncResultCallback = func(data []byte, err error) {
 		if err != nil {
-			glog.Warning("Error while posting log: ", err)
+			log.Warningf("Error while posting log: %v", err)
 		}
 	}
 	var err error
 	Logger, err = fluent.New(*fluentConfig)
 	if err != nil {
-		glog.Errorf("fail to load fluent config: %v", err)
+		log.Errorf("fail to load fluent config: %v", err)
 	}
 }
 
@@ -170,15 +170,15 @@ func PostLog(r *http.Request, HTTPStatusCode int, errorCode ErrorCode) {
 		return
 	}
 	if err := Logger.Post(tag, *GetAccessLog(r, HTTPStatusCode, errorCode)); err != nil {
-		glog.Warning("Error while posting log: ", err)
+		log.Warningf("Error while posting log: %v", err)
 	}
 }
 
-func PostAccessLog(log AccessLog) {
-	if Logger == nil || len(log.Key) == 0 {
+func PostAccessLog(accessLog AccessLog) {
+	if Logger == nil || len(accessLog.Key) == 0 {
 		return
 	}
-	if err := Logger.Post(tag, log); err != nil {
-		glog.Warning("Error while posting log: ", err)
+	if err := Logger.Post(tag, accessLog); err != nil {
+		log.Warningf("Error while posting log: %v", err)
 	}
 }
diff --git a/weed/s3api/s3err/error_handler.go b/weed/s3api/s3err/error_handler.go
index 910dab12a..14fdb8819 100644
--- a/weed/s3api/s3err/error_handler.go
+++ b/weed/s3api/s3err/error_handler.go
@@ -6,7 +6,7 @@ import (
 	"fmt"
 	"github.com/aws/aws-sdk-go/private/protocol/xml/xmlutil"
 	"github.com/gorilla/mux"
-	"github.com/seaweedfs/seaweedfs/weed/glog"
+	"github.com/seaweedfs/seaweedfs/weed/util/log"
 	"net/http"
 	"strconv"
 	"strings"
@@ -93,10 +93,10 @@ func WriteResponse(w http.ResponseWriter, r *http.Request, statusCode int, respo
 	}
 	w.WriteHeader(statusCode)
 	if response != nil {
-		glog.V(4).Infof("status %d %s: %s", statusCode, mType, string(response))
+		log.V(-1).Infof("status %d %s: %s", statusCode, mType, string(response))
 		_, err := w.Write(response)
 		if err != nil {
-			glog.V(0).Infof("write err: %v", err)
+			log.V(3).Infof("write err: %v", err)
 		}
 		w.(http.Flusher).Flush()
 	}
@@ -104,6 +104,6 @@ func WriteResponse(w http.ResponseWriter, r *http.Request, statusCode int, respo
 
 // If none of the http routes match respond with MethodNotAllowed
 func NotFoundHandler(w http.ResponseWriter, r *http.Request) {
-	glog.V(0).Infof("unsupported %s %s", r.Method, r.RequestURI)
+	log.V(3).Infof("unsupported %s %s", r.Method, r.RequestURI)
 	WriteErrorResponse(w, r, ErrMethodNotAllowed)
 }