Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 302 for selbst (0.04 seconds)

  1. cmd/data-usage-cache.go

    // save the content of the cache to minioMetaBackgroundOpsBucket with the provided name.
    // Note that no locking is done when saving.
    func (d *dataUsageCache) save(ctx context.Context, store objectIO, name string) error {
    	select {
    	case <-ctx.Done():
    		return ctx.Err()
    	case maxConcurrentScannerSaves <- struct{}{}:
    	}
    
    	buf := bytebufferpool.Get()
    	defer func() {
    		<-maxConcurrentScannerSaves
    		buf.Reset()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  2. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("got: %q; want: %q", result, "hello")
    	}
    }
    
    func timeout(after time.Duration) (cancel func()) {
    	c := time.After(after)
    	cc := make(chan struct{})
    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  3. doc/go_mem.html

    </p>
    
    <pre>
    var limit = make(chan int, 3)
    
    func main() {
    	for _, w := range work {
    		go func(w func()) {
    			limit &lt;- 1
    			w()
    			&lt;-limit
    		}(w)
    	}
    	select{}
    }
    </pre>
    
    <h3 id="locks">Locks</h3>
    
    <p>
    The <code>sync</code> package implements two lock data types,
    <code>sync.Mutex</code> and <code>sync.RWMutex</code>.
    </p>
    
    <p class="rule">
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 05 15:41:37 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  4. cmd/server-main.go

    	}
    
    	globalTrace.Publish(info)
    }
    
    func initServerConfig(ctx context.Context, newObject ObjectLayer) error {
    	t1 := time.Now()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	for {
    		select {
    		case <-ctx.Done():
    			// Retry was canceled successfully.
    			return fmt.Errorf("Initializing sub-systems stopped gracefully %w", ctx.Err())
    		default:
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  5. docs/bucket/notifications/README.md

    ```
    mc cp myphoto.jpg myminio/images
    ```
    
    Open PostgreSQL terminal to list the rows in the `bucketevents` table.
    
    ```
    $ psql -h 127.0.0.1 -U postgres -d minio_events
    minio_events=# select * from bucketevents;
    
    key                 |                      value
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  6. .bazelrc

    # CUDA: This config refers to building CUDA op kernels with clang.
    common:cuda_clang --config=cuda
    common:cuda_clang --@local_config_cuda//:cuda_compiler=clang
    common:cuda_clang --copt=-Qunused-arguments
    # Select supported compute capabilities (supported graphics cards).
    # This is the same as the official TensorFlow builds.
    # See https://developer.nvidia.com/cuda-gpus#compute
    # `compute_XY` enables PTX embedding in addition to SASS. PTX
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Fri Dec 26 23:20:26 GMT 2025
    - 56.8K bytes
    - Click Count (0)
  7. impl/maven-core/src/main/java/org/apache/maven/project/MavenProject.java

            this.resolvedArtifacts = (artifacts != null) ? artifacts : Collections.emptySet();
            this.artifacts = null;
            this.artifactMap = null;
        }
    
        /**
         * Sets the scope filter to select the artifacts being exposed to the currently executed mojo.
         * <strong>Warning:</strong> This is an internal utility method that is only public for technical reasons, it is not
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Aug 29 12:47:20 GMT 2025
    - 67K bytes
    - Click Count (0)
  8. cmd/object-handlers.go

    	for k, v := range reqParams {
    		if header, ok := supportedHeadGetReqParams[strings.ToLower(k)]; ok {
    			w.Header()[header] = []string{strings.Join(v, ",")}
    		}
    	}
    }
    
    // SelectObjectContentHandler - GET Object?select
    // ----------
    // This implementation of the GET operation retrieves object content based
    // on an SQL expression. In the request, along with the sql expression, you must
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  9. tests/migrate_test.go

    		gorm.ViewOption{Query: nil}); err != gorm.ErrSubQueryRequired {
    		t.Fatalf("no view should be created, got %v", err)
    	}
    
    	query := DB.Model(&User{}).
    		Select("users.id as users_id, users.name as users_name, pets.id as pets_id, pets.name as pets_name").
    		Joins("inner join pets on pets.user_id = users.id")
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed Aug 20 04:51:17 GMT 2025
    - 65.2K bytes
    - Click Count (0)
  10. src/bufio/bufio_test.go

    	return 0, nil
    }
    
    func TestZeroReader(t *testing.T) {
    	var z zeroReader
    	r := NewReader(z)
    
    	c := make(chan error)
    	go func() {
    		_, err := r.ReadByte()
    		c <- err
    	}()
    
    	select {
    	case err := <-c:
    		if err == nil {
    			t.Error("error expected")
    		} else if err != io.ErrNoProgress {
    			t.Error("unexpected error:", err)
    		}
    	case <-time.After(time.Second):
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
Back to Top