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...

recoverFromInitializationFailure(parameters: Pair<FileSystem, Boolean>) { L124: setUp(parameters.first, parameters.second) L125: // Add an uncommitted entry. This will get detected on initialization, and the cache will L126: // attempt to delete the file. Do not explicitly close the cache here so the entry is left as L127: // incomplete. L128: val creator = cache.edit("k1")!! L129: creator.newSink(0).buffer().use { L130: it.writeUtf8("Hello") L131: } L132: L133: // Simulate...

* Fix: Reused `Request.Builder` instances no longer hold stale URL fields. L325: * New: ConnectionSpec can now be configured to use the SSL socket's default L326: cipher suites. To use, set the cipher suites to `null`. L327: * New: Support `DELETE` with a request body. L328: * New: `Headers.of(Map)` creates headers from a Map. L329: L330: L331:## Version 2.2.0 L332: L333:_2014-12-30_ L334: L335: * **`RequestBody.contentLength()` now throws `IOException`.** L336: This is a source-incompatible...

sb.append(dm).append(teletexTerminalIdentifier); L351: sb.append(dm).append(title); L352: sb.append(dm).append(uidNumber); L353: sb.append(dm).append(x121Address); L354: if (sb.length() > dm.length()) { L355: sb.delete(0, dm.length()); L356: } L357: sb.insert(0, "{").append("}"); L358: return sb.toString(); L359: } L360: L361: // =================================================================================== L362: // ...

FacetInfo(); L61: ComponentUtil.register(facetInfo, "facetInfo"); L62: viewHelper = new ViewHelper(); L63: viewHelper.init(); L64: } L65: L66: @Override L67: public void tearDown() throws Exception { L68: propertiesFile.delete(); L69: super.tearDown(); L70: } L71: L72: public void test_facetQueries() { L73: final List<FacetQueryView> list = viewHelper.getFacetQueryViewList(); L74: assertEquals(3, list.size()); L75: FacetQueryView view1...

void update(final User user) { L60: final String username = user.getName(); L61: final String password = user.getOriginalPassword(); L62: changePassword(username, password); L63: } L64: L65: @Override L66: public void delete(final User user) { L67: final String username = user.getName(); L68: if (isTargetUser(username)) { L69: executeCommand(deleteCommand, username, StringUtil.EMPTY); L70: } L71: } L72: L73: @Override L74: public...

aders= L176:api.json.response.exception.included=false L177:api.gsa.response.headers= L178:api.gsa.response.exception.included=false L179:api.dashboard.response.headers= L180:api.cors.allow.origin=* L181:api.cors.allow.methods=GET, POST, OPTIONS, DELETE, PUT L182:api.cors.max.age=3600 L183:api.cors.allow.headers=Origin, Content-Type, Accept, Authorization, X-Requested-With L184:api.cors.allow.credentials=true L185:api.jsonp.enabled=false L186:api.ping.search_engine.fields=status,timed_out L187: L188:...

builder.headers(headersOf()) L1093: builder = builder.cacheControl(CacheControl.FORCE_CACHE) L1094: builder = builder.get() L1095: builder = builder.head() L1096: builder = builder.post(requestBody) L1097: builder = builder.delete(requestBody) L1098: builder = builder.delete(null) L1099: builder = builder.put(requestBody) L1100: builder = builder.patch(requestBody) L1101: builder = builder.method("", requestBody) L1102: builder = builder.method("", null) L1103: builder = builder.tag("")...

0x1c] = encoding // File Separator L79: encodings[ 0x1d] = encoding // Group Separator L80: encodings[ 0x1e] = encoding // Record Separator L81: encodings[ 0x1f] = encoding // Unit Separator L82: encodings[ 0x7f] = encoding // Delete L83: } L84: L85: fun nonAscii(encoding: Encoding) = L86: apply { L87: encodings[UNICODE_2] = encoding L88: encodings[UNICODE_3] = encoding L89: encodings[UNICODE_4] = encoding L90: } L91: L92: fun test(component: Component)...

L88: * Fix: Don't leak gzip streams on redirects. L89: * Fix: Don't do DNS lookups on invalid hosts. L90: * Fix: Exhaust the underlying stream when reading gzip streams. L91: * Fix: Support the `PATCH` method. L92: * Fix: Support request bodies on `DELETE` method. L93: * Fix: Drop the `okhttp-protocols` module. L94: * Internal: Replaced internal byte array buffers with pooled buffers ("OkBuffer"). L95: L96: L97:## Version 1.3.0 L98: L99:_2014-01-11_ L100: L101: * New: Support for "PATCH" HTTP method...