- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 75 for canceling (0.15 sec)
-
src/net/http/transport_test.go
go func() { _, err := cl.Do(req) eventLog.Printf("Get error = %v", err != nil) test.checkErr("Get", err) gotres <- true }() inDial <- true eventLog.Printf("canceling") test.cancel(tr, req) test.cancel(tr, req) // used to panic on second call to Transport.Cancel if d, ok := t.Deadline(); ok { // When the test's deadline is about to expire, log the pending events for
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
okhttp-coroutines/README.md
but uses the standard Dispatcher in OkHttp. This means that by default Kotlin's Dispatchers are not used. Cancellation if implemented sensibly in both directions. Cancelling a coroutine scope, will cancel the call. Cancelling a call, will throw a CancellationException
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Nov 09 15:47:27 UTC 2023 - 609 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go
noteExecutingDelta(1) defer noteExecutingDelta(-1) served = true setResponseHeaders(classification, w) h.handler.ServeHTTP(w, r) } func() { handleCtx, cancelFn := h.newReqWaitCtxFn(ctx) defer cancelFn() h.fcIfc.Handle(handleCtx, digest, noteFn, estimateWork, queueNote, execute) }() } if !served { setResponseHeaders(classification, w)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/CancellationSpec.groovy
settingsFile << ''' rootProject.name = 'cancelling' ''' } void setupCancelInSettingsBuild() { settingsFile << waitForCancel() buildFile << """ throw new RuntimeException("should not run") """ } void setupCancelInConfigurationBuild() { settingsFile << ''' include 'sub' rootProject.name = 'cancelling' ''' buildFile << waitForCancel()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6.1K bytes - Viewed (0) -
internal/grid/muxclient.go
type Response struct { Msg []byte Err error } func newMuxClient(ctx context.Context, muxID uint64, parent *Connection) *muxClient { ctx, cancelFn := context.WithCancelCause(ctx) return &muxClient{ MuxID: muxID, ctx: ctx, cancelFn: cancelFn, parent: parent, LastPong: time.Now().UnixNano(), BaseFlags: parent.baseFlags,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/ContinuousBuildCancellationCrossVersionSpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
func (m *kubeletServerCertificateDynamicFileManager) Start() { var ctx context.Context ctx, m.cancelFn = context.WithCancel(context.Background()) go m.dynamicCertificateContent.Run(ctx, 1) } // Stop stops watching the certificate and key files func (m *kubeletServerCertificateDynamicFileManager) Stop() { if m.cancelFn != nil { m.cancelFn() } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
src/database/sql/sql_test.go
} if prepares := numPrepares(t, db) - prepares0; prepares != 1 { t.Errorf("executed %d Prepare statements; want 1", prepares) } } // TestQueryContext tests canceling the context while scanning the rows. func TestQueryContext(t *testing.T) { db := newTestDB(t, "people") defer closeDB(t, db) prepares0 := numPrepares(t, db)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r21/CancellationCrossVersionSpec.groovy
import org.gradle.tooling.model.gradle.GradleBuild class CancellationCrossVersionSpec extends ToolingApiSpecification { def setup() { settingsFile << ''' rootProject.name = 'cancelling' ''' } def "early cancel stops the build before beginning"() { buildFile << """ throw new GradleException("should not run") """ def cancel = GradleConnector.newCancellationTokenSource()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy.go
func NewRequestForProxy(location *url.URL, req *http.Request) (*http.Request, context.CancelFunc) { newCtx := req.Context() cancelFn := func() {} if requestInfo, ok := genericapirequest.RequestInfoFrom(req.Context()); ok { // trim leading and trailing slashes. Then "/apis/group/version" requests are for discovery, so if we have exactly three
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 5.6K bytes - Viewed (0)