Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 731 for reread (0.05 sec)

  1. cmd/iam.go

    	}
    
    	updatedAt, err := sys.store.SetPolicy(ctx, policyName, p)
    	if err != nil {
    		return updatedAt, err
    	}
    
    	if !sys.HasWatcher() {
    		// Notify all other MinIO peers to reload policy
    		for _, nerr := range globalNotificationSys.LoadPolicy(ctx, policyName) {
    			if nerr.Err != nil {
    				logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String())
    				iamLogIf(ctx, nerr.Err)
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  2. docs/de/docs/contributing.md

    ### Dokumentation live
    
    Während der lokalen Entwicklung gibt es ein Skript, das die Site erstellt, auf Änderungen prüft und direkt neu lädt (Live Reload):
    
    <div class="termy">
    
    ```console
    $ python ./scripts/docs.py live
    
    <span style="color: green;">[INFO]</span> Serving on http://127.0.0.1:8008
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. internal/ringbuffer/ring_buffer.go

    	}
    
    	r.wg.Add(1)
    	defer r.wg.Done()
    	n, err = r.read(p)
    	for err == ErrIsEmpty && r.block {
    		r.writeCond.Wait()
    		if err = r.readErr(true); err != nil {
    			break
    		}
    		n, err = r.read(p)
    	}
    	if r.block && n > 0 {
    		r.readCond.Broadcast()
    	}
    	return n, err
    }
    
    // TryRead read up to len(p) bytes into p like Read but it is not blocking.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        checkNotNull(runnable, "Runnable was null.");
        checkNotNull(executor, "Executor was null.");
    
        // Lock while we check state. We must maintain the lock while adding the new pair so that
        // another thread can't run the list out from under us. We only add to the list if we have not
        // yet started execution.
        synchronized (this) {
          if (!executed) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/misc/DynamicProperties.java

            } else if (!this.propertiesFile.isFile()) {
                throw new FileAccessException("ECL0111", new Object[] { file.getAbsolutePath() });
            }
            load();
        }
    
        public synchronized void reload(final String path) {
            final File file = new File(path);
            if (!file.exists()) {
                final File parentDir = file.getParentFile();
                if (!parentDir.exists()) {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

         * may be necessary that an addition thread be used to read and
         * write to a Named Pipe.
         */
    
        public InputStream getNamedPipeInputStream() throws IOException {
            if( pipeIn == null ) {
                if(( pipeType & PIPE_TYPE_CALL ) == PIPE_TYPE_CALL ||
                        ( pipeType & PIPE_TYPE_TRANSACT ) == PIPE_TYPE_TRANSACT ) {
                    pipeIn = new TransactNamedPipeInputStream( this );
                } else {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.base.Preconditions.checkArgument;
    import static java.lang.Thread.currentThread;
    import static java.util.Arrays.asList;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.annotations.VisibleForTesting;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 17:40:56 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  8. src/test/java/jcifs/tests/KerberosTest.java

                try ( SmbTreeHandle th = f.getTreeHandle() ) {
                    Assume.assumeTrue("Not SMB2", th.isSMB2());
                }
    
                f.exists();
                Thread.sleep(wait);
    
                try ( SmbResource r = f.resolve("test") ) {
                    r.exists();
                }
            }
            catch ( SmbUnsupportedOperationException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Mar 01 09:46:04 UTC 2020
    - 11.5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbTransportImpl.java

            /*
             * Note the Transport thread isn't running yet so we can
             * read from the socket here.
             */
            try {
                this.socket.setSoTimeout(this.transportContext.getConfig().getConnTimeout());
                if ( peekKey() == null ) /* try to read header */
                    throw new IOException("transport closed in negotiate");
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/ImmutableSortedSet.java

       * comparable.
       *
       * <p>This method is safe to use even when {@code elements} is a synchronized or concurrent
       * collection that is currently being modified by another thread.
       *
       * @throws ClassCastException if the elements are not mutually comparable
       * @throws NullPointerException if any of {@code elements} is null
       * @since 7.0 (source-compatible since 2.0)
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 39.1K bytes
    - Viewed (0)
Back to top