Mapper - Code Search

docs/bucket/replication/test_del_marker_proxying.sh

./mc mb siteb/bucket
./mc version enable siteb/bucket

# Set bucket replication
./mc replicate add sitea/bucket --remote-bucket siteb/bucket

# Run the test to make sure proxying of DEL marker doesn't happen
loop_count=0
while true; do
	if [ $loop_count -eq 1000 ]; then
		break
	fi
	echo "Hello World" | ./mc pipe sitea/bucket/obj$loop_count
	./mc rm sitea/bucket/obj$loop_count

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

- Last Modified: Sun Sep 29 22:40:36 UTC 2024

- 2.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb/SmbUnsupportedOperationExceptionTest.java

        });
        assertEquals("Operation is not supported with the negotiated capabilities", ex.getMessage());
    }

    @Test
    @DisplayName("Mockito: stubbed collaborator throws RuntimeException wrapper and interactions are verified")
    void mockInteraction_stubsThrow_andVerifiesInvocation() {
        // Arrange: Since SmbUnsupportedOperationException is a checked exception (extends IOException),

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

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 5.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/user/admin_user_details.jsp

</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">
    <jsp:include page="/WEB-INF/view/common/admin/header.jsp"></jsp:include>
    <jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp">
        <jsp:param name="menuCategoryType" value="user"/>
        <jsp:param name="menuType" value="user"/>
    </jsp:include>
    <main class="content-wrapper">
        <div class="content-header">

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

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

- 17.9K bytes

- Viewed (0)

github.com/apache/maven

api/maven-api-core/src/main/java/org/apache/maven/api/SessionData.java

     */
    <T> void set(@Nonnull Key<T> key, @Nullable T value);

    /**
     * Associates the specified session data with the given key if the key is currently mapped to the given value. This
     * method provides an atomic compare-and-update of some key's value.
     *
     * @param key the key under which to store the session data, must not be {@code null}

Registered: Sun Dec 28 03:35:09 UTC 2025

- Last Modified: Wed Feb 28 23:31:09 UTC 2024

- 4.7K bytes

- Viewed (0)

github.com/go-gorm/gorm

tests/create_test.go

		ID uint
	}
	DB.Migrator().DropTable(&EmptyStruct{})

	if err := DB.AutoMigrate(&EmptyStruct{}); err != nil {
		t.Errorf("no error should happen when auto migrate, but got %v", err)
	}

	if err := DB.Create(&EmptyStruct{}).Error; err != nil {
		t.Errorf("No error should happen when creating user, but got %v", err)
	}
}

func TestCreateEmptySlice(t *testing.T) {
	data := []User{}

Registered: Sun Dec 28 09:35:17 UTC 2025

- Last Modified: Mon Jul 21 09:55:20 UTC 2025

- 26.8K bytes

- Viewed (0)

github.com/minio/minio

internal/config/bool-flag.go

// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package config

import (
	"encoding/json"
	"fmt"
	"strconv"
	"strings"
)

// BoolFlag - wrapper bool type.
type BoolFlag bool

// String - returns string of BoolFlag.
func (bf BoolFlag) String() string {
	if bf {
		return "on"
	}

	return "off"
}

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

- Last Modified: Thu Apr 07 15:10:40 UTC 2022

- 2.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/postpolicyform.go

		return strings.HasPrefix(input1, input2)
	}
	return false
}

// S3 docs: "Each form field that you specify in a form (except x-amz-signature, file, policy, and field names
// that have an x-ignore- prefix) must appear in the list of conditions."
// https://docs.aws.amazon.com/AmazonS3/latest/API/sigv4-HTTPPOSTConstructPolicy.html
// keyInPolicyExceptions - list of keys that, when present in the form, can be missing in the conditions of the policy.

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

- Last Modified: Thu Oct 23 15:10:12 UTC 2025

- 12.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/cache/CacheEvictionTest.java

    assertThat(cache.asMap().keySet()).containsExactly(2, 4);

    CacheTesting.processPendingNotifications(cache);
    assertThat(removalListener.getCount()).isEqualTo(2);

    // Should we pepper more of these calls throughout the above? Where?
    CacheTesting.checkValidState(cache);
  }

  /**
   * Tests that when a single entry exceeds the segment's max weight, the new entry is immediately

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Tue Oct 28 18:19:59 UTC 2025

- 15.1K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/stream/StreamUtil.java

        return new StreamOf<>(() -> map != null ? map.entrySet().stream() : Collections.<K, V> emptyMap().entrySet().stream());
    }

    /**
     * A wrapper class for a {@link Stream} that provides utility methods.
     *
     * @param <T> the type of elements in the stream
     */
    public static class StreamOf<T> {

        private final Supplier<Stream<T>> supplier;

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

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

- 4.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/dynamic-timeouts.go

	if failPct > dynamicTimeoutIncreaseThresholdPct {
		// We are hitting the timeout too often, so increase the timeout by 25%
		timeout := min(
			// Set upper cap.
			atomic.LoadInt64(&dt.timeout)*125/100, int64(maxDynamicTimeout))
		// Safety, shouldn't happen
		if timeout < dt.minimum {
			timeout = dt.minimum
		}
		atomic.StoreInt64(&dt.timeout, timeout)
	} else if failPct < dynamicTimeoutDecreaseThresholdPct {

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

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 4.5K bytes

- Viewed (0)

Search Options