Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 2461 - 2470 of 2,719 for match (0.02 seconds)

  1. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

                                    allUrls.add(polled.getUrl());
                                }
                            }
                        }
                        totalPolled.addAndGet(count);
                    } catch (final InterruptedException e) {
                        Thread.currentThread().interrupt();
                    } finally {
                        doneLatch.countDown();
                    }
                }).start();
            }
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Jan 14 23:48:16 GMT 2026
    - 14.5K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketWriterTest.kt

          )
        }
      }
    
      private fun assertData(hex: String) {
        assertData(hex.decodeHex())
      }
    
      private fun assertData(expected: ByteString) {
        val actual = data.readByteString(Math.min(expected.size.toLong(), data.size))
        assertThat(actual).isEqualTo(expected)
      }
    
      companion object {
        private fun binaryData(length: Int): ByteString {
          val junk = ByteArray(length)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 9.3K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsFileConfigBhv.java

                result.setUpdatedTime(DfTypeUtil.toLong(source.get("updatedTime")));
                result.setVirtualHosts(toStringArray(source.get("virtualHosts")));
                return updateEntity(source, result);
            } catch (InstantiationException | IllegalAccessException e) {
                final String msg = "Cannot create a new instance: " + entityType.getName();
                throw new IllegalBehaviorStateException(msg, e);
            }
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/opensearch/log/bsbhv/BsSearchLogBhv.java

                result.setUserSessionId(DfTypeUtil.toString(source.get("userSessionId")));
                result.setVirtualHost(DfTypeUtil.toString(source.get("virtualHost")));
                return updateEntity(source, result);
            } catch (InstantiationException | IllegalAccessException e) {
                final String msg = "Cannot create a new instance: " + entityType.getName();
                throw new IllegalBehaviorStateException(msg, e);
            }
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  5. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/AssembleDslDocTask.groovy

                classDoc.classProperties.each { propertyDoc ->
                    linkMetaData.addPropertyAccessorMethod(propertyDoc.name, propertyDoc.metaData.getter ?: propertyDoc.metaData.setter)
                }
            } catch (Exception e) {
                throw new DocGenerationException("Failed to generate documentation for class '$classDoc.name'.", e)
            }
        }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 9.8K bytes
    - Click Count (0)
  6. impl/maven-core/src/main/java/org/apache/maven/internal/aether/ReverseTreeRepositoryListener.java

                    } else {
                        trackingData.add("No repositories configured");
                    }
                }
    
                Files.write(trackingFile, trackingData, StandardCharsets.UTF_8);
            } catch (IOException e) {
                throw new UncheckedIOException(e);
            }
        }
    
        /**
         * Returns {@code true} if passed in artifact is originating from local repository. In other words, we want
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jan 29 08:17:07 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  7. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/InternalBwcGitPlugin.java

                return defaultRefSpec;
            }
    
            String timeOfCurrent = execInCheckoutDir(execSpec -> {
                execSpec.commandLine(asList("git", "show", "--no-patch", "--no-notes", "--pretty='%cD'"));
                execSpec.workingDir(project.getRootDir());
            });
    
            logger.lifecycle("Commit date of current: {}", timeOfCurrent);
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 9.9K bytes
    - Click Count (0)
  8. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleJavadocsPlugin.java

                        }
                        return notSeeBefore;
                    } else {
                        return true; // not a package-info.java file, we ignore it
                    }
                } catch (IOException e) {
                    throw UncheckedException.throwAsUncheckedException(e, true);
                }
            }
    
            private String getPackageName(File file) throws IOException {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Sun Mar 01 05:52:34 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  9. cmd/erasure-coding.go

    // erasureSelfTest performs a self-test to ensure that erasure
    // algorithms compute expected erasure codes. If any algorithm
    // produces an incorrect value it fails with a hard error.
    //
    // erasureSelfTest tries to catch any issue in the erasure implementation
    // early instead of silently corrupting data.
    func erasureSelfTest() {
    	// Approx runtime ~1ms
    	var testConfigs [][2]uint8
    	for total := uint8(4); total < 16; total++ {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  10. build-tools-internal/src/main/groovy/org/elasticsearch/gradle/internal/test/AntFixture.groovy

            // so now evaluates if the waitCondition is successful
            // TODO: change this to a loop?
            boolean success
            try {
                success = waitCondition(this, ant)
            } catch (Exception e) {
                String msg = "Wait condition caught exception for ${name}"
                logger.error(msg, e)
                fail(msg, e)
            }
            if (success == false) {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 10.1K bytes
    - Click Count (0)
Back to Top