- Sort Score
- Result 10 results
- Languages All
Results 521 - 530 of 731 for reread (0.09 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/test/java/jcifs/tests/KerberosTest.java
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Mar 01 09:46:04 UTC 2020 - 11.5K bytes - Viewed (0) -
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) -
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)