clone - Code Search

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 Dec 31 11:36:14 UTC 2025

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

- 23.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/netbios/SocketInputStream.java

    public int available() throws IOException {
        if (bip > 0) {
            return bip;
        }
        return in.available();
    }

    @Override
    public void close() throws IOException {
        in.close();
    }

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

- Last Modified: Thu Aug 14 07:14:38 UTC 2025

- 3.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

  internal val writeTimeout = StreamTimeout()

  /**
   * The reason why this stream was closed, or null if it closed normally or has not yet been
   * closed.
   *
   * If there are multiple reasons to abnormally close this stream (such as both peers closing it
   * near-simultaneously) then this is the first reason known to this peer.
   */
  internal var errorCode: ErrorCode? = null
    get() = withLock { field }

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

- Last Modified: Mon Jul 07 18:57:05 UTC 2025

- 22.4K bytes

- Viewed (0)

github.com/square/okhttp

mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

  @Test
  fun closeWithoutStart() {
    val server = MockWebServer()
    server.close()
  }

  @Test
  fun closeViaClosable() {
    val server: Closeable = MockWebServer()
    server.close()
  }

  @Test
  fun closeWithoutEnqueue() {
    val server = MockWebServer()
    server.start()
    server.close()
  }

  @Test
  fun portValidAfterStart() {

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

- Last Modified: Sun Aug 03 22:38:00 UTC 2025

- 28K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/documentation/src/test/resources/org/gradle/test/GroovyClassWithImports.groovy

package org.gradle.test

import org.gradle.test.sub.*;

class GroovyClassWithImports extends SubGroovyClass implements SubJavaInterface, GroovyInterface {
    void close() {
    }
}

Registered: Wed Dec 31 11:36:14 UTC 2025

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

- 228 bytes

- Viewed (0)

github.com/google/guava

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

              throw new IllegalStateException("More than one source open");
            }
            return new FilterInputStream(source.openStream()) {
              @Override
              public void close() throws IOException {
                super.close();
                counter[0]--;
              }
            };
          }
        };
    byte[] result = ByteSource.concat(checker, checker, checker).read();

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

- Last Modified: Tue Oct 28 18:44:53 UTC 2025

- 4.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/post-policy-fan-out.go

			if err != nil {
				errs[idx] = err
				return
			}

			reader := NewPutObjReader(hr)
			defer func() {
				if err := reader.Close(); err != nil {
					errs[idx] = err
				}
				if err := hr.Close(); err != nil {
					errs[idx] = err
				}
			}()

			userDefined := make(map[string]string, len(req.UserMetadata))
			maps.Copy(userDefined, req.UserMetadata)

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

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

- 3.5K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/nsq.go

	}

	if err := target.send(eventData); err != nil {
		return err
	}

	// Delete the event from store.
	return target.store.Del(key)
}

// Close - closes underneath connections to NSQD server.
func (target *NSQTarget) Close() (err error) {
	close(target.quitCh)
	if target.producer != nil {
		// this blocks until complete:
		target.producer.Stop()
	}
	return nil
}

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/minio/minio

.github/workflows/lock.yml

    runs-on: ubuntu-latest
    steps:
      - uses: dessant/lock-threads@v3
        with:
          github-token: ${{ github.token }}
          issue-inactive-days: '365'
          exclude-any-issue-labels: 'do-not-close'
          issue-lock-reason: 'resolved'

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

- Last Modified: Sun Jan 30 03:27:43 UTC 2022

- 447 bytes

- Viewed (0)

github.com/go-gorm/gorm

tests/prepared_stmt_test.go

	}

	pdb.Mux.Lock()
	if len(pdb.Stmts.Keys()) == 0 {
		pdb.Mux.Unlock()
		t.Fatalf("prepared stmt can not be empty")
	}
	pdb.Mux.Unlock()

	pdb.Close()
	pdb.Mux.Lock()
	defer pdb.Mux.Unlock()
	if len(pdb.Stmts.Keys()) != 0 {
		t.Fatalf("prepared stmt should be empty")
	}
}

func isUsingClosedConnError(err error) bool {

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

- Last Modified: Fri Apr 25 08:22:26 UTC 2025

- 8K bytes

- Viewed (0)

Search Options