flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java
/**
	 * Create the RpcInvocation message for the given RPC.
	 *
	 * @param methodName of the RPC
	 * @param parameterTypes of the RPC
	 * @param args of the RPC
	 * @return RpcInvocation message which encapsulates the RPC details
	 * @throws IOException if we cannot serialize the RPC invocation parameters
	 */
Create the RpcInvocation message for the given RPC.
Create the RpcInvocation message for the given RPC .
protected RpcInvocation createRpcInvocationMessage(
			final String methodName,
			final Class<?>[] parameterTypes,
			final Object[] args) throws IOException {
		final RpcInvocation rpcInvocation;
		if (isLocal) {
			rpcInvocation = new LocalRpcInvocation(
				methodName,
				parameterTypes,
				args);
		} else {
			try {
				RemoteRpcInvocation remoteRpcInvocation = new RemoteRpcInvocation(
					methodName,
					parameterTypes,
					args);
				if (remoteRpcInvocation.getSize() > maximumFramesize) {
					throw new IOException("The rpc invocation size exceeds the maximum akka framesize.");
				} else {
					rpcInvocation = remoteRpcInvocation;
				}
			} catch (IOException e) {
				LOG.warn("Could not create remote rpc invocation message. Failing rpc invocation because...", e);
				throw e;
			}
		}
		return rpcInvocation;
	}
protected RpcInvocation createRpcInvocationMessage ( final String methodName , final Class < ? > [ ] parameterTypes , final Object [ ] args ) throws IOException { final RpcInvocation rpcInvocation ; if ( isLocal ) { rpcInvocation = new LocalRpcInvocation ( methodName , parameterTypes , args ) ; } else { try { RemoteRpcInvocation remoteRpcInvocation = new RemoteRpcInvocation ( methodName , parameterTypes , args ) ; if ( remoteRpcInvocation . getSize ( ) > maximumFramesize ) { throw new IOException ( "The rpc invocation size exceeds the maximum akka framesize." ) ; } else { rpcInvocation = remoteRpcInvocation ; } } catch ( IOException e ) { LOG . warn ( "Could not create remote rpc invocation message. Failing rpc invocation because..." , e ) ; throw e ; } } return rpcInvocation ; }
Create the RpcInvocation message for the given RPC.
Create the RpcInvocation message for the given RPC .