1 /**
2  * Licensed to the Apache Software Foundation (ASF) under one
3  * or more contributor license agreements.  See the NOTICE file
4  * distributed with this work for additional information
5  * regarding copyright ownership.  The ASF licenses this file
6  * to you under the Apache License, Version 2.0 (the
7  * "License"); you may not use this file except in compliance
8  * with the License.  You may obtain a copy of the License at
9  *
10  *     http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing, software
13  * distributed under the License is distributed on an "AS IS" BASIS,
14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  * See the License for the specific language governing permissions and
16  * limitations under the License.
17  */
18 package org.apache.hadoop.oncrpc;
19 
20 import static org.junit.Assert.assertEquals;
21 
22 import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState;
23 import org.apache.hadoop.oncrpc.RpcReply.ReplyState;
24 import org.apache.hadoop.oncrpc.security.Verifier;
25 import org.apache.hadoop.oncrpc.security.VerifierNone;
26 import org.junit.Test;
27 
28 /**
29  * Test for {@link RpcAcceptedReply}
30  */
31 public class TestRpcAcceptedReply {
32   @Test
testAcceptState()33   public void testAcceptState() {
34     assertEquals(AcceptState.SUCCESS, AcceptState.fromValue(0));
35     assertEquals(AcceptState.PROG_UNAVAIL, AcceptState.fromValue(1));
36     assertEquals(AcceptState.PROG_MISMATCH, AcceptState.fromValue(2));
37     assertEquals(AcceptState.PROC_UNAVAIL, AcceptState.fromValue(3));
38     assertEquals(AcceptState.GARBAGE_ARGS, AcceptState.fromValue(4));
39     assertEquals(AcceptState.SYSTEM_ERR, AcceptState.fromValue(5));
40   }
41 
42   @Test(expected = IndexOutOfBoundsException.class)
testAcceptStateFromInvalidValue()43   public void testAcceptStateFromInvalidValue() {
44     AcceptState.fromValue(6);
45   }
46 
47   @Test
testConstructor()48   public void testConstructor() {
49     Verifier verifier = new VerifierNone();
50     RpcAcceptedReply reply = new RpcAcceptedReply(0,
51         ReplyState.MSG_ACCEPTED, verifier, AcceptState.SUCCESS);
52     assertEquals(0, reply.getXid());
53     assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType());
54     assertEquals(ReplyState.MSG_ACCEPTED, reply.getState());
55     assertEquals(verifier, reply.getVerifier());
56     assertEquals(AcceptState.SUCCESS, reply.getAcceptState());
57   }
58 }
59 
60