n.firstToDisconnect = time.Now()
	}
}

func (n *netPerfRX) ActiveConnections() uint64 {
	n.RLock()
	defer n.RUnlock()
	return n.activeConnections
}

func (n *netPerfRX) Reset() {
	n.Lock()
	defer n.Unlock()
	n.RX = 0
	n.RXSample = 0
	n.lastToConnect = time.Time{}
	n.firstToDisconnect = time.Time{}
}

// Reader to read random data.
type netperfReader struct {

      val request = Request.Builder().url("https://facebook.com/robots.txt").build()

      var socketClass: String? = null

      // Need fresh client to reset sslSocketFactoryOrNull
      client =
        OkHttpClient
          .Builder()
          .eventListenerFactory(
            clientTestRule.wrap(
              object : EventListener() {

        if (totalTimeSeconds <= 0.0) {
            return 0.0;
        }
        return (bytesTransferred.get() / 1024.0 / 1024.0) / totalTimeSeconds;
    }

    /**
     * Reset all statistics
     */
    public void reset() {
        rdmaReads.set(0);
        rdmaWrites.set(0);
        rdmaSends.set(0);
        rdmaReceives.set(0);
        bytesTransferred.set(0);
        operationErrors.set(0);

                if (fileId != null) {
                    capturedFileId[0] = fileId[0];
                }
            }
        };

        // When
        byte[] testId = new byte[] { 42 };
        anonymousImpl.setFileId(testId);

        // Then
        assertEquals(42, capturedFileId[0], "Anonymous implementation should work correctly");
    }

    @Test

        assertEquals("", blob.toString(), "toString() should be empty for empty buffer");
    }

    // Ensures set(null) resets the buffer to empty and does not NPE
    @Test
    @DisplayName("set(null) resets to empty")
    void set_null_resetsToEmpty() {
        // Arrange
        SecurityBlob blob = new SecurityBlob(new byte[] { 1, 2, 3 });

        // Act
        blob.set(null);

 */
public class AccessToken extends BsAccessToken {

    private static final long serialVersionUID = 1L;

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

    public void setVersionNo(final Long version) {

public class LabelType extends BsLabelType {

    private static final long serialVersionUID = 1L;
    private Locale locale;

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

    public void setVersionNo(final Long version) {

    }

    public ScheduledJob getScheduledJob() {
        return scheduledJob;
    }

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

    public void setVersionNo(final Long version) {

  /** Deflates [buffer] in place as described in RFC 7692 section 7.2.1. */
  @Throws(IOException::class)
  fun deflate(buffer: Buffer) {
    require(deflatedBytes.size == 0L)

    if (noContextTakeover) {
      deflater.reset()
    }

    deflaterSink.write(buffer, buffer.size)
    deflaterSink.flush()

    if (deflatedBytes.endsWith(EMPTY_DEFLATE_BLOCK)) {
      val newSize = deflatedBytes.size - LAST_OCTETS_COUNT_TO_REMOVE_AFTER_DEFLATION

            searchPaging(data, form);
        });
    }

    /**
     * Reset the search form.
     * @param form The search form.
     * @return The HTML response.
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })
    public HtmlResponse reset(final SearchForm form) {
        saveToken();
        crawlingInfoPager.clear();