Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for unblockSend (0.24 sec)

  1. internal/grid/muxserver.go

    		m.disconnect("handler blocked", true)
    	}
    }
    
    func (m *muxServer) unblockSend(seq uint32) {
    	if !m.checkSeq(seq) {
    		return
    	}
    	m.recvMu.Lock()
    	defer m.recvMu.Unlock()
    	if m.outBlock == nil {
    		// Closed
    		return
    	}
    	select {
    	case m.outBlock <- struct{}{}:
    	default:
    		gridLogIf(m.ctx, errors.New("output unblocked overflow"))
    	}
    }
    
    func (m *muxServer) ping(seq uint32) pongMsg {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. internal/grid/muxclient.go

    	for i := 0; i < available; i++ {
    		m.outBlock <- struct{}{}
    	}
    	m.acked = true
    }
    
    func (m *muxClient) unblockSend(seq uint32) {
    	if !m.checkSeq(seq) {
    		return
    	}
    	select {
    	case m.outBlock <- struct{}{}:
    	default:
    		gridLogIf(m.ctx, errors.New("output unblocked overflow"))
    	}
    }
    
    func (m *muxClient) pong(msg pongMsg) {
    	if msg.NotFound || msg.Err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    		}
    		// We can expect to receive unblocks for closed muxes
    		return
    	}
    	v.unblockSend(m.Seq)
    }
    
    func (c *Connection) handleUnblockSrvMux(m message) {
    	if m.Payload != nil {
    		PutByteBuffer(m.Payload)
    	}
    	m.Payload = nil
    	if v, ok := c.inStream.Load(m.MuxID); ok {
    		v.unblockSend(m.Seq)
    		return
    	}
    	// We can expect to receive unblocks for closed muxes
    	if debugPrint {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  4. src/cmd/cgo/internal/test/sigprocmask.go

    	// Verify that SIGIO stays blocked on the C thread
    	// even when unblocked for signal.Notify().
    	signal.Notify(make(chan os.Signal), syscall.SIGIO)
    	blocked = C.CheckBlocked() != 0
    }
    
    func testSigprocmask(t *testing.T) {
    	if r := C.RunSigThread(); r != 0 {
    		t.Errorf("pthread_create/pthread_join failed: %d", r)
    	}
    	if !blocked {
    		t.Error("Go runtime unblocked SIGIO")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 12:00:02 UTC 2023
    - 808 bytes
    - Viewed (0)
  5. src/internal/trace/parser.go

    	EvGoSleep           = 19 // goroutine calls Sleep [timestamp, stack]
    	EvGoBlock           = 20 // goroutine blocks [timestamp, stack]
    	EvGoUnblock         = 21 // goroutine is unblocked [timestamp, goroutine id, seq, stack]
    	EvGoBlockSend       = 22 // goroutine blocks on chan send [timestamp, stack]
    	EvGoBlockRecv       = 23 // goroutine blocks on chan recv [timestamp, stack]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:31:04 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting.go

    // This implementation tracks active goroutines:
    // the given counter is decremented for a goroutine waiting for this
    // varible to be set and incremented when such a goroutine is
    // unblocked.
    type countingPromise struct {
    	lock          sync.Locker
    	cond          sync.Cond
    	activeCounter counter.GoRoutineCounter // counter of active goroutines
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 10 14:37:53 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight_test.go

    	responses := &sync.WaitGroup{}
    	responses.Add(AllowedNonMutatingInflightRequestsNo * 2)
    
    	// Block is used to keep requests in flight for as long as we need to. All requests will
    	// be unblocked at the same time.
    	block := &sync.WaitGroup{}
    	block.Add(1)
    
    	waitForCalls := true
    	waitForCallsMutex := sync.Mutex{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 10.2K bytes
    - Viewed (0)
  8. src/internal/trace/testdata/generators/go122-confuse-seq-across-generations.go

    	b10.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning)
    	b10.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning)
    	b10.Event("GoStop", "whatever", testgen.NoStack)
    
    	// The running goroutine gets unblocked.
    	b11 := g1.Batch(trace.ThreadID(1), 0)
    	b11.Event("ProcStatus", trace.ProcID(1), go122.ProcRunning)
    	b11.Event("GoStart", trace.GoID(1), testgen.Seq(1))
    	b11.Event("GoStop", "whatever", testgen.NoStack)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  9. src/os/signal/doc.go

    signal, while Ignore will cause the system to ignore the signal
    entirely.
    
    If the program is started with a non-empty signal mask, some signals
    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
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:11:00 UTC 2024
    - 11K bytes
    - Viewed (0)
  10. internal/grid/msg.go

    	// OpMuxServerMsg contains a message to a server Mux
    	OpMuxServerMsg
    
    	// OpUnblockSrvMux contains a message that a server mux is unblocked with one.
    	// Only Stateful streams has flow control.
    	OpUnblockSrvMux
    
    	// OpUnblockClMux contains a message that a client mux is unblocked with one.
    	// Only Stateful streams has flow control.
    	OpUnblockClMux
    
    	// OpAckMux acknowledges a mux was created.
    	OpAckMux
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Nov 28 19:22:29 UTC 2023
    - 7.3K bytes
    - Viewed (0)
Back to top