Bug 38434644 - [36166441->25.09] Using Long.MAX_VALUE as a ttl to a NamedCache put results in error

(merge main -> ce/main 118592)

[git-p4: depot-paths = "//dev/coherence-ce/main/": change = 118603]

Author: thegridman

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java

@@ -8,6 +8,7 @@
 package com.tangosol.coherence.component.util.daemon.queueProcessor.service.grid.partitionedService.partitionedCache;
 
 import com.oracle.coherence.common.base.Blocking;
+import com.oracle.coherence.common.base.TimeHelper;
 import com.oracle.coherence.persistence.PersistentStore;
 import com.tangosol.coherence.component.net.Lease;
 import com.tangosol.coherence.component.net.MemberSet;
@@ -737,6 +738,12 @@ public class Storage
 
     private static final Object[] EMPTY_OBJECT_ARRAY = new Object[0];
 
+    /**
+     * The maximum accepted value used in {#link {@link #scheduleEviction(long)}}.
+     * This equals {@link Long#MAX_VALUE} minus millis in one day
+     */
+    private static final long MAX_EXPIRY = Long.MAX_VALUE - TimeUnit.DAYS.toMillis(1);
+
     // Static initializer
     static
         {
@@ -9100,15 +9107,12 @@ protected static void rethrow(Throwable e)
      * Schedule to run the eviction task at specified expiry delay
      * (cExpiryMillis) if no task is currently scheduled.  Cancel the
      * existing task and create a new one if new expiry time is sooner than
-     * previosely scheduled one.
+     * previously scheduled one.
      *
      * @param cExpiryMillis   expiry delay in millis
      */
     public synchronized void scheduleEviction(long cExpiryMillis)
         {
-        // import Component.Util.DaemonPool as com.tangosol.coherence.component.util.DaemonPool;
-        // import com.tangosol.util.Base;
-
         com.tangosol.coherence.component.util.DaemonPool pool = getService().getDaemonPool();
 
         if (!pool.isStarted())
@@ -9126,7 +9130,22 @@ public synchronized void scheduleEviction(long cExpiryMillis)
             }
 
         long ldtOldNext = task.getEvictionTime();
-        long ldtNewNext = Base.getSafeTimeMillis() + cExpiryMillis;
+        long ldtNow     = TimeHelper.getSafeTimeMillis();
+        long ldtMax     = MAX_EXPIRY - ldtNow;
+
+        long ldtNewNext;
+        long ldtSchedule;
+
+        if (cExpiryMillis < ldtMax)
+            {
+            ldtNewNext  = ldtNow + cExpiryMillis;
+            ldtSchedule = cExpiryMillis;
+            }
+        else
+            {
+            ldtNewNext  = MAX_EXPIRY;
+            ldtSchedule = MAX_EXPIRY - ldtNow;
+            }
 
         task.setPrune(cExpiryMillis == 0L);
 

prj/test/functional/cache/src/main/java/cache/PutWithExpiryTests.java

@@ -0,0 +1,46 @@
+/*
+ * Copyright (c) 2000, 2025, Oracle and/or its affiliates.
+ *
+ * Licensed under the Universal Permissive License v 1.0 as shown at
+ * https://oss.oracle.com/licenses/upl.
+ */
+
+package cache;
+
+import com.oracle.coherence.common.base.TimeHelper;
+import com.tangosol.net.Coherence;
+import com.tangosol.net.NamedCache;
+import com.tangosol.net.Session;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import java.util.concurrent.TimeUnit;
+
+public class PutWithExpiryTests
+    {
+    @BeforeClass
+    public static void setup() throws Exception
+        {
+        session = Coherence.clusterMember().startAndWait().getSession();
+        }
+
+    @Test
+    public void shouldPutWithLongMaxValueExpiry() throws Exception
+        {
+        NamedCache<String, String> cache = session.getCache("test");
+        cache.put("key", "value", Long.MAX_VALUE);
+        }
+
+    @Test
+    public void shouldPutWithExpiryPastUnixEpochEnd() throws Exception
+        {
+        long epochEnd = Long.MAX_VALUE;
+        long now      = TimeHelper.getSafeTimeMillis();
+        long expiry   = epochEnd - now + TimeUnit.DAYS.toMillis(1);
+        // expiry delay would be one day past epoch end
+        NamedCache<String, String> cache = session.getCache("test");
+        cache.put("key", "value", expiry);
+        }
+
+    public static Session session;
+    }