Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 164 for cancelFn (0.05 seconds)

  1. internal/grid/muxclient.go

    	}
    }
    
    func (m *muxClient) close() {
    	if debugPrint {
    		fmt.Println("closing outgoing mux", m.MuxID)
    	}
    	if !m.respMu.TryLock() {
    		// Cancel before locking - will unblock any pending sends.
    		if m.cancelFn != nil {
    			m.cancelFn(context.Canceled)
    		}
    		// Wait for senders to release.
    		m.respMu.Lock()
    	}
    
    	defer m.respMu.Unlock()
    	m.closeLocked()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  2. internal/grid/connection.go

    	go c.readStream(ctx, conn, cancel)
    	c.writeStream(ctx, conn, cancel)
    }
    
    // readStream handles the read side of the connection.
    // It will read messages and send them to c.handleMsg.
    // If an error occurs the cancel function will be called and conn be closed.
    // The function will block until the connection is closed or an error occurs.
    func (c *Connection) readStream(ctx context.Context, conn net.Conn, cancel context.CancelCauseFunc) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

       */
      override fun cancel() {
        if (canceled) return // Already canceled.
    
        canceled = true
        exchange?.cancel()
        for (plan in plansToCancel) {
          plan.cancel()
        }
    
        eventListener.canceled(this)
      }
    
      override fun isCanceled(): Boolean = canceled
    
      override fun execute(): Response {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

            else -> JavaNetSocket(route.proxy)
          }
        this.rawSocket = rawSocket
    
        // Handle the race where cancel() precedes connectSocket(). We don't want to miss a cancel.
        if (canceled) {
          throw IOException("canceled")
        }
    
        rawSocket.soTimeout = socketReadTimeoutMillis
        try {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
  5. internal/dsync/dsync_test.go

    	ctx, cancel := context.WithCancel(t.Context())
    
    	if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Make it run twice.
    	timer := time.NewTimer(testDrwMutexRefreshInterval * 2)
    
    	select {
    	case <-ctx.Done():
    		t.Fatal("Lock context canceled which is not expected")
    	case <-timer.C:
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        taskFaker.advanceUntil(500.ms)
        assertEvents(
          "take plan 2",
          "plan 0 cancel",
          "plan 1 cancel",
        )
    
        taskFaker.advanceUntil(510.ms)
        assertEvents(
          "plan 1 TCP connect canceled",
        )
    
        taskFaker.advanceUntil(520.ms)
        assertEvents(
          "plan 0 TCP connect canceled",
        )
      }
    
      @Test
      fun takeMultipleConnections() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 20.9K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

        assertThat(client.canceled).isFalse()
    
        taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS - 1))
        assertThat(client.canceled).isFalse()
    
        taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS))
        assertThat(client.canceled).isTrue()
    
        client.processNextFrame() // This won't get a frame, but it will get a closed pipe.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 18.7K bytes
    - Click Count (0)
  8. docs/recipes.md

            val startNanos = System.nanoTime()
            val call = client.newCall(request)
    
            // Schedule a job to cancel the call in 1 second.
            executor.schedule({
              System.out.printf("%.2f Canceling call.%n", (System.nanoTime() - startNanos) / 1e9f)
              call.cancel()
              System.out.printf("%.2f Canceled call.%n", (System.nanoTime() - startNanos) / 1e9f)
            }, 1, TimeUnit.SECONDS)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 47.8K bytes
    - Click Count (0)
  9. cmd/metacache-server-pool.go

    			c = &resp
    		} else {
    			rctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			c, err = rpc.GetMetacacheListing(rctx, *o)
    			cancel()
    		}
    		if err != nil {
    			if errors.Is(err, context.Canceled) {
    				// Context is canceled, return at once.
    				// request canceled, no entries to return
    				return entries, io.EOF
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  10. internal/grid/grid_test.go

    				time.Sleep(10 * time.Millisecond)
    			default:
    				sendReq = false
    			}
    		}
    		cancel()
    		<-serverCanceled
    		t.Log("server cancel time:", time.Since(start))
    		clientEnd := <-clientCanceled
    		if !errors.Is(err, context.Canceled) {
    			t.Error("expected context.Canceled, got", err)
    		}
    		t.Log("client after", time.Since(clientEnd))
    	}
    	// local to remote, unbuffered
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
Back to Top