key - Code Search

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt

  internal const val CLOSE_NO_STATUS_CODE = 1005

  fun toggleMask(
    cursor: Buffer.UnsafeCursor,
    key: ByteArray,
  ) {
    var keyIndex = 0
    val keyLength = key.size
    do {
      val buffer = cursor.data
      var i = cursor.start
      val end = cursor.end
      if (buffer != null) {
        while (i < end) {

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Wed Mar 19 19:25:20 UTC 2025

- 4.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/util/transport/Transport.java

    }

    /**
     * Generate a unique key for the given request
     *
     * @param request the request to generate a key for
     * @return the generated key
     * @throws IOException if an I/O error occurs
     */
    protected abstract long makeKey(Request request) throws IOException;

    /**
     * Peek at the next key without removing it from the input stream
     *

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

- Last Modified: Sun Aug 31 08:00:57 UTC 2025

- 27.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

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

    /**
     * Create a new directory lease context
     *
     * @param key the lease key
     * @param leaseState requested lease state
     * @param scope cache scope for directory entries
     */
    public DirectoryLeaseContext(Smb2LeaseKey key, int leaseState, DirectoryCacheScope scope) {
        this.leaseKey = key;
        this.leaseState = leaseState;
        this.cacheScope = scope;

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

- Last Modified: Sat Aug 23 02:21:31 UTC 2025

- 9.4K bytes

- Viewed (0)

github.com/google/guava

guava-testlib/src/com/google/common/collect/testing/google/SetMultimapAsMapTester.java

  public void testAsMapGetImplementsSet() {
    for (K key : multimap().keySet()) {
      assertTrue(multimap().asMap().get(key) instanceof Set);
    }
  }

  @MapFeature.Require(SUPPORTS_REMOVE)
  public void testAsMapRemoveImplementsSet() {
    List<K> keys = new ArrayList<>(multimap().keySet());
    for (K key : keys) {
      resetCollection();
      assertTrue(multimap().asMap().remove(key) instanceof Set);
    }
  }

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

- Last Modified: Tue May 13 17:27:14 UTC 2025

- 4.3K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/RemoteSnapshotMetadata.java

        if (versioning != null) {
            for (SnapshotVersion sv : versioning.getSnapshotVersions()) {
                String key = getKey(sv.getClassifier(), sv.getExtension());
                if (!versions.containsKey(key)) {
                    versions.put(key, sv);
                }
            }
        }

        metadata.getVersioning().setSnapshotVersions(new ArrayList<>(versions.values()));

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

- Last Modified: Fri Oct 25 12:31:46 UTC 2024

- 5.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb1/com/SmbComNegotiateResponseTest.java

        int bufferIndex = 0;
        byte[] key = new byte[] { 1, 2, 3, 4, 5, 6, 7, 8 };
        System.arraycopy(key, 0, buffer, bufferIndex, key.length);
        bufferIndex += key.length;
        System.arraycopy(domainBytes, 0, buffer, bufferIndex, domainBytes.length);

        response.readBytesWireFormat(buffer, 0);

        assertArrayEquals(key, response.getServerData().encryptionKey);

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

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

- 11.4K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/cache/AbstractCache.java

  @Override
  public ImmutableMap<K, V> getAllPresent(Iterable<? extends Object> keys) {
    Map<K, V> result = new LinkedHashMap<>();
    for (Object key : keys) {
      if (!result.containsKey(key)) {
        @SuppressWarnings("unchecked")
        K castKey = (K) key;
        V value = getIfPresent(key);
        if (value != null) {
          result.put(castKey, value);
        }
      }
    }
    return ImmutableMap.copyOf(result);

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

- Last Modified: Tue May 13 17:27:14 UTC 2025

- 9.1K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/amqp.go

	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
	if err != nil {
		return err
	}
	key := eventData.S3.Bucket.Name + "/" + objectName

	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
	if err != nil {
		return err
	}

	headers := make(amqp091.Table)

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

- Last Modified: Thu Aug 21 04:25:07 UTC 2025

- 10K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/nsq.go

func (target *NSQTarget) send(eventData event.Event) error {
	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
	if err != nil {
		return err
	}
	key := eventData.S3.Bucket.Name + "/" + objectName

	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
	if err != nil {
		return err
	}

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

- Last Modified: Sun Mar 30 00:56:02 UTC 2025

- 7.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/role/admin_role_edit.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.role_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

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

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

- 3.4K bytes

- Viewed (0)

Search Options