Examples of incrementOutstandingFlowCounter()

Examples of org.apache.uima.aae.controller.LocalCache.CasStateEntry.incrementOutstandingFlowCounter()

2130
2131
2132
2133
2134
2135
2136
2137
2138
2139
2140
          }
          CasStateEntry parentCasStateEntry =
            parentController.getLocalCache().lookupEntry(inputCasId);
          if ( parentCasStateEntry != null ) {
            parentCasStateEntry.incrementSubordinateCasInPlayCount();
            parentCasStateEntry.incrementOutstandingFlowCounter();
          }
        }
      }
      // Send CAS to a given reply endpoint
      sendVMMessage(mType, replyEndpoint, cacheEntry);
View Full Code Here

Examples of org.apache.uima.aae.controller.LocalCache.CasStateEntry.incrementOutstandingFlowCounter()

2177
2178
2179
2180
2181
2182
2183
2184
2185
2186
2187
          // Update counters in the parents controller local cache.
          CasStateEntry parentCasStateEntry =
            parentController.getLocalCache().lookupEntry(inputCasId);
          if ( parentCasStateEntry != null ) {
            parentCasStateEntry.incrementSubordinateCasInPlayCount();
            parentCasStateEntry.incrementOutstandingFlowCounter();
          }
        }
      }
      // Send CAS to a given reply endpoint
      sendVMMessage(mType, replyEndpoint, cacheEntry);
View Full Code Here

Examples of org.apache.uima.aae.controller.LocalCache.CasStateEntry.incrementOutstandingFlowCounter()

183
184
185
186
187
188
189
190
191
192
193
          //  increment a counter that counts number of child CASes that have no
          //  flow object yet. The flow object is created for each child CAS from
          //  the parent flow object. The method below will actually acquire a
          //  permit from a binary semaphore to force the parent to block until
          //  the last of its children acquires its Flow object.
          parentEntry.incrementOutstandingFlowCounter();

        } catch (Exception e) {
          if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.WARNING)) {
           
            UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING, CLASS_NAME.getName(),
View Full Code Here

Examples of org.apache.uima.aae.controller.LocalCache.CasStateEntry.incrementOutstandingFlowCounter()

2177
2178
2179
2180
2181
2182
2183
2184
2185
2186
2187
          // Update counters in the parents controller local cache.
          CasStateEntry parentCasStateEntry =
            parentController.getLocalCache().lookupEntry(inputCasId);
          if ( parentCasStateEntry != null ) {
            parentCasStateEntry.incrementSubordinateCasInPlayCount();
            parentCasStateEntry.incrementOutstandingFlowCounter();
          }
        }
      }
      // Send CAS to a given reply endpoint
      sendVMMessage(mType, replyEndpoint, cacheEntry);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.