lose - Code Search

lib/time/mkzip.go

		if err != nil {
			log.Fatal(err)
		}
		if _, err := w.Write(data); err != nil {
			log.Fatal(err)
		}
		seen[name] = true
		return nil
	})
	if err != nil {
		log.Fatal(err)
	}
	if err := zw.Close(); err != nil {
		log.Fatal(err)
	}
	if len(seen) == 0 {
		log.Fatalf("did not find any files to add")
	}
	if !seen["US/Eastern"] {
		log.Fatalf("did not find US/Eastern to add")
	}

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Mon Mar 04 17:32:07 GMT 2024

- 2.1K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/AboutTheStubs.html

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
        "http://www.w3.org/TR/html4/loose.dtd">
<!--
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.  See the NOTICE file
distributed with this work for additional information
regarding copyright ownership.  The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance

Created: Sun Dec 28 03:35:09 GMT 2025

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

- 2.3K bytes

- Click Count (0)

github.com/tensorflow/tensorflow

.github/workflows/create_issue.js

    assignees: assignee_logins,
    title: `Issue created for Rollback of PR #${pr_number}: ${pr_title}`,
    body: `Merged PR #${pr_number} is rolled back in ${rollback_commit}.
    Please follow up with the reviewer and close this issue once its resolved.`
  });
  return `Issue created: ${resp.data.number} with Title: ${resp.data.title}`;

Created: Tue Dec 30 12:39:10 GMT 2025

- Last Modified: Mon Oct 18 23:04:59 GMT 2021

- 2.8K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

  private val routeB1 = factory.newRoute(addressB)
  private val addressC = factory.newAddress("c")
  private val routeC1 = factory.newRoute(addressC)

  @AfterEach fun tearDown() {
    factory.close()
    peer.close()
  }

  @Test fun connectionsEvictedWhenIdleLongEnough() {
    val pool = factory.newConnectionPool()
    val c1 = factory.newConnection(pool, routeA1, 50L)

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Tue Oct 07 21:55:03 GMT 2025

- 8.2K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/util/SMBUtilTest.java

        for (long time : testTimes) {
            SMBUtil.writeTime(time, buffer, 0);
            long readTime = SMBUtil.readTime(buffer, 0);

            // Account for precision loss in conversion
            long expectedTime = ((time + SmbConstants.MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L) / 10000L
                    - SmbConstants.MILLISECONDS_BETWEEN_1970_AND_1601;

Created: Sat Dec 20 13:44:44 GMT 2025

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

- 11.1K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/util/SimpleCircuitBreaker.java

     *
     * @param name the circuit breaker name
     * @param failureThreshold number of consecutive failures to open circuit
     * @param successThreshold number of successes in half-open to close circuit
     * @param timeoutMillis timeout before attempting to close open circuit
     */
    public SimpleCircuitBreaker(String name, int failureThreshold, int successThreshold, long timeoutMillis) {
        this.name = name;

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sat Aug 30 05:58:03 GMT 2025

- 11.3K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

     *
     * @throws IOException if a network error occurs
     */

    @Override
    public void close() throws IOException {
        try {
            file.close();
            tmp = null;
        } catch (final SmbException se) {
            throw seToIoe(se);
        }
    }

    /**

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 9.4K bytes

- Click Count (0)

github.com/google/guava

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

    StringWriter writer = new StringWriter();
    char[] buf = new char[64];
    int read;
    while ((read = reader.read(buf)) != -1) {
      writer.write(buf, 0, read);
    }
    reader.close();
    writer.close();

    assertTrue(source.wasStreamClosed());
    assertEquals(STRING, writer.toString());
  }

  public void testLines() throws IOException {
    source = new TestCharSource(LINES);

Created: Fri Dec 26 12:43:10 GMT 2025

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

- 11.5K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    fakePool.runAll();

    // Check that this thread has been marked as interrupted again now that the thread has been
    // returned by SequentialExecutor. Clear the bit while checking so that the test doesn't hose
    // JUnit or some other test case.
    assertThat(Thread.interrupted()).isTrue();
  }

  public void testInterrupt_doesNotInterruptSubsequentTask() throws Exception {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Fri Jul 11 18:52:30 GMT 2025

- 11.4K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb1/com/SmbComTreeDisconnect.java

 * It releases the tree ID and terminates access to the share.
 */
public class SmbComTreeDisconnect extends ServerMessageBlock {

    /**
     * Constructs a tree disconnect request to close a connection to a shared resource.
     *
     * @param config the configuration to use
     */
    public SmbComTreeDisconnect(final Configuration config) {
        super(config, SMB_COM_TREE_DISCONNECT);
    }

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 2.1K bytes

- Click Count (0)

Search Options