Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 283 for waiters (0.73 sec)

  1. src/sync/rwmutex.go

    //
    // [the Go memory model]: https://go.dev/ref/mem
    type RWMutex struct {
    	w           Mutex        // held if there are pending writers
    	writerSem   uint32       // semaphore for writers to wait for completing readers
    	readerSem   uint32       // semaphore for readers to wait for completing writers
    	readerCount atomic.Int32 // number of pending readers
    	readerWait  atomic.Int32 // number of departing readers
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  2. cmd/erasure-heal_test.go

    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize())
    		}
    		_, err = erasure.Encode(context.Background(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. src/mdo/writer-stax.vm

        } //-- void setStringFormatter(InputLocation.StringFormatter)
    
    #end
        /**
         * Method write.
         *
         * @param writer a writer object
         * @param ${rootLcapName} a ${root.name} object
         * @throws IOException IOException if any
         */
        public void write(Writer writer, ${root.name} ${rootLcapName}) throws IOException, XMLStreamException {
            XMLOutputFactory factory = new com.ctc.wstx.stax.WstxOutputFactory();
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Dec 05 08:11:33 UTC 2023
    - 20.2K bytes
    - Viewed (0)
  4. operator/pkg/version/version_test.go

    			if gotErr, wantErr := errToString(err), tt.wantErr; gotErr != wantErr {
    				t.Fatalf("yaml.Unmarshal(%s): got error: %s, want error: %s", tt.desc, gotErr, wantErr)
    			}
    			if tt.wantErr == "" {
    				assert.Equal(t, got, tt.want)
    			}
    		})
    	}
    }
    
    // errToString returns the string representation of err and the empty string if
    // err is nil.
    func errToString(err error) string {
    	if err == nil {
    		return ""
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 25 19:30:47 UTC 2022
    - 6.1K bytes
    - Viewed (0)
  5. maven-toolchain-model/src/site/apt/index.apt

     The following are generated from this model:
    
       * {{{./apidocs/index.html}Java sources}} with Reader and Writers for the Xpp3 XML parser, <<<ToAPiV3()>>> and <<<ToApiV4()>>> transformers, and <<<v4>>> package
         for Merger and v4 Reader and Writers for the Xpp3 XML parser,
    
       * A {{{./toolchains.html}Descriptor Reference}}
    
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Jan 03 21:08:35 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  6. operator/pkg/validate/validate_test.go

    				t.Fatalf("unmarshalWithJSONPB(%s): got error %s", tt.desc, err)
    			}
    
    			errs := CheckIstioOperatorSpec(ispec, false)
    			if gotErrs, wantErrs := errs, tt.wantErrs; !util.EqualErrors(gotErrs, wantErrs) {
    				t.Errorf("ProtoToValues(%s)(%v): gotErrs:%s, wantErrs:%s", tt.desc, tt.yamlStr, gotErrs, wantErrs)
    			}
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Jun 25 11:44:31 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  7. maven-model/src/site/apt/index.apt

     The following are generated from this model:
    
       * {{{./apidocs/index.html}Java sources}} with Reader and Writers for the Xpp3 XML parser, <<<ToAPiV3()>>> and <<<ToApiV4()>>> transformers, and <<<v4>>> package
         for Merger and v4 Reader and Writers for the Xpp3 XML parser,
    
       * A {{{./maven.html}Descriptor Reference}}
    
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Jan 03 21:08:35 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  8. src/runtime/rwmutex.go

    	wLock  mutex    // serializes writers
    	writer muintptr // pending writer waiting for completing readers
    
    	readerCount atomic.Int32 // number of pending readers
    	readerWait  atomic.Int32 // number of departing readers
    
    	readRank lockRank // semantic lock rank for read locking
    }
    
    // Lock ranking an rwmutex has two aspects:
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 14:29:04 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. maven-settings/src/site/apt/index.apt

     The following are generated from this model:
    
       * {{{./apidocs/index.html}Java sources}} with Reader and Writers for the Xpp3 XML parser, <<<ToAPiV3()>>> and <<<ToApiV4()>>> transformers, and <<<v4>>> package
         for Merger and v4 Reader and Writers for the Xpp3 XML parser,
    
       * A {{{./settings.html}Descriptor Reference}}
    
       * An {{{https://maven.apache.org/xsd/settings-1.2.0.xsd}XSD}}
    
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Sat Feb 17 18:40:11 UTC 2024
    - 2K bytes
    - Viewed (0)
  10. pkg/scheduler/apis/config/validation/validation_test.go

    	scenarios := map[string]struct {
    		config   *config.KubeSchedulerConfiguration
    		wantErrs field.ErrorList
    	}{
    		"good": {
    			config: validConfig,
    		},
    		"bad-parallelism-invalid-value": {
    			config: invalidParallelismValue,
    			wantErrs: field.ErrorList{
    				&field.Error{
    					Type:  field.ErrorTypeInvalid,
    					Field: "parallelism",
    				},
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
Back to top