补充修复

Author: 豆腐花

memcache_req.go

@@ -8,7 +8,6 @@ import (
 	"io"
 	"strconv"
 	"strings"
-	"time"
 )
 
 // RealtimeMaxDelta is max delta time.
@@ -127,11 +126,11 @@ func ReadRequest(r *bufio.Reader) (req *Request, err error) {
 		if err != nil {
 			return nil, NewError("cannot read exptime " + err.Error())
 		}
-		if req.Exptime > 0 {
-			if req.Exptime <= RealtimeMaxDelta {
-				req.Exptime = time.Now().Unix()/1e9 + req.Exptime
-			}
-		}
+		// if req.Exptime > 0 {
+		// 	if req.Exptime <= RealtimeMaxDelta { // <= 30 days
+		// 		req.Exptime = time.Now().Unix() + req.Exptime
+		// 	}
+		// }
 
 		bytes, err := strconv.Atoi(arr[4])
 		if err != nil {
@@ -172,7 +171,7 @@ func ReadRequest(r *bufio.Reader) (req *Request, err error) {
 		}
 		req := &Request{}
 		req.Command = arr[0]
-		req.Key = arr[2]
+		req.Key = arr[1]
 
 		if len(arr) > 2 && arr[2] == "noreply" {
 			req.Noreply = true
@@ -223,11 +222,11 @@ func ReadRequest(r *bufio.Reader) (req *Request, err error) {
 		if err != nil {
 			return nil, NewError("cannot read exptime " + err.Error())
 		}
-		if req.Exptime > 0 {
-			if req.Exptime <= RealtimeMaxDelta {
-				req.Exptime = time.Now().Unix()/1e9 + req.Exptime
-			}
-		}
+		// if req.Exptime > 0 {
+		// 	if req.Exptime <= RealtimeMaxDelta { // <= 30 days
+		// 		req.Exptime = time.Now().Unix() + req.Exptime
+		// 	}
+		// }
 
 		if len(arr) > 3 && arr[3] == "noreply" {
 			req.Noreply = true

memcached_test.go

@@ -117,14 +117,8 @@ func DefaultSet(ctx context.Context, req *Request, res *Response) error {
 }
 
 func DefaultDelete(ctx context.Context, req *Request, res *Response) error {
-	count := 0
-	for _, key := range req.Keys {
-		if _, exists := memStore.Load(key); exists {
-			memStore.Delete(key)
-			count++
-		}
-	}
-	if count > 0 {
+	if _, exists := memStore.Load(req.Key); exists {
+		memStore.Delete(req.Key)
 		res.Response = RespDeleted
 	} else {
 		res.Response = RespNotFound