- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 52 for sendZero (0.3 sec)
-
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
var sendErr error var evIndex int // If the delegateBackend was shutdown and the buffer channel was closed, an // attempt to add an event to it will result in panic that we should // recover from. defer func() { if err := recover(); err != nil { sendErr = fmt.Errorf("audit backend shut down") } if sendErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
src/internal/bytealg/count_amd64.s
PCMPEQB X0, X1 PMOVMSKB X1, DX // Apply mask ANDQ R10, DX POPCNTL DX, DX ADDQ DX, R12 end: MOVQ R12, (R8) RET // handle for lengths < 16 small: TESTQ BX, BX JEQ endzero // Check if we'll load across a page boundary. LEAQ 16(SI), AX TESTW $0xff0, AX JEQ endofpage // We must ignore high bytes as they aren't part of our slice. // Create mask. MOVB BX, CX
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 06 20:54:43 UTC 2023 - 4.7K bytes - Viewed (0) -
src/runtime/race/testdata/chan_test.go
_ = data[i] } } // Test that sender synchronizes with receiver even if the sender was blocked. func TestNoRaceBlockedSendSync(t *testing.T) { c := make(chan *int, 1) c <- nil go func() { i := 42 c <- &i }() // Give the sender time to actually block. // This sleep is completely optional: race report must not be printed // regardless of whether the sender actually blocks or not.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 11K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/classpath/CallInterceptingMetaClassTest.groovy
"invokeMethod(sender, receiver, methodName, arguments, false, false)" | { instance.metaClass.invokeMethod(getClass(), instance, "test", [].toArray(), false, false) } | true | false // These should not be intercepted because of isCallToSuper and fromInsideClass
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Nov 24 13:33:59 UTC 2023 - 15K bytes - Viewed (0) -
src/net/http/internal/chunked.go
if cr.err != nil { return } cr.n, cr.err = parseHexUint(line) if cr.err != nil { return } // A sender who sends one byte per chunk will send 5 bytes of overhead // for every byte of data. ("1\r\nX\r\n" to send "X".) // We want to allow this, since streaming a byte at a time can be legitimate. // // A sender can use chunk extensions to add arbitrary amounts of additional
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7.8K bytes - Viewed (0) -
internal/event/targetlist_test.go
package event import ( "context" "crypto/rand" "errors" "reflect" "testing" "time" "github.com/minio/minio/internal/store" ) type ExampleTarget struct { id TargetID sendErr bool closeErr bool } func (target ExampleTarget) ID() TargetID { return target.id } // Save - Sends event directly without persisting. func (target ExampleTarget) Save(eventData Event) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 6.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
const val MAX_CONCURRENT_STREAMS = 4 /** HTTP/2: Size in bytes of the largest frame payload the sender will accept. */ const val MAX_FRAME_SIZE = 5 /** HTTP/2: Advisory only. Size in bytes of the largest header list the sender will accept. */ const val MAX_HEADER_LIST_SIZE = 6 /** Window size in bytes. */ const val INITIAL_WINDOW_SIZE = 7
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.8K bytes - Viewed (0) -
cmd/admin-handlers-idp-ldap.go
} // Check if we are creating svc account for request sender. isSvcAccForRequestor := false if targetUser == requestorUser || targetUser == requestorParentUser { isSvcAccForRequestor = true } var ( targetGroups []string err error ) // If we are creating svc account for request sender, ensure that targetUser // is a real user (i.e. not derived credentials).
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 19:58:48 UTC 2024 - 14.1K bytes - Viewed (0) -
src/net/smtp/smtp_test.go
250-mx.google.com at your service 250 FEATURE ` var helloServer = []string{ "", "502 Not implemented\n", "250 User is valid\n", "235 Accepted\n", "250 Sender ok\n", "", "250 Reset ok\n", "221 Goodbye\n", "250 Sender ok\n", "250 ok\n", } var baseHelloClient = `EHLO customhost HELO customhost ` var helloClient = []string{ "", "STARTTLS\n",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 28.5K bytes - Viewed (0) -
.github/workflows/trusted-partners.yml
permissions: # Needed to attach tags into the PR issues: write contents: write pull-requests: write if: | github.event.pull_request.draft == false && github.event.sender.type == 'User' steps: - name: Checkout repo uses: actions/checkout@755da8c3cf115ac066823e79a1e1788f8940201b # v3.2.0 - name: Trusted-Partners-PR
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Sep 12 14:49:29 UTC 2023 - 2.4K bytes - Viewed (0)