2632

Committed 07 Nov 2024 12:17AM UTC coverage: 78.326% (-1.5%) from 79.78%

Build # 2632

Build Type

Pull #951

buildkite

Committed by

fimanishi

Commit Message

Add tests for PollerOptions.java

Pull Request Pull Request #951: Add tests for PollerOptions.java

Run Details

15185 of 19387 relevant lines covered (78.33%)

0.78 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

6.95

/src/main/java/com/uber/cadence/internal/logging/ReplayAwareLogger.java

/*
 *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 *  Modifications copyright (C) 2017 Uber Technologies, Inc.
 *
 *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
 *  use this file except in compliance with the License. A copy of the License is
 *  located at
 *
 *  http://aws.amazon.com/apache2.0
 *
 *  or in the "license" file accompanying this file. This file is distributed on
 *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
 *  express or implied. See the License for the specific language governing
 *  permissions and limitations under the License.
 */

package com.uber.cadence.internal.logging;

import com.uber.cadence.internal.replay.ReplayAware;
import java.util.function.Supplier;
import org.slf4j.Logger;
import org.slf4j.Marker;

public class ReplayAwareLogger implements Logger {
  private final Logger log;
  private final ReplayAware context;
  private final Supplier<Boolean> enableLoggingInReplay;

  public ReplayAwareLogger(
      Logger logger, ReplayAware context, Supplier<Boolean> enableLoggingInReplay) {
    this.log = logger;
    this.context = context;
    this.enableLoggingInReplay = enableLoggingInReplay;
  }

  @Override
  public String getName() {
    return log.getName();
  }

  @Override
  public boolean isTraceEnabled() {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isTraceEnabled();
  }

  @Override
  public void trace(String msg) {
    if (shouldSkipLogging()) return;

    log.trace(msg);
  }

  @Override
  public void trace(String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.trace(format, arg);
  }

  @Override
  public void trace(String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.trace(format, arg1, arg2);
  }

  @Override
  public void trace(String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.trace(format, arguments);
  }

  @Override
  public void trace(String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.trace(msg, t);
  }

  @Override
  public boolean isTraceEnabled(Marker marker) {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isTraceEnabled(marker);
  }

  @Override
  public void trace(Marker marker, String msg) {
    if (shouldSkipLogging()) return;

    log.trace(marker, msg);
  }

  @Override
  public void trace(Marker marker, String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.trace(marker, format, arg);
  }

  @Override
  public void trace(Marker marker, String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.trace(marker, format, arg1, arg2);
  }

  @Override
  public void trace(Marker marker, String format, Object... argArray) {
    if (shouldSkipLogging()) return;

    log.trace(marker, format, argArray);
  }

  @Override
  public void trace(Marker marker, String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.trace(marker, msg, t);
  }

  @Override
  public boolean isDebugEnabled() {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isDebugEnabled();
  }

  @Override
  public void debug(String msg) {
    if (shouldSkipLogging()) return;

    log.debug(msg);
  }

  @Override
  public void debug(String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.debug(format, arg);
  }

  @Override
  public void debug(String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.debug(format, arg1, arg2);
  }

  @Override
  public void debug(String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.debug(format, arguments);
  }

  @Override
  public void debug(String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.debug(msg, t);
  }

  @Override
  public boolean isDebugEnabled(Marker marker) {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isDebugEnabled(marker);
  }

  @Override
  public void debug(Marker marker, String msg) {
    if (shouldSkipLogging()) return;

    log.debug(marker, msg);
  }

  @Override
  public void debug(Marker marker, String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.debug(marker, format, arg);
  }

  @Override
  public void debug(Marker marker, String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.debug(marker, format, arg1, arg2);
  }

  @Override
  public void debug(Marker marker, String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.debug(marker, format, arguments);
  }

  @Override
  public void debug(Marker marker, String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.debug(marker, msg, t);
  }

  @Override
  public boolean isInfoEnabled() {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isInfoEnabled();
  }

  @Override
  public void info(String msg) {
    if (shouldSkipLogging()) return;

    log.info(msg);
  }

  @Override
  public void info(String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.info(format, arg);
  }

  @Override
  public void info(String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.info(format, arg1, arg2);
  }

  @Override
  public void info(String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.info(format, arguments);
  }

  @Override
  public void info(String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.info(msg, t);
  }

  @Override
  public boolean isInfoEnabled(Marker marker) {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isInfoEnabled(marker);
  }

  @Override
  public void info(Marker marker, String msg) {
    if (shouldSkipLogging()) return;

    log.info(marker, msg);
  }

  @Override
  public void info(Marker marker, String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.info(marker, format, arg);
  }

  @Override
  public void info(Marker marker, String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.info(marker, format, arg1, arg2);
  }

  @Override
  public void info(Marker marker, String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.info(marker, format, arguments);
  }

  @Override
  public void info(Marker marker, String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.info(marker, msg, t);
  }

  @Override
  public boolean isWarnEnabled() {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isWarnEnabled();
  }

  @Override
  public void warn(String msg) {
    if (shouldSkipLogging()) return;

    log.warn(msg);
  }

  @Override
  public void warn(String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.warn(format, arg);
  }

  @Override
  public void warn(String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.warn(format, arguments);
  }

  @Override
  public void warn(String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.warn(format, arg1, arg2);
  }

  @Override
  public void warn(String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.warn(msg, t);
  }

  @Override
  public boolean isWarnEnabled(Marker marker) {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isWarnEnabled(marker);
  }

  @Override
  public void warn(Marker marker, String msg) {
    if (shouldSkipLogging()) return;

    log.warn(marker, msg);
  }

  @Override
  public void warn(Marker marker, String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.warn(marker, format, arg);
  }

  @Override
  public void warn(Marker marker, String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.warn(marker, format, arg1, arg2);
  }

  @Override
  public void warn(Marker marker, String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.warn(marker, format, arguments);
  }

  @Override
  public void warn(Marker marker, String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.warn(marker, msg, t);
  }

  @Override
  public boolean isErrorEnabled() {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isErrorEnabled();
  }

  @Override
  public void error(String msg) {
    if (shouldSkipLogging()) return;

    log.error(msg);
  }

  @Override
  public void error(String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.error(format, arg);
  }

  @Override
  public void error(String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.error(format, arg1, arg2);
  }

  @Override
  public void error(String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.error(format, arguments);
  }

  @Override
  public void error(String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.error(msg, t);
  }

  @Override
  public boolean isErrorEnabled(Marker marker) {
    if (shouldSkipLogging()) {
      return false;
    }

    return log.isErrorEnabled(marker);
  }

  @Override
  public void error(Marker marker, String msg) {
    if (shouldSkipLogging()) return;

    log.error(marker, msg);
  }

  @Override
  public void error(Marker marker, String format, Object arg) {
    if (shouldSkipLogging()) return;

    log.error(marker, format, arg);
  }

  @Override
  public void error(Marker marker, String format, Object arg1, Object arg2) {
    if (shouldSkipLogging()) return;

    log.error(marker, format, arg1, arg2);
  }

  @Override
  public void error(Marker marker, String format, Object... arguments) {
    if (shouldSkipLogging()) return;

    log.error(marker, format, arguments);
  }

  @Override
  public void error(Marker marker, String msg, Throwable t) {
    if (shouldSkipLogging()) return;

    log.error(marker, msg, t);
  }

  private boolean shouldSkipLogging() {
    return context.isReplaying() && !enableLoggingInReplay.get();
  }
}

1	/*
2	* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3	*
4	* Modifications copyright (C) 2017 Uber Technologies, Inc.
5	*
6	* Licensed under the Apache License, Version 2.0 (the "License"). You may not
7	* use this file except in compliance with the License. A copy of the License is
8	* located at
9	*
10	* http://aws.amazon.com/apache2.0
11	*
12	* or in the "license" file accompanying this file. This file is distributed on
13	* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
14	* express or implied. See the License for the specific language governing
15	* permissions and limitations under the License.
16	*/
17
18	package com.uber.cadence.internal.logging;
19
20	import com.uber.cadence.internal.replay.ReplayAware;
21	import java.util.function.Supplier;
22	import org.slf4j.Logger;
23	import org.slf4j.Marker;
24
25	public class ReplayAwareLogger implements Logger {
26	private final Logger log;
27	private final ReplayAware context;
28	private final Supplier<Boolean> enableLoggingInReplay;
29
30	public ReplayAwareLogger(
31	Logger logger, ReplayAware context, Supplier<Boolean> enableLoggingInReplay) {	1✔
32	this.log = logger;	1✔
33	this.context = context;	1✔
34	this.enableLoggingInReplay = enableLoggingInReplay;	1✔
35	}	1✔
36
37	@Override
38	public String getName() {
39	return log.getName();	×
40	}
41
42	@Override
43	public boolean isTraceEnabled() {
44	if (shouldSkipLogging()) {	×
45	return false;	×
46	}
47
48	return log.isTraceEnabled();	×
49	}
50
51	@Override
52	public void trace(String msg) {
53	if (shouldSkipLogging()) return;	×
54
55	log.trace(msg);	×
56	}	×
57
58	@Override
59	public void trace(String format, Object arg) {
60	if (shouldSkipLogging()) return;	×
61
62	log.trace(format, arg);	×
63	}	×
64
65	@Override
66	public void trace(String format, Object arg1, Object arg2) {
67	if (shouldSkipLogging()) return;	×
68
69	log.trace(format, arg1, arg2);	×
70	}	×
71
72	@Override
73	public void trace(String format, Object... arguments) {
74	if (shouldSkipLogging()) return;	×
75
76	log.trace(format, arguments);	×
77	}	×
78
79	@Override
80	public void trace(String msg, Throwable t) {
81	if (shouldSkipLogging()) return;	×
82
83	log.trace(msg, t);	×
84	}	×
85
86	@Override
87	public boolean isTraceEnabled(Marker marker) {
88	if (shouldSkipLogging()) {	×
89	return false;	×
90	}
91
92	return log.isTraceEnabled(marker);	×
93	}
94
95	@Override
96	public void trace(Marker marker, String msg) {
97	if (shouldSkipLogging()) return;	×
98
99	log.trace(marker, msg);	×
100	}	×
101
102	@Override
103	public void trace(Marker marker, String format, Object arg) {
104	if (shouldSkipLogging()) return;	×
105
106	log.trace(marker, format, arg);	×
107	}	×
108
109	@Override
110	public void trace(Marker marker, String format, Object arg1, Object arg2) {
111	if (shouldSkipLogging()) return;	×
112
113	log.trace(marker, format, arg1, arg2);	×
114	}	×
115
116	@Override
117	public void trace(Marker marker, String format, Object... argArray) {
118	if (shouldSkipLogging()) return;	×
119
120	log.trace(marker, format, argArray);	×
121	}	×
122
123	@Override
124	public void trace(Marker marker, String msg, Throwable t) {
125	if (shouldSkipLogging()) return;	×
126
127	log.trace(marker, msg, t);	×
128	}	×
129
130	@Override
131	public boolean isDebugEnabled() {
132	if (shouldSkipLogging()) {	×
133	return false;	×
134	}
135
136	return log.isDebugEnabled();	×
137	}
138
139	@Override
140	public void debug(String msg) {
141	if (shouldSkipLogging()) return;	1✔
142
143	log.debug(msg);	1✔
144	}	1✔
145
146	@Override
147	public void debug(String format, Object arg) {
148	if (shouldSkipLogging()) return;	×
149
150	log.debug(format, arg);	×
151	}	×
152
153	@Override
154	public void debug(String format, Object arg1, Object arg2) {
155	if (shouldSkipLogging()) return;	×
156
157	log.debug(format, arg1, arg2);	×
158	}	×
159
160	@Override
161	public void debug(String format, Object... arguments) {
162	if (shouldSkipLogging()) return;	×
163
164	log.debug(format, arguments);	×
165	}	×
166
167	@Override
168	public void debug(String msg, Throwable t) {
169	if (shouldSkipLogging()) return;	×
170
171	log.debug(msg, t);	×
172	}	×
173
174	@Override
175	public boolean isDebugEnabled(Marker marker) {
176	if (shouldSkipLogging()) {	×
177	return false;	×
178	}
179
180	return log.isDebugEnabled(marker);	×
181	}
182
183	@Override
184	public void debug(Marker marker, String msg) {
185	if (shouldSkipLogging()) return;	×
186
187	log.debug(marker, msg);	×
188	}	×
189
190	@Override
191	public void debug(Marker marker, String format, Object arg) {
192	if (shouldSkipLogging()) return;	×
193
194	log.debug(marker, format, arg);	×
195	}	×
196
197	@Override
198	public void debug(Marker marker, String format, Object arg1, Object arg2) {
199	if (shouldSkipLogging()) return;	×
200
201	log.debug(marker, format, arg1, arg2);	×
202	}	×
203
204	@Override
205	public void debug(Marker marker, String format, Object... arguments) {
206	if (shouldSkipLogging()) return;	×
207
208	log.debug(marker, format, arguments);	×
209	}	×
210
211	@Override
212	public void debug(Marker marker, String msg, Throwable t) {
213	if (shouldSkipLogging()) return;	×
214
215	log.debug(marker, msg, t);	×
216	}	×
217
218	@Override
219	public boolean isInfoEnabled() {
220	if (shouldSkipLogging()) {	×
221	return false;	×
222	}
223
224	return log.isInfoEnabled();	×
225	}
226
227	@Override
228	public void info(String msg) {
229	if (shouldSkipLogging()) return;	1✔
230
231	log.info(msg);	×
232	}	×
233
234	@Override
235	public void info(String format, Object arg) {
236	if (shouldSkipLogging()) return;	1✔
237
238	log.info(format, arg);	1✔
239	}	1✔
240
241	@Override
242	public void info(String format, Object arg1, Object arg2) {
243	if (shouldSkipLogging()) return;	×
244
245	log.info(format, arg1, arg2);	×
246	}	×
247
248	@Override
249	public void info(String format, Object... arguments) {
250	if (shouldSkipLogging()) return;	×
251
252	log.info(format, arguments);	×
253	}	×
254
255	@Override
256	public void info(String msg, Throwable t) {
257	if (shouldSkipLogging()) return;	×
258
259	log.info(msg, t);	×
260	}	×
261
262	@Override
263	public boolean isInfoEnabled(Marker marker) {
264	if (shouldSkipLogging()) {	×
265	return false;	×
266	}
267
268	return log.isInfoEnabled(marker);	×
269	}
270
271	@Override
272	public void info(Marker marker, String msg) {
273	if (shouldSkipLogging()) return;	×
274
275	log.info(marker, msg);	×
276	}	×
277
278	@Override
279	public void info(Marker marker, String format, Object arg) {
280	if (shouldSkipLogging()) return;	×
281
282	log.info(marker, format, arg);	×
283	}	×
284
285	@Override
286	public void info(Marker marker, String format, Object arg1, Object arg2) {
287	if (shouldSkipLogging()) return;	×
288
289	log.info(marker, format, arg1, arg2);	×
290	}	×
291
292	@Override
293	public void info(Marker marker, String format, Object... arguments) {
294	if (shouldSkipLogging()) return;	×
295
296	log.info(marker, format, arguments);	×
297	}	×
298
299	@Override
300	public void info(Marker marker, String msg, Throwable t) {
301	if (shouldSkipLogging()) return;	×
302
303	log.info(marker, msg, t);	×
304	}	×
305
306	@Override
307	public boolean isWarnEnabled() {
308	if (shouldSkipLogging()) {	×
309	return false;	×
310	}
311
312	return log.isWarnEnabled();	×
313	}
314
315	@Override
316	public void warn(String msg) {
317	if (shouldSkipLogging()) return;	×
318
319	log.warn(msg);	×
320	}	×
321
322	@Override
323	public void warn(String format, Object arg) {
324	if (shouldSkipLogging()) return;	×
325
326	log.warn(format, arg);	×
327	}	×
328
329	@Override
330	public void warn(String format, Object... arguments) {
331	if (shouldSkipLogging()) return;	×
332
333	log.warn(format, arguments);	×
334	}	×
335
336	@Override
337	public void warn(String format, Object arg1, Object arg2) {
338	if (shouldSkipLogging()) return;	×
339
340	log.warn(format, arg1, arg2);	×
341	}	×
342
343	@Override
344	public void warn(String msg, Throwable t) {
345	if (shouldSkipLogging()) return;	×
346
347	log.warn(msg, t);	×
348	}	×
349
350	@Override
351	public boolean isWarnEnabled(Marker marker) {
352	if (shouldSkipLogging()) {	×
353	return false;	×
354	}
355
356	return log.isWarnEnabled(marker);	×
357	}
358
359	@Override
360	public void warn(Marker marker, String msg) {
361	if (shouldSkipLogging()) return;	×
362
363	log.warn(marker, msg);	×
364	}	×
365
366	@Override
367	public void warn(Marker marker, String format, Object arg) {
368	if (shouldSkipLogging()) return;	×
369
370	log.warn(marker, format, arg);	×
371	}	×
372
373	@Override
374	public void warn(Marker marker, String format, Object arg1, Object arg2) {
375	if (shouldSkipLogging()) return;	×
376
377	log.warn(marker, format, arg1, arg2);	×
378	}	×
379
380	@Override
381	public void warn(Marker marker, String format, Object... arguments) {
382	if (shouldSkipLogging()) return;	×
383
384	log.warn(marker, format, arguments);	×
385	}	×
386
387	@Override
388	public void warn(Marker marker, String msg, Throwable t) {
389	if (shouldSkipLogging()) return;	×
390
391	log.warn(marker, msg, t);	×
392	}	×
393
394	@Override
395	public boolean isErrorEnabled() {
396	if (shouldSkipLogging()) {	×
397	return false;	×
398	}
399
400	return log.isErrorEnabled();	×
401	}
402
403	@Override
404	public void error(String msg) {
405	if (shouldSkipLogging()) return;	×
406
407	log.error(msg);	×
408	}	×
409
410	@Override
411	public void error(String format, Object arg) {
412	if (shouldSkipLogging()) return;	×
413
414	log.error(format, arg);	×
415	}	×
416
417	@Override
418	public void error(String format, Object arg1, Object arg2) {
419	if (shouldSkipLogging()) return;	×
420
421	log.error(format, arg1, arg2);	×
422	}	×
423
424	@Override
425	public void error(String format, Object... arguments) {
426	if (shouldSkipLogging()) return;	×
427
428	log.error(format, arguments);	×
429	}	×
430
431	@Override
432	public void error(String msg, Throwable t) {
433	if (shouldSkipLogging()) return;	×
434
435	log.error(msg, t);	×
436	}	×
437
438	@Override
439	public boolean isErrorEnabled(Marker marker) {
440	if (shouldSkipLogging()) {	×
441	return false;	×
442	}
443
444	return log.isErrorEnabled(marker);	×
445	}
446
447	@Override
448	public void error(Marker marker, String msg) {
449	if (shouldSkipLogging()) return;	×
450
451	log.error(marker, msg);	×
452	}	×
453
454	@Override
455	public void error(Marker marker, String format, Object arg) {
456	if (shouldSkipLogging()) return;	×
457
458	log.error(marker, format, arg);	×
459	}	×
460
461	@Override
462	public void error(Marker marker, String format, Object arg1, Object arg2) {
463	if (shouldSkipLogging()) return;	×
464
465	log.error(marker, format, arg1, arg2);	×
466	}	×
467
468	@Override
469	public void error(Marker marker, String format, Object... arguments) {
470	if (shouldSkipLogging()) return;	×
471
472	log.error(marker, format, arguments);	×
473	}	×
474
475	@Override
476	public void error(Marker marker, String msg, Throwable t) {
477	if (shouldSkipLogging()) return;	×
478
479	log.error(marker, msg, t);	×
480	}	×
481
482	private boolean shouldSkipLogging() {
483	return context.isReplaying() && !enableLoggingInReplay.get();	1✔
484	}
485	}

uber / cadence-java-client / 2632

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous