You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by vi...@apache.org on 2013/08/12 23:26:02 UTC
svn commit: r1513258 [9/9] - in
/hadoop/common/branches/YARN-321/hadoop-common-project: ./
hadoop-annotations/ hadoop-auth-examples/
hadoop-auth-examples/src/main/webapp/
hadoop-auth-examples/src/main/webapp/annonymous/
hadoop-auth-examples/src/main/we...
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcAcceptedReply.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcAcceptedReply.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcAcceptedReply.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcAcceptedReply.java Mon Aug 12 21:25:49 2013
@@ -25,39 +25,34 @@ import org.apache.hadoop.oncrpc.RpcAuthI
*/
public class RpcAcceptedReply extends RpcReply {
public enum AcceptState {
- SUCCESS(0), /* RPC executed successfully */
- PROG_UNAVAIL(1), /* remote hasn't exported program */
- PROG_MISMATCH(2), /* remote can't support version # */
- PROC_UNAVAIL(3), /* program can't support procedure */
- GARBAGE_ARGS(4), /* procedure can't decode params */
- SYSTEM_ERR(5); /* e.g. memory allocation failure */
+ // the order of the values below are significant.
+ SUCCESS, /* RPC executed successfully */
+ PROG_UNAVAIL, /* remote hasn't exported program */
+ PROG_MISMATCH, /* remote can't support version # */
+ PROC_UNAVAIL, /* program can't support procedure */
+ GARBAGE_ARGS, /* procedure can't decode params */
+ SYSTEM_ERR; /* e.g. memory allocation failure */
- private final int value;
-
- AcceptState(int value) {
- this.value = value;
- }
-
public static AcceptState fromValue(int value) {
return values()[value];
}
public int getValue() {
- return value;
+ return ordinal();
}
};
private final RpcAuthInfo verifier;
private final AcceptState acceptState;
- RpcAcceptedReply(int xid, int messageType, ReplyState state,
+ RpcAcceptedReply(int xid, RpcMessage.Type messageType, ReplyState state,
RpcAuthInfo verifier, AcceptState acceptState) {
super(xid, messageType, state);
this.verifier = verifier;
this.acceptState = acceptState;
}
- public static RpcAcceptedReply read(int xid, int messageType,
+ public static RpcAcceptedReply read(int xid, RpcMessage.Type messageType,
ReplyState replyState, XDR xdr) {
RpcAuthInfo verifier = RpcAuthInfo.read(xdr);
AcceptState acceptState = AcceptState.fromValue(xdr.readInt());
@@ -79,7 +74,7 @@ public class RpcAcceptedReply extends Rp
public static XDR voidReply(XDR xdr, int xid, AcceptState acceptState) {
xdr.writeInt(xid);
- xdr.writeInt(RpcMessage.RPC_REPLY);
+ xdr.writeInt(RpcMessage.Type.RPC_REPLY.getValue());
xdr.writeInt(ReplyState.MSG_ACCEPTED.getValue());
xdr.writeInt(AuthFlavor.AUTH_NONE.getValue());
xdr.writeVariableOpaque(new byte[0]);
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcCall.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcCall.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcCall.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcCall.java Mon Aug 12 21:25:49 2013
@@ -33,7 +33,7 @@ public class RpcCall extends RpcMessage
private final RpcAuthInfo credential;
private final RpcAuthInfo verifier;
- protected RpcCall(int xid, int messageType, int rpcVersion, int program,
+ protected RpcCall(int xid, RpcMessage.Type messageType, int rpcVersion, int program,
int version, int procedure, RpcAuthInfo credential, RpcAuthInfo verifier) {
super(xid, messageType);
this.rpcVersion = rpcVersion;
@@ -56,7 +56,7 @@ public class RpcCall extends RpcMessage
}
public void validate() {
- validateMessageType(RPC_CALL);
+ validateMessageType(RpcMessage.Type.RPC_CALL);
validateRpcVersion();
// Validate other members
// Throw exception if validation fails
@@ -88,7 +88,8 @@ public class RpcCall extends RpcMessage
}
public static RpcCall read(XDR xdr) {
- return new RpcCall(xdr.readInt(), xdr.readInt(), xdr.readInt(), xdr.readInt(),
+ return new RpcCall(xdr.readInt(), RpcMessage.Type.fromValue(xdr.readInt()),
+ xdr.readInt(), xdr.readInt(),
xdr.readInt(), xdr.readInt(), RpcAuthInfo.read(xdr),
RpcAuthInfo.read(xdr));
}
@@ -96,7 +97,7 @@ public class RpcCall extends RpcMessage
public static void write(XDR out, int xid, int program, int progVersion,
int procedure) {
out.writeInt(xid);
- out.writeInt(RpcMessage.RPC_CALL);
+ out.writeInt(RpcMessage.Type.RPC_CALL.getValue());
out.writeInt(2);
out.writeInt(program);
out.writeInt(progVersion);
@@ -105,7 +106,7 @@ public class RpcCall extends RpcMessage
@Override
public String toString() {
- return String.format("Xid:%d, messageType:%d, rpcVersion:%d, program:%d,"
+ return String.format("Xid:%d, messageType:%s, rpcVersion:%d, program:%d,"
+ " version:%d, procedure:%d, credential:%s, verifier:%s", xid,
messageType, rpcVersion, program, version, procedure,
credential.toString(), verifier.toString());
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcDeniedReply.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcDeniedReply.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcDeniedReply.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcDeniedReply.java Mon Aug 12 21:25:49 2013
@@ -25,16 +25,12 @@ import org.apache.hadoop.oncrpc.RpcAuthI
*/
public class RpcDeniedReply extends RpcReply {
public enum RejectState {
- RPC_MISMATCH(0), AUTH_ERROR(1);
-
- private final int value;
-
- RejectState(int value) {
- this.value = value;
- }
+ // the order of the values below are significant.
+ RPC_MISMATCH,
+ AUTH_ERROR;
int getValue() {
- return value;
+ return ordinal();
}
static RejectState fromValue(int value) {
@@ -44,13 +40,13 @@ public class RpcDeniedReply extends RpcR
private final RejectState rejectState;
- RpcDeniedReply(int xid, int messageType, ReplyState replyState,
+ RpcDeniedReply(int xid, RpcMessage.Type messageType, ReplyState replyState,
RejectState rejectState) {
super(xid, messageType, replyState);
this.rejectState = rejectState;
}
- public static RpcDeniedReply read(int xid, int messageType,
+ public static RpcDeniedReply read(int xid, RpcMessage.Type messageType,
ReplyState replyState, XDR xdr) {
RejectState rejectState = RejectState.fromValue(xdr.readInt());
return new RpcDeniedReply(xid, messageType, replyState, rejectState);
@@ -70,7 +66,7 @@ public class RpcDeniedReply extends RpcR
public static XDR voidReply(XDR xdr, int xid, ReplyState msgAccepted,
RejectState rejectState) {
xdr.writeInt(xid);
- xdr.writeInt(RpcMessage.RPC_REPLY);
+ xdr.writeInt(RpcMessage.Type.RPC_REPLY.getValue());
xdr.writeInt(msgAccepted.getValue());
xdr.writeInt(AuthFlavor.AUTH_NONE.getValue());
xdr.writeVariableOpaque(new byte[0]);
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcMessage.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcMessage.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcMessage.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcMessage.java Mon Aug 12 21:25:49 2013
@@ -21,14 +21,29 @@ package org.apache.hadoop.oncrpc;
* Represent an RPC message as defined in RFC 1831.
*/
public abstract class RpcMessage {
- public static final int RPC_CALL = 0;
- public static final int RPC_REPLY = 1;
+ /** Message type */
+ public static enum Type {
+ // the order of the values below are significant.
+ RPC_CALL,
+ RPC_REPLY;
+
+ public int getValue() {
+ return ordinal();
+ }
+
+ public static Type fromValue(int value) {
+ if (value < 0 || value >= values().length) {
+ return null;
+ }
+ return values()[value];
+ }
+ }
protected final int xid;
- protected final int messageType;
+ protected final Type messageType;
- RpcMessage(int xid, int messageType) {
- if (messageType != RPC_CALL && messageType != RPC_REPLY) {
+ RpcMessage(int xid, Type messageType) {
+ if (messageType != Type.RPC_CALL && messageType != Type.RPC_REPLY) {
throw new IllegalArgumentException("Invalid message type " + messageType);
}
this.xid = xid;
@@ -39,11 +54,11 @@ public abstract class RpcMessage {
return xid;
}
- public int getMessageType() {
+ public Type getMessageType() {
return messageType;
}
- protected void validateMessageType(int expected) {
+ protected void validateMessageType(Type expected) {
if (expected != messageType) {
throw new IllegalArgumentException("Message type is expected to be "
+ expected + " but got " + messageType);
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcReply.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcReply.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcReply.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/RpcReply.java Mon Aug 12 21:25:49 2013
@@ -23,16 +23,12 @@ package org.apache.hadoop.oncrpc;
public abstract class RpcReply extends RpcMessage {
/** RPC reply_stat as defined in RFC 1831 */
public enum ReplyState {
- MSG_ACCEPTED(0),
- MSG_DENIED(1);
-
- private final int value;
- ReplyState(int value) {
- this.value = value;
- }
+ // the order of the values below are significant.
+ MSG_ACCEPTED,
+ MSG_DENIED;
int getValue() {
- return value;
+ return ordinal();
}
public static ReplyState fromValue(int value) {
@@ -42,15 +38,15 @@ public abstract class RpcReply extends R
private final ReplyState state;
- RpcReply(int xid, int messageType, ReplyState state) {
+ RpcReply(int xid, RpcMessage.Type messageType, ReplyState state) {
super(xid, messageType);
this.state = state;
- validateMessageType(RPC_REPLY);
+ validateMessageType(RpcMessage.Type.RPC_REPLY);
}
public static RpcReply read(XDR xdr) {
int xid = xdr.readInt();
- int messageType = xdr.readInt();
+ final Type messageType = Type.fromValue(xdr.readInt());
ReplyState stat = ReplyState.fromValue(xdr.readInt());
switch (stat) {
case MSG_ACCEPTED:
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/PortmapInterface.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/PortmapInterface.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/PortmapInterface.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/PortmapInterface.java Mon Aug 12 21:25:49 2013
@@ -25,31 +25,29 @@ import org.apache.hadoop.oncrpc.XDR;
*/
public interface PortmapInterface {
public enum Procedure {
- PMAPPROC_NULL(0),
- PMAPPROC_SET(1),
- PMAPPROC_UNSET(2),
- PMAPPROC_GETPORT(3),
- PMAPPROC_DUMP(4),
- PMAPPROC_CALLIT(5),
- PMAPPROC_GETTIME(6),
- PMAPPROC_UADDR2TADDR(7),
- PMAPPROC_TADDR2UADDR(8),
- PMAPPROC_GETVERSADDR(9),
- PMAPPROC_INDIRECT(10),
- PMAPPROC_GETADDRLIST(11),
- PMAPPROC_GETSTAT(12);
-
- private final int value;
-
- Procedure(int value) {
- this.value = value;
- }
+ // the order of the values below are significant.
+ PMAPPROC_NULL,
+ PMAPPROC_SET,
+ PMAPPROC_UNSET,
+ PMAPPROC_GETPORT,
+ PMAPPROC_DUMP,
+ PMAPPROC_CALLIT,
+ PMAPPROC_GETTIME,
+ PMAPPROC_UADDR2TADDR,
+ PMAPPROC_TADDR2UADDR,
+ PMAPPROC_GETVERSADDR,
+ PMAPPROC_INDIRECT,
+ PMAPPROC_GETADDRLIST,
+ PMAPPROC_GETSTAT;
public int getValue() {
- return value;
+ return ordinal();
}
public static Procedure fromValue(int value) {
+ if (value < 0 || value >= values().length) {
+ return null;
+ }
return values()[value];
}
}
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/RpcProgramPortmap.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/RpcProgramPortmap.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/RpcProgramPortmap.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/RpcProgramPortmap.java Mon Aug 12 21:25:49 2013
@@ -131,29 +131,22 @@ public class RpcProgramPortmap extends R
@Override
public XDR handleInternal(RpcCall rpcCall, XDR in, XDR out,
InetAddress client, Channel channel) {
- Procedure procedure = Procedure.fromValue(rpcCall.getProcedure());
+ final Procedure portmapProc = Procedure.fromValue(rpcCall.getProcedure());
int xid = rpcCall.getXid();
- switch (procedure) {
- case PMAPPROC_NULL:
+ if (portmapProc == Procedure.PMAPPROC_NULL) {
out = nullOp(xid, in, out);
- break;
- case PMAPPROC_SET:
+ } else if (portmapProc == Procedure.PMAPPROC_SET) {
out = set(xid, in, out);
- break;
- case PMAPPROC_UNSET:
+ } else if (portmapProc == Procedure.PMAPPROC_UNSET) {
out = unset(xid, in, out);
- break;
- case PMAPPROC_DUMP:
+ } else if (portmapProc == Procedure.PMAPPROC_DUMP) {
out = dump(xid, in, out);
- break;
- case PMAPPROC_GETPORT:
+ } else if (portmapProc == Procedure.PMAPPROC_GETPORT) {
out = getport(xid, in, out);
- break;
- case PMAPPROC_GETVERSADDR:
+ } else if (portmapProc == Procedure.PMAPPROC_GETVERSADDR) {
out = getport(xid, in, out);
- break;
- default:
- LOG.info("PortmapHandler unknown rpc procedure=" + procedure);
+ } else {
+ LOG.info("PortmapHandler unknown rpc procedure=" + portmapProc);
RpcAcceptedReply.voidReply(out, xid,
RpcAcceptedReply.AcceptState.PROC_UNAVAIL);
}
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcAcceptedReply.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcAcceptedReply.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcAcceptedReply.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcAcceptedReply.java Mon Aug 12 21:25:49 2013
@@ -46,10 +46,10 @@ public class TestRpcAcceptedReply {
@Test
public void testConstructor() {
RpcAuthInfo verifier = new RpcAuthInfo(AuthFlavor.AUTH_NONE, new byte[0]);
- RpcAcceptedReply reply = new RpcAcceptedReply(0, RpcMessage.RPC_REPLY,
+ RpcAcceptedReply reply = new RpcAcceptedReply(0, RpcMessage.Type.RPC_REPLY,
ReplyState.MSG_ACCEPTED, verifier, AcceptState.SUCCESS);
assertEquals(0, reply.getXid());
- assertEquals(RpcMessage.RPC_REPLY, reply.getMessageType());
+ assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType());
assertEquals(ReplyState.MSG_ACCEPTED, reply.getState());
assertEquals(verifier, reply.getVerifier());
assertEquals(AcceptState.SUCCESS, reply.getAcceptState());
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcCall.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcCall.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcCall.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcCall.java Mon Aug 12 21:25:49 2013
@@ -34,9 +34,10 @@ public class TestRpcCall {
int program = 2;
int version = 3;
int procedure = 4;
- RpcCall call = new RpcCall(0, RpcMessage.RPC_CALL, rpcVersion, program, version, procedure, credential, verifier);
+ RpcCall call = new RpcCall(0, RpcMessage.Type.RPC_CALL, rpcVersion, program,
+ version, procedure, credential, verifier);
assertEquals(0, call.getXid());
- assertEquals(RpcMessage.RPC_CALL, call.getMessageType());
+ assertEquals(RpcMessage.Type.RPC_CALL, call.getMessageType());
assertEquals(rpcVersion, call.getRpcVersion());
assertEquals(program, call.getProgram());
assertEquals(version, call.getVersion());
@@ -48,12 +49,12 @@ public class TestRpcCall {
@Test(expected=IllegalArgumentException.class)
public void testInvalidRpcVersion() {
int invalidRpcVersion = 3;
- new RpcCall(0, RpcMessage.RPC_CALL, invalidRpcVersion, 2, 3, 4, null, null);
+ new RpcCall(0, RpcMessage.Type.RPC_CALL, invalidRpcVersion, 2, 3, 4, null, null);
}
@Test(expected=IllegalArgumentException.class)
public void testInvalidRpcMessageType() {
- int invalidMessageType = 3; // Message typ is not RpcMessage.RPC_CALL
+ RpcMessage.Type invalidMessageType = RpcMessage.Type.RPC_REPLY; // Message typ is not RpcMessage.RPC_CALL
new RpcCall(0, invalidMessageType, RpcCall.RPC_VERSION, 2, 3, 4, null, null);
}
}
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcDeniedReply.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcDeniedReply.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcDeniedReply.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcDeniedReply.java Mon Aug 12 21:25:49 2013
@@ -39,12 +39,12 @@ public class TestRpcDeniedReply {
@Test
public void testConstructor() {
- RpcDeniedReply reply = new RpcDeniedReply(0, RpcMessage.RPC_REPLY,
+ RpcDeniedReply reply = new RpcDeniedReply(0, RpcMessage.Type.RPC_REPLY,
ReplyState.MSG_ACCEPTED, RejectState.AUTH_ERROR) {
// Anonymous class
};
Assert.assertEquals(0, reply.getXid());
- Assert.assertEquals(RpcMessage.RPC_REPLY, reply.getMessageType());
+ Assert.assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType());
Assert.assertEquals(ReplyState.MSG_ACCEPTED, reply.getState());
Assert.assertEquals(RejectState.AUTH_ERROR, reply.getRejectState());
}
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcMessage.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcMessage.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcMessage.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcMessage.java Mon Aug 12 21:25:49 2013
@@ -24,34 +24,28 @@ import org.junit.Test;
* Test for {@link RpcMessage}
*/
public class TestRpcMessage {
- private RpcMessage getRpcMessage(int xid, int msgType) {
+ private RpcMessage getRpcMessage(int xid, RpcMessage.Type msgType) {
return new RpcMessage(xid, msgType) {
// Anonymous class
};
}
- @Test(expected=IllegalArgumentException.class)
- public void testInvalidMessageType() {
- int invalidMsgType = 2; // valid values are 0 and 1
- getRpcMessage(0, invalidMsgType);
- }
-
@Test
public void testRpcMessage() {
- RpcMessage msg = getRpcMessage(0, RpcMessage.RPC_CALL);
+ RpcMessage msg = getRpcMessage(0, RpcMessage.Type.RPC_CALL);
Assert.assertEquals(0, msg.getXid());
- Assert.assertEquals(RpcMessage.RPC_CALL, msg.getMessageType());
+ Assert.assertEquals(RpcMessage.Type.RPC_CALL, msg.getMessageType());
}
@Test
public void testValidateMessage() {
- RpcMessage msg = getRpcMessage(0, RpcMessage.RPC_CALL);
- msg.validateMessageType(RpcMessage.RPC_CALL);
+ RpcMessage msg = getRpcMessage(0, RpcMessage.Type.RPC_CALL);
+ msg.validateMessageType(RpcMessage.Type.RPC_CALL);
}
@Test(expected = IllegalArgumentException.class)
public void testValidateMessageException() {
- RpcMessage msg = getRpcMessage(0, RpcMessage.RPC_CALL);
- msg.validateMessageType(RpcMessage.RPC_REPLY);
+ RpcMessage msg = getRpcMessage(0, RpcMessage.Type.RPC_CALL);
+ msg.validateMessageType(RpcMessage.Type.RPC_REPLY);
}
}
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcReply.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcReply.java?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcReply.java (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/hadoop-nfs/src/test/java/org/apache/hadoop/oncrpc/TestRpcReply.java Mon Aug 12 21:25:49 2013
@@ -39,11 +39,11 @@ public class TestRpcReply {
@Test
public void testRpcReply() {
- RpcReply reply = new RpcReply(0, 1, ReplyState.MSG_ACCEPTED) {
+ RpcReply reply = new RpcReply(0, RpcMessage.Type.RPC_REPLY, ReplyState.MSG_ACCEPTED) {
// Anonymous class
};
Assert.assertEquals(0, reply.getXid());
- Assert.assertEquals(1, reply.getMessageType());
+ Assert.assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType());
Assert.assertEquals(ReplyState.MSG_ACCEPTED, reply.getState());
}
}
Modified: hadoop/common/branches/YARN-321/hadoop-common-project/pom.xml
URL: http://svn.apache.org/viewvc/hadoop/common/branches/YARN-321/hadoop-common-project/pom.xml?rev=1513258&r1=1513257&r2=1513258&view=diff
==============================================================================
--- hadoop/common/branches/YARN-321/hadoop-common-project/pom.xml (original)
+++ hadoop/common/branches/YARN-321/hadoop-common-project/pom.xml Mon Aug 12 21:25:49 2013
@@ -20,12 +20,12 @@
<parent>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-project</artifactId>
- <version>2.2.0-SNAPSHOT</version>
+ <version>2.3.0-SNAPSHOT</version>
<relativePath>../hadoop-project</relativePath>
</parent>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-common-project</artifactId>
- <version>2.2.0-SNAPSHOT</version>
+ <version>2.3.0-SNAPSHOT</version>
<description>Apache Hadoop Common Project</description>
<name>Apache Hadoop Common Project</name>
<packaging>pom</packaging>