L150: logger.warn("Failed to delete url queues: {}", sessionId, e); L151: } L152: try { L153: dataService.delete(sessionId); L154: } catch (final Exception e) { L155: logger.warn("Failed to delete data: {}", sessionId, e); L156: } L157: } L158: L159: @Override L160: public void run() { L161: if (dataService == null) { L162: throw new FessSystemException("DataService is null."); L163: } L164: L165: if...

the same behavior as {@link DataInput#readFully(byte[], int, int)}. Does not close L792: * the stream. L793: * L794: * @param in the input stream to read from. L795: * @param b the buffer into which the data is read. L796: * @param off an int specifying the offset into the data. L797: * @param len an int specifying the number of bytes to read. L798: * @throws EOFException if this stream reaches the end before reading all the bytes. L799: * @throws IOException if an I/O error occurs....

nonzero value after the web socket has been canceled; this indicates L62: * that enqueued messages were not transmitted. L63: */ L64: fun queueSize(): Long L65: L66: /** L67: * Attempts to enqueue `text` to be UTF-8 encoded and sent as a the data of a text (type `0x1`) L68: * message. L69: * L70: * This method returns true if the message was enqueued. Messages that would overflow the outgoing L71: * message buffer will be rejected and trigger a [graceful shutdown][close] of this web...

OR CONDITIONS OF ANY KIND, either express or implied. L13: * See the License for the specific language governing permissions and L14: * limitations under the License. L15: */ L16:package okhttp3.survey.types L17: L18:import okio.ByteString L19: L20:data class SuiteId(val id: ByteString?, val name: String) { L21: fun matches(suiteId: SuiteId): Boolean { L22: return id == suiteId.id || name.substring(4) == suiteId.name.substring(4) L23: } L24:}...

MessageDigest}s. L29: * L30: * <p>Parameters for the benchmark are: L31: * L32: * <ul> L33: * <li>size: The length of the byte array to hash. L34: * <li>algorithm: the algorithm to hash with (e.g. MD5, SHA1, etc.). L35: * <li>hashMethod: how to hash the data (using the Hashing API or the MessageDigest API). L36: * </ul> L37: * L38: * @author Kurt Alfred Kluever L39: */ L40:public class MessageDigestAlgorithmBenchmark { L41: @Param({"10", "1000", "100000", "1000000"}) L42: int size; L43: L44: @Param...

MessageDigest}s. L29: * L30: * <p>Parameters for the benchmark are: L31: * L32: * <ul> L33: * <li>size: The length of the byte array to hash. L34: * <li>algorithm: the algorithm to hash with (e.g. MD5, SHA1, etc.). L35: * <li>hashMethod: how to hash the data (using the Hashing API or the MessageDigest API). L36: * </ul> L37: * L38: * @author Kurt Alfred Kluever L39: */ L40:public class MessageDigestAlgorithmBenchmark { L41: @Param({"10", "1000", "100000", "1000000"}) L42: int size; L43: L44: @Param...

SerializedForm"); L550: } L551: L552: private static class SerialForm<T extends @Nullable Object> implements Serializable { L553: final long[] data; L554: final int numHashFunctions; L555: final Funnel<? super T> funnel; L556: final Strategy strategy; L557: L558: SerialForm(BloomFilter<T> bf) { L559: this.data = LockFreeBitArray.toPlainArray(bf.bits.data); L560: this.numHashFunctions = bf.numHashFunctions; L561: this.funnel = bf.funnel; L562: this.strategy = bf.strategy; L563:...

Type||d.valAttr("recaptcha-type")||"image";if(!f)throw new Error("Google reCaptcha site key is required.");var j=grecaptcha.render(e,{sitekey:f,theme:g,size:h,type:i,callback:function(a){b.find('[data-validation~="recaptcha"]').trigger("validation",a&&""!==a)},"expired-callback":function(){b.find('[data-validation~="recaptcha"]').trigger("validation",!1)}});d.valAttr("recaptcha-widget-id",j).hide().on("beforeValidation",function(a){a.stopImmediatePropagation()}).parent().append(e)})})},a(b).on("validatorsLoaded...

L17:package com.google.common.collect.testing.google; L18: L19:import com.google.common.annotations.GwtCompatible; L20:import com.google.common.collect.SetMultimap; L21: L22:/** L23: * A generator for {@code SetMultimap} implementations based on test data. L24: * L25: * @author Louis Wasserman L26: */ L27:@GwtCompatible L28:public interface TestSetMultimapGenerator<K, V> L29: extends TestMultimapGenerator<K, V, SetMultimap<K, V>> {}...

call, to append L331: * more values and build again. L332: * L333: * <p><b>Performance note:</b> the returned array is backed by the same array as the builder, so L334: * no data is copied as part of this step, but this may occupy more memory than strictly L335: * necessary. To copy the data to a right-sized backing array, use {@code .build().trimmed()}. L336: */ L337: public ImmutableLongArray build() { L338: return count == 0 ? EMPTY : new ImmutableLongArray(array,...