chubaostream / joyqueue / 635

pending completion

Build # 635

Build Type

Pull #273

travis-ci

Committed by

web-flow

Commit Message

<a href="https://github.com/chubaostream/joyqueue/commit/<a class=hub.com/chubaostream/joyqueue/commit/<a class="double-link" href="https://git"><a class=hub.com/chubaostream/joyqueue/commit/<a class="double-link" href="https://git"><a class=hub.com/chubaostream/joyqueue/commit/<a class="double-link" href="https://git"><a class=hub.com/chubaostream/joyqueue/commit/<a class="double-link" href="https://git"><a class=hub.com/chubaostream/joyqueue/commit/6d66ed58e6d546a404624c4bea09dc8f4c64d9da">6d66ed58e">&lt;a href=&quot;https://github.com/chubaostream/joyqueue/commit/</a><a class="double-link" href="https://github.com/chubaostream/joyqueue/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/chubaostream/joyqueue/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/chubaostream/joyqueue/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/chubaostream/joyqueue/commit/6d66ed58e6d546a404624c4bea09dc8f4c64d9da">6d66ed58e</a><a href="https://github.com/chubaostream/joyqueue/commit/6d66ed58e6d546a404624c4bea09dc8f4c64d9da">&lt;a href=&quot;https://github.com/chubaostream/joyqueue/commit/6d66ed58e6d546a404624c4bea09dc8f4c64d9da&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/chubaostream/joyqueue/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/chubaostream/joyqueue/commit/&amp;amp;lt;a class=&amp;amp;quot;double-link&amp;amp;quot; href=&amp;amp;quot;https://git&amp;quot;&amp;gt;&amp;amp;lt;a class=&amp;lt;/a&amp;gt;hub.com/chubaostream/joyqueue/commit/6d66ed58e6d546a404624c4bea09dc8f4c64d9da&amp;quot;&amp;gt;6d66ed58e&amp;lt;/a&amp;gt;&amp;lt;a href=&amp;quot;https://github.com/chubaostream/joyqueue/commit/6d66ed58e6d546a404624c4bea09dc8f4c64d9da&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/chubaostream/joyqueue/commit/6d66ed58e6d546a404624c4bea09dc8f&amp;lt;/a&amp;gt;4c64d9da&amp;</a>quot;&gt;&amp;quot;&amp;gt;Merge &amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/chubaostream/joyqueue/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/chubaostream/joyqueue/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/chubaostream/joyqu... (continued)

Pull Request Pull Request #273: Multi storage engine

Run Details

3561 of 3561 new or added lines in 107 files covered. (100.0%)

5629 of 42555 relevant lines covered (13.23%)

0.13 hits per line

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

0.0

/joyqueue-server/joyqueue-store/joyqueue-store-origin/src/main/java/org/joyqueue/store/ha/election/codec/AppendEntriesRequestEncoder.java

/**
 * Copyright 2019 The JoyQueue Authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.joyqueue.store.ha.election.codec;

import io.netty.buffer.ByteBuf;
import org.joyqueue.network.command.CommandType;
import org.joyqueue.network.serializer.Serializer;
import org.joyqueue.network.transport.codec.PayloadEncoder;
import org.joyqueue.network.transport.command.Type;
import org.joyqueue.store.ha.election.command.AppendEntriesRequest;

import java.nio.ByteBuffer;

/**
 * author: zhuduohui
 * email: zhuduohui@jd.com
 * date: 2018/9/27
 */
public class AppendEntriesRequestEncoder implements PayloadEncoder<AppendEntriesRequest>, Type {
    @Override
    public void encode(final AppendEntriesRequest payload, ByteBuf buffer) throws Exception {
        Serializer.write(payload.getTopic(), buffer, Serializer.SHORT_SIZE);
        buffer.writeInt(payload.getPartitionGroup());
        buffer.writeInt(payload.getTerm());
        buffer.writeInt(payload.getLeaderId());

        buffer.writeInt(payload.getPrevTerm());
        buffer.writeLong(payload.getPrevPosition());

        buffer.writeLong(payload.getStartPosition());
        buffer.writeLong(payload.getCommitPosition());
        buffer.writeLong(payload.getLeftPosition());

        buffer.writeBoolean(payload.isMatch());

        ByteBuffer entries = payload.getEntries();
        if (entries == null) {
            buffer.writeInt(0);
            return;
        }
        buffer.writeInt(entries.remaining());
        entries.mark();
        buffer.writeBytes(entries);
        entries.reset();
    }

    @Override
    public int type() {
        return CommandType.RAFT_APPEND_ENTRIES_REQUEST;
    }
}

1	/**
2	* Copyright 2019 The JoyQueue Authors.
3	*
4	* Licensed under the Apache License, Version 2.0 (the "License");
5	* you may not use this file except in compliance with the License.
6	* You may obtain a copy of the License at
7	*
8	* http://www.apache.org/licenses/LICENSE-2.0
9	*
10	* Unless required by applicable law or agreed to in writing, software
11	* distributed under the License is distributed on an "AS IS" BASIS,
12	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13	* See the License for the specific language governing permissions and
14	* limitations under the License.
15	*/
16	package org.joyqueue.store.ha.election.codec;
17
18	import io.netty.buffer.ByteBuf;
19	import org.joyqueue.network.command.CommandType;
20	import org.joyqueue.network.serializer.Serializer;
21	import org.joyqueue.network.transport.codec.PayloadEncoder;
22	import org.joyqueue.network.transport.command.Type;
23	import org.joyqueue.store.ha.election.command.AppendEntriesRequest;
24
25	import java.nio.ByteBuffer;
26
27	/**
28	* author: zhuduohui
29	* email: zhuduohui@jd.com
30	* date: 2018/9/27
31	*/
32	public class AppendEntriesRequestEncoder implements PayloadEncoder<AppendEntriesRequest>, Type {	×
33	@Override
34	public void encode(final AppendEntriesRequest payload, ByteBuf buffer) throws Exception {
35	Serializer.write(payload.getTopic(), buffer, Serializer.SHORT_SIZE);	×
36	buffer.writeInt(payload.getPartitionGroup());	×
37	buffer.writeInt(payload.getTerm());	×
38	buffer.writeInt(payload.getLeaderId());	×
39
40	buffer.writeInt(payload.getPrevTerm());	×
41	buffer.writeLong(payload.getPrevPosition());	×
42
43	buffer.writeLong(payload.getStartPosition());	×
44	buffer.writeLong(payload.getCommitPosition());	×
45	buffer.writeLong(payload.getLeftPosition());	×
46
47	buffer.writeBoolean(payload.isMatch());	×
48
49	ByteBuffer entries = payload.getEntries();	×
50	if (entries == null) {	×
51	buffer.writeInt(0);	×
52	return;	×
53	}
54	buffer.writeInt(entries.remaining());	×
55	entries.mark();	×
56	buffer.writeBytes(entries);	×
57	entries.reset();	×
58	}	×
59
60	@Override
61	public int type() {
62	return CommandType.RAFT_APPEND_ENTRIES_REQUEST;	×
63	}
64	}

chubaostream / joyqueue / 635

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