Search Options

Results per page
Sort
Preferred Languages
Advance

Results 821 - 830 of 1,379 for pread (0.04 sec)

  1. guava/src/com/google/common/collect/HashMultimap.java

     * <p>Keys and values may be null. All optional multimap methods are supported, and all returned
     * views are modifiable.
     *
     * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent
     * read operations will work correctly if the last write <i>happens-before</i> any reads. To allow
     * concurrent update operations, wrap your multimap with a call to {@link
     * Multimaps#synchronizedSetMultimap}.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 10:02:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub.go

    				} else {
    					remainTypes.Merge(s.types)
    				}
    			}
    			atomic.StoreUint64(&ps.types, uint64(remainTypes))
    			atomic.AddInt32(&ps.numSubscribers, -1)
    		}()
    
    		// Read from subChT and write to subCh
    		var buf bytes.Buffer
    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-doneCh:
    				return
    			case v, ok := <-subChT:
    				if !ok {
    					return
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/netbios/NbtSocket.java

                        log.println( "session established ok with " + address );
                    return;
                case SessionServicePacket.NEGATIVE_SESSION_RESPONSE:
                    int errorCode = (int)( in.read() & 0xFF );
                    close();
                    throw new NbtException( NbtException.ERR_SSN_SRVC, errorCode );
                case -1:
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 4.8K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    			if errors.Is(err, io.EOF) {
    				err = nil
    			}
    			break
    		}
    
    		stat = append(stat, st)
    	}
    
    	return stat, toStorageErr(err)
    }
    
    // ReadMultiple will read multiple files and send each back as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context or network errors returns an error.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

          )
        val response = call.execute()
        interruptLater(500)
        val responseBody = response.body.byteStream()
        val buffer = ByteArray(1024)
        assertFailsWith<IOException> {
          while (responseBody.read(buffer) != -1) {
          }
        }
        responseBody.close()
      }
    
      private fun sleep(delayMillis: Int) {
        try {
          Thread.sleep(delayMillis.toLong())
        } catch (e: InterruptedException) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/google/MultisetElementSetTester.java

      @CollectionFeature.Require(SUPPORTS_REMOVE)
      public void testElementSetClear() {
        getMultiset().elementSet().clear();
        assertEmpty(getMultiset());
      }
    
      /**
       * Returns {@link Method} instances for the read tests that assume multisets support duplicates so
       * that the test of {@code Multisets.forSet()} can suppress them.
       */
      @J2ktIncompatible
      @GwtIncompatible // reflection
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  7. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

      // Deprecated: selfLink is a legacy read-only field that is no longer populated by the system.
      // +optional
      optional string selfLink = 4;
    
      // UID is the unique in time and space value for this object. It is typically generated by
      // the server on successful creation of a resource and is not allowed to change on PUT
      // operations.
      //
      // Populated by the system.
      // Read-only.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  8. docs/en/docs/fastapi-people.md

    {% endfor %}
    
    </div>
    {% endif %}
    
    I'm the creator of **FastAPI**. You can read more about that in [Help FastAPI - Get Help - Connect with the author](help-fastapi.md#connect-with-the-author){.internal-link target=_blank}.
    
    ...But here I want to show you the community.
    
    ---
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/hash/BloomFilterTest.java

        }
    
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        bf.writeTo(out);
    
        BloomFilter<byte[]> read =
            BloomFilter.readFrom(new ByteArrayInputStream(out.toByteArray()), funnel);
        assertThat(read).isEqualTo(bf);
        assertThat(read.expectedFpp()).isGreaterThan(0);
      }
    
      /**
       * This test will fail whenever someone updates/reorders the BloomFilterStrategies constants. Only
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  10. internal/logger/target/http/http.go

    	maxWorkers int64
    
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    	// If this webhook is being re-configured we will
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top