if err != nil {
		return
	}
	err = z.Notify.EncodeMsg(en)
	if err != nil {
		err = msgp.WrapError(err, "Notify")
		return
	}
	// write "Retry"
	err = en.Append(0xa5, 0x52, 0x65, 0x74, 0x72, 0x79)
	if err != nil {
		return
	}
	err = z.Retry.EncodeMsg(en)
	if err != nil {
		err = msgp.WrapError(err, "Retry")
		return
	}
	return
}

	if err != nil {
		return
	}
	err = z.Notify.EncodeMsg(en)
	if err != nil {
		err = msgp.WrapError(err, "Notify")
		return
	}
	// write "Retry"
	err = en.Append(0xa5, 0x52, 0x65, 0x74, 0x72, 0x79)
	if err != nil {
		return
	}
	err = z.Retry.EncodeMsg(en)
	if err != nil {
		err = msgp.WrapError(err, "Retry")
		return
	}
	return
}

// MarshalMsg implements msgp.Marshaler
func (z *CompleteMultipartUpload) MarshalMsg(b []byte) (o []byte, err error) {
	o = msgp.Require(b, z.Msgsize())
	// map header, size 1
	// string "Parts"
	o = append(o, 0x81, 0xa5, 0x50, 0x61, 0x72, 0x74, 0x73)
	o = msgp.AppendArrayHeader(o, uint32(len(z.Parts)))
	for za0001 := range z.Parts {
		o, err = z.Parts[za0001].MarshalMsg(o)
		if err != nil {
			err = msgp.WrapError(err, "Parts", za0001)

		}
	}
	return
}

// EncodeMsg implements msgp.Encodable
func (z *BucketReplicationStats) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 11
	// write "Stats"
	err = en.Append(0x8b, 0xa5, 0x53, 0x74, 0x61, 0x74, 0x73)
	if err != nil {
		return
	}
	err = en.WriteMapHeader(uint32(len(z.Stats)))
	if err != nil {
		err = msgp.WrapError(err, "Stats")
		return
	}

    }

    @Test
    public void testReadLong() throws IOException {
        // Little-endian 0x123456789ABCDEF0 -> 0xF0 0xDE 0xBC 0x9A 0x78 0x56 0x34 0x12
        byte[] data = new byte[] { (byte) 0xF0, (byte) 0xDE, (byte) 0xBC, (byte) 0x9A, 0x78, 0x56, 0x34, 0x12 };
        PacDataInputStream pdis = createInputStream(data);
        assertEquals(0x123456789ABCDEF0L, pdis.readLong());
    }

    @Test

	if err != nil {
		return
	}
	err = en.WriteString(z.ForwardTo)
	if err != nil {
		err = msgp.WrapError(err, "ForwardTo")
		return
	}
	// write "Limit"
	err = en.Append(0xa5, 0x4c, 0x69, 0x6d, 0x69, 0x74)
	if err != nil {
		return
	}
	err = en.WriteInt(z.Limit)
	if err != nil {
		err = msgp.WrapError(err, "Limit")
		return
	}
	// write "DiskID"

func (z RStat) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 2
	// write "Count"
	err = en.Append(0x82, 0xa5, 0x43, 0x6f, 0x75, 0x6e, 0x74)
	if err != nil {
		return
	}
	err = en.WriteInt64(z.Count)
	if err != nil {
		err = msgp.WrapError(err, "Count")
		return
	}
	// write "Bytes"
	err = en.Append(0xa5, 0x42, 0x79, 0x74, 0x65, 0x73)
	if err != nil {
		return
	}
	err = en.WriteInt64(z.Bytes)
	if err != nil {

	}
	for za0001 := range z.Resources {
		err = en.WriteString(z.Resources[za0001])
		if err != nil {
			err = msgp.WrapError(err, "Resources", za0001)
			return
		}
	}
	// write "Owner"
	err = en.Append(0xa5, 0x4f, 0x77, 0x6e, 0x65, 0x72)
	if err != nil {
		return
	}
	err = en.WriteString(z.Owner)
	if err != nil {
		err = msgp.WrapError(err, "Owner")
		return
	}
	// write "Source"

            DummySSPContext ctx =
                    new DummySSPContext(new byte[] { 1, 2, 3 }, true, "NBHOST", new ASN1ObjectIdentifier[] { mech1, mech2 }, 0xA5, true);

            // Act & Assert
            assertArrayEquals(new byte[] { 1, 2, 3 }, ctx.getSigningKey(), "signing key");
            assertTrue(ctx.isEstablished(), "should be established");

    }

    @Test
    void testReadInt8() {
        byte[] src = new byte[] {
                // 0x123456789ABCDEF0L
                (byte) 0xF0, (byte) 0xDE, (byte) 0xBC, (byte) 0x9A, (byte) 0x78, (byte) 0x56, (byte) 0x34, (byte) 0x12,
                // 0xFFFFFFFFFFFFFFFFL
                (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF,