Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 478 for Durrant (0.03 sec)

  1. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

       * thread.
       */
      private static final class ThreadConfinedTaskQueue {
        /**
         * This field is only used for identity comparisons with the current thread. Field assignments
         * are atomic, but do not provide happens-before ordering; however:
         *
         * <ul>
         *   <li>If this field's value == currentThread, we know that it's up to date, because write
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  2. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

        return (++i == items.length) ? 0 : i;
      }
    
      /**
       * Inserts element at current put position, advances, and signals. Call only when occupying
       * monitor.
       */
      private void insert(E x) {
        items[putIndex] = x;
        putIndex = inc(putIndex);
        ++count;
      }
    
      /**
       * Extracts element at current take position, advances, and signals. Call only when occupying
       * monitor.
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

                    log(buf);
                }
            });
        }
    
        /**
         * Gets the current system time in milliseconds.
         *
         * @return current time in milliseconds
         */
        protected long getCurrentTimeMillis() {
            return ComponentUtil.getSystemHelper().getCurrentTimeAsLong();
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb1/com/SmbComSeek.java

    import jcifs.internal.SMBProtocolDecodingException;
    import jcifs.internal.smb1.ServerMessageBlock;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB1 COM_SEEK command implementation.
     *
     * This command changes the current file position pointer for a file.
     * It allows seeking to different positions within an open file.
     *
     * @author mbechler
     */
    public class SmbComSeek extends ServerMessageBlock {
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/accesstoken/CreateForm.java

        public Long createdTime;
    
        /**
         * Initializes the form with default values for creation.
         * Sets the CRUD mode to CREATE and populates created by and created time fields
         * with current user and timestamp information.
         */
        public void initialize() {
            crudMode = CrudMode.CREATE;
            createdBy = ComponentUtil.getSystemHelper().getUsername();
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/core/sql/DriverManagerUtil.java

            } catch (final SQLException e) {
                throw new SQLRuntimeException(e);
            }
        }
    
        /**
         * Deregisters all JDBC drivers associated with the current class loader.
         */
        public static synchronized void deregisterAllDrivers() {
            for (final Enumeration<Driver> e = DriverManager.getDrivers(); e.hasMoreElements();) {
                deregisterDriver(e.nextElement());
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/ObjectCountHashMap.java

        @Nullable Object[] keys = this.keys;
        int[] values = this.values;
    
        int hash = smearedHash(key);
        int tableIndex = hash & hashTableMask();
        int newEntryIndex = this.size; // current size, and pointer to the entry to be appended
        int next = table[tableIndex];
        if (next == UNSET) {
          table[tableIndex] = newEntryIndex;
        } else {
          int last;
          long entry;
          do {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 14.5K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/general/AdminGeneralAction.java

            if (StringUtil.isNotBlank(form.logLevel)) {
                systemHelper.setLogLevel(form.logLevel);
            }
        }
    
        /**
         * Updates the form with current configuration values.
         *
         * @param fessConfig the current Fess configuration
         * @param form the form to populate with configuration values
         */
        public static void updateForm(final FessConfig fessConfig, final EditForm form) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 13 02:21:17 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/PreauthIntegrityService.java

                }
            }
    
            return isValid;
        }
    
        /**
         * Gets the current preauth hash for a session.
         *
         * @param sessionId the session identifier
         * @return the current hash, or null if no context exists
         */
        public byte[] getCurrentPreauthHash(String sessionId) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

            if (shouldStop) {
              break;
            }
            interruptee.interrupt();
          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
      /** Interrupts the current thread after sleeping for the specified delay. */
      static void requestInterruptIn(long time, TimeUnit unit) {
        checkNotNull(unit);
        Thread interruptee = Thread.currentThread();
        new Thread(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
Back to top