response.setHeaders(headers);

        Map<String, List<String>> result = response.getHeaders();
        assertNotNull(result);
        assertEquals(1, result.size()); // null key should be filtered out
        assertTrue(result.containsKey("content-type"));
    }

    @Test
    public void testHeadersWithNullMap() {
        CurlResponse response = new CurlResponse();

        response.setHeaders(null);

    // If we clip the safe range used during the per-character tests so it is
    // below the values of characters in surrogate pairs, this cannot occur.
    // This approach does mean that we break out of the fast path code in cases
    // where we don't strictly need to, but this situation will almost never
    // occur in practice.
    if (safeMin >= Character.MIN_HIGH_SURROGATE) {

                    logger.debug("Logout response.", e);
                }
                saveInfo(e.getMessageCode());
            } else {
                logger.warn("Failed to log out.", e);
                saveError(e.getMessageCode());
            }
            return redirect(LoginAction.class);
        }
    }

        assertThrows(EOFException.class, () -> {
            ASN1Util.readLength(s, 100, false);
        });
    }

    @Test
    void testReadLength_OutOfBounds() {
        // Length out of bounds
        InputStream s = new ByteArrayInputStream(new byte[] { (byte) 0x81, (byte) 0xFF }); // length 255
        assertThrows(IOException.class, () -> {
            ASN1Util.readLength(s, 200, false); // limit 200

  </dependencies>
  <build>
    <resources>
      <resource>
        <directory>..</directory>
        <includes>
          <include>LICENSE</include> <!-- copied from the parent pom because I couldn't figure out a way to make combine.children="append" work -->
          <include>proguard/*</include>
        </includes>
        <targetPath>META-INF</targetPath>
      </resource>
    </resources>
    <plugins>
      <plugin>

        boundaryIndex != -1L -> boundaryIndex // We found the boundary.
        source.buffer.size >= toIndex -> minOf(toIndex, maxByteCount) // No boundary before toIndex.
        else -> throw EOFException() // We ran out of data before we found the required boundary.
      }
    }

    @Throws(IOException::class)
    override fun close() {
      if (closed) return
      closed = true
      currentPart = null

      }
      socketHost = proxyAddress.socketHost
      socketPort = proxyAddress.port
    }

    if (socketPort !in 1..65535) {
      throw SocketException("No route to $socketHost:$socketPort; port is out of range")
    }

    if (proxy.type() == Proxy.Type.SOCKS) {
      mutableInetSocketAddresses += InetSocketAddress.createUnresolved(socketHost, socketPort)
    } else {
      val addresses =

func (c *minioBucketCollector) Collect(out chan<- prometheus.Metric) {
	var wg sync.WaitGroup
	publish := func(in <-chan MetricV2) {
		defer wg.Done()
		for metric := range in {
			labels, values := getOrderedLabelValueArrays(metric.VariableLabels)
			collectMetric(metric, labels, values, "bucket", out)
		}
	}

	// Call peer api to fetch metrics
	wg.Add(2)

//
// If index is out of bounds, an error code will be set in the status object,
// and -1 will be returned.
TF_CAPI_EXPORT extern int64_t TF_DeviceListMemoryBytes(
    const TF_DeviceList* list, int index, TF_Status* status);

// Retrieve the incarnation number of a given device.
//
// If index is out of bounds, an error code will be set in the status object,

                            o--;
                        } while (o > 1 && out[o - 1] != '/');
                        break;
                    }
                    state = 2;
                case 2:
                    if (in[i] == '/') {
                        state = 1;
                    }
                    out[o++] = in[i];
                    break;
                }
            }