}
			buf.WriteString(rec)
		}

		// Write the extended header file.
		var name string
		var flag byte
		if isGlobal {
			name = realName
			if name == "" {
				name = "GlobalHead.0.0"
			}
			flag = TypeXGlobalHeader
		} else {
			dir, file := path.Split(realName)
			name = path.Join(dir, "PaxHeaders.0", file)
			flag = TypeXHeader
		}
		data := buf.String()

      peer.sendFrame().data(false, 3, data(1), 1)
      peer.acceptFrame() // connection WINDOW UPDATE
      peer.acceptFrame() // stream WINDOW UPDATE
    }
    peer.sendFrame().data(true, 3, data(0), 0)
    peer.play()

    // Play it back.
    val connection = connect(peer)
    connection.okHttpSettings[Settings.INITIAL_WINDOW_SIZE] = windowSize

- cloud.google.com/go/pubsub: v1.3.1 → v1.30.0
- cloud.google.com/go: v0.97.0 → v0.110.0
- github.com/Azure/azure-sdk-for-go: [v55.0.0+incompatible → v68.0.0+incompatible](https://github.com/Azure/azure-sdk-for-go/compare/v55.0.0...v68.0.0)
- github.com/Azure/go-autorest/autorest/adal: [v0.9.20 → v0.9.23](https://github.com/Azure/go-autorest/autorest/adal/compare/v0.9.20...v0.9.23)

        byte[] data = new byte[] { 0x01, 0x02, 0x03, 0x04 };

        // Should return immediately without processing
        assertDoesNotThrow(() -> digest.update(data, 0, 0));
    }

    @Test
    @DisplayName("Test digest method")
    void testDigest() {
        SMB1SigningDigest digest = new SMB1SigningDigest(testMacSigningKey);

        assertEquals(0, stats.getBytesTransferred(), "Bytes should be reset to 0");
        assertEquals(0, stats.getOperationErrors(), "Errors should be reset to 0");
        assertEquals(0.0, stats.getErrorRate(), 0.001, "Error rate should be 0% after reset");
    }

    @Test
    public void testRdmaErrorHandlerBehavior() {
        RdmaStatistics stats = new RdmaStatistics();

	// data state and a list of outdated disks on which data needs
	// to be healed.
	outDatedDisks := make([]StorageAPI, len(storageDisks))
	disksToHealCount, xlMetaToHealCount := 0, 0
	for i := range onlineDisks {
		yes, isMeta, reason := shouldHealObjectOnDisk(errs[i], dataErrsByDisk[i], partsMetadata[i], latestMeta)
		if yes {
			outDatedDisks[i] = storageDisks[i]
			disksToHealCount++

        }

        public double getPoolUtilization() {
            return maxPoolSize > 0 ? (double) activeConnections / maxPoolSize : 0.0;
        }

        @Override
        public String toString() {
            return String.format(
                    "PoolHealthMetrics[active=%d, nonPooled=%d, tracked=%d, max=%d, "

            byte[] buffer = new byte[100];
            // Write "Test" in UTF-16LE directly at position 2 (even offset)
            System.arraycopy(Strings.getUNIBytes("Test\0"), 0, buffer, 2, 10);

            String result = testBlock.readString(buffer, 2);

            assertEquals("Test", result);
        }

        @Test

    public static final String DEFAULT_CRON_EXPRESSION = "0 0 * * *";

    /** Default cron expression for search log processing (every minute). */
    public static final String DEFAULT_SEARCH_LOG_CRON_EXPRESSION = "* * * * *";

    /** Default cron expression for daily tasks (daily at midnight). */
    public static final String DEFAULT_DAILY_CRON_EXPRESSION = "0 0 * * *";

     * crc1 = int1
     * crc2 = int2
     * crc3 = int3
     *
     * ...so we set crc0 so that computeForWord(crc0) = -1 and xoring it with the first int
     * gives us the desired result.  computeForWord(0) == 0, so all the others do the right thing.
     */
    private int crc0 = INVERSE_COMPUTE_FOR_WORD_OF_ALL_1S;
    private int crc1 = 0;
    private int crc2 = 0;
    private int crc3 = 0;

    @Override