lose - Code Search

okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt

 * `server_max_window_bits`. This harms our ability to support these parameters:
 *
 *  * If `client_max_window_bits` is less than 15, OkHttp must close the web socket with code 1010.
 *    Otherwise it would compress values in a way that servers could not decompress.
 *  * If `server_max_window_bits` is less than 15, OkHttp will waste memory on an oversized buffer.
 *

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 8.1K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/mqtt.go

	_, err := target.isActive()
	if err != nil {
		return err
	}

	return target.send(eventData)
}

// Close - does nothing and available for interface compatibility.
func (target *MQTTTarget) Close() error {
	if target.client != nil {
		target.client.Disconnect(100)
	}
	close(target.quitCh)
	return nil
}

func (target *MQTTTarget) init() error {
	return target.initOnce.Do(target.initMQTT)
}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Sep 06 23:06:30 UTC 2024

- 8.2K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/dependencies/tutorial010.py

class MySuperContextManager:
    def __init__(self):
        self.db = DBSession()

    def __enter__(self):
        return self.db

    def __exit__(self, exc_type, exc_value, traceback):
        self.db.close()


async def get_db():
    with MySuperContextManager() as db:

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Thu Mar 26 19:09:53 UTC 2020

- 292 bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

          windowSizeIncrement = increment,
        ),
      )
    }
    handler.windowUpdate(streamId, increment)
  }

  @Throws(IOException::class)
  override fun close() {
    source.close()
  }

  /**
   * Decompression of the header block occurs above the framing layer. This class lazily reads
   * continuation frames as they are needed by [Hpack.Reader.readHeaders].
   */

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 19.9K bytes

- Viewed (0)

github.com/minio/minio

internal/http/check_port_linux.go

	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
	if err != nil {
		return err
	}

	// As we are able to listen on this network, the port is not in use.
	// Close the listener and continue check other networks.
	return l.Close()

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Wed May 03 21:12:25 UTC 2023

- 1.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/fmt-gen.go

	if err != nil {
		log.Fatalln(err)
	}

	zipFile, err := os.Create("format.json.zip")
	if err != nil {
		log.Fatalf("failed to create format.json.zip: %v", err)
	}
	defer zipFile.Close()
	fmtZipW := zip.NewWriter(zipFile)
	defer fmtZipW.Close()
	for _, pool := range pools { // for each pool
		setCount, setDriveCount := pool.SetCount, pool.DrivesPerSet
		format := newFormatErasureV3(setCount, setDriveCount)
		format.ID = deploymentID

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Tue Aug 13 22:22:04 UTC 2024

- 3.7K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic-commons/code-quality-rules/src/main/resources/classycle/classycle_report_resources.zip

+ "</td>"; } text += "</tr>"; } } text += "</table>"; } showText(text); } function showText(text) { list = window.open("", "list", "dependent=yes,location=no,menubar=yes,resizable=yes,toolbar=no,scrollbars=yes,width=500,height=400"); list.document.close(); list.document.open(); list.document.write("<html><head><style type=\"text/css\">"); list.document.write("body { font-family:Helvetica,Arial,sans-serif; } "); list.document.write(".link { cursor:pointer;text-decoration:underline; } "); list.document.writeln("th...

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Wed Dec 09 08:14:05 UTC 2020

- 23.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/ByteSinkTester.java

    } finally {
      out.close();
    }

    assertContainsExpectedBytes();
  }

  public void testOpenBufferedStream() throws IOException {
    OutputStream out = sink.openBufferedStream();
    try {
      ByteStreams.copy(new ByteArrayInputStream(data), out);
    } finally {
      out.close();
    }

    assertContainsExpectedBytes();
  }

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Jul 23 14:22:54 UTC 2024

- 4K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/io/ByteSinkTester.java

    } finally {
      out.close();
    }

    assertContainsExpectedBytes();
  }

  public void testOpenBufferedStream() throws IOException {
    OutputStream out = sink.openBufferedStream();
    try {
      ByteStreams.copy(new ByteArrayInputStream(data), out);
    } finally {
      out.close();
    }

    assertContainsExpectedBytes();
  }

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Jul 23 14:22:54 UTC 2024

- 4K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/jar/JarFileUtil.java

     * Jarファイルをクローズします。
     * <p>
     * {@link JarFile#close()}が例外をスローした場合はログにエラーメッセージを出力します。 例外は再スローされません。
     * </p>
     *
     * @param jarFile
     *            Jarファイル。{@literal null}であってはいけません
     */
    public static void close(final JarFile jarFile) {
        assertArgumentNotNull("jarFile", jarFile);

        try {
            jarFile.close();
        } catch (final IOException e) {

Registered: Fri Nov 01 20:58:10 UTC 2024

- Last Modified: Thu Mar 07 01:59:08 UTC 2024

- 5.4K bytes

- Viewed (0)

Search Options