Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 3,071 for wave (0.05 sec)

  1. cmd/background-newdisks-heal-ops.go

    		h.ID, _ = h.disk.GetDiskID()
    		h.PoolIndex, h.SetIndex, h.DiskIndex = h.disk.GetDiskLoc()
    	}
    	h.mu.Unlock()
    	return h.save(ctx)
    }
    
    // save will unconditionally save the tracker and will be created if not existing.
    func (h *healingTracker) save(ctx context.Context) error {
    	h.mu.Lock()
    	if h.PoolIndex < 0 || h.SetIndex < 0 || h.DiskIndex < 0 {
    		// Attempt to get location.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    	}
    
    	return nil
    }
    
    // Maximum running concurrent saves on server.
    var maxConcurrentScannerSaves = make(chan struct{}, 4)
    
    // 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()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  3. tests/hooks_test.go

    	DB.AutoMigrate(&Product{})
    
    	p := Product{Code: "Invalid", Price: 100}
    	if DB.Save(&p).Error == nil {
    		t.Fatalf("An error from before create callbacks happened when create with invalid value")
    	}
    
    	if DB.Where("code = ?", "Invalid").First(&Product{}).Error == nil {
    		t.Fatalf("Should not save record that have errors")
    	}
    
    	if DB.Save(&Product{Code: "dont_save", Price: 100}).Error == nil {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Mon Jun 17 03:59:06 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. internal/event/target/nsq.go

    		if xnet.IsConnRefusedErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the nsq connection is active.
    func (target *NSQTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    
    	if err := target.init(); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  5. internal/event/target/webhook.go

    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	defer conn.Close()
    	return true, nil
    }
    
    // Save - saves the events to the store if queuestore is configured,
    // which will be replayed when the webhook connection is active.
    func (target *WebhookTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. ci/official/installer_wheel.sh

    # Extract the package name from the wheel name. That is, extract every character
    # before the pattern "-py3-" in the wheel name.
    pkg_name=$(echo "${pure_python_whl}" | awk -F'-py3-' '{print $1}')
    
    # Save the current working directory and then switch to the output directory.
    pushd "${TFCI_OUTPUT_DIR}"
    
    # Unpack the wheel to get all the file contents. The pure python wheel we built
    Registered: Tue Dec 30 12:39:10 UTC 2025
    - Last Modified: Tue Mar 04 22:39:12 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  7. docs/en/docs/async.md

    ```Python hl_lines="2"
    @app.get('/')
    def results():
        results = some_library()
        return results
    ```
    
    ---
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Protocol.kt

       * `INADEQUATE_SECURITY`.
       */
      HTTP_2("h2"),
    
      /**
       * Cleartext HTTP/2 with no "upgrade" round trip. This option requires the client to have prior
       * knowledge that the server supports cleartext HTTP/2.
       *
       * See also [Starting HTTP/2 with Prior Knowledge][rfc_7540_34].
       *
       * [rfc_7540_34]: https://datatracker.ietf.org/doc/html/rfc7540#autoid-10
       */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Jun 23 18:58:57 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  9. internal/event/target/redis.go

    			return false, store.ErrNotConnected
    		}
    		return false, pingErr
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the redis connection is active.
    func (target *RedisTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  10. tests/gaussdb_test.go

    	}
    
    	if err := DB.Where("id = $1", yasuo.ID).First(&Yasuo{}).Error; err != nil || yasuo.Name != "jinzhu" {
    		t.Errorf("No error should happen, but got %v", err)
    	}
    
    	yasuo.Name = "jinzhu1"
    	if err := DB.Save(&yasuo).Error; err != nil {
    		t.Errorf("Failed to update date, got error %v", err)
    	}
    
    	if err := DB.First(&result, "id = ?", yasuo.ID).Error; err != nil || yasuo.Name != "jinzhu1" {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Mon Jul 21 02:46:58 UTC 2025
    - 6.6K bytes
    - Viewed (0)
Back to top