Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for broadcast (0.19 sec)

  1. docs/LICENSE

         accordance with the terms and conditions of this Public License.
    
      c. Copyright and Similar Rights means copyright and/or similar rights
         closely related to copyright including, without limitation,
         performance, broadcast, sound recording, and Sui Generis Database
         Rights, without regard to how the rights are labeled or
         categorized. For purposes of this Public License, the rights
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon May 10 16:50:06 GMT 2021
    - 18.2K bytes
    - Viewed (0)
  2. internal/dsync/drwmutex.go

    	tc, ok := ctx.Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    	if ok {
    		netLockCtx = context.WithValue(netLockCtx, mcontext.ContextTraceKey, tc)
    	}
    
    	for index, c := range restClnts {
    		wg.Add(1)
    		// broadcast lock request to all nodes
    		go func(index int, isReadLock bool, c NetLocker) {
    			defer wg.Done()
    
    			g := Granted{index: index}
    			if c == nil {
    				log("dsync: nil locker\n")
    				ch <- g
    				return
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    		atomic.StoreInt64(&c.LastPong, time.Now().UnixNano())
    	}
    	atomic.StoreUint32((*uint32)(&c.state), uint32(s))
    	if debugPrint {
    		fmt.Println(c.Local, "updateState:", gotState, "->", s)
    	}
    	c.connChange.Broadcast()
    }
    
    // monitorState will monitor the state of the connection and close the net.Conn if it changes.
    func (c *Connection) monitorState(conn net.Conn, cancel context.CancelCauseFunc) {
    	c.connChange.L.Lock()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top