// Verify that writeQuestionSectionWireFormat was called
        verify((NameServicePacket) request, times(1)).writeQuestionSectionWireFormat(dst, dstIndex);
        assertEquals(10, result);
    }

    @Test
    void testReadBodyWireFormat() {
        // Test that readBodyWireFormat calls readQuestionSectionWireFormat

 */

package com.google.common.util.concurrent;

import static com.google.common.util.concurrent.MoreExecutors.directExecutor;

import com.google.caliper.BeforeExperiment;
import com.google.caliper.Param;
import com.google.caliper.api.Footprint;
import com.google.caliper.api.SkipThisScenarioException;
import com.google.common.util.concurrent.AbstractFutureBenchmarks.Facade;

 * the License.
 */

package com.google.common.io;

import com.google.caliper.BeforeExperiment;
import com.google.caliper.Benchmark;
import com.google.caliper.Param;
import com.google.caliper.api.VmOptions;
import java.io.IOException;
import java.io.StringReader;
import java.io.StringWriter;
import java.nio.Buffer;
import java.nio.CharBuffer;

                super.close(); // Call original close to set closeCalled
                throw new CIFSException("Test exception during close");
            }
        };

        // Simulate the shutdown hook being run
        spyContext.run();

        assertTrue(spyContext.isCloseCalled()); // Verify close() was called
        // We can't directly assert on log.warn, but we've covered the path

                return existingInfo;
            }

            @Override
            public void store(CrawlingInfo entity) {
                // Should not be called for existing info
                fail("Store should not be called for existing info");
            }

            @Override
            public void storeInfo(List<CrawlingInfoParam> crawlingInfoParamList) {

        // if a buffer isn't being cleared correctly, this method will eventually start being called
        // with a len of 0 forever
        if (len <= 0) {
          fail("read called with a len of " + len);
        }
        // read fewer than the max number of chars to read
        // shouldn't be a problem unless the buffer is shrinking each call
        return in.read(cbuf, off, Math.max(len - 1024, 0));
      }
    };
  }

        // if a buffer isn't being cleared correctly, this method will eventually start being called
        // with a len of 0 forever
        if (len <= 0) {
          fail("read called with a len of " + len);
        }
        // read fewer than the max number of chars to read
        // shouldn't be a problem unless the buffer is shrinking each call
        return in.read(cbuf, off, Math.max(len - 1024, 0));
      }
    };
  }

     * mirror, its URL and ID will be updated to match the values from the mirror specification. Repositories without a
     * matching mirror will pass through unchanged. Note: This method must be called before
     * {@link #injectAuthentication(List, List)} or the repositories will end up with the wrong credentials.
     *

            return loadCallback.call();
        }

        public void setLoadCallback(LoadCallback callback) {
            this.loadCallback = callback;
        }

        public int getLoadCallCount() {
            return loadCallCount.get();
        }
    }

    @FunctionalInterface
    interface LoadCallback {
        int call();
    }

//	}
//	close(c.done)
// }

// removeOldest removes the oldest item from the cache. Has to be called with lock!
func (c *LRU[K, V]) removeOldest() {
	if ent := c.evictList.Back(); ent != nil {
		c.removeElement(ent)
	}
}

// removeElement is used to remove a given list element from the cache. Has to be called with lock!
func (c *LRU[K, V]) removeElement(e *Entry[K, V]) {
	c.evictList.Remove(e)