Package org.gudy.azureus2.core3.util

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


     
      Map  result;
     
      if ( scratch_file_is == null ){
       
        result = new LightHashMap();
       
      }else{
     
          // System.out.println( "read cache file " + scratch_file_name + " for " + this );

       
        Properties p = new Properties();
       
        InputStream  fis = scratch_file_is;
       
        try{
                 
          p.load( fis );
         
          fis.close();
         
          scratch_file_is = new FileInputStream( scratch_file_name );
         
          messages = new LightHashMap();
         
          messages.putAll( p );
         
          result = messages;
         
        }catch( Throwable e ){
         
          if ( fis != null ){
           
            try{
              fis.close();
             
            }catch( Throwable f ){
            }
          }
         
          Debug.out( "Failed to load message bundle scratch file", e );
         
          scratch_file_name.delete();
         
          scratch_file_is = null;
         
          result = new LightHashMap();
        }
      }
     
      if ( added_strings != null ){
       
View Full Code Here


      null_values = null;
    }
  }
 
  public void clearUsedMessagesMap(int initialCapacity) {
    used_messages = new LightHashMap(initialCapacity);
    if (null_values != null) {
      null_values = new ArrayList(0);
    }
  }
View Full Code Here

        else if( type.equalsIgnoreCase("string") ) {
          COConfigurationManager.setParameter( internal_name, setto );
          success = true;
        }
        else if( type.equalsIgnoreCase("password") ) {
          SHA1Hasher hasher = new SHA1Hasher();
         
          byte[] password = setto.getBytes();
         
          byte[] encoded;
         
          if(password.length > 0){
           
            encoded = hasher.calculateHash(password);
           
          }else{
           
            encoded = password;
          }
View Full Code Here

      if ( compact_timer == null && System.getProperty("transitory.startup", "0").equals("0")){
               
        compact_timer = SimpleTimer.addPeriodicEvent(
          "IRB:compactor",
          60*1000,
          new TimerEventPerformer()
          {
            public void
            perform(
              TimerEvent event )
            { 
View Full Code Here

    if ( announcers.size() > activated.size()){
     
      event = SimpleTimer.addEvent(
        "TRMuxer:check",
        SystemTime.getOffsetTime( delay ),
        new TimerEventPerformer()
        {
          public void
          perform(
            TimerEvent event )
          {
View Full Code Here

            }
           
            event =
              timer.addEvent(
                  now + idle_dispatch_time,
                  new TimerEventPerformer()
                  {
                    public void
                    perform(
                      TimerEvent  event )
                    {
                      dispatch();
                    }
                  });
          }finally{
           
            timer_mon.exit();
          }
         
          if ( dispatch_now != null ){
           
            dispatch( dispatch_now );
          }
        }

        public Object
        remove(
          Object  obj )
        {
          Object  res = null;
         
          try{
            timer_mon.enter();
         
            res = list.remove( obj )?obj:null;
             
            if ( res != null ){
             
              long  now = SystemTime.getCurrentTime();
             
              if ( event != null ){
               
                event.cancel();
              }
               
              if ( list.size() == 0 ){
               
                event  = null;
               
              }else{
               
                event =
                  timer.addEvent(
                      now + idle_dispatch_time,
                      new TimerEventPerformer()
                      {
                        public void
                        perform(
                          TimerEvent  event )
                        {
View Full Code Here

           
            timer =
              SimpleTimer.addPeriodicEvent(
                "DMRC",
                TIMER_MILLIS,
                new TimerEventPerformer()
                {
                  public void
                  perform(
                    TimerEvent event )
                  {
View Full Code Here

    final long      timeout )
  {
    SimpleTimer.addEvent(
      "CryptoManager:pw_timeout",
      timeout,
      new TimerEventPerformer()
      {
        public void
        perform(
          TimerEvent event)
        {
View Full Code Here

   
        timer_event =
          SimpleTimer.addPeriodicEvent(
            "Tivo:Beacon",
            60*1000,
            new TimerEventPerformer()
            {
              public void
              perform(
                TimerEvent   event )
              {
View Full Code Here

       
        averages = new HashMap();
       
        average_timer.addPeriodicEvent(
          AVERAGE_PERIOD,
          new TimerEventPerformer()
          {
            private Map  ave = averages;

            public void
            perform(
View Full Code Here

TOP

Related Classes of org.gudy.azureus2.core3.util.TimerEventPerformer

Copyright © 2018 www.massapicom. 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.