#405

Committed 16 Apr 2024 05:58AM UTC coverage: 0.0% (-88.9%) from 88.866%

Build # #405

Build Type

push

Committed by

Commit Message

add encoding to fix coverage report

Run Details

0 of 5353 relevant lines covered (0.0%)

0.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/jetcache-core/src/main/java/com/alicp/jetcache/support/AbstractValueDecoder.java

package com.alicp.jetcache.support;

import java.util.Objects;
import java.util.function.Function;

/**
 * Created on 2016/10/4.
 *
 * @author huangli
 */
public abstract class AbstractValueDecoder implements Function<byte[], Object>, ValueEncoders {

    protected boolean useIdentityNumber;

    private DecoderMap decoderMap = DecoderMap.defaultInstance();

    public AbstractValueDecoder(boolean useIdentityNumber) {
        this.useIdentityNumber = useIdentityNumber;
    }

    protected int parseHeader(byte[] buf) {
        int x = 0;
        x = x | (buf[0] & 0xFF);
        x <<= 8;
        x = x | (buf[1] & 0xFF);
        x <<= 8;
        x = x | (buf[2] & 0xFF);
        x <<= 8;
        x = x | (buf[3] & 0xFF);
        return x;
    }

    protected abstract Object doApply(byte[] buffer) throws Exception;

    @Override
    public Object apply(byte[] buffer) {
        try {
            if (useIdentityNumber) {
                decoderMap.initDefaultDecoder();
                int identityNumber = parseHeader(buffer);
                AbstractValueDecoder decoder = decoderMap.getDecoder(identityNumber);
                Objects.requireNonNull(decoder, "no decoder for identity number:" + identityNumber);
                return decoder.doApply(buffer);
            } else {
                return doApply(buffer);
            }
        } catch (Throwable e) {
            throw new CacheEncodeException("decode error", e);
        }
    }

    public boolean isUseIdentityNumber() {
        return useIdentityNumber;
    }

    public void setDecoderMap(DecoderMap decoderMap) {
        this.decoderMap = decoderMap;
    }
}

1	package com.alicp.jetcache.support;
2
3	import java.util.Objects;
4	import java.util.function.Function;
5
6	/**
7	* Created on 2016/10/4.
8	*
9	* @author huangli
10	*/
11	public abstract class AbstractValueDecoder implements Function<byte[], Object>, ValueEncoders {
12
13	protected boolean useIdentityNumber;
14
15	private DecoderMap decoderMap = DecoderMap.defaultInstance();	×
16
17	public AbstractValueDecoder(boolean useIdentityNumber) {	×
18	this.useIdentityNumber = useIdentityNumber;	×
19	}	×
20
21	protected int parseHeader(byte[] buf) {
22	int x = 0;	×
23	x = x \| (buf[0] & 0xFF);	×
24	x <<= 8;	×
25	x = x \| (buf[1] & 0xFF);	×
26	x <<= 8;	×
27	x = x \| (buf[2] & 0xFF);	×
28	x <<= 8;	×
29	x = x \| (buf[3] & 0xFF);	×
30	return x;	×
31	}
32
33	protected abstract Object doApply(byte[] buffer) throws Exception;
34
35	@Override
36	public Object apply(byte[] buffer) {
37	try {
38	if (useIdentityNumber) {	×
39	decoderMap.initDefaultDecoder();	×
40	int identityNumber = parseHeader(buffer);	×
41	AbstractValueDecoder decoder = decoderMap.getDecoder(identityNumber);	×
42	Objects.requireNonNull(decoder, "no decoder for identity number:" + identityNumber);	×
43	return decoder.doApply(buffer);	×
44	} else {
45	return doApply(buffer);	×
46	}
47	} catch (Throwable e) {	×
48	throw new CacheEncodeException("decode error", e);	×
49	}
50	}
51
52	public boolean isUseIdentityNumber() {
53	return useIdentityNumber;	×
54	}
55
56	public void setDecoderMap(DecoderMap decoderMap) {
57	this.decoderMap = decoderMap;	×
58	}	×
59	}

alibaba / jetcache / #405

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous