- Sort Score
- Num 10 results
- Language All
Results 321 - 330 of 376 for fatalIf (0.08 seconds)
-
internal/event/target/mysql_test.go
// is registered and fails otherwise. func TestMySQLRegistration(t *testing.T) { var found bool if slices.Contains(sql.Drivers(), "mysql") { found = true } if !found { t.Fatal("mysql driver not registered") }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.1K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/Result.java
import java.util.List; import static java.util.Collections.singleton; import static org.apache.maven.model.building.ModelProblem.Severity.ERROR; import static org.apache.maven.model.building.ModelProblem.Severity.FATAL; /** * There are various forms of results that are represented by this class: * <ol> * <li>success - in which case only the model field is set * <li>success with warnings - model field + non-error model problems
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Mar 26 19:31:34 GMT 2025 - 6.9K bytes - Click Count (0) -
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/ConscryptSocketAdapter.kt
override fun create(sslSocket: SSLSocket): SocketAdapter = ConscryptSocketAdapter() } val isSupported: Boolean = try { // Trigger an early exception over a fatal error, prefer a RuntimeException over Error. Class.forName("org.conscrypt.Conscrypt\$Version", false, javaClass.classLoader) when { // Bump this version if we ever have a binary incompatibilityCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 3K bytes - Click Count (0) -
cmd/kms-router.go
KMSVersions := []string{ kmsAPIVersionPrefix, } gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed)) if err != nil { // Static params, so this is very unlikely. logger.Fatal(err, "Unable to initialize server") } for _, version := range KMSVersions { // KMS Status APIs kmsRouter.Methods(http.MethodGet).Path(version + "/status").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSStatusHandler)))Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 07 23:55:37 GMT 2024 - 2.7K bytes - Click Count (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/DefaultSettingsBuilder.java
SettingsProblem.Severity.FATAL, "Non-parseable settings " + settingsSource.getLocation() + ": " + e.getMessage(), e.getLineNumber(), e.getColumnNumber(), e); return new Settings(); } catch (IOException e) { problems.add( SettingsProblem.Severity.FATAL,Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jul 23 17:27:08 GMT 2025 - 9.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FailedPlan.kt
* to use `H2_PRIOR_KNOWLEDGE` but the URL's scheme is `https:`. * * Preemptive proxy authentication failed. * * Planning failures are not necessarily fatal. For example, even if we can't DNS lookup the first * proxy in a list, looking up a subsequent one may succeed. */ internal class FailedPlan( e: Throwable, ) : RoutePlanner.Plan {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.5K bytes - Click Count (0) -
cmd/metacache-bucket_test.go
import ( "fmt" "testing" ) func Benchmark_bucketMetacache_findCache(b *testing.B) { bm := newBucketMetacache("", false) const elements = 50000 const paths = 100 if elements%paths != 0 { b.Fatal("elements must be divisible by the number of paths") } var pathNames [paths]string for i := range pathNames[:] { pathNames[i] = fmt.Sprintf("prefix/%d", i) } for i := range elements {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.8K bytes - Click Count (0) -
docs/auditlog/auditlog-echo.go
log.Printf("%s\n", out.String()) w.WriteHeader(http.StatusOK) } func main() { flag.Parse() http.HandleFunc("/", mainHandler) log.Printf("Listening on :%d\n", port) log.Fatal(http.ListenAndServe(fmt.Sprintf(":%d", port), nil))
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed May 01 21:31:13 GMT 2024 - 1.5K bytes - Click Count (0) -
cmd/postpolicyform_test.go
policyBytes, err := base64.StdEncoding.DecodeString(base64.StdEncoding.EncodeToString([]byte(pp.String()))) if err != nil { t.Fatal(err) } postPolicyForm, err := parsePostPolicyForm(bytes.NewReader(policyBytes)) if err != nil { t.Fatal(err) } errStr := "" err = checkPostPolicy(tt.fv.Header, postPolicyForm) if err != nil { errStr = err.Error() }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.3K bytes - Click Count (0) -
cmd/prepare-storage.go
} else { logger.Fatal(err, "Unable to connect to %s: %v", endpoints[i], isServerResolvable(endpoints[i], time.Second)) } } else { if globalEndpoints.NEndpoints() > 1 { logger.Info("Unable to use the drive %s: %v, will be retried", endpoints[i], err) } else { logger.Fatal(errInvalidArgument, "Unable to use the drive %s: %v", endpoints[i], err) } }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jul 12 20:51:54 GMT 2024 - 11.1K bytes - Click Count (1)