Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1791 - 1800 of 2,761 for errPos (0.16 seconds)

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

          throw new IllegalArgumentException(name + " must be positive but was: " + value);
        }
      }
    
      /**
       * Precondition tester for {@code Iterator.remove()} that throws an exception with a consistent
       * error message.
       */
      static void checkRemove(boolean canRemove) {
        checkState(canRemove, "no calls to next() since the last call to remove()");
      }
    
      private CollectPreconditions() {}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Nov 10 21:56:42 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  2. internal/event/target/nsq_test.go

    			n := NSQArgs{
    				Enable:      tt.fields.Enable,
    				NSQDAddress: tt.fields.NSQDAddress,
    				Topic:       tt.fields.Topic,
    			}
    			if err := n.Validate(); (err != nil) != tt.wantErr {
    				t.Errorf("NSQArgs.Validate() error = %v, wantErr %v", err, tt.wantErr)
    			}
    		})
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 2.2K bytes
    - Click Count (0)
  3. internal/amztime/iso8601_time.go

    		return value + strings.Repeat("0", (len(iso8601TimeFormat)-1)-len(value)) + "Z"
    	}
    	return value
    }
    
    // ISO8601Parse parses ISO8601 date string
    func ISO8601Parse(iso8601 string) (t time.Time, err error) {
    	for _, layout := range []string{
    		iso8601TimeFormat,
    		iso8601TimeFormatLong,
    		time.RFC3339,
    	} {
    		t, err = time.Parse(layout, iso8601)
    		if err == nil {
    			return t, nil
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 16 23:38:33 GMT 2023
    - 1.9K bytes
    - Click Count (0)
  4. cmd/http-tracer_test.go

    	}
    	wg.Wait()
    
    	finalStats := httpStats.toServerHTTPStats(false)
    	totalRequests := 0
    	for _, v := range finalStats.TotalS3Requests.APIStats {
    		totalRequests += v
    	}
    	if totalRequests == 0 {
    		t.Error("Expected some total requests to be recorded, but got zero")
    	}
    	t.Logf("Total requests recorded: %d", totalRequests)
    	t.Logf("Race condition test passed - no races detected")
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  5. cmd/bucket-replication-utils.go

    	ResyncTimestamp       string
    	ReplicationResynced   bool // true only if resync attempted for this target
    	endpoint              string
    	secure                bool
    	Err                   error // replication error if any
    }
    
    // Empty returns true for a target if arn is empty
    func (rt replicatedTargetInfo) Empty() bool {
    	return rt.Arn == ""
    }
    
    type replicatedInfos struct {
    	ReplicationTimeStamp time.Time
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  6. tensorflow/c/eager/c_api.h

    // Set the config in TF_ContextOptions.options.
    // config should be a serialized tensorflow.ConfigProto proto.
    // If config was not parsed successfully as a ConfigProto, record the
    // error information in *status.
    TF_CAPI_EXPORT extern void TFE_ContextOptionsSetConfig(
        TFE_ContextOptions* options, const void* proto, size_t proto_len,
        TF_Status* status);
    
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Apr 27 21:07:00 GMT 2023
    - 22.8K bytes
    - Click Count (0)
  7. cmd/metacache-entries.go

    // The entry not chosen will be discarded.
    // If the context is canceled the function will return the error,
    // otherwise the function will return nil.
    func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error {
    	defer xioutil.SafeClose(out)
    	top := make([]*metaCacheEntry, len(in))
    	nDone := 0
    	ctxDone := ctx.Done()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/curl/io/ContentCache.java

         * If the content is cached in a file, the file contents are read.
         *
         * @return the content as a byte array
         * @throws IOException if an I/O error occurs while reading the file
         */
        public byte[] getContentAsBytes() throws IOException {
            if (data != null) {
                return data.clone();
            }
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 4.8K bytes
    - Click Count (0)
  9. internal/bucket/replication/replication_test.go

    import (
    	"bytes"
    	"fmt"
    	"testing"
    )
    
    func TestParseAndValidateReplicationConfig(t *testing.T) {
    	testCases := []struct {
    		inputConfig           string
    		expectedParsingErr    error
    		expectedValidationErr error
    		destBucket            string
    		sameTarget            bool
    	}{
    		{ // 1 Invalid delete marker status in replication config
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.4K bytes
    - Click Count (0)
  10. src/main/webapp/WEB-INF/orig/view/error/notFound.jsp

    	type="text/css" />
    <link href="${fe:url('/css/style.css')}" rel="stylesheet"
    	type="text/css" />
    <link href="${fe:url('/css/font-awesome.min.css')}"
    	rel="stylesheet" type="text/css" />
    </head>
    <body class="error">
    	<jsp:include page="../header.jsp" />
    	<main class="container">
    		<div class="text-center">
    			<h2>
    				<la:message key="labels.page_not_found_title" />
    			</h2>
    			<div>
    				<la:message key="labels.check_url" />
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Feb 23 08:03:44 GMT 2026
    - 1.5K bytes
    - Click Count (0)
Back to Top