6233274834

Committed 19 Sep 2023 08:46AM UTC coverage: 36.409% (-0.6%) from 36.982%

Build # 6233274834

Build Type

Pull #658

github

Committed by

dkfellows

Commit Message

Merge branch 'master' into java-17

Pull Request Pull Request #658: Update Java version to 17

Run Details

1656 of 1656 new or added lines in 260 files covered. (100.0%)

8373 of 22997 relevant lines covered (36.41%)

0.36 hits per line

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

0.0

/SpiNNaker-comms/src/main/java/uk/ac/manchester/spinnaker/alloc/client/ProxyProtocol.java

/*
 * Copyright (c) 2022 The University of Manchester
 *
 * 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
 *
 *     https://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 uk.ac.manchester.spinnaker.alloc.client;

import static uk.ac.manchester.spinnaker.utils.ByteBufferUtils.alloc;

import java.nio.ByteBuffer;

/** Message IDs in the proxy protocol. */
enum ProxyProtocol {
        /** Open a connected channel, or its response. Two-way. */
        OPEN(20),
        /** Close a channel, or its response. Two-way. */
        CLOSE(12),
        /** Send a message on a connected channel, or receive a message. One-way. */
        MSG(1600),
        /** Open an unconnected channel, or its response. Two-way. */
        OPEN_U(8),
        /** Send a message on an unconnected channel. Never received. One-way. */
        MSG_TO(1600),
        /**
         * Indicates an error from a message that expects a correlated response.
         * Never sent by the client.
         */
        ERR(0);

        private final int size;

        ProxyProtocol(int size) {
                this.size = size;
        }

        /**
         * Create a buffer big enough to hold a message and fill the first word with
         * the protocol ID.
         *
         * @return A little endian buffer of sufficient size. Position will be after
         *         first word.
         */
        ByteBuffer allocate() {
                var b = alloc(size);
                b.putInt(ordinal());
                return b;
        }
}

1	/*
2	* Copyright (c) 2022 The University of Manchester
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	* https://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 uk.ac.manchester.spinnaker.alloc.client;
17
18	import static uk.ac.manchester.spinnaker.utils.ByteBufferUtils.alloc;
19
20	import java.nio.ByteBuffer;
21
22	/** Message IDs in the proxy protocol. */
23	enum ProxyProtocol {	×
24	/** Open a connected channel, or its response. Two-way. */
25	OPEN(20),	×
26	/** Close a channel, or its response. Two-way. */
27	CLOSE(12),	×
28	/** Send a message on a connected channel, or receive a message. One-way. */
29	MSG(1600),	×
30	/** Open an unconnected channel, or its response. Two-way. */
31	OPEN_U(8),	×
32	/** Send a message on an unconnected channel. Never received. One-way. */
33	MSG_TO(1600),	×
34	/**
35	* Indicates an error from a message that expects a correlated response.
36	* Never sent by the client.
37	*/
38	ERR(0);	×
39
40	private final int size;
41
42	ProxyProtocol(int size) {	×
43	this.size = size;	×
44	}	×
45
46	/**
47	* Create a buffer big enough to hold a message and fill the first word with
48	* the protocol ID.
49	*
50	* @return A little endian buffer of sufficient size. Position will be after
51	* first word.
52	*/
53	ByteBuffer allocate() {
54	var b = alloc(size);	×
55	b.putInt(ordinal());	×
56	return b;	×
57	}
58	}

SpiNNakerManchester / JavaSpiNNaker / 6233274834

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