Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. src/cmd/asm/internal/asm/line_test.go

    		{"VADDPD.SAE.BCST X0, X1, X2", `can't combine rounding/SAE and broadcast`},
    		{"VADDPD.BCST.SAE X0, X1, X2", `can't combine rounding/SAE and broadcast`},
    		{"VADDPD.BCST.Z.SAE X0, X1, X2", `Z suffix should be the last; can't combine rounding/SAE and broadcast`},
    		{"VADDPD.SAE.SAE X0, X1, X2", `duplicate suffix "SAE"`},
    		{"VADDPD.RZ_SAE.SAE X0, X1, X2", `bad suffix combination`},
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Aug 29 07:48:38 GMT 2023
    - 1.9K 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