nobody - Code Search

cmd/bitrot-streaming.go

	shardSize  int64
	hashBytes  []byte
}

func (b *streamingBitrotReader) Close() error {
	if b.rc == nil {
		return nil
	}
	if closer, ok := b.rc.(io.Closer); ok {
		// drain the body for connection reuse at network layer.
		xhttp.DrainBody(io.NopCloser(b.rc))
		return closer.Close()
	}
	return nil
}

func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Jan 17 19:19:30 GMT 2025

- 6.2K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/tr/docs/tutorial/security/simple-oauth2.md

{* ../../docs_src/security/tutorial003_an_py310.py hl[4,78] *}

`OAuth2PasswordRequestForm`, şu alanları içeren bir form body tanımlayan bir class dependency’sidir:

* `username`.
* `password`.
* Boşlukla ayrılmış string’lerden oluşan büyük bir string olarak opsiyonel `scope` alanı.
* Opsiyonel `grant_type`.

/// tip | İpucu

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Mar 20 07:53:17 GMT 2026

- 10.4K bytes

- Click Count (0)

github.com/minio/minio

internal/dsync/dsync-server_test.go

	lockServers = make([]*lockServer, numberOfNodes)
)

func getLockArgs(r *http.Request) (args LockArgs, err error) {
	buf, err := io.ReadAll(r.Body)
	if err != nil {
		return args, err
	}
	_, err = args.UnmarshalMsg(buf)
	return args, err
}

type lockServerHandler struct {
	lsrv *lockServer
}

Created: Sun Apr 05 19:28:12 GMT 2026

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

- 8.3K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/http/NetworkExplorer.java

            out.println("    a:hover {");
            out.println("        background: #a2ff01;");
            out.println("    }");
        }

        out.println("</STYLE>");
        out.println("</head><body>");

        out.print("<a class=\"sort\" style=\"width: " + maxLen + ";\" href=\"?fmt=detail&sort=name\">Name</a>");
        out.println("<a class=\"sort\" href=\"?fmt=detail&sort=size\">Size</a>");

Created: Sun Apr 05 00:10:12 GMT 2026

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

- 22.6K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/js/suggestor.js

            isMouseHover = false;
          });

          this.resize();
          suggestor = this;
          $(window).resize(function () {
            suggestor.resize();
          });

          $("body").append($boxElement);
        },

        /**
         * Fetch and display suggestions based on current input
         */
        suggest: function () {
          suggestingSts = true;

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Nov 20 11:04:08 GMT 2025

- 13.3K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt

      .filter { "Cache" in it.simpleName!! }
      .also { eventRecorder.clearAllEvents() }

  private fun dnsResponse(s: String): MockResponse =
    MockResponse
      .Builder()
      .body(Buffer().write(s.decodeHex()))
      .addHeader("content-type", "application/dns-message")
      .addHeader("content-length", s.length / 2)
      .build()

  private fun buildLocalhost(

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Nov 04 19:13:52 GMT 2025

- 11.9K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb/SIDCacheImplTest.java

import jcifs.dcerpc.msrpc.LsaPolicyHandle;
import jcifs.dcerpc.msrpc.lsarpc;

@ExtendWith(MockitoExtension.class)
class SIDCacheImplTest {

    // Helper to create a SID from text without throwing in the test body
    private static SID sid(String textual) {
        try {
            return new SID(textual);
        } catch (SmbException e) {
            throw new RuntimeException(e);
        }
    }

    @Test

Created: Sun Apr 05 00:10:12 GMT 2026

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

- 14K bytes

- Click Count (0)

github.com/minio/minio

cmd/admin-handlers.go

		Timeout:   10 * time.Second,
	}

	resp, err := client.Do(req)
	if err != nil {
		ki.Error = err.Error()
		return ki
	}
	defer resp.Body.Close()
	decoder := json.NewDecoder(resp.Body)
	if err := decoder.Decode(&ki); err != nil {
		ki.Error = err.Error()
	}
	return ki
}

Created: Sun Apr 05 19:28:12 GMT 2026

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

- 99.7K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

    skip(buffer.size)
  }
}

/**
 * Attempts to exhaust this, returning true if successful. This is useful when reading a complete
 * source is helpful, such as when doing so completes a cache body or frees a socket connection for
 * reuse.
 */
internal fun Source.discard(
  timeout: Int,
  timeUnit: TimeUnit,
): Boolean =
  try {
    this.skipAll(timeout, timeUnit)
  } catch (_: IOException) {

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Jan 27 09:00:39 GMT 2026

- 10.3K bytes

- Click Count (1)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

      val callReference = reference as CallReference
      val message =
        "A connection to ${connection.route().address.url} was leaked. " +
          "Did you forget to close a response body?"
      Platform.get().logCloseableLeak(message, callReference.callStackTrace)

      references.removeAt(i)

      // If this was the last allocation, the connection is eligible for immediate eviction.

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Jan 27 09:00:39 GMT 2026

- 11.1K bytes

- Click Count (0)

Search Options