log2 - Code Search

internal/store/store.go

		key.Name = strings.TrimSuffix(key.Name, key.Extension)
	}
	return key
}

// replayItems - Reads the items from the store and replays.
func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key {
	keyCh := make(chan Key)

	go func() {
		defer xioutil.SafeClose(keyCh)

		retryTicker := time.NewTicker(retryInterval)
		defer retryTicker.Stop()

		for {

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 4.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/profile/index.jsp

<script src="${fe:url('/css/admin/respond.min.js')}"></script>
<![endif]-->
</head>
<body class="hold-transition login-page">
	<div class="login-box">
		<div class="login-logo">
			<la:link href="/">
				<img src="${fe:url('/images/logo-top.png')}"
					alt="<la:message key="labels.header_brand_name" />" />
			</la:link>
		</div>
		<div class="card">
			<div class="card-body login-card-body">
				<p class="login-box-msg">

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Nov 13 05:54:52 UTC 2025

- 3.6K bytes

- Viewed (0)

github.com/minio/minio

go.mod

	github.com/go-asn1-ber/asn1-ber v1.5.8-0.20250403174932-29230038a667 // indirect
	github.com/go-ini/ini v1.67.0 // indirect
	github.com/go-jose/go-jose/v4 v4.1.0 // indirect
	github.com/go-logr/logr v1.4.2 // indirect
	github.com/go-logr/stdr v1.2.2 // indirect
	github.com/go-ole/go-ole v1.3.0 // indirect
	github.com/go-openapi/analysis v0.23.0 // indirect
	github.com/go-openapi/errors v0.22.1 // indirect

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Fri Oct 10 18:57:03 UTC 2025

- 12.2K bytes

- Viewed (0)

github.com/minio/minio

docs/resiliency/resiliency-verify-failure-script.sh

echo "script failed" >resiliency-verify-failure.log # assume initial state

ALIAS_NAME=myminio
BUCKET="test-bucket"
DEST_DIR="/tmp/dest"

OUT=$(./mc cp --quiet --recursive "${ALIAS_NAME}"/"${BUCKET}"/initial-data/ "${DEST_DIR}"/)
RET=${?}
if [ ${RET} -ne 0 ]; then
	# It is a success scenario as get objects should fail
	echo "GET objects failed as expected"
	echo "script passed" >resiliency-verify-failure.log
	exit 0
else

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sat Dec 21 04:24:45 UTC 2024

- 509 bytes

- Viewed (0)

github.com/minio/minio

docs/site-replication/run-sse-kms-object-replication.sh

#!/usr/bin/env bash

# shellcheck disable=SC2120
exit_1() {
	cleanup

	echo "minio1 ============"
	cat /tmp/minio1_1.log
	echo "minio2 ============"
	cat /tmp/minio2_1.log
	echo "minio3 ============"
	cat /tmp/minio3_1.log
	echo "minio4 ============"
	cat /tmp/minio4_1.log
	exit 1
}

cleanup() {
	echo -n "Cleaning up instances of MinIO ..."
	pkill -9 minio || sudo pkill -9 minio
	pkill -9 kes || sudo pkill -9 kes

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Thu Oct 10 06:49:55 UTC 2024

- 11.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java

import jcifs.CIFSContext;
import jcifs.Configuration;
import jcifs.smb.SmbFile;

/**
 * Manager for directory leases and caching
 */
public class DirectoryLeaseManager {

    private static final Logger log = LoggerFactory.getLogger(DirectoryLeaseManager.class);

    private final CIFSContext context;
    private final LeaseManager baseLeaseManager;
    private final ConcurrentHashMap<String, DirectoryCacheEntry> directoryCache;

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 23 01:47:47 UTC 2025

- 12.3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/rdma/disni/DisniMemoryRegion.java

        log.debug("DiSNI memory region registered, size: {}", buffer.remaining());
    }

    @Override
    public void invalidate() {
        if (valid && memoryRegister != null) {
            try {
                // In real implementation, this would deregister the memory:
                // memoryRegister.deregisterMemory();

                log.debug("DiSNI memory region invalidated");

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 23 05:11:12 UTC 2025

- 5.3K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/sql/StatementUtil.java

import static org.codelibs.core.log.Logger.format;
import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotEmpty;
import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.codelibs.core.exception.SQLRuntimeException;
import org.codelibs.core.log.Logger;

/**

Registered: Sat Dec 20 08:55:33 UTC 2025

- Last Modified: Thu Jul 31 08:16:49 UTC 2025

- 5K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/zip/ZipInputStreamUtil.java

 */
package org.codelibs.core.zip;

import static org.codelibs.core.log.Logger.format;
import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull;

import java.io.IOException;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;

import org.codelibs.core.exception.IORuntimeException;
import org.codelibs.core.log.Logger;

/**
 * Utility class for handling {@link java.util.zip.ZipInputStream}.

Registered: Sat Dec 20 08:55:33 UTC 2025

- Last Modified: Thu Jul 31 08:16:49 UTC 2025

- 2.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

                availableReceiveRegions.offer(region);
                totalAllocated.incrementAndGet();
            } catch (IOException e) {
                log.warn("Failed to pre-allocate receive buffer", e);
            }
        }

        log.info("Initialized RDMA buffer pool with {} send and {} receive buffers", availableSendRegions.size(),
                availableReceiveRegions.size());
    }

    /**

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 23 05:11:12 UTC 2025

- 8.7K bytes

- Viewed (0)

Search Options