Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 343 for notifyCh (0.15 sec)

  1. src/os/signal/example_test.go

    	// if we're not ready to receive when the signal is sent.
    	c := make(chan os.Signal, 1)
    
    	// Passing no signals to Notify means that
    	// all signals will be sent to the channel.
    	signal.Notify(c)
    
    	// Block until any signal is received.
    	s := <-c
    	fmt.Println("Got signal:", s)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 01 18:38:23 UTC 2017
    - 1001 bytes
    - Viewed (0)
  2. cmd/config-versions.go

    	Worm       config.BoolFlag  `json:"worm"`
    
    	// Storage class configuration
    	StorageClass storageclass.Config `json:"storageclass"`
    
    	// Notification queue configuration.
    	Notify notify.Config `json:"notify"`
    
    	// Logger configuration
    	Logger logger.Config `json:"logger"`
    
    	// Compression configuration
    	Compression compress.Config `json:"compress"`
    
    	// OpenID configuration
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. cmd/batch-rotate.go

    }
    
    // BatchJobKeyRotateFlags various configurations for replication job definition currently includes
    // - filter
    // - notify
    // - retry
    type BatchJobKeyRotateFlags struct {
    	Filter BatchKeyRotateFilter `yaml:"filter" json:"filter"`
    	Notify BatchJobNotification `yaml:"notify" json:"notify"`
    	Retry  BatchJobRetry        `yaml:"retry" json:"retry"`
    }
    
    // BatchJobKeyRotateV1 v1 of batch key rotation job
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  4. cmd/batch-rotate_gen.go

    		case "Filter":
    			err = z.Filter.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Filter")
    				return
    			}
    		case "Notify":
    			err = z.Notify.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Notify")
    				return
    			}
    		case "Retry":
    			err = z.Retry.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Retry")
    				return
    			}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 27.1K bytes
    - Viewed (0)
  5. .github/actions/notify-translations/action.yml

    name: "Notify Translations"
    description: "Notify in the issue for a translation when there's a new PR available"
    author: "Sebastián Ramírez <******@****.***>"
    inputs:
      token:
        description: 'Token, to read the GitHub API. Can be passed in using {{ secrets.GITHUB_TOKEN }}'
        required: true
    runs:
      using: 'docker'
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Wed Aug 18 13:07:08 UTC 2021
    - 346 bytes
    - Viewed (0)
  6. src/runtime/race/testdata/cgo_test_main.go

    // license that can be found in the LICENSE file.
    
    package main
    
    /*
    int sync;
    
    void Notify(void)
    {
    	__sync_fetch_and_add(&sync, 1);
    }
    
    void Wait(void)
    {
    	while(__sync_fetch_and_add(&sync, 0) == 0) {}
    }
    */
    import "C"
    
    func main() {
    	data := 0
    	go func() {
    		data = 1
    		C.Notify()
    	}()
    	C.Wait()
    	_ = data
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 08 04:08:51 UTC 2014
    - 415 bytes
    - Viewed (0)
  7. src/sync/cond.go

    //
    //	c.L.Lock()
    //	for !condition() {
    //	    c.Wait()
    //	}
    //	... make use of condition ...
    //	c.L.Unlock()
    func (c *Cond) Wait() {
    	c.checker.check()
    	t := runtime_notifyListAdd(&c.notify)
    	c.L.Unlock()
    	runtime_notifyListWait(&c.notify, t)
    	c.L.Lock()
    }
    
    // Signal wakes one goroutine waiting on c, if there is any.
    //
    // It is allowed but not required for the caller to hold c.L
    // during the call.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. src/os/signal/doc.go

    will be explicitly unblocked as described above. If Notify is called
    for a blocked signal, it will be unblocked. If, later, Reset is
    called for that signal, or Stop is called on all channels passed to
    Notify for that signal, the signal will once again be blocked.
    
    # SIGPIPE
    
    When a Go program writes to a broken pipe, the kernel will raise a
    SIGPIPE signal.
    
    If the program has not called Notify to receive SIGPIPE signals, then
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:11:00 UTC 2024
    - 11K bytes
    - Viewed (0)
  9. src/os/signal/signal.go

    //
    // It is allowed to call Notify multiple times with the same channel:
    // each call expands the set of signals sent to that channel.
    // The only way to remove signals from the set is to call [Stop].
    //
    // It is allowed to call Notify multiple times with different channels
    // and the same signals: each channel receives copies of incoming
    // signals independently.
    func Notify(c chan<- os.Signal, sig ...os.Signal) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 21:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  10. pkg/kubelet/container/cache.go

    		return d
    	}
    	// The pod status is not ready.
    	return nil
    }
    
    // notify sends notifications for pod with the given id, if the requirements
    // are met. Note that the caller should acquire the lock.
    func (c *cache) notify(id types.UID, timestamp time.Time) {
    	list, ok := c.subscribers[id]
    	if !ok {
    		// No one to notify.
    		return
    	}
    	newList := []*subRecord{}
    	for i, r := range list {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 07:37:01 UTC 2023
    - 6.6K bytes
    - Viewed (0)
Back to top