GH-236: fix cache state

Signed-off-by: Denis Lisenkov <[email protected]>

src/main/kotlin/org/zowe/explorer/dataops/fetch/FileFetchProvider.kt

@@ -37,6 +37,8 @@ interface FileFetchProvider<R : Any, Q : Query<R, Unit>, File : VirtualFile> {
 
   fun isCacheValid(query: Q): Boolean
 
+  fun markCacheAsFetching(query: Q)
+
   fun isCacheFetching(query: Q): Boolean
 
   fun getFetchedErrorMessage(query: Q): String? = "Error"

src/main/kotlin/org/zowe/explorer/dataops/fetch/RemoteFileFetchProviderBase.kt

@@ -70,6 +70,19 @@ abstract class RemoteFileFetchProviderBase<Connection : ConnectionConfigBase, Re
     return lock.withLock { cacheState[query] != CacheState.ERROR }
   }
 
+  /**
+   * Sets cache state to [CacheState.FETCHING] for the specified query.
+   * @param query query that identifies the cache.
+   */
+  override fun markCacheAsFetching(query: RemoteQuery<Connection, Request, Unit>) {
+    lock.withLock { cacheState[query] = CacheState.FETCHING }
+  }
+
+  /**
+   * Checks if the cache is fetching.
+   * @param query query that identifies the cache.
+   * @return true if fetching is in progress, false if not.
+   */
   override fun isCacheFetching(query: RemoteQuery<Connection, Request, Unit>): Boolean {
     return lock.withLock { cacheState[query] == CacheState.FETCHING }
   }

src/main/kotlin/org/zowe/explorer/explorer/ui/FileFetchNode.kt

@@ -133,6 +133,7 @@ abstract class FileFetchNode<Connection : ConnectionConfigBase, Value : Any, R :
               }
           } else {
             if (!fileFetchProvider.isCacheFetching(q)) {
+              fileFetchProvider.markCacheAsFetching(q)
               runBackgroundableSyncTask(
                 title = makeFetchTaskTitle(q),
                 project = project,