Examples of Timer


Examples of org.drools.time.impl.Timer

            Declaration target = constraint.getRequiredDeclarations()[0];
            if ( target.isPatternDeclaration() && target.getPattern().getObjectType().isEvent() ) {
                long uplimit = ((IntervalProviderConstraint) constraint).getInterval().getUpperBound();
                // only makes sense to add the new timer if the uplimit is not infinity (Long.MAX_VALUE)
                if( uplimit < Long.MAX_VALUE ) {
                    Timer timer = context.getRule().getTimer();
                    DurationTimer durationTimer = new DurationTimer( uplimit );

                    if ( timer instanceof CompositeMaxDurationTimer ) {
                        // already a composite so just add
                        ((CompositeMaxDurationTimer) timer).addDurationTimer( durationTimer );
View Full Code Here

Examples of org.eatbacon.util.Timer

      e.printStackTrace();
    }
  }
 
  public void run() throws Exception {
    Timer timer = null;
    long count = 0;
   
    timer = Timer.start();
    count = fetchFullObject();
    timer.finish();
    report(this.getClass().getSimpleName(), "full", count, timer.getRate(count), getThroughput(charsRead, timer.getElapsedTimeMillis()));

    timer.reset();
    count = fetchOneLevelObject();
    timer.finish();
    report(this.getClass().getSimpleName(), "one-level", count, timer.getRate(count), getThroughput(charsRead, timer.getElapsedTimeMillis()));

    timer.reset();
    count = fetchTopLevelObject();
    timer.finish();
    report(this.getClass().getSimpleName(), "top-level", count, timer.getRate(count), getThroughput(charsRead, timer.getElapsedTimeMillis()));
  }
View Full Code Here

Examples of org.glite.ce.commonj.utils.Timer

            }
        }
    }

    public void start() {
        timer = new Timer("POLICY_TIMER", true);
       
        for (Policy policy : policyTable.values()) {
            PolicyTask task = getPolicyTask(policy.getType());
           
            if (task != null) {
View Full Code Here

Examples of org.graylog2.restclient.lib.metrics.Timer

    private Timer totalTiming;
    private Timer converterTiming;

    public ExtractorMetrics(TimerRateMetricsResponse total, TimerRateMetricsResponse converters) {
        if (total.durationUnit != null) {
            this.totalTiming = new Timer(total.time, Timer.Unit.valueOf(total.durationUnit.toUpperCase()));
        }

        if (converters.durationUnit != null) {
            this.converterTiming = new Timer(converters.time, Timer.Unit.valueOf(converters.durationUnit.toUpperCase()));
        }

        if (total.rate == null) {
            this.meter = null;
        } else {
View Full Code Here

Examples of org.gudy.azureus2.core3.util.Timer

      lblX.setImage(img);
    }


    filterDelayTimer = new Timer("Filter");
    filterDelayTimer.addEvent(SystemTime.getCurrentTime() + 300,
        new TimerEventPerformer() {
          public void perform(TimerEvent event) {
            filterDelayTimer.destroy();
            filterDelayTimer = null;
View Full Code Here

Examples of org.imagearchive.lsm.toolbox.info.scaninfo.Timer

    ScanInfoTag tag = new ScanInfoTag();
    Vector v = new Vector();
    while (tag.entry != 0x0FFFFFFFF) {
      tag = getScanInfoTag(stream);
      if (Timer.isTimer(tag.entry)) {
        Timer t = new Timer();

        while (tag.entry != 0x0FFFFFFFF) {
          tag = getScanInfoTag(stream);
          t.records = getRecords(stream, tag, t.data, t.records);
        }
View Full Code Here

Examples of org.infoglue.deliver.util.Timer

   * This method gets a list of users
   */
 
  public List getUsers() throws Exception
  {
    Timer t = new Timer();
    if(!logger.isInfoEnabled())
      t.setActive(false);
   
    logger.info("*******************");
      logger.info("* getUsers start  *");
      logger.info("*******************");
     
    String userCacheTimeout = this.extraProperties.getProperty("userCacheTimeout", "1800");

      String authorizerIndex = this.extraProperties.getProperty("authorizerIndex");
      if(authorizerIndex == null)
        authorizerIndex = "";

    String key = "allUsers" + authorizerIndex;
    List users = (List)CacheController.getCachedObjectFromAdvancedCache("JNDIAuthorizationCache", key, new Integer(userCacheTimeout).intValue());
    if(users != null)
      return users;
   
    users = new ArrayList();
   
    String userBase          = this.extraProperties.getProperty("userBase");
   
    String[] userBases = null;
    if(userBase != null)
      userBases = userBase.split(";");
     
    String userListSearch      = this.extraProperties.getProperty("userListSearch");
    String userAttributesFilter    = this.extraProperties.getProperty("userAttributesFilter");
    String userNameAttributeFilter    = this.extraProperties.getProperty("userNameAttributeFilter", "distinguishedName");
    String userDisplayNameAttributeFilter  = this.extraProperties.getProperty("userDisplayNameAttributeFilter", "cn");
    String userFirstNameAttributeFilter  = this.extraProperties.getProperty("userFirstNameAttributeFilter", "givenName");
    String userLastNameAttributeFilter  = this.extraProperties.getProperty("userLastNameAttributeFilter", "sn");
    String userMailAttributeFilter  = this.extraProperties.getProperty("userMailAttributeFilter", "mail");
    String memberOfAttributeFilter  = this.extraProperties.getProperty("memberOfAttributeFilter", "memberOf");
    String roleFilter        = this.extraProperties.getProperty("roleFilter", "InfoGlue");
    String roleNameAttribute     = this.extraProperties.getProperty("roleNameAttribute");
    String userSearchScope       = this.extraProperties.getProperty("userSearchScope");

    String userFirstNameDummy    = this.extraProperties.getProperty("userFirstNameDummy");
    String userLastNameDummy    = this.extraProperties.getProperty("userLastNameDummy");
    String userDisplayNameDummy    = this.extraProperties.getProperty("userDisplayNameDummy");
    String userMailDummy      = this.extraProperties.getProperty("userMailDummy");

    t.printElapsedTime("Got context took:");
   
    int index = 0;

    for(int userBaseIndex=0; userBaseIndex < userBases.length; userBaseIndex++)
    {
      String baseDN = userBases[userBaseIndex];
     
      if(logger.isInfoEnabled())
        logger.info("Searching for users in " + baseDN + " - users was " + users.size());

      DirContext ctx = getContext();

      try
      {
        //String baseDN = userBase;
        String searchFilter = "(CN=*)";
        if(userListSearch != null && userListSearch.length() > 0)
          searchFilter = userListSearch;
       
        String attributesFilter = "name, displayName, givenName, sn, mail, memberOf";
        if(userAttributesFilter != null && userAttributesFilter.length() > 0)
          attributesFilter = userAttributesFilter;
             
        String[] attrID = attributesFilter.split(",");
        String[] userMailAttributeFilterAttributeId = userMailAttributeFilter.split(",");
       
        if(logger.isInfoEnabled())
        {
          logger.info("attributesFilter:" + attributesFilter);
          logger.info("userMailAttributeFilterAttributeId:" + userMailAttributeFilterAttributeId);
          logger.info("baseDN:" + baseDN);
          logger.info("searchFilter:" + searchFilter);
          //logger.info("attrID" + attrID);
        }
       
        SearchControls ctls = new SearchControls();
 
        int userSearchScopeInt = SearchControls.SUBTREE_SCOPE;
        if(userSearchScope != null && userSearchScope.equalsIgnoreCase("ONELEVEL_SCOPE"))
            userSearchScopeInt = SearchControls.ONELEVEL_SCOPE;
        else if(userSearchScope != null && userSearchScope.equalsIgnoreCase("OBJECT_SCOPE"))
            userSearchScopeInt = SearchControls.OBJECT_SCOPE;
           
          ctls.setSearchScope(userSearchScopeInt);
        ctls.setReturningAttributes(attrID);
 
        NamingEnumeration answer = ctx.search(baseDN, searchFilter, ctls);
 
        t.printElapsedTime("Answer took:");
       
        if(!answer.hasMore())
          throw new Exception("The was no users found in the JNDI Data Source.");
     
        while (answer.hasMore())
        {
          try
          {
            SearchResult sr = (SearchResult)answer.next();
            if(logger.isInfoEnabled())
              logger.info("Person:" + sr.toString() + "\n");
           
            Attributes attributes = sr.getAttributes();
            if(logger.isInfoEnabled())
              logger.info("attributes:" + attributes.toString());
            Attribute userNameAttribute = attributes.get(userNameAttributeFilter);
            Attribute userDisplayNameAttribute = attributes.get(userDisplayNameAttributeFilter);
            Attribute userFirstNameAttribute = attributes.get(userFirstNameAttributeFilter);
            Attribute userLastNameAttribute = attributes.get(userLastNameAttributeFilter);
 
            Attribute userMailAttribute = null;
            for(int i=0; i<userMailAttributeFilterAttributeId.length; i++)
            {
              userMailAttribute = attributes.get(userMailAttributeFilterAttributeId[i]);
              if(userMailAttribute != null)
                break;
            }
 
            Attribute memberOfAttribute = attributes.get(memberOfAttributeFilter);
            Attribute memberOfGroupsAttribute = attributes.get(memberOfAttributeFilter);
 
            String userFirstName = null;
            if(userFirstNameAttribute != null)
              userFirstName = userFirstNameAttribute.get().toString();
            else if(userFirstNameDummy != null && !userFirstNameDummy.equals(""))
              userFirstName = userFirstNameDummy;
           
            String userLastName = null;
            if(userLastNameAttribute != null)
              userLastName = userLastNameAttribute.get().toString();
            else if(userLastNameDummy != null && !userLastNameDummy.equals(""))
              userLastName = userLastNameDummy;

            String userDisplayName = null;
            if(userDisplayNameAttribute != null)
              userDisplayName = userDisplayNameAttribute.get().toString();
            else if(userDisplayNameDummy != null && !userDisplayNameDummy.equals(""))
              userDisplayName = userDisplayNameDummy;

            String userMail = null;
            if(userMailAttribute != null)
              userMail = userMailAttribute.get().toString();
            else if(userMailDummy != null && !userMailDummy.equals(""))
              userMail = userMailDummy;

            if(userFirstName == null || userLastName == null || userDisplayName == null || userMail == null)
            {
              if(logger.isInfoEnabled())
                logger.info("User not valid " + userNameAttribute);
              throw new SystemException("The user " + userNameAttribute + " did not have firstName, lastName or email attribute which InfoGlue requires");
            }
           
            if(logger.isInfoEnabled())
            {
              logger.info("userNameAttribute:" + userNameAttribute);
              logger.info("userDisplayName:" + userDisplayName);
              logger.info("userFirstName:" + userFirstName);
              logger.info("userLastName:" + userLastName);
              logger.info("userMail:" + userMail);
            }
           
            List roles = new ArrayList();
            List groups = new ArrayList();
 
            if(memberOfAttribute != null)
            {
              if(logger.isInfoEnabled())
                logger.info("memberOfAttribute:" + memberOfAttribute);
           
              NamingEnumeration allEnum = memberOfAttribute.getAll();
              while(allEnum.hasMore())
              {
                String roleName = (String)allEnum.next();
 
                if(logger.isInfoEnabled())
                  logger.info("roleName:" + roleName);
               
                if(roleFilter.equalsIgnoreCase("*") || roleName.indexOf(roleFilter) > -1)
                {
                  if(logger.isInfoEnabled())
                  {
                    logger.info("roleNameAttribute:" + roleNameAttribute);
                    logger.info("groupName:" + roleName);
                    logger.info("indexOf:" + roleName.indexOf(roleNameAttribute));
                  }
                 
                  InfoGlueRole infoGlueRole = this.getAuthorizedInfoGlueRole(roleName, ctx);
                    //InfoGlueRole infoGlueRole = new InfoGlueRole(roleName, "Not available from JNDI-source", this);
                  roles.add(infoGlueRole);
                }
              }
            }
            else
            {
              if(logger.isInfoEnabled())
                logger.info("No memberOfAttribute named :" + memberOfAttributeFilter + " was found.");
            }
 
            if(memberOfGroupsAttribute != null)
            {
              NamingEnumeration allGroupsEnum = memberOfGroupsAttribute.getAll();
              while(allGroupsEnum.hasMore())
              {
                String groupName = (String)allGroupsEnum.next();
               
                if(logger.isInfoEnabled())
                  logger.info("groupName:" + groupName);
               
                if(roleFilter.equalsIgnoreCase("*") || groupName.indexOf(roleFilter) > -1)
                {
                  if(logger.isInfoEnabled())
                  {
                    logger.info("roleNameAttribute:" + roleNameAttribute);
                    logger.info("groupName:" + groupName);
                    logger.info("indexOf:" + groupName.indexOf(roleNameAttribute));
                  }
                 
                  InfoGlueGroup infoGlueGroup = this.getAuthorizedInfoGlueGroup(groupName, ctx);
                  //InfoGlueGroup infoGlueGroup = new InfoGlueGroup(groupName, "Not available from JNDI-source", this);
                    groups.add(infoGlueGroup);
                }
              }
            }
            else
            {
              if(logger.isInfoEnabled())
                logger.info("No memberOfGroupsAttribute named :" + memberOfAttributeFilter + " was found.");
            }
 
            InfoGluePrincipal infoGluePrincipal = new InfoGluePrincipal(userNameAttribute.get().toString(), userDisplayName, userFirstName, userLastName, userMail, roles, groups, false, this);
            users.add(infoGluePrincipal);
          }
          catch(Exception e)
          {
            logger.warn("An error occurred when we tried to read user: " + e.getMessage(), e);
          }
        }
      }
      catch (Exception e)
      {
        logger.warn("Could not find Users: " + e.getMessage(), e);
      }
      finally
      {
        ctx.close();
      }

      if(logger.isInfoEnabled())
        logger.info("After searching for users in " + baseDN + " - users was " + users.size());
    }

    t.printElapsedTime("all users took " + index + ":");
   
    logger.info("getUsers end...");

      if(users != null)
        CacheController.cacheObjectInAdvancedCache("JNDIAuthorizationCache", key, users, null, false);
View Full Code Here

Examples of org.jbehave.core.util.Timer

*/
public class PlainTextScenarioListener extends PlainTextListener implements BehaviourListener {
    private final List usedMocks = new ArrayList();
   
    public PlainTextScenarioListener(Writer writer) {
        super(writer, new Timer());
    }
View Full Code Here

Examples of org.jboss.byteman.synchronization.Timer

     * @return true if a new timer was created and false if one already existed under the given identifier
     */
    public boolean createTimer(Object o)
    {
        synchronized (timerMap) {
            Timer timer = timerMap.get(o);
            if  (timer != null) {
                return false;
            } else {
                timerMap.put(o, new Timer());
                return true;
            }
        }
    }
View Full Code Here

Examples of org.jboss.cdi.tck.Timer

        MissileInterceptor.reset();

        producer.sendQueueMessage();

        // Wait for async processing
        new Timer().setDelay(3000l).addStopCondition(new StopCondition() {
            @Override
            public boolean isSatisfied() {
                return MessageDrivenMissile.messageAccepted;
            }
        }).start();
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.