getZ - Code Search

android/guava/src/com/google/common/hash/LongAdder.java

    Cell[] as;
    long b, v;
    int[] hc;
    Cell a;
    int n;
    if ((as = cells) != null || !casBase(b = base, b + x)) {
      boolean uncontended = true;
      if ((hc = threadHashCode.get()) == null
          || as == null
          || (n = as.length) < 1
          || (a = as[(n - 1) & hc[0]]) == null
          || !(uncontended = a.cas(v = a.value, v + x))) retryUpdate(x, hc, uncontended);
    }
  }

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

- Last Modified: Thu Mar 20 13:05:10 GMT 2025

- 5.5K bytes

- Click Count (0)

github.com/apache/maven

README.md

Documentation
-------------

More information can be found on [Apache Maven Homepage][maven-home].
Questions related to the usage of Maven should be posted on
the [Maven User List][users-list].


Where can I get the latest release?
-----------------------------------
You can download the release source from our [download page][maven-download].

Contributing
------------

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

- Last Modified: Sun Nov 16 13:30:57 GMT 2025

- 4.8K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_body/test_tutorial001.py

        response = client.post("/items/", json={"test": "test2"})
        assert response.status_code == 400, response.text


def test_openapi_schema(client: TestClient):
    response = client.get("/openapi.json")
    assert response.status_code == 200, response.text
    assert response.json() == {
        "openapi": "3.1.0",
        "info": {"title": "FastAPI", "version": "0.1.0"},
        "paths": {

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sat Dec 27 18:19:10 GMT 2025

- 10.6K bytes

- Click Count (0)

github.com/minio/minio

cmd/listen-notification-handlers.go

		if peer == nil {
			continue
		}
		peer.Listen(ctx, mergeCh, values)
	}

	var (
		emptyEventTicker <-chan time.Time
		keepAliveTicker  <-chan time.Time
	)

	if p := values.Get("ping"); p != "" {
		pingInterval, err := strconv.Atoi(p)
		if err != nil {
			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidQueryParams), r.URL)
			return
		}
		if pingInterval < 1 {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Feb 18 16:25:55 GMT 2025

- 6K bytes

- Click Count (0)

github.com/minio/minio

docs/debugging/reorder-disks/main.go

		if err != nil {
			log.Printf("Unable to read format.json from `%s`, error: %v\n", disk.path, err)
			continue
		}
		foundDiskLoc, err := getDiskLocation(format)
		if err != nil {
			log.Printf("Unable to get disk location of `%s`, error: %v\n", disk.path, err)
			continue
		}
		actualDisksName[foundDiskLoc] = disk.path
	}

	uuidMap, err := getDiskUUIDMap()
	if err != nil {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri May 24 23:05:23 GMT 2024

- 5.4K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/go/GoAction.java

                final SearchLogHelper searchLogHelper = ComponentUtil.getSearchLogHelper();
                final ClickLog clickLog = new ClickLog();
                clickLog.setUrlId((String) doc.get(fessConfig.getIndexFieldId()));
                clickLog.setUrl(url);
                clickLog.setRequestedAt(systemHelper.getCurrentTimeAsLocalDateTime());

Created: Sat Dec 20 09:19:18 GMT 2025

- Last Modified: Thu Dec 11 09:47:03 GMT 2025

- 9K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/opensearch/user/bsbhv/BsRoleBhv.java

        try {
            final RESULT result = entityType.newInstance();
            result.setName(DfTypeUtil.toString(source.get("name")));
            return updateEntity(source, result);
        } catch (InstantiationException | IllegalAccessException e) {
            final String msg = "Cannot create a new instance: " + entityType.getName();

Created: Sat Dec 20 09:19:18 GMT 2025

- Last Modified: Sat Mar 15 06:53:53 GMT 2025

- 8.8K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/index.jsp

<link href="${fe:url('/css/style.css')}" rel="stylesheet" type="text/css" />
<link href="${fe:url('/css/font-awesome.min.css')}" rel="stylesheet"
	type="text/css" />
</head>
<body>
	<la:form action="/search" method="get" styleId="searchForm">
		${fe:facetForm()}${fe:geoForm()}
		<header>
			<nav class="navbar navbar-expand-md navbar-dark fixed-top bg-dark">
				<div id="content" class="container">
					<div class="navbar-brand"></div>

Created: Sat Dec 20 09:19:18 GMT 2025

- Last Modified: Thu Nov 20 05:40:20 GMT 2025

- 7K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

    if (headerName.equals(name(h), ignoreCase = true)) {
      val header = Buffer().writeUtf8(value(h))
      try {
        header.readChallengeHeader(result)
      } catch (e: EOFException) {
        Platform.get().log("Unable to parse challenge", Platform.WARN, e)
      }
    }
  }
  return result
}

@Throws(EOFException::class)
private fun Buffer.readChallengeHeader(result: MutableList<Challenge>) {

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

- Last Modified: Mon May 05 16:01:00 GMT 2025

- 7.2K bytes

- Click Count (0)

github.com/google/guava

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

    }

    assertEquals(1, logHandler.getStoredLogRecords().size());
    assertEquals(
        "Exception while executing callback: MyListener custom-label",
        logHandler.getStoredLogRecords().get(0).getMessage());
  }

  public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);

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

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

- 8.2K bytes

- Click Count (0)

Search Options