@Throws(IOException::class)
  fun writePong(payload: ByteString) {
    writeControlFrame(OPCODE_CONTROL_PONG, payload)
  }

  /**
   * Send a close frame with optional code and reason.
   *
   * @param code Status code as defined by
   *     [Section 7.4 of RFC 6455](http://tools.ietf.org/html/rfc6455#section-7.4) or `0`.
   * @param reason Reason for shutting down or `null`.
   */
  @Throws(IOException::class)
  fun writeClose(

			}
			api.GetObjectLambdaHandler(rec, req)

			res := rec.Result()
			defer res.Body.Close()
			respBody, _ := io.ReadAll(res.Body)

			if res.StatusCode != expectStatus {
				t.Errorf("Expected status %d, got %d", expectStatus, res.StatusCode)
			}

			if contentType != "" {
				if ct := res.Header.Get("Content-Type"); ct != contentType {
					t.Errorf("Expected Content-Type %q, got %q", contentType, ct)
				}

### Set legal hold on an object

PutObject API allows setting legal hold using `x-amz-object-lock-legal-hold` header.

```sh
aws s3api put-object --bucket testbucket --key legalhold --object-lock-legal-hold-status ON --body /etc/issue
```

See <https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lock-overview.html> for AWS S3 spec on object locking and permissions required for specifying legal hold.

## Concepts

            }
            wait() // Wait until we receive a WINDOW_UPDATE.
          }
        } catch (e: InterruptedException) {
          Thread.currentThread().interrupt() // Retain interrupted status.
          throw InterruptedIOException()
        }

        toWrite = minOf(byteCount, writeBytesMaximum - writeBytesTotal).toInt()
        toWrite = minOf(toWrite, writer.maxDataLength())

 */

package com.google.common.collect;

import static com.google.common.collect.Platform.reduceExponentIfGwt;
import static com.google.common.collect.Platform.reduceIterationsIfGwt;
import static com.google.common.collect.ReflectionFreeAssertThrows.assertThrows;
import static com.google.common.collect.Sets.newHashSet;
import static com.google.common.truth.Truth.assertThat;
import static java.util.Arrays.asList;

        // The fact that we can create the instance verifies the serialVersionUID is defined
        assertNotNull(runtimeException);

        // Verify the exception maintains its state
        assertEquals(servletException, runtimeException.getCause());
    }

    /**
     * Returns a string representation of this request, used for debugging and logging purposes.
     * The format should include the request type and any significant attributes that define the
     * request's state.
     *
     * @return a string representation of this request, never {@code null}
     */
    @Override
    @Nonnull
    String toString();

 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler;

import static org.codelibs.core.stream.StreamUtil.split;
import static org.codelibs.core.stream.StreamUtil.stream;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;

    /**
     * The NTLMSSP "preamble".
     */
    protected static final byte[] NTLMSSP_SIGNATURE =
            { (byte) 'N', (byte) 'T', (byte) 'L', (byte) 'M', (byte) 'S', (byte) 'S', (byte) 'P', (byte) 0 };

    private static final String OEM_ENCODING = Config.DEFAULT_OEM_ENCODING;
    /**
     * Unicode encoding used for NTLM messages.
     */
    protected static final String UNI_ENCODING = "UTF-16LE";

    private int flags;

./mc ls -r myminio/versioned/ >expanded_ns.txt
./mc ls -r --versions myminio/versioned/ >expanded_ns_versions.txt

./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1}

until $(./mc admin decom status myminio/ | grep -q Complete); do
	echo "waiting for decom to finish..."
	sleep 1
done

kill $pid_1
kill $pid_2

sleep 5