_src.dec_ndr_long(); /* union discriminant */
            final int _infop = _src.dec_ndr_long();
            if (_infop != 0) {
                if (this.info == null) { /* YOYOYO */
                    this.info = new ShareInfoCtr0();
                }
                _src = _src.deferred;
                this.info.decode(_src);

            }
            this.totalentries = _src.dec_ndr_long();

            _src.dec_ndr_long(); /* union discriminant */
            final int _infop = _src.dec_ndr_long();
            if (_infop != 0) {
                if (info == null) { /* YOYOYO */
                    info = new ShareInfoCtr0();
                }
                _src = _src.deferred;
                info.decode(_src);

            }
            totalentries = _src.dec_ndr_long();

            final int _infop = _src.dec_ndr_long();
            if (_infop != 0) {
                _src.dec_ndr_short(); /* union discriminant */
                this.info.decode(_src);

            }
            this.retval = _src.dec_ndr_long();
        }
    }

    /**
     * LSA lookup SIDs message.
     */
    public static class LsarLookupSids extends DcerpcMessage {

        @Override

            }
            _dst.enc_ndr_referent(this.totalentries, 1);
            if (this.totalentries != null) {
                this.totalentries.encode(_dst);

            }
        }

        @Override
        public void decode_out(final NdrBuffer _src) throws NdrException {
            final int _infop = _src.dec_ndr_long();
            if (_infop != 0) {

            if (_infop != 0) {
                _src.dec_ndr_short(); /* union discriminant */
                info.decode(_src);

            }
            retval = _src.dec_ndr_long();
        }
    }

    /**
     * LSA lookup SIDs message.
     */
    public static class LsarLookupSids extends DcerpcMessage {

        @Override

        @Override
        public void decode_out(final NdrBuffer _src) throws NdrException {
            final int _infop = _src.dec_ndr_long();
            if (_infop != 0) {
                if (info == null) { /* YOYOYO */
                    info = new DfsEnumStruct();
                }
                info.decode(_src);

            }
            final int _totalentriesp = _src.dec_ndr_long();

        lsarpc.LsarQueryInformationPolicy queryInfoPolicy = new lsarpc.LsarQueryInformationPolicy(mockHandle, (short) 1, mockInfo);

        when(mockNdrBuffer.dec_ndr_long()).thenReturn(1, 123); // _infop, retval
        when(mockNdrBuffer.dec_ndr_short()).thenReturn((int) (short) 0); // union discriminant

        queryInfoPolicy.decode_out(mockNdrBuffer);

        verify(mockInfo).decode(mockNdrBuffer);

        NetworkInterfaceInfo info1 = new NetworkInterfaceInfo(testAddress, 1000);
        info1.setInterfaceIndex(1);

        NetworkInterfaceInfo info2 = new NetworkInterfaceInfo(testAddress, 1000);
        info2.setInterfaceIndex(1);

        NetworkInterfaceInfo info3 = new NetworkInterfaceInfo(testAddress, 1000);
        info3.setInterfaceIndex(2);

        assertEquals(info1, info2);

        FileEndOfFileInformation info1 = new FileEndOfFileInformation();
        FileEndOfFileInformation info2 = new FileEndOfFileInformation();

        int bytes1 = info1.decode(buffer, 0, 8);
        int bytes2 = info2.decode(buffer, 0, 8);

        assertEquals(8, bytes1);
        assertEquals(8, bytes2);
        assertEquals(info1.toString(), info2.toString());
    }

    @Test

		if rinfos.Action() == replicateAll {
			opType = replication.ObjectReplicationType
		}
		for _, rinfo := range rinfos.Targets {
			if rinfo.ReplicationStatus != rinfo.PrevReplicationStatus {
				rinfo.OpType = opType // update optype to reflect correct operation.
				globalReplicationStats.Load().Update(bucket, rinfo, rinfo.ReplicationStatus, rinfo.PrevReplicationStatus)
			}
		}
	}