flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java
// this method does not mutate state and is thus thread-safe
this method does not mutate state and is thus thread-safe
this method does not mutate state and is thus thread - safe
@Override
	public <F extends Serializable, C extends FencedRpcGateway<F>> CompletableFuture<C> connect(String address, F fencingToken, Class<C> clazz) {
		return connectInternal(
			address,
			clazz,
			(ActorRef actorRef) -> {
				Tuple2<String, String> addressHostname = extractAddressHostname(actorRef);
				return new FencedAkkaInvocationHandler<>(
					addressHostname.f0,
					addressHostname.f1,
					actorRef,
					timeout,
					maximumFramesize,
					null,
					null,
					() -> fencingToken);
			});
	}
@ Override public < F extends Serializable , C extends FencedRpcGateway < F > > CompletableFuture < C > connect ( String address , F fencingToken , Class < C > clazz ) { return connectInternal ( address , clazz , ( ActorRef actorRef ) -> { Tuple2 < String , String > addressHostname = extractAddressHostname ( actorRef ) ; return new FencedAkkaInvocationHandler < > ( addressHostname . f0 , addressHostname . f1 , actorRef , timeout , maximumFramesize , null , null , ( ) -> fencingToken ) ; } ) ; }
this method does not mutate state and is thus thread-safe
this method does not mutate state and is thus thread - safe