http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java index e3ab3a9..7ea2c03 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsMetaManager.java @@ -77,14 +77,14 @@ public class GridGgfsMetaManager extends GridGgfsManager { try { metaCacheStartFut.get(); } - catch (GridException e) { - throw new GridRuntimeException(e); + catch (IgniteCheckedException e) { + throw new IgniteException(e); } } } /** {@inheritDoc} */ - @Override protected void start0() throws GridException { + @Override protected void start0() throws IgniteCheckedException { cfg = ggfsCtx.configuration(); metaCache = ggfsCtx.kernalContext().cache().cache(cfg.getMetaCacheName()); @@ -93,7 +93,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { .startFuture(); if (metaCache.configuration().getAtomicityMode() != TRANSACTIONAL) - throw new GridException("Meta cache should be transactional: " + cfg.getMetaCacheName()); + throw new IgniteCheckedException("Meta cache should be transactional: " + cfg.getMetaCacheName()); evts = ggfsCtx.kernalContext().event(); @@ -107,7 +107,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { } /** {@inheritDoc} */ - @Override protected void onKernalStart0() throws GridException { + @Override protected void onKernalStart0() throws IgniteCheckedException { locNode = ggfsCtx.kernalContext().discovery().localNode(); // Start background delete worker. @@ -158,9 +158,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param path Path. * @return File ID for specified path or {@code null} if such file doesn't exist. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - @Nullable public IgniteUuid fileId(IgniteFsPath path) throws GridException { + @Nullable public IgniteUuid fileId(IgniteFsPath path) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -181,9 +181,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path. * @param skipTx Whether to skip existing transaction. * @return File ID for specified path or {@code null} if such file doesn't exist. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - @Nullable private IgniteUuid fileId(IgniteFsPath path, boolean skipTx) throws GridException { + @Nullable private IgniteUuid fileId(IgniteFsPath path, boolean skipTx) throws IgniteCheckedException { List<IgniteUuid> ids = fileIds(path, skipTx); assert ids != null && !ids.isEmpty() : "Invalid file IDs [path=" + path + ", ids=" + ids + ']'; @@ -197,9 +197,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param parentId Parent directory ID to get child ID for. * @param fileName File name in parent listing to get file ID for. * @return File ID. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - @Nullable public IgniteUuid fileId(IgniteUuid parentId, String fileName) throws GridException { + @Nullable public IgniteUuid fileId(IgniteUuid parentId, String fileName) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { return fileId(parentId, fileName, false); @@ -220,9 +220,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fileName File name in parent listing to get file ID for. * @param skipTx Whether to skip existing transaction. * @return File ID. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - @Nullable private IgniteUuid fileId(IgniteUuid parentId, String fileName, boolean skipTx) throws GridException { + @Nullable private IgniteUuid fileId(IgniteUuid parentId, String fileName, boolean skipTx) throws IgniteCheckedException { GridGgfsListingEntry entry = directoryListing(parentId, skipTx).get(fileName); if (entry == null) { @@ -241,9 +241,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param path Path. * @return Collection of file IDs for components of specified path. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public List<IgniteUuid> fileIds(IgniteFsPath path) throws GridException { + public List<IgniteUuid> fileIds(IgniteFsPath path) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -266,9 +266,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path. * @param skipTx Whether to skip existing transaction. * @return Collection of file IDs for components of specified path. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - private List<IgniteUuid> fileIds(IgniteFsPath path, boolean skipTx) throws GridException { + private List<IgniteUuid> fileIds(IgniteFsPath path, boolean skipTx) throws IgniteCheckedException { assert path != null; // Path components. @@ -298,9 +298,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param fileId File id. * @return {@code True} in case such entry exists. - * @throws GridException IF failed. + * @throws IgniteCheckedException IF failed. */ - public boolean exists(IgniteUuid fileId) throws GridException{ + public boolean exists(IgniteUuid fileId) throws IgniteCheckedException{ if (busyLock.enterBusy()) { try { assert fileId != null; @@ -322,9 +322,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param fileId File ID to get details for. * @return File info. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - @Nullable public GridGgfsFileInfo info(@Nullable IgniteUuid fileId) throws GridException { + @Nullable public GridGgfsFileInfo info(@Nullable IgniteUuid fileId) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { if (fileId == null) @@ -351,9 +351,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param fileIds file IDs to get details for. * @return Files details. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public Map<IgniteUuid, GridGgfsFileInfo> infos(Collection<IgniteUuid> fileIds) throws GridException { + public Map<IgniteUuid, GridGgfsFileInfo> infos(Collection<IgniteUuid> fileIds) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -390,9 +390,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param fileId File ID to lock. * @return Locked file info or {@code null} if file cannot be locked or doesn't exist. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public GridGgfsFileInfo lock(IgniteUuid fileId) throws GridException { + public GridGgfsFileInfo lock(IgniteUuid fileId) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -405,7 +405,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { GridGgfsFileInfo oldInfo = info(fileId); if (oldInfo == null) - throw new GridException("Failed to lock file (file not found): " + fileId); + throw new IgniteCheckedException("Failed to lock file (file not found): " + fileId); GridGgfsFileInfo newInfo = lockInfo(oldInfo); @@ -437,15 +437,15 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param info File info. * @return New file info with lock set. - * @throws GridException In case lock is already set on that file. + * @throws IgniteCheckedException In case lock is already set on that file. */ - public GridGgfsFileInfo lockInfo(GridGgfsFileInfo info) throws GridException { + public GridGgfsFileInfo lockInfo(GridGgfsFileInfo info) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert info != null; if (info.lockId() != null) - throw new GridException("Failed to lock file (file is being concurrently written) [fileId=" + + throw new IgniteCheckedException("Failed to lock file (file is being concurrently written) [fileId=" + info.id() + ", lockId=" + info.lockId() + ']'); return new GridGgfsFileInfo(info, IgniteUuid.randomUuid(), info.modificationTime()); @@ -463,9 +463,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param info File info to unlock. * @param modificationTime Modification time to write to file info. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public void unlock(GridGgfsFileInfo info, long modificationTime) throws GridException { + public void unlock(GridGgfsFileInfo info, long modificationTime) throws IgniteCheckedException { assert validTxState(false); assert info != null; @@ -491,7 +491,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { throw new IgniteFsFileNotFoundException("Failed to unlock file (file not found): " + fileId); if (!info.lockId().equals(oldInfo.lockId())) - throw new GridException("Failed to unlock file (inconsistent file lock ID) [fileId=" + fileId + + throw new IgniteCheckedException("Failed to unlock file (inconsistent file lock ID) [fileId=" + fileId + ", lockId=" + info.lockId() + ", actualLockId=" + oldInfo.lockId() + ']'); GridGgfsFileInfo newInfo = new GridGgfsFileInfo(oldInfo, null, modificationTime); @@ -527,9 +527,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param fileIds file IDs to lock. * @return Locked file details. Resulting map doesn't contain details for not-existent files. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - private Map<IgniteUuid, GridGgfsFileInfo> lockIds(IgniteUuid... fileIds) throws GridException { + private Map<IgniteUuid, GridGgfsFileInfo> lockIds(IgniteUuid... fileIds) throws IgniteCheckedException { assert validTxState(true); assert fileIds != null && fileIds.length > 0; @@ -568,9 +568,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param fileId File to list child files for. * @return Directory listing for the specified file. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public Map<String, GridGgfsListingEntry> directoryListing(IgniteUuid fileId) throws GridException { + public Map<String, GridGgfsListingEntry> directoryListing(IgniteUuid fileId) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { return directoryListing(fileId, false); @@ -588,9 +588,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param exclude File IDs to exclude from result. * @return First qualified file info. - * @throws GridException If failed to get file for fragmentizer. + * @throws IgniteCheckedException If failed to get file for fragmentizer. */ - public GridGgfsFileInfo fileForFragmentizer(Collection<IgniteUuid> exclude) throws GridException { + public GridGgfsFileInfo fileForFragmentizer(Collection<IgniteUuid> exclude) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { return fileForFragmentizer0(ROOT_ID, exclude); @@ -609,10 +609,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param parentId Parent ID to scan. * @param exclude File IDs to exclude from result. * @return First qualified file info. - * @throws GridException If failed to get file for fragmentizer. + * @throws IgniteCheckedException If failed to get file for fragmentizer. */ private GridGgfsFileInfo fileForFragmentizer0(IgniteUuid parentId, Collection<IgniteUuid> exclude) - throws GridException { + throws IgniteCheckedException { GridGgfsFileInfo info = info(parentId); // Check if file was concurrently deleted. @@ -651,9 +651,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fileId File to list child files for. * @param skipTx Whether to skip existing transaction. * @return Directory listing for the specified file.* - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - private Map<String, GridGgfsListingEntry> directoryListing(IgniteUuid fileId, boolean skipTx) throws GridException { + private Map<String, GridGgfsListingEntry> directoryListing(IgniteUuid fileId, boolean skipTx) throws IgniteCheckedException { assert fileId != null; GridGgfsFileInfo info = skipTx ? id2InfoPrj.getAllOutTx(Collections.singletonList(fileId)).get(fileId) : @@ -669,10 +669,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fileName File name in the parent's listing. * @param newFileInfo File info to store in the parent's listing. * @return File id already stored in meta cache or {@code null} if passed file info was stored. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ public IgniteUuid putIfAbsent(IgniteUuid parentId, String fileName, GridGgfsFileInfo newFileInfo) - throws GridException { + throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -711,10 +711,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fileName File name in the parent's listing. * @param newFileInfo File info to store in the parent's listing. * @return File id already stored in meta cache or {@code null} if passed file info was stored. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ private IgniteUuid putIfAbsentNonTx(IgniteUuid parentId, String fileName, GridGgfsFileInfo newFileInfo) - throws GridException { + throws IgniteCheckedException { if (log.isDebugEnabled()) log.debug("Locking parent id [parentId=" + parentId + ", fileName=" + fileName + ", newFileInfo=" + newFileInfo + ']'); @@ -763,10 +763,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param srcParentId Parent directory ID. * @param destFileName New file name in the parent's listing after moving. * @param destParentId New parent directory ID. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ public void move(IgniteUuid fileId, String srcFileName, IgniteUuid srcParentId, String destFileName, - IgniteUuid destParentId) throws GridException { + IgniteUuid destParentId) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -800,10 +800,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param srcParentId Parent directory ID. * @param destFileName New file name in the parent's listing after moving. * @param destParentId New parent directory ID. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ private void moveNonTx(IgniteUuid fileId, @Nullable String srcFileName, IgniteUuid srcParentId, String destFileName, - IgniteUuid destParentId) throws GridException { + IgniteUuid destParentId) throws IgniteCheckedException { assert validTxState(true); assert fileId != null; assert srcFileName != null; @@ -882,11 +882,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path of the deleted file. * @param rmvLocked Whether to remove this entry in case it is has explicit lock. * @return The last actual file info or {@code null} if such file no more exist. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ @Nullable public GridGgfsFileInfo removeIfEmpty(IgniteUuid parentId, String fileName, IgniteUuid fileId, IgniteFsPath path, boolean rmvLocked) - throws GridException { + throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -929,11 +929,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path of the deleted file. * @param rmvLocked Whether to remove this entry in case it has explicit lock. * @return The last actual file info or {@code null} if such file no more exist. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ @Nullable private GridGgfsFileInfo removeIfEmptyNonTx(@Nullable IgniteUuid parentId, String fileName, IgniteUuid fileId, IgniteFsPath path, boolean rmvLocked) - throws GridException { + throws IgniteCheckedException { assert validTxState(true); assert parentId != null; assert fileName != null; @@ -953,7 +953,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { // If file info does not exists but listing entry exists, throw inconsistent exception. if (entry != null && entry.fileId().equals(fileId)) - throw new GridException("Failed to remove file (file system is in inconsistent state) " + + throw new IgniteCheckedException("Failed to remove file (file system is in inconsistent state) " + "[fileInfo=" + fileInfo + ", fileName=" + fileName + ", fileId=" + fileId + ']'); } @@ -998,9 +998,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param pathName Path name. * @param pathId Path ID. * @return ID of an entry located directly under the trash directory. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - IgniteUuid softDelete(@Nullable IgniteUuid parentId, @Nullable String pathName, IgniteUuid pathId) throws GridException { + IgniteUuid softDelete(@Nullable IgniteUuid parentId, @Nullable String pathName, IgniteUuid pathId) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -1041,10 +1041,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param name Path name. * @param id Path ID. * @return ID of an entry located directly under the trash directory. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ @Nullable private IgniteUuid softDeleteNonTx(@Nullable IgniteUuid parentId, @Nullable String name, IgniteUuid id) - throws GridException { + throws IgniteCheckedException { assert validTxState(true); IgniteUuid resId; @@ -1116,10 +1116,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param parentId Parent ID. * @param listing Listing entries. * @return Collection of really deleted entries. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ Collection<IgniteUuid> delete(IgniteUuid parentId, Map<String, GridGgfsListingEntry> listing) - throws GridException { + throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert parentId != null; @@ -1204,9 +1204,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param name Name. * @param id ID. * @return {@code True} in case the entry really was removed from the cache by this call. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - boolean delete(IgniteUuid parentId, String name, IgniteUuid id) throws GridException { + boolean delete(IgniteUuid parentId, String name, IgniteUuid id) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -1255,9 +1255,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * Check whether there are any pending deletes and return collection of pending delete entry IDs. * * @return Collection of entry IDs to be deleted. - * @throws GridException If operation failed. + * @throws IgniteCheckedException If operation failed. */ - public Collection<IgniteUuid> pendingDeletes() throws GridException { + public Collection<IgniteUuid> pendingDeletes() throws IgniteCheckedException { if (busyLock.enterBusy()) { try { GridGgfsFileInfo trashInfo = id2InfoPrj.get(TRASH_ID); @@ -1292,10 +1292,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fileId File ID to update information for. * @param props Properties to set for the file. * @return Updated file info or {@code null} if such file ID not found. - * @throws GridException If operation failed. + * @throws IgniteCheckedException If operation failed. */ @Nullable private GridGgfsFileInfo updatePropertiesNonTx(@Nullable IgniteUuid parentId, IgniteUuid fileId, - String fileName, Map<String, String> props) throws GridException { + String fileName, Map<String, String> props) throws IgniteCheckedException { assert fileId != null; assert !F.isEmpty(props) : "Expects not-empty file's properties"; assert validTxState(true); @@ -1376,10 +1376,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fileId File ID to update information for. * @param props Properties to set for the file. * @return Updated file info or {@code null} if such file ID not found. - * @throws GridException If operation failed. + * @throws IgniteCheckedException If operation failed. */ @Nullable public GridGgfsFileInfo updateProperties(@Nullable IgniteUuid parentId, IgniteUuid fileId, String fileName, - Map<String, String> props) throws GridException { + Map<String, String> props) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -1441,10 +1441,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fileId File ID to update information for. * @param c Closure to update file's info inside transaction. * @return Updated file info or {@code null} if such file ID not found. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ @Nullable public GridGgfsFileInfo updateInfo(IgniteUuid fileId, IgniteClosure<GridGgfsFileInfo, GridGgfsFileInfo> c) - throws GridException { + throws IgniteCheckedException { assert validTxState(false); assert fileId != null; assert c != null; @@ -1510,9 +1510,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param val Sampling flag state or {@code null} to clear sampling state and mark it as "not set". * @return {@code True} if sampling mode was actually changed by this call. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public boolean sampling(Boolean val) throws GridException { + public boolean sampling(Boolean val) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { validTxState(false); @@ -1543,9 +1543,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @return {@code True} in case sampling is enabled, {@code false} otherwise or {@code null} in case sampling * is not set. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public Boolean sampling() throws GridException { + public Boolean sampling() throws IgniteCheckedException { if (busyLock.enterBusy()) { try { validTxState(false); @@ -1575,12 +1575,12 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param blockSize Block size. * @param affKey Affinity key. * @return Output stream descriptor. - * @throws GridException If file creation failed. + * @throws IgniteCheckedException If file creation failed. */ public GridGgfsSecondaryOutputStreamDescriptor createDual(final IgniteFsFileSystem fs, final IgniteFsPath path, final boolean simpleCreate, @Nullable final Map<String, String> props, final boolean overwrite, final int bufSize, final short replication, final long blockSize, final IgniteUuid affKey) - throws GridException { + throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert fs != null; @@ -1674,7 +1674,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { evts.record(new IgniteFsEvent(path, locNode, EVT_GGFS_FILE_PURGED)); } - catch (GridException e) { + catch (IgniteCheckedException e) { LT.warn(log, e, "Old file deletion failed in DUAL mode [path=" + path + ", simpleCreate=" + simpleCreate + ", props=" + props + ", overwrite=" + overwrite + ", bufferSize=" + bufSize + @@ -1697,7 +1697,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { } @Override public GridGgfsSecondaryOutputStreamDescriptor onFailure(Exception err) - throws GridException { + throws IgniteCheckedException { U.closeQuiet(out); U.error(log, "File create in DUAL mode failed [path=" + path + ", simpleCreate=" + @@ -1735,10 +1735,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path. * @param bufSize Buffer size. * @return Output stream descriptor. - * @throws GridException If output stream open for append has failed. + * @throws IgniteCheckedException If output stream open for append has failed. */ public GridGgfsSecondaryOutputStreamDescriptor appendDual(final IgniteFsFileSystem fs, final IgniteFsPath path, - final int bufSize) throws GridException { + final int bufSize) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert fs != null; @@ -1787,7 +1787,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { } @Override public GridGgfsSecondaryOutputStreamDescriptor onFailure(@Nullable Exception err) - throws GridException { + throws IgniteCheckedException { U.closeQuiet(out); U.error(log, "File append in DUAL mode failed [path=" + path + ", bufferSize=" + bufSize + @@ -1796,7 +1796,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { if (err instanceof IgniteFsException) throw (IgniteFsException)err; else - throw new GridException("Failed to append to the file due to secondary file system " + + throw new IgniteCheckedException("Failed to append to the file due to secondary file system " + "exception: " + path, err); } }; @@ -1818,11 +1818,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path to open. * @param bufSize Buffer size. * @return Input stream descriptor. - * @throws GridException If input stream open has failed. + * @throws IgniteCheckedException If input stream open has failed. */ public GridGgfsSecondaryInputStreamDescriptor openDual(final IgniteFsFileSystem fs, final IgniteFsPath path, final int bufSize) - throws GridException { + throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert fs != null; @@ -1854,14 +1854,14 @@ public class GridGgfsMetaManager extends GridGgfsManager { } @Override public GridGgfsSecondaryInputStreamDescriptor onFailure(@Nullable Exception err) - throws GridException { + throws IgniteCheckedException { U.error(log, "File open in DUAL mode failed [path=" + path + ", bufferSize=" + bufSize + ']', err); if (err instanceof IgniteFsException) - throw (GridException)err; + throw (IgniteCheckedException)err; else - throw new GridException("Failed to open the path due to secondary file system " + + throw new IgniteCheckedException("Failed to open the path due to secondary file system " + "exception: " + path, err); } }; @@ -1882,10 +1882,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fs File system. * @param path Path. * @return File info or {@code null} if file not found. - * @throws GridException If sync task failed. + * @throws IgniteCheckedException If sync task failed. */ @Nullable public GridGgfsFileInfo synchronizeFileDual(final IgniteFsFileSystem fs, final IgniteFsPath path) - throws GridException { + throws IgniteCheckedException { assert fs != null; assert path != null; @@ -1905,11 +1905,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { return infos.get(path); } - @Override public GridGgfsFileInfo onFailure(@Nullable Exception err) throws GridException { + @Override public GridGgfsFileInfo onFailure(@Nullable Exception err) throws IgniteCheckedException { if (err instanceof IgniteFsException) - throw (GridException)err; + throw (IgniteCheckedException)err; else - throw new GridException("Failed to synchronize path due to secondary file system " + + throw new IgniteCheckedException("Failed to synchronize path due to secondary file system " + "exception: " + path, err); } }; @@ -1933,10 +1933,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path to create. * @param props Properties to be applied. * @return {@code True} in case rename was successful. - * @throws GridException If directory creation failed. + * @throws IgniteCheckedException If directory creation failed. */ public boolean mkdirsDual(final IgniteFsFileSystem fs, final IgniteFsPath path, final Map<String, String> props) - throws GridException { + throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert fs != null; @@ -1984,11 +1984,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { return true; } - @Override public Boolean onFailure(@Nullable Exception err) throws GridException { + @Override public Boolean onFailure(@Nullable Exception err) throws IgniteCheckedException { U.error(log, "Directory creation in DUAL mode failed [path=" + path + ", properties=" + props + ']', err); - throw new GridException("Failed to create the path due to secondary file system exception: " + + throw new IgniteCheckedException("Failed to create the path due to secondary file system exception: " + path, err); } }; @@ -2017,10 +2017,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param src Source path. * @param dest Destination path. * @return Operation result. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ public boolean renameDual(final IgniteFsFileSystem fs, final IgniteFsPath src, final IgniteFsPath dest) throws - GridException { + IgniteCheckedException { if (busyLock.enterBusy()) { try { assert fs != null; @@ -2082,14 +2082,14 @@ public class GridGgfsMetaManager extends GridGgfsManager { return true; } - @Override public Boolean onFailure(@Nullable Exception err) throws GridException { + @Override public Boolean onFailure(@Nullable Exception err) throws IgniteCheckedException { U.error(log, "Path rename in DUAL mode failed [source=" + src + ", destination=" + dest + ']', err); if (err instanceof IgniteFsException) - throw (GridException)err; + throw (IgniteCheckedException)err; else - throw new GridException("Failed to rename the path due to secondary file system " + + throw new IgniteCheckedException("Failed to rename the path due to secondary file system " + "exception: " + src, err); } }; @@ -2118,10 +2118,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path to update. * @param recursive Recursive flag. * @return Operation result. - * @throws GridException If delete failed. + * @throws IgniteCheckedException If delete failed. */ public boolean deleteDual(final IgniteFsFileSystem fs, final IgniteFsPath path, final boolean recursive) - throws GridException { + throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert fs != null; @@ -2154,11 +2154,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { return true; // No additional handling is required. } - @Override public Boolean onFailure(@Nullable Exception err) throws GridException { + @Override public Boolean onFailure(@Nullable Exception err) throws IgniteCheckedException { U.error(log, "Path delete in DUAL mode failed [path=" + path + ", recursive=" + recursive + ']', err); - throw new GridException("Failed to delete the path due to secondary file system exception: ", + throw new IgniteCheckedException("Failed to delete the path due to secondary file system exception: ", err); } }; @@ -2184,10 +2184,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param path Path to update. * @param props Properties to be applied. * @return Update file info. - * @throws GridException If update failed. + * @throws IgniteCheckedException If update failed. */ public GridGgfsFileInfo updateDual(final IgniteFsFileSystem fs, final IgniteFsPath path, final Map<String, String> props) - throws GridException { + throws IgniteCheckedException { assert fs != null; assert path != null; assert props != null && !props.isEmpty(); @@ -2208,11 +2208,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { props); } - @Override public GridGgfsFileInfo onFailure(@Nullable Exception err) throws GridException { + @Override public GridGgfsFileInfo onFailure(@Nullable Exception err) throws IgniteCheckedException { U.error(log, "Path update in DUAL mode failed [path=" + path + ", properties=" + props + ']', err); - throw new GridException("Failed to update the path due to secondary file system exception: " + + throw new IgniteCheckedException("Failed to update the path due to secondary file system exception: " + path, err); } }; @@ -2237,11 +2237,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param strict Whether all paths must exist in the secondary file system. * @param created Optional map where data about all created values is put. * @return File info of the end path. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ private GridGgfsFileInfo synchronize(IgniteFsFileSystem fs, IgniteFsPath startPath, GridGgfsFileInfo startPathInfo, IgniteFsPath endPath, boolean strict, @Nullable Map<IgniteFsPath, GridGgfsFileInfo> created) - throws GridException { + throws IgniteCheckedException { assert fs != null; assert startPath != null && startPathInfo != null && endPath != null; @@ -2265,13 +2265,13 @@ public class GridGgfsMetaManager extends GridGgfsManager { if (status != null) { if (!status.isDirectory() && !curPath.equals(endPath)) - throw new GridException("Failed to create path the locally because secondary file system " + + throw new IgniteCheckedException("Failed to create path the locally because secondary file system " + "directory structure was modified concurrently and the path is not a directory as " + "expected: " + curPath); } else { if (strict) { - throw new GridException("Failed to create path locally due to secondary file system " + + throw new IgniteCheckedException("Failed to create path locally due to secondary file system " + "exception: " + curPath); } else if (created != null) @@ -2309,11 +2309,11 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param strict Whether paths must be re-created strictly. * @param paths Paths to synchronize. * @return Result of task execution. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ private <T> T synchronizeAndExecute(SynchronizationTask<T> task, IgniteFsFileSystem fs, boolean strict, IgniteFsPath... paths) - throws GridException { + throws IgniteCheckedException { return synchronizeAndExecute(task, fs, strict, null, paths); } @@ -2327,10 +2327,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param extraLockIds Additional IDs to lock (optional). * @param paths Paths to synchronize. * @return Result of task execution. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ private <T> T synchronizeAndExecute(SynchronizationTask<T> task, IgniteFsFileSystem fs, boolean strict, - @Nullable Collection<IgniteUuid> extraLockIds, IgniteFsPath... paths) throws GridException { + @Nullable Collection<IgniteUuid> extraLockIds, IgniteFsPath... paths) throws IgniteCheckedException { assert task != null; assert fs != null; assert paths != null && paths.length > 0; @@ -2505,7 +2505,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { tx.commit(); } - catch (GridException e) { + catch (IgniteCheckedException e) { if (!finished) { finished = true; @@ -2529,9 +2529,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param key Key to retrieve/update the value for. * @param c Closure to apply to cached value. * @return {@code True} if value was stored in cache, {@code false} otherwise. - * @throws GridException If operation failed. + * @throws IgniteCheckedException If operation failed. */ - private <K, V> boolean putx(GridCacheProjection<K, V> cache, K key, IgniteClosure<V, V> c) throws GridException { + private <K, V> boolean putx(GridCacheProjection<K, V> cache, K key, IgniteClosure<V, V> c) throws IgniteCheckedException { assert validTxState(true); V oldVal = cache.get(key); @@ -2564,10 +2564,10 @@ public class GridGgfsMetaManager extends GridGgfsManager { * @param fileName File name to update. Must match file ID. * @param accessTime Access time to set. If {@code -1}, will not be updated. * @param modificationTime Modification time to set. If {@code -1}, will not be updated. - * @throws GridException If update failed. + * @throws IgniteCheckedException If update failed. */ public void updateTimes(IgniteUuid parentId, IgniteUuid fileId, String fileName, long accessTime, - long modificationTime) throws GridException { + long modificationTime) throws IgniteCheckedException { if (busyLock.enterBusy()) { try { assert validTxState(false); @@ -2641,9 +2641,9 @@ public class GridGgfsMetaManager extends GridGgfsManager { * * @param err Optional exception. * @return Task result. - * @throws GridException In case exception is to be thrown in that case. + * @throws IgniteCheckedException In case exception is to be thrown in that case. */ - public T onFailure(Exception err) throws GridException; + public T onFailure(Exception err) throws IgniteCheckedException; } /** @@ -2880,7 +2880,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { GridGgfsListingEntry oldEntry = listing.get(fileName); if (oldEntry == null || !oldEntry.fileId().equals(entry.fileId())) - throw new GridRuntimeException("Directory listing doesn't contain expected file" + + throw new IgniteException("Directory listing doesn't contain expected file" + " [listing=" + listing + ", fileName=" + fileName + ", entry=" + entry + ']'); // Modify listing in-place. @@ -2891,7 +2891,7 @@ public class GridGgfsMetaManager extends GridGgfsManager { GridGgfsListingEntry oldEntry = listing.put(fileName, entry); if (oldEntry != null && !oldEntry.fileId().equals(entry.fileId())) - throw new GridRuntimeException("Directory listing contains unexpected file" + + throw new IgniteException("Directory listing contains unexpected file" + " [listing=" + listing + ", fileName=" + fileName + ", entry=" + entry + ", oldEntry=" + oldEntry + ']'); }
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsProcessor.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsProcessor.java index bdaacd6..76d49e8 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsProcessor.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsProcessor.java @@ -65,7 +65,7 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { } /** {@inheritDoc} */ - @Override public void start() throws GridException { + @Override public void start() throws IgniteCheckedException { if (ctx.config().isDaemon()) return; @@ -137,7 +137,7 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { } /** {@inheritDoc} */ - @Override public void onKernalStart() throws GridException { + @Override public void onKernalStart() throws IgniteCheckedException { if (ctx.config().isDaemon()) return; @@ -229,7 +229,7 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override public void addAttributes(Map<String, Object> attrs) throws GridException { + @Override public void addAttributes(Map<String, Object> attrs) throws IgniteCheckedException { super.addAttributes(attrs); IgniteConfiguration gridCfg = ctx.config(); @@ -292,39 +292,39 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { /** * Validates local GGFS configurations. Compares attributes only for GGFSes with same name. * @param cfgs GGFS configurations - * @throws GridException If any of GGFS configurations is invalid. + * @throws IgniteCheckedException If any of GGFS configurations is invalid. */ - private void validateLocalGgfsConfigurations(IgniteFsConfiguration[] cfgs) throws GridException { + private void validateLocalGgfsConfigurations(IgniteFsConfiguration[] cfgs) throws IgniteCheckedException { Collection<String> cfgNames = new HashSet<>(); for (IgniteFsConfiguration cfg : cfgs) { String name = cfg.getName(); if (cfgNames.contains(name)) - throw new GridException("Duplicate GGFS name found (check configuration and " + + throw new IgniteCheckedException("Duplicate GGFS name found (check configuration and " + "assign unique name to each): " + name); GridCacheAdapter<Object, Object> dataCache = ctx.cache().internalCache(cfg.getDataCacheName()); if (dataCache == null) - throw new GridException("Data cache is not configured locally for GGFS: " + cfg); + throw new IgniteCheckedException("Data cache is not configured locally for GGFS: " + cfg); if (dataCache.configuration().isQueryIndexEnabled()) - throw new GridException("GGFS data cache cannot start with enabled query indexing."); + throw new IgniteCheckedException("GGFS data cache cannot start with enabled query indexing."); GridCache<Object, Object> metaCache = ctx.cache().cache(cfg.getMetaCacheName()); if (metaCache == null) - throw new GridException("Metadata cache is not configured locally for GGFS: " + cfg); + throw new IgniteCheckedException("Metadata cache is not configured locally for GGFS: " + cfg); if (metaCache.configuration().isQueryIndexEnabled()) - throw new GridException("GGFS metadata cache cannot start with enabled query indexing."); + throw new IgniteCheckedException("GGFS metadata cache cannot start with enabled query indexing."); if (F.eq(cfg.getDataCacheName(), cfg.getMetaCacheName())) - throw new GridException("Cannot use same cache as both data and meta cache: " + cfg.getName()); + throw new IgniteCheckedException("Cannot use same cache as both data and meta cache: " + cfg.getName()); if (!(dataCache.configuration().getAffinityMapper() instanceof IgniteFsGroupDataBlocksKeyMapper)) - throw new GridException("Invalid GGFS data cache configuration (key affinity mapper class should be " + + throw new IgniteCheckedException("Invalid GGFS data cache configuration (key affinity mapper class should be " + IgniteFsGroupDataBlocksKeyMapper.class.getSimpleName() + "): " + cfg); long maxSpaceSize = cfg.getMaxSpaceSize(); @@ -336,11 +336,11 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { if (offHeapSize < 0 && maxSpaceSize > maxHeapSize) // Offheap is disabled. - throw new GridException("Maximum GGFS space size cannot be greater that size of available heap " + + throw new IgniteCheckedException("Maximum GGFS space size cannot be greater that size of available heap " + "memory [maxHeapSize=" + maxHeapSize + ", maxGgfsSpaceSize=" + maxSpaceSize + ']'); else if (offHeapSize > 0 && maxSpaceSize > maxHeapSize + offHeapSize) // Offheap is enabled, but limited. - throw new GridException("Maximum GGFS space size cannot be greater than size of available heap " + + throw new IgniteCheckedException("Maximum GGFS space size cannot be greater than size of available heap " + "memory and offheap storage [maxHeapSize=" + maxHeapSize + ", offHeapSize=" + offHeapSize + ", maxGgfsSpaceSize=" + maxSpaceSize + ']'); } @@ -349,7 +349,7 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { int backups = dataCache.configuration().getBackups(); if (backups != 0) - throw new GridException("GGFS data cache cannot be used with backups (set backup count " + + throw new IgniteCheckedException("GGFS data cache cannot be used with backups (set backup count " + "to 0 and restart the grid): " + cfg.getDataCacheName()); } @@ -380,9 +380,9 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { * Check GGFS config on remote node. * * @param rmtNode Remote node. - * @throws GridException If check failed. + * @throws IgniteCheckedException If check failed. */ - private void checkGgfsOnRemoteNode(ClusterNode rmtNode) throws GridException { + private void checkGgfsOnRemoteNode(ClusterNode rmtNode) throws IgniteCheckedException { GridGgfsAttributes[] locAttrs = ctx.discovery().localNode().attribute(GridNodeAttributes.ATTR_GGFS); GridGgfsAttributes[] rmtAttrs = rmtNode.attribute(GridNodeAttributes.ATTR_GGFS); @@ -396,7 +396,7 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { // Checking the use of different caches on the different GGFSes. if (!F.eq(rmtAttr.ggfsName(), locAttr.ggfsName())) { if (F.eq(rmtAttr.metaCacheName(), locAttr.metaCacheName())) - throw new GridException("Meta cache names should be different for different GGFS instances " + + throw new IgniteCheckedException("Meta cache names should be different for different GGFS instances " + "configuration (fix configuration or set " + "-D" + GG_SKIP_CONFIGURATION_CONSISTENCY_CHECK + "=true system " + "property) [metaCacheName=" + rmtAttr.metaCacheName() + @@ -406,7 +406,7 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { ", rmtGgfsName=" + rmtAttr.ggfsName() + ']'); if (F.eq(rmtAttr.dataCacheName(), locAttr.dataCacheName())) - throw new GridException("Data cache names should be different for different GGFS instances " + + throw new IgniteCheckedException("Data cache names should be different for different GGFS instances " + "configuration (fix configuration or set " + "-D" + GG_SKIP_CONFIGURATION_CONSISTENCY_CHECK + "=true system " + "property)[dataCacheName=" + rmtAttr.dataCacheName() + @@ -443,9 +443,9 @@ public class GridGgfsProcessor extends GridGgfsProcessorAdapter { } private void checkSame(String name, String propName, UUID rmtNodeId, Object rmtVal, Object locVal, String ggfsName) - throws GridException { + throws IgniteCheckedException { if (!F.eq(rmtVal, locVal)) - throw new GridException(name + " should be the same on all nodes in grid for GGFS configuration " + + throw new IgniteCheckedException(name + " should be the same on all nodes in grid for GGFS configuration " + "(fix configuration or set " + "-D" + GG_SKIP_CONFIGURATION_CONSISTENCY_CHECK + "=true system " + "property ) [rmtNodeId=" + rmtNodeId + http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServer.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServer.java index 3e8bf3e..ac5b3f3 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServer.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServer.java @@ -81,13 +81,13 @@ public class GridGgfsServer { /** * Starts this server. * - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public void start() throws GridException { + public void start() throws IgniteCheckedException { srvEndpoint = GridIpcServerEndpointDeserializer.deserialize(endpointCfg); if (U.isWindows() && srvEndpoint instanceof GridIpcSharedMemoryServerEndpoint) - throw new GridException(GridIpcSharedMemoryServerEndpoint.class.getSimpleName() + + throw new IgniteCheckedException(GridIpcSharedMemoryServerEndpoint.class.getSimpleName() + " should not be configured on Windows (configure " + GridIpcServerTcpEndpoint.class.getSimpleName() + ")"); @@ -104,7 +104,7 @@ public class GridGgfsServer { srvEndpoint0.setHost(U.resolveLocalHost(locHostName).getHostAddress()); } catch (IOException e) { - throw new GridException("Failed to resolve local host: " + locHostName, e); + throw new IgniteCheckedException("Failed to resolve local host: " + locHostName, e); } } else @@ -155,7 +155,7 @@ public class GridGgfsServer { try { hnd.stop(); } - catch (GridException e) { + catch (IgniteCheckedException e) { U.error(log, "Failed to stop GGFS server handler (will close client connections anyway).", e); } @@ -172,7 +172,7 @@ public class GridGgfsServer { try { ggfsCtx.kernalContext().resource().cleanupGeneric(srvEndpoint); } - catch (GridException e) { + catch (IgniteCheckedException e) { U.error(log, "Failed to cleanup server endpoint.", e); } } @@ -207,9 +207,9 @@ public class GridGgfsServer { * * @param idx Worker index for worker thread naming. * @param endpoint Connected client endpoint. - * @throws GridException If endpoint output stream cannot be obtained. + * @throws IgniteCheckedException If endpoint output stream cannot be obtained. */ - protected ClientWorker(GridIpcEndpoint endpoint, int idx) throws GridException { + protected ClientWorker(GridIpcEndpoint endpoint, int idx) throws IgniteCheckedException { super(ggfsCtx.kernalContext().gridName(), "ggfs-client-worker-" + idx, log); this.endpoint = endpoint; @@ -259,7 +259,7 @@ public class GridGgfsServer { try { res = fut.get(); } - catch (GridException e) { + catch (IgniteCheckedException e) { res = new GridGgfsControlResponse(); ((GridGgfsControlResponse)res).error(e); @@ -275,7 +275,7 @@ public class GridGgfsServer { out.flush(); } } - catch (IOException | GridException e) { + catch (IOException | IgniteCheckedException e) { shutdown0(e); } } @@ -287,7 +287,7 @@ public class GridGgfsServer { try { res = fut.get(); } - catch (GridException e) { + catch (IgniteCheckedException e) { res = new GridGgfsControlResponse(); ((GridGgfsControlResponse)res).error(e); @@ -302,7 +302,7 @@ public class GridGgfsServer { out.flush(); } } - catch (IOException | GridException e) { + catch (IOException | IgniteCheckedException e) { shutdown0(e); } } @@ -314,7 +314,7 @@ public class GridGgfsServer { catch (EOFException ignored) { // Client closed connection. } - catch (GridException | IOException e) { + catch (IgniteCheckedException | IOException e) { if (!isCancelled()) U.error(log, "Failed to read data from client (will close connection)", e); } @@ -401,7 +401,7 @@ public class GridGgfsServer { workerThread.start(); } } - catch (GridException e) { + catch (IgniteCheckedException e) { if (!isCancelled()) U.error(log, "Failed to accept client IPC connection (will shutdown accept thread).", e); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerHandler.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerHandler.java index 222ea31..5927d01 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerHandler.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerHandler.java @@ -9,8 +9,8 @@ package org.gridgain.grid.kernal.processors.ggfs; +import org.apache.ignite.*; import org.apache.ignite.lang.*; -import org.gridgain.grid.*; import org.gridgain.grid.kernal.ggfs.common.*; import org.jetbrains.annotations.*; @@ -43,7 +43,7 @@ public interface GridGgfsServerHandler { /** * Stops handling of incoming requests. No server commands will be handled anymore. * - * @throws GridException If error occurred. + * @throws IgniteCheckedException If error occurred. */ - public void stop() throws GridException; + public void stop() throws IgniteCheckedException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerManager.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerManager.java index 9cfa972..ab76cb0 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerManager.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsServerManager.java @@ -9,13 +9,13 @@ package org.gridgain.grid.kernal.processors.ggfs; +import org.apache.ignite.*; import org.apache.ignite.fs.*; import org.apache.ignite.lang.*; import org.apache.ignite.thread.*; -import org.gridgain.grid.*; +import org.gridgain.grid.util.ipc.*; import org.gridgain.grid.util.typedef.*; import org.gridgain.grid.util.typedef.internal.*; -import org.gridgain.grid.util.ipc.*; import org.gridgain.grid.util.worker.*; import java.util.*; @@ -40,7 +40,7 @@ public class GridGgfsServerManager extends GridGgfsManager { private CountDownLatch kernalStartLatch = new CountDownLatch(1); /** {@inheritDoc} */ - @Override protected void start0() throws GridException { + @Override protected void start0() throws IgniteCheckedException { IgniteFsConfiguration ggfsCfg = ggfsCtx.configuration(); Map<String,String> cfg = ggfsCfg.getIpcEndpointConfiguration(); @@ -74,9 +74,9 @@ public class GridGgfsServerManager extends GridGgfsManager { * * @param endpointCfg Endpoint configuration to start. * @param mgmt {@code True} if endpoint is management. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - private void bind(final Map<String,String> endpointCfg, final boolean mgmt) throws GridException { + private void bind(final Map<String,String> endpointCfg, final boolean mgmt) throws IgniteCheckedException { if (srvrs == null) srvrs = new ConcurrentLinkedQueue<>(); @@ -115,7 +115,7 @@ public class GridGgfsServerManager extends GridGgfsManager { } /** {@inheritDoc} */ - @Override protected void onKernalStart0() throws GridException { + @Override protected void onKernalStart0() throws IgniteCheckedException { if (!F.isEmpty(srvrs)) { for (GridGgfsServer srv : srvrs) srv.onKernalStart(); @@ -189,7 +189,7 @@ public class GridGgfsServerManager extends GridGgfsManager { it.remove(); } - catch (GridException e) { + catch (IgniteCheckedException e) { if (GridWorker.log.isDebugEnabled()) GridWorker.log.debug("Failed to bind GGFS endpoint [cfg=" + cfg + ", err=" + e.getMessage() + ']'); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridNoopGgfsHelper.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridNoopGgfsHelper.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridNoopGgfsHelper.java index df8ff1e..a47a2f9 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridNoopGgfsHelper.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/GridNoopGgfsHelper.java @@ -9,7 +9,7 @@ package org.gridgain.grid.kernal.processors.ggfs; -import org.gridgain.grid.*; +import org.apache.ignite.*; import org.gridgain.grid.cache.*; /** @@ -23,7 +23,7 @@ public class GridNoopGgfsHelper implements GridGgfsHelper { } /** {@inheritDoc} */ - @Override public void validateCacheConfiguration(GridCacheConfiguration cfg) throws GridException { + @Override public void validateCacheConfiguration(GridCacheConfiguration cfg) throws IgniteCheckedException { // No-op. } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamAdapter.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamAdapter.java index 7eac170..c50b2f7 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamAdapter.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamAdapter.java @@ -9,8 +9,8 @@ package org.gridgain.grid.kernal.processors.ggfs; +import org.apache.ignite.*; import org.apache.ignite.fs.*; -import org.gridgain.grid.*; import org.gridgain.grid.util.typedef.internal.*; import org.jetbrains.annotations.*; @@ -140,7 +140,7 @@ abstract class IgniteFsOutputStreamAdapter extends IgniteFsOutputStream { try { storeDataBlocks(in, len); } - catch (GridException e) { + catch (IgniteCheckedException e) { throw new IOException(e.getMessage(), e); } @@ -186,18 +186,18 @@ abstract class IgniteFsOutputStreamAdapter extends IgniteFsOutputStream { * Note! If file concurrently deleted we'll get lost blocks. * * @param data Data to store. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - protected abstract void storeDataBlock(ByteBuffer data) throws GridException, IOException; + protected abstract void storeDataBlock(ByteBuffer data) throws IgniteCheckedException, IOException; /** * Store data blocks in file reading appropriate number of bytes from given data input. * * @param in Data input to read from. * @param len Data length to store. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - protected abstract void storeDataBlocks(DataInput in, int len) throws GridException, IOException; + protected abstract void storeDataBlocks(DataInput in, int len) throws IgniteCheckedException, IOException; /** * Close callback. It will be called only once in synchronized section. @@ -241,7 +241,7 @@ abstract class IgniteFsOutputStreamAdapter extends IgniteFsOutputStream { storeDataBlock(buf); } - catch (GridException e) { + catch (IgniteCheckedException e) { throw new IOException("Failed to store data into file: " + path, e); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamImpl.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamImpl.java index a9bc393..04ab237 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamImpl.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/ggfs/IgniteFsOutputStreamImpl.java @@ -88,11 +88,11 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { * @param mode Grid GGFS mode. * @param batch Optional secondary file system batch. * @param metrics Local GGFs metrics. - * @throws GridException If stream creation failed. + * @throws IgniteCheckedException If stream creation failed. */ IgniteFsOutputStreamImpl(GridGgfsContext ggfsCtx, IgniteFsPath path, GridGgfsFileInfo fileInfo, IgniteUuid parentId, int bufSize, IgniteFsMode mode, @Nullable GridGgfsFileWorkerBatch batch, GridGgfsLocalMetrics metrics) - throws GridException { + throws IgniteCheckedException { super(path, optimizeBufferSize(bufSize, fileInfo)); assert fileInfo != null; @@ -159,7 +159,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { } /** {@inheritDoc} */ - @Override protected synchronized void storeDataBlock(ByteBuffer block) throws GridException, IOException { + @Override protected synchronized void storeDataBlock(ByteBuffer block) throws IgniteCheckedException, IOException { int writeLen = block.remaining(); preStoreDataBlocks(null, writeLen); @@ -193,7 +193,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { } /** {@inheritDoc} */ - @Override protected synchronized void storeDataBlocks(DataInput in, int len) throws GridException, IOException { + @Override protected synchronized void storeDataBlocks(DataInput in, int len) throws IgniteCheckedException, IOException { preStoreDataBlocks(in, len); int blockSize = fileInfo.blockSize(); @@ -229,7 +229,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { * * @param len Data length to be written. */ - private void preStoreDataBlocks(@Nullable DataInput in, int len) throws GridException, IOException { + private void preStoreDataBlocks(@Nullable DataInput in, int len) throws IgniteCheckedException, IOException { // Check if any exception happened while writing data. if (writeCompletionFut.isDone()) { assert ((GridFutureAdapter)writeCompletionFut).isFailed(); @@ -255,7 +255,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { try { exists = meta.exists(fileInfo.id()); } - catch (GridException e) { + catch (IgniteCheckedException e) { throw new IOError(e); // Something unrecoverable. } @@ -290,7 +290,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { space = 0; } } - catch (GridException e) { + catch (IgniteCheckedException e) { throw new IOException("Failed to flush data [path=" + path + ", space=" + space + ']', e); } } @@ -323,7 +323,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { try { exists = !deleted && meta.exists(fileInfo.id()); } - catch (GridException e) { + catch (IgniteCheckedException e) { throw new IOError(e); // Something unrecoverable. } @@ -335,7 +335,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { writeCompletionFut.get(); } - catch (GridException e) { + catch (IgniteCheckedException e) { err = new IOException("Failed to close stream [path=" + path + ", fileInfo=" + fileInfo + ']', e); } @@ -346,7 +346,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { try { batch.await(); } - catch (GridException e) { + catch (IgniteCheckedException e) { if (err == null) err = new IOException("Failed to close secondary file system stream [path=" + path + ", fileInfo=" + fileInfo + ']', e); @@ -363,7 +363,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { throw new IOException("File was concurrently deleted: " + path); } - catch (GridException e) { + catch (IgniteCheckedException e) { throw new IOError(e); // Something unrecoverable. } @@ -377,7 +377,7 @@ class IgniteFsOutputStreamImpl extends IgniteFsOutputStreamAdapter { if (mode == DUAL_SYNC) batch.await(); } - catch (GridException e) { + catch (IgniteCheckedException e) { throw new IOException("Failed to close secondary file system stream [path=" + path + ", fileInfo=" + fileInfo + ']', e); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopNoopProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopNoopProcessor.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopNoopProcessor.java index 0e20489..6cc26ca 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopNoopProcessor.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopNoopProcessor.java @@ -9,8 +9,8 @@ package org.gridgain.grid.kernal.processors.hadoop; +import org.apache.ignite.*; import org.apache.ignite.lang.*; -import org.gridgain.grid.*; import org.gridgain.grid.hadoop.*; import org.gridgain.grid.kernal.*; import org.gridgain.grid.util.future.*; @@ -43,11 +43,11 @@ public class GridHadoopNoopProcessor extends GridHadoopProcessorAdapter { /** {@inheritDoc} */ @Override public IgniteFuture<?> submit(GridHadoopJobId jobId, GridHadoopJobInfo jobInfo) { - return new GridFinishedFutureEx<>(new GridException("Hadoop is not available.")); + return new GridFinishedFutureEx<>(new IgniteCheckedException("Hadoop is not available.")); } /** {@inheritDoc} */ - @Override public GridHadoopJobStatus status(GridHadoopJobId jobId) throws GridException { + @Override public GridHadoopJobStatus status(GridHadoopJobId jobId) throws IgniteCheckedException { return null; } @@ -57,12 +57,12 @@ public class GridHadoopNoopProcessor extends GridHadoopProcessorAdapter { } /** {@inheritDoc} */ - @Override public IgniteFuture<?> finishFuture(GridHadoopJobId jobId) throws GridException { + @Override public IgniteFuture<?> finishFuture(GridHadoopJobId jobId) throws IgniteCheckedException { return null; } /** {@inheritDoc} */ - @Override public boolean kill(GridHadoopJobId jobId) throws GridException { + @Override public boolean kill(GridHadoopJobId jobId) throws IgniteCheckedException { return false; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopProcessorAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopProcessorAdapter.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopProcessorAdapter.java index e0ed2f4..a390081 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopProcessorAdapter.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/GridHadoopProcessorAdapter.java @@ -9,8 +9,8 @@ package org.gridgain.grid.kernal.processors.hadoop; +import org.apache.ignite.*; import org.apache.ignite.lang.*; -import org.gridgain.grid.*; import org.gridgain.grid.hadoop.*; import org.gridgain.grid.kernal.*; import org.gridgain.grid.kernal.processors.*; @@ -55,34 +55,34 @@ public abstract class GridHadoopProcessorAdapter extends GridProcessorAdapter { * * @param jobId Job ID to get status for. * @return Job execution status. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public abstract GridHadoopJobStatus status(GridHadoopJobId jobId) throws GridException; + public abstract GridHadoopJobStatus status(GridHadoopJobId jobId) throws IgniteCheckedException; /** * Returns Hadoop job counters. * * @param jobId Job ID to get counters for. * @return Job counters. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public abstract GridHadoopCounters counters(GridHadoopJobId jobId) throws GridException; + public abstract GridHadoopCounters counters(GridHadoopJobId jobId) throws IgniteCheckedException; /** * Gets Hadoop job finish future. * * @param jobId Job ID. * @return Job finish future or {@code null}. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public abstract IgniteFuture<?> finishFuture(GridHadoopJobId jobId) throws GridException; + public abstract IgniteFuture<?> finishFuture(GridHadoopJobId jobId) throws IgniteCheckedException; /** * Kills job. * * @param jobId Job ID. * @return {@code True} if job was killed. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public abstract boolean kill(GridHadoopJobId jobId) throws GridException; + public abstract boolean kill(GridHadoopJobId jobId) throws IgniteCheckedException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropAware.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropAware.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropAware.java index 1663345..0a86eae 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropAware.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropAware.java @@ -9,7 +9,7 @@ package org.gridgain.grid.kernal.processors.interop; -import org.gridgain.grid.*; +import org.apache.ignite.*; import org.gridgain.grid.kernal.*; /** @@ -20,15 +20,15 @@ public interface GridInteropAware { * Initializes interop-aware component. * * @param ctx Context. - * @throws GridException In case of error. + * @throws IgniteCheckedException In case of error. */ - public void initialize(GridKernalContext ctx) throws GridException; + public void initialize(GridKernalContext ctx) throws IgniteCheckedException; /** * Destroys interop-aware component. * * @param ctx Context. - * @throws GridException In case of error. + * @throws IgniteCheckedException In case of error. */ - public void destroy(GridKernalContext ctx) throws GridException; + public void destroy(GridKernalContext ctx) throws IgniteCheckedException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java index 62bfbe4..78498a5 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropProcessor.java @@ -9,7 +9,7 @@ package org.gridgain.grid.kernal.processors.interop; -import org.gridgain.grid.*; +import org.apache.ignite.*; import org.gridgain.grid.kernal.processors.*; import org.jetbrains.annotations.*; @@ -25,14 +25,14 @@ public interface GridInteropProcessor extends GridProcessor { /** * Await start on native side. * - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public void awaitStart() throws GridException; + public void awaitStart() throws IgniteCheckedException; /** * @return Environment pointer. */ - public long environmentPointer() throws GridException; + public long environmentPointer() throws IgniteCheckedException; /** * @return Grid name. @@ -43,18 +43,18 @@ public interface GridInteropProcessor extends GridProcessor { * Gets native wrapper for default Grid projection. * * @return Native compute wrapper. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public GridInteropTarget projection() throws GridException; + public GridInteropTarget projection() throws IgniteCheckedException; /** * Gets native wrapper for cache with the given name. * * @param name Cache name ({@code null} for default cache). * @return Native cache wrapper. - * @throws GridException If failed. + * @throws IgniteCheckedException If failed. */ - public GridInteropTarget cache(@Nullable String name) throws GridException; + public GridInteropTarget cache(@Nullable String name) throws IgniteCheckedException; /** * Stops grid. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/06931b4b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropTarget.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropTarget.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropTarget.java index 3477554..a2626ba 100644 --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropTarget.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/interop/GridInteropTarget.java @@ -9,7 +9,7 @@ package org.gridgain.grid.kernal.processors.interop; -import org.gridgain.grid.*; +import org.apache.ignite.*; import org.gridgain.grid.kernal.processors.portable.*; import org.jetbrains.annotations.*; @@ -23,9 +23,9 @@ public interface GridInteropTarget { * @param type Operation type. * @param stream Input stream. * @return Value specific for the given operation otherwise. - * @throws GridException In case of failure. + * @throws IgniteCheckedException In case of failure. */ - public int inOp(int type, GridPortableInputStream stream) throws GridException; + public int inOp(int type, GridPortableInputStream stream) throws IgniteCheckedException; /** * Synchronous IN operation which returns managed object as result. @@ -33,9 +33,9 @@ public interface GridInteropTarget { * @param type Operation type. * @param stream Input stream. * @return Managed result. - * @throws GridException If case of failure. + * @throws IgniteCheckedException If case of failure. */ - public Object inOpObject(int type, GridPortableInputStream stream) throws GridException; + public Object inOpObject(int type, GridPortableInputStream stream) throws IgniteCheckedException; /** * Synchronous OUT operation. @@ -44,9 +44,9 @@ public interface GridInteropTarget { * @param stream Native stream address. * @param arr Native array address. * @param cap Capacity. - * @throws GridException In case of failure. + * @throws IgniteCheckedException In case of failure. */ - public void outOp(int type, long stream, long arr, int cap) throws GridException; + public void outOp(int type, long stream, long arr, int cap) throws IgniteCheckedException; /** * Synchronous IN-OUT operation. @@ -56,10 +56,10 @@ public interface GridInteropTarget { * @param outStream Native stream address. * @param outArr Native array address. * @param outCap Capacity. - * @throws GridException In case of failure. + * @throws IgniteCheckedException In case of failure. */ public void inOutOp(int type, GridPortableInputStream inStream, long outStream, long outArr, int outCap) - throws GridException; + throws IgniteCheckedException; /** * Synchronous IN-OUT operation with optional argument. @@ -70,10 +70,10 @@ public interface GridInteropTarget { * @param outArr Native array address. * @param outCap Capacity. * @param arg Argument (optional). - * @throws GridException In case of failure. + * @throws IgniteCheckedException In case of failure. */ public void inOutOp(int type, GridPortableInputStream inStream, long outStream, long outArr, int outCap, - @Nullable Object arg) throws GridException; + @Nullable Object arg) throws IgniteCheckedException; /** * Asynchronous IN operation. @@ -81,9 +81,9 @@ public interface GridInteropTarget { * @param type Operation type. * @param futId Future ID. * @param in Input stream. - * @throws GridException In case of failure. + * @throws IgniteCheckedException In case of failure. */ - public void inOpAsync(int type, long futId, GridPortableInputStream in) throws GridException; + public void inOpAsync(int type, long futId, GridPortableInputStream in) throws IgniteCheckedException; /** * Asynchronous IN-OUT operation. @@ -94,8 +94,8 @@ public interface GridInteropTarget { * @param outStream Native stream address. * @param outArr Native array address. * @param outCap Capacity. - * @throws GridException In case of failure. + * @throws IgniteCheckedException In case of failure. */ public void inOutOpAsync(int type, long futId, GridPortableInputStream in, long outStream, long outArr, int outCap) - throws GridException; + throws IgniteCheckedException; }
