fix:set expire timestamp(OpenAtomFoundation#1099) (OpenAtomFoundation#1413)

Signed-off-by: Hao Lee <1838249551@qq.com>

Author: ForestLH

src/storage/src/base_value_format.h

@@ -11,6 +11,7 @@
 #include "rocksdb/env.h"
 #include "rocksdb/slice.h"
 #include "src/coding.h"
+#include "src/redis.h"
 
 namespace storage {
 
@@ -24,10 +25,14 @@ class InternalValue {
     }
   }
   void set_timestamp(int32_t timestamp = 0) { timestamp_ = timestamp; }
-  void SetRelativeTimestamp(int32_t ttl) {
+  Status SetRelativeTimestamp(int32_t ttl) {
     int64_t unix_time;
     rocksdb::Env::Default()->GetCurrentTime(&unix_time);
     timestamp_ = static_cast<int32_t>(unix_time) + ttl;
+    if (timestamp_ != unix_time + static_cast<int64_t>(ttl)) {
+      return Status::InvalidArgument("invalid expire time");
+    }
+    return Status::OK();
   }
   void set_version(int32_t version = 0) { version_ = version; }
   static const size_t kDefaultValueSuffixLength = sizeof(int32_t) * 2;

src/storage/src/redis_strings.cc

@@ -690,7 +690,10 @@ Status RedisStrings::Setex(const Slice& key, const Slice& value, int32_t ttl) {
     return Status::InvalidArgument("invalid expire time");
   }
   StringsValue strings_value(value);
-  strings_value.SetRelativeTimestamp(ttl);
+  auto s = strings_value.SetRelativeTimestamp(ttl);
+  if (s != Status::OK()) {
+    return s;
+  }
   ScopeRecordLock l(lock_mgr_, key);
   return db_->Put(default_write_options_, key, strings_value.Encode());
 }