Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for defBlock (0.13 sec)

  1. pkg/istio-agent/xds_proxy.go

    		// only send so much data without being Recv'd before it starts blocking), along with the
    		// backpressure provided by our channels, we have a risk of deadlock where both Xdsproxy and
    		// Istiod are trying to Send, but both are blocked by gRPC backpressure until Recv() is called.
    		// However, Recv can fail to be called by Send being blocked. This can be triggered by the two
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * under {@code directExecutor}: Not only might the wait for a lock be long, but if the running
       * thread was holding a lock, the listener may deadlock or break lock isolation.
       *
       * <p>This instance is equivalent to:
       *
       * <pre>{@code
       * final class DirectExecutor implements Executor {
       *   public void execute(Runnable r) {
       *     r.run();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 39K bytes
    - Viewed (0)
  3. internal/ringbuffer/ring_buffer_test.go

    	cc := make(chan struct{})
    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  4. internal/grid/grid_test.go

    	cc := make(chan struct{})
    	go func() {
    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    }
    
    func assertNoActive(t *testing.T, c *Connection) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * under {@code directExecutor}: Not only might the wait for a lock be long, but if the running
       * thread was holding a lock, the listener may deadlock or break lock isolation.
       *
       * <p>This instance is equivalent to:
       *
       * <pre>{@code
       * final class DirectExecutor implements Executor {
       *   public void execute(Runnable r) {
       *     r.run();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 43.7K bytes
    - Viewed (0)
  6. src/runtime/signal_unix.go

    		// these expectations of *libc code are mostly met by
    		// the combined go+cgo system of threads. However,
    		// when go causes a thread to exit, via a return from
    		// mstart(), the combined runtime can deadlock if
    		// these signals are blocked. Thus, don't block these
    		// signals when exiting threads.
    		// - glibc: SIGCANCEL (32), SIGSETXID (33)
    		// - musl: SIGTIMER (32), SIGCANCEL (33), SIGSYNCCALL (34)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 16:04:54 UTC 2024
    - 45K bytes
    - Viewed (0)
Back to top