if (bufs.isEmpty()) {
      return new byte[0];
    }
    byte[] result = bufs.remove();
    if (result.length == totalLen) {
      return result;
    }
    int remaining = totalLen - result.length;
    result = Arrays.copyOf(result, totalLen);
    while (remaining > 0) {
      byte[] buf = bufs.remove();
      int bytesToCopy = min(remaining, buf.length);

        int result = request.writeBodyWireFormat(dst, dstIndex);

        // Verify that writeQuestionSectionWireFormat was called
        verify((NameServicePacket) request, times(1)).writeQuestionSectionWireFormat(dst, dstIndex);
        assertEquals(10, result);
    }

    @Test
    void testReadBodyWireFormat() {

        String result = dcerpcBinding.toString();
        assertTrue(result.startsWith(PROTO + ":" + SERVER + "[null,"), "toString should start correctly.");
        assertTrue(result.contains("connect=80"), "toString should contain connect option.");
        assertTrue(result.contains("bind=123"), "toString should contain bind option.");
    }

    @Test

        } else {
          connectionUser.dnsStart(socketHost)

          val result = address.dns.lookup(socketHost)
          if (result.isEmpty()) {
            throw UnknownHostException("${address.dns} returned no addresses for $socketHost")
          }

          connectionUser.dnsEnd(socketHost, result)
          result
        }

      // Try each address for best behavior in mixed IPv4/IPv6 environments.

    /**
     * Searches for related content items based on the provided search criteria.
     *
     * @param form the search form containing search criteria
     * @return HTML response with filtered related content results
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })
    public HtmlResponse search(final SearchForm form) {
        copyBeanToBean(form, relatedContentPager, op -> op.exclude(Constants.PAGER_CONVERSION_RULE));

    if (planToReplace != null) {
      nextRouteToTry = planToReplace.route
      planToReplace.closeQuietly()
    }

    connectionUser.connectionAcquired(result)
    connectionUser.connectionConnectionAcquired(result)
    return ReusePlan(result)
  }

  /** Returns a plan for the first attempt at [route]. This throws if no plan is possible. */
  @Throws(IOException::class)
  internal fun planConnectToRoute(

                return mockResource1;
            }
        };

        // When
        SmbResource result = iterator.next();

        // Then
        assertTrue(adaptCalled[0], "Adapt method should have been called");
        assertNotNull(result, "Result should not be null");
        assertEquals("file1.txt", result.getName());
    }

		if len(s) != 11 {
			return nil, errors.New("unsupported /proc/self/mountinfo format")
		}
		result[s[2]] = s[9]
	}

	if err := scanner.Err(); err != nil {
		return nil, err
	}

	return result, nil
}

func getDiskUUIDMap() (map[string]string, error) {
	result := make(map[string]string)
	err := filepath.Walk("/dev/disk/by-uuid/",
		func(path string, info os.FileInfo, err error) error {

        Map<String, Object> result = event.toSource();
        assertEquals("test", result.get("string"));
        assertEquals(42, result.get("integer"));
        assertEquals(100L, result.get("long"));
        assertEquals(3.14, result.get("double"));
        assertEquals(false, result.get("boolean"));
        assertNull(result.get("null_value"));
        assertNotNull(result.get("nested"));

          add(client.newCall(buildRequest(hostname, DnsRecordCodec.TYPE_AAAA)))
        }
      }

    val failures = ArrayList<Exception>(2)
    val results = ArrayList<InetAddress>(5)
    executeRequests(hostname, networkRequests, results, failures)

    return results.ifEmpty {
      throwBestFailure(hostname, failures)
    }
  }

  private fun executeRequests(
    hostname: String,
    networkRequests: List<Call>,