sink.writeUtf8(content) L3327: sink.close() L3328: } L3329: L3330: /** L3331: * @param delta the offset from the current date to use. Negative values yield dates in the past; L3332: * positive values yield dates in the future. L3333: */ L3334: private fun formatDate( L3335: delta: Long, L3336: timeUnit: TimeUnit, L3337: ): String { L3338: return formatDate(Date(System.currentTimeMillis() + timeUnit.toMillis(delta))) L3339: } L3340: L3341: private fun formatDate(date: Date): String { L3342:...

L391: } L392: return fileName; L393: } L394: L395: @Override L396: public void destroy() { L397: try { L398: fileItem.delete(); L399: } catch (final IOException e) { L400: throw new IllegalStateException("Failed to delete the fileItem: " + fileItem, e); L401: } L402: } L403: L404: @Override L405: public String toString() { L406: return "formFile:{" + getFileName()...

L326: @Secured({ ROLE }) L327: public HtmlResponse delete(final EditForm form) { L328: verifyCrudMode(form.crudMode, CrudMode.DETAILS, form.dictId); L329: validate(form, messages -> {}, this::asDetailsHtml); L330: verifyToken(this::asDetailsHtml); L331: stemmerOverrideService.getStemmerOverrideItem(form.dictId, form.id).ifPresent(entity -> { L332: try { L333: stemmerOverrideService.delete(form.dictId, entity); L334: saveInfo(messages...

@Secured({ ROLE }) L265: public HtmlResponse delete(final EditForm form) { L266: verifyCrudMode(form.crudMode, CrudMode.DETAILS); L267: final String id = form.id; L268: validate(form, messages -> {}, () -> asDetailsHtml(id)); L269: verifyToken(() -> asDetailsHtml(id)); L270: scheduledJobService.getScheduledJob(id).ifPresent(entity -> { L271: try { L272: scheduledJobService.delete(entity); L273: saveInfo(messages ->...

super.insertEntry(entryIndex, key, value, hash, mask); L187: setSucceeds(lastEntry, entryIndex); L188: setSucceeds(entryIndex, ENDPOINT); L189: } L190: L191: @Override L192: void accessEntry(int index) { L193: if (accessOrder) { L194: // delete from previous position... L195: setSucceeds(getPredecessor(index), getSuccessor(index)); L196: // ...and insert at the end. L197: setSucceeds(lastEntry, index); L198: setSucceeds(index, ENDPOINT); L199: incrementModCount();...

duplicates.get(entry); L194: // null=>not dup'd; true=>dup'd, first; false=>dup'd, not first L195: if (status != null) { L196: if (status) { L197: duplicates.put(entry, false); L198: } else { L199: continue; // delete this entry; we already copied an earlier one for the same key L200: } L201: } L202: newEntries[out++] = entry; L203: } L204: return newEntries; L205: } L206: L207: /** Makes an entry usable internally by a new ImmutableMap...

RefreshResponse; L44:import org.opensearch.action.bulk.BulkItemResponse; L45:import org.opensearch.action.bulk.BulkRequestBuilder; L46:import org.opensearch.action.bulk.BulkResponse; L47:import org.opensearch.action.delete.DeleteRequestBuilder; L48:import org.opensearch.action.delete.DeleteResponse; L49:import org.opensearch.action.index.IndexRequestBuilder; L50:import org.opensearch.action.index.IndexResponse; L51:import org.opensearch.action.search.SearchRequestBuilder; L52:import org.opensear...

RefreshResponse; L44:import org.opensearch.action.bulk.BulkItemResponse; L45:import org.opensearch.action.bulk.BulkRequestBuilder; L46:import org.opensearch.action.bulk.BulkResponse; L47:import org.opensearch.action.delete.DeleteRequestBuilder; L48:import org.opensearch.action.delete.DeleteResponse; L49:import org.opensearch.action.index.IndexRequestBuilder; L50:import org.opensearch.action.index.IndexResponse; L51:import org.opensearch.action.search.SearchRequestBuilder; L52:import org.opensear...

alTo(body) L83: assertThat(request.tags).isEmpty() L84: } L85: L86: @Test L87: fun constructorNoBody() { L88: val url = "https://example.com/".toHttpUrl() L89: val headers = headersOf("User-Agent", "RequestTest") L90: val method = "DELETE" L91: val request = L92: Request( L93: url = url, L94: headers = headers, L95: method = method, L96: ) L97: assertThat(request.url).isEqualTo(url) L98: assertThat(request.headers).isEqualTo(headers) L99: ...

L133: sb.append(dm).append(scriptResult); L134: sb.append(dm).append(scriptType); L135: sb.append(dm).append(startTime); L136: sb.append(dm).append(target); L137: if (sb.length() > dm.length()) { L138: sb.delete(0, dm.length()); L139: } L140: sb.insert(0, "{").append("}"); L141: return sb.toString(); L142: } L143: L144: // =================================================================================== L145: // ...