ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [24/51] [partial] incubator-ignite git commit: Rename GridException to IgniteCheckedException, GridRuntimeException to IgniteException.
Date Thu, 11 Dec 2014 13:14:01 GMT
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;
 }


Mime
View raw message