#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/KryoValueDecoder.java

package com.alicp.jetcache.support;

import com.esotericsoftware.kryo.Kryo;
import com.esotericsoftware.kryo.io.Input;

import java.io.ByteArrayInputStream;

/**
 * Created on 2016/10/4.
 *
 * @author huangli
 */
public class KryoValueDecoder extends AbstractValueDecoder {

    public static final KryoValueDecoder INSTANCE = new KryoValueDecoder(true);

    public KryoValueDecoder(boolean useIdentityNumber) {
        super(useIdentityNumber);
    }

    @Override
    public Object doApply(byte[] buffer) {
        ByteArrayInputStream in;
        if (useIdentityNumber) {
            in = new ByteArrayInputStream(buffer, 4, buffer.length - 4);
        } else {
            in = new ByteArrayInputStream(buffer);
        }
        Input input = new Input(in);
        KryoValueEncoder.KryoCache kryoCache = null;
        try {
            kryoCache =  KryoValueEncoder.kryoCacheObjectPool.borrowObject();
            Kryo kryo = kryoCache.getKryo();
            ClassLoader classLoader = KryoValueDecoder.class.getClassLoader();
            Thread t = Thread.currentThread();
            if (t != null) {
                ClassLoader ctxClassLoader = t.getContextClassLoader();
                if (ctxClassLoader != null) {
                    classLoader = ctxClassLoader;
                }
            }
            kryo.setClassLoader(classLoader);
            return kryo.readClassAndObject(input);
        }finally {
            if(kryoCache != null){
                KryoValueEncoder.kryoCacheObjectPool.returnObject(kryoCache);
            }
        }
    }
}

1	package com.alicp.jetcache.support;
2
3	import com.esotericsoftware.kryo.Kryo;
4	import com.esotericsoftware.kryo.io.Input;
5
6	import java.io.ByteArrayInputStream;
7
8	/**
9	* Created on 2016/10/4.
10	*
11	* @author huangli
12	*/
13	public class KryoValueDecoder extends AbstractValueDecoder {
14
15	public static final KryoValueDecoder INSTANCE = new KryoValueDecoder(true);	×
16
17	public KryoValueDecoder(boolean useIdentityNumber) {
18	super(useIdentityNumber);	×
19	}	×
20
21	@Override
22	public Object doApply(byte[] buffer) {
23	ByteArrayInputStream in;
24	if (useIdentityNumber) {	×
25	in = new ByteArrayInputStream(buffer, 4, buffer.length - 4);	×
26	} else {
27	in = new ByteArrayInputStream(buffer);	×
28	}
29	Input input = new Input(in);	×
30	KryoValueEncoder.KryoCache kryoCache = null;	×
31	try {
32	kryoCache = KryoValueEncoder.kryoCacheObjectPool.borrowObject();	×
33	Kryo kryo = kryoCache.getKryo();	×
34	ClassLoader classLoader = KryoValueDecoder.class.getClassLoader();	×
35	Thread t = Thread.currentThread();	×
36	if (t != null) {	×
37	ClassLoader ctxClassLoader = t.getContextClassLoader();	×
38	if (ctxClassLoader != null) {	×
39	classLoader = ctxClassLoader;	×
40	}
41	}
42	kryo.setClassLoader(classLoader);	×
43	return kryo.readClassAndObject(input);	×
44	}finally {
45	if(kryoCache != null){	×
46	KryoValueEncoder.kryoCacheObjectPool.returnObject(kryoCache);	×
47	}
48	}
49	}
50	}

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