if (scheduleFailure != null) {
          service.notifyFailed(scheduleFailure);
        }
        return toReturn;
      }

      @GuardedBy("lock")
      /*
       * The GuardedBy checker warns us that we're not holding cancellationDelegate.lock. But in
       * fact we are holding it because it is the same as this.lock, which we know we are holding,

        if (scheduleFailure != null) {
          service.notifyFailed(scheduleFailure);
        }
        return toReturn;
      }

      @GuardedBy("lock")
      /*
       * The GuardedBy checker warns us that we're not holding cancellationDelegate.lock. But in
       * fact we are holding it because it is the same as this.lock, which we know we are holding,

- Checking etcd version to warn about deprecated etcd versions if `ConsistentListFromCache` is enabled. ([#124612](https://github.com/kubernetes/kubernetes/pull/124612), [@ah8ad3](https://github.com/ah8ad3)) [SIG API Machinery]

                .setLoggerName("test.logger")
                .setLevel(Level.WARN)
                .setMessage(new SimpleMessage("test warn message"))
                .build();

        LogEvent result = policy.rewrite(warnEvent);

        assertSame(warnEvent, result);
        assertEquals(Level.WARN, result.getLevel());
    }

    public void test_rewrite_info_level() {

            log.warn("Response buffer too small: {} < {}", buffer.length, expectedSize);
            throw new SmbException("Response buffer too small: " + buffer.length + " < " + expectedSize);
        }

        if (buffer.length > maxSize) {
            failedValidations.incrementAndGet();
            bufferOverflowsPrevented.incrementAndGet();

        });
        try {
            badWordService.store(entity);
            suggestHelper.addBadWord(entity.getSuggestWord(), false);
        } catch (final Exception e) {
            logger.warn("Failed to process a request.", e);
            throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)));
        }

                    final String password = paramMap.get(CRAWLER_FILE_AUTH + "." + fileAuthName + ".password");

                    if (StringUtil.isEmpty(username)) {
                        logger.warn("username is empty. fileAuth:{}", fileAuthName);
                        continue;
                    }

                    final SmbAuthentication smbAuth = new SmbAuthentication();

        // Check for null bytes
        if (NULL_BYTE.matcher(path).find()) {
            log.warn("Path contains null bytes: {}", sanitizeForLog(path));
            throw new SmbException("Path contains null bytes");
        }

        // Check for control characters
        if (strictMode && CONTROL_CHARS.matcher(path).find()) {
            log.warn("Path contains control characters: {}", sanitizeForLog(path));

	if l.LogLevel >= Info {
		l.Logger.InfoContext(ctx, msg, slog.Any("data", data))
	}
}

func (l *slogLogger) Warn(ctx context.Context, msg string, data ...interface{}) {
	if l.LogLevel >= Warn {
		l.Logger.WarnContext(ctx, msg, slog.Any("data", data))
	}
}

func (l *slogLogger) Error(ctx context.Context, msg string, data ...interface{}) {
	if l.LogLevel >= Error {

                        .prepareOpen(docIndex)
                        .execute(ActionListener.wrap(res2 -> logger.info("Open {}", docIndex),
                                e -> logger.warn("Failed to open {}", docIndex, e)));
            }, e -> logger.warn("Failed to close {}", docIndex, e)));
        });
        saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL));
        return redirect(getClass());
    }

    /**