2121import java .io .IOException ;
2222import java .io .InputStream ;
2323import java .io .OutputStream ;
24- import java .lang .reflect .Constructor ;
2524import java .net .BindException ;
2625import java .net .InetAddress ;
2726import java .net .InetSocketAddress ;
4645
4746import javax .net .SocketFactory ;
4847
49- import org .apache .hadoop .security .AccessControlException ;
50- import org .apache .hadoop .thirdparty .com .google .common .cache .Cache ;
51- import org .apache .hadoop .thirdparty .com .google .common .cache .CacheBuilder ;
52-
5348import org .apache .commons .net .util .SubnetUtils ;
5449import org .apache .commons .net .util .SubnetUtils .SubnetInfo ;
5550import org .apache .hadoop .classification .InterfaceAudience ;
5853import org .apache .hadoop .fs .CommonConfigurationKeysPublic ;
5954import org .apache .hadoop .ipc .Server ;
6055import org .apache .hadoop .ipc .VersionedProtocol ;
56+ import org .apache .hadoop .security .AccessControlException ;
6157import org .apache .hadoop .security .SecurityUtil ;
58+ import org .apache .hadoop .thirdparty .com .google .common .cache .Cache ;
59+ import org .apache .hadoop .thirdparty .com .google .common .cache .CacheBuilder ;
6260import org .apache .hadoop .util .ReflectionUtils ;
6361import org .apache .hadoop .util .Preconditions ;
62+ import org .apache .hadoop .util .dynamic .DynConstructors ;
6463
6564import org .slf4j .Logger ;
6665import org .slf4j .LoggerFactory ;
@@ -941,10 +940,59 @@ public static IOException wrapException(final String destHost,
941940
942941 }
943942 } catch (IOException ex ) {
944- return (IOException ) new IOException ("Failed on local exception: "
945- + exception + "; Host Details : "
946- + getHostDetailsAsString (destHost , destPort , localHost ))
947- .initCause (exception );
943+ try {
944+ return new IOException ("Failed on local exception: "
945+ + exception + "; Host Details : "
946+ + getHostDetailsAsString (destHost , destPort , localHost ), exception );
947+ } catch (Exception ignore ) {
948+ // in worst case, return the original exception
949+ return exception ;
950+ }
951+ }
952+ }
953+
954+ /**
955+ * Return an @{@link IOException} of the same type as the input exception but with
956+ * a modified exception message that includes the node name.
957+ *
958+ * @param ioe existing exception.
959+ * @param nodeName name of the node.
960+ * @return IOException
961+ */
962+ public static IOException addNodeNameToIOException (final IOException ioe , final String nodeName ) {
963+ try {
964+ final Throwable cause = ioe .getCause ();
965+ IOException newIoe = null ;
966+ if (cause != null ) {
967+ try {
968+ DynConstructors .Ctor <? extends IOException > ctor =
969+ new DynConstructors .Builder ()
970+ .impl (ioe .getClass (), String .class , Throwable .class )
971+ .buildChecked ();
972+ newIoe = ctor .newInstance (nodeName + ": " + ioe .getMessage (), cause );
973+ } catch (NoSuchMethodException e ) {
974+ // no matching constructor - try next approach below
975+ }
976+ }
977+ if (newIoe == null ) {
978+ DynConstructors .Ctor <? extends IOException > ctor =
979+ new DynConstructors .Builder ()
980+ .impl (ioe .getClass (), String .class )
981+ .buildChecked ();
982+ newIoe = ctor .newInstance (nodeName + ": " + ioe .getMessage ());
983+ if (cause != null ) {
984+ try {
985+ newIoe .initCause (cause );
986+ } catch (Exception e ) {
987+ // Unable to initCause. Ignore the exception.
988+ }
989+ }
990+ }
991+ newIoe .setStackTrace (ioe .getStackTrace ());
992+ return newIoe ;
993+ } catch (Exception e ) {
994+ // Unable to create new exception. Return the original exception.
995+ return ioe ;
948996 }
949997 }
950998
@@ -957,9 +1005,22 @@ private static <T extends IOException> T wrapWithMessage(
9571005 T exception , String msg ) throws T {
9581006 Class <? extends Throwable > clazz = exception .getClass ();
9591007 try {
960- Constructor <? extends Throwable > ctor = clazz .getConstructor (String .class );
961- Throwable t = ctor .newInstance (msg );
962- return (T )(t .initCause (exception ));
1008+ try {
1009+ DynConstructors .Ctor <T > ctor =
1010+ new DynConstructors .Builder ()
1011+ .impl (clazz , String .class , Throwable .class )
1012+ .buildChecked ();
1013+ return ctor .newInstance (msg , exception );
1014+ } catch (NoSuchMethodException e ) {
1015+ // no matching constructor - try next approach below
1016+ }
1017+ DynConstructors .Ctor <T > ctor =
1018+ new DynConstructors .Builder ()
1019+ .impl (clazz , String .class )
1020+ .buildChecked ();
1021+ T newException = ctor .newInstance (msg );
1022+ newException .initCause (exception );
1023+ return newException ;
9631024 } catch (NoSuchMethodException e ) {
9641025 return exception ;
9651026 } catch (Throwable e ) {
@@ -1114,7 +1175,7 @@ public static Set<Integer> getFreeSocketPorts(int numOfPorts) {
11141175
11151176 /**
11161177 * Return an @{@link InetAddress} to bind to. If bindWildCardAddress is true
1117- * than returns null.
1178+ * then returns null.
11181179 *
11191180 * @param localAddr local addr.
11201181 * @param bindWildCardAddress bind wildcard address.
0 commit comments