return 0; L50: } L51: final Calendar cal = getCurrentCal(); L52: final int h = cal.get(Calendar.HOUR_OF_DAY); L53: final int m = cal.get(Calendar.MINUTE); L54: final int d = cal.get(Calendar.DAY_OF_WEEK); // SUN(1) - SAT(7) L55: for (final IntervalRule rule : ruleList) { L56: if (rule.isTarget(h, m, d)) { L57: return rule.getDelay(); L58: } L59: } L60: return 0; L61: } L62: L63: protected Calendar getCurrentCal()...

L95: - [Deprecations](#deprecations) L96: - [Major Themes](#major-themes) L97: - [SIG API Machinery](#sig-api-machinery) L98: - [SIG Auth](#sig-auth) L99: - [SIG AWS](#sig-aws) L100: - [SIG Azure](#sig-azure) L101: - [SIG Big Data](#sig-big-data) L102: - [SIG CLI](#sig-cli) L103: - [SIG Cloud Provider](#sig-cloud-provider) L104: - [SIG Cluster Lifecycle](#sig-cluster-lifecycle) L105: - [SIG IBM Cloud](#sig-ibm-cloud) L106: - [SIG Multicluster](#sig-multicluster) L107:...

getCsvEncoding()))) { L169: elevateWordService.importCsv(reader); L170: suggestHelper.storeAllElevateWords(false); L171: } catch (final Exception e) { L172: throw new FessSystemException("Failed to import data.", e); L173: } L174: }); L175: return asJson(new ApiResult.ApiResponse().status(ApiResult.Status.OK).result()); L176: } L177: L178: // GET /api/admin/elevateword/download L179: @Execute L180: public StreamResponse...

"norrköping","norrtälje","norsjö","nybro","nykvarn","nyköping","nynäshamn","nässjö","ockelbo","olofström","orsa","orust","osby","oskarshamn","ovanåker","oxelösund","pajala","partille","perstorp","piteå","ragunda","robertsfors","ronneby","rättvik","sala","salem","sandviken","sigtuna","simrishamn","sjöbo","skara","skellefteå","skinnskatteberg","skurup","skövde","smedjebacken","sollefteå","sollentuna","solna","sorsele","sotenäs","staffanstorp","stenungsund","stockholm","storfors","storuman","sträng...

in kubelet logs. ([#99538](https://github.com/kubernetes/kubernetes/pull/99538), [@liggitt](https://github.com/liggitt)) [SIG Auth and Node] L729:- We will no longer automatically delete all data when a failure is detected during creation of the volume data file on a CSI volume. Now we will only remove the data file and volume path. ([#96021](https://github.com/kubernetes/kubernetes/pull/96021), [@huffmanca](https://github.com/huffmanca)) [SIG Storage] L730: L731:## Dependencies L732: L733:### Added...

L582: if (response.socketPolicy === NoResponse) { L583: // This read should block until the socket is closed. (Because nobody is writing.) L584: if (source.exhausted()) return false L585: throw ProtocolException("unexpected data") L586: } L587: L588: var reuseSocket = true L589: val requestWantsWebSockets = L590: "Upgrade".equals(request.headers["Connection"], ignoreCase = true) && L591: "websocket".equals(request.headers["Upgrade"], ignoreCase...

ComponentUtil.getPathMappingHelper(); L813: } L814: L815: @Override L816: public Object getData(final AccessResultData<?> accessResultData) { L817: final byte[] data = accessResultData.getData(); L818: if (data != null) { L819: try { L820: return SerializeUtil.fromBinaryToObject(data); L821: } catch (final Exception e) { L822: throw new CrawlerSystemException("Could not create an instanced from bytes.", e); L823: } L824:...

ordering, create a L122: * {@link Builder} and call {@link Builder#orderRowsBy}, {@link Builder#orderColumnsBy}, and L123: * {@link Builder#putAll} L124: * L125: * <p>Despite the method name, this method attempts to avoid actually copying the data when it is L126: * safe to do so. The exact circumstances under which a copy will or will not be performed are L127: * undocumented and subject to change. L128: */ L129: public static <R, C, V> ImmutableTable<R, C, V> copyOf( L130: Table<?...

iterating the cache. We had a bug where iterating L55: `Cache.urls()` would prevent in-flight entries from being written. L56: L57: L58:## Version 3.14.3 L59: L60:_2019-09-10_ L61: L62: * Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this L63: happened enough then eventually the connection would stall. L64: L65: * Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we L66: could use new flow control...

current thread's exception but also the initial thread's. L99: */ L100: Set<Throwable> seenExceptionsLocal = seenExceptions; L101: if (seenExceptionsLocal == null) { L102: // TODO(cpovirk): Should we use a simpler (presumably cheaper) data structure? L103: /* L104: * Using weak references here could let us release exceptions earlier, but: L105: * L106: * 1. On Android, querying a WeakReference blocks if the GC is doing an otherwise-concurrent L107: * pass....