- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 283 for Shan (0.17 sec)
-
cmd/storage-errors.go
// errLessData - returned when less data available than what was requested. var errLessData = StorageErr("less data available than what was requested") // errMoreData = returned when more data was sent by the caller than what it was supposed to. var errMoreData = StorageErr("more data was sent than what was advertised") // indicates readDirFn to return without further applying the fn()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/service.go
globalServiceFreezeMu.Lock() // Close when we reach 0 globalServiceFreezeCnt-- if globalServiceFreezeCnt <= 0 { // Set to a nil channel. var _ch chan struct{} if val := globalServiceFreeze.Swap(_ch); val != nil { if ch, ok := val.(chan struct{}); ok && ch != nil { // Close previous non-nil channel. xioutil.SafeClose(ch) } } globalServiceFreezeCnt = 0 // Don't risk going negative. }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
clause/expression.go
Eq(neq).Build(builder) } // Gt greater than for where type Gt Eq func (gt Gt) Build(builder Builder) { builder.WriteQuoted(gt.Column) builder.WriteString(" > ") builder.AddVar(builder, gt.Value) } func (gt Gt) NegationBuild(builder Builder) { Lte(gt).Build(builder) } // Gte greater than or equal to for where type Gte Eq
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Oct 10 06:45:48 GMT 2023 - 8.3K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
type WaitGroup struct { count int32 done chan struct{} } func NewWaitGroup() *WaitGroup { return &WaitGroup{ done: make(chan struct{}), } } func NewWaitForNCalls(t *testing.T, n int32) (*WaitGroup, func()) { wg := &WaitGroup{ done: make(chan struct{}), } wg.Add(n) return wg, func() { select { case <-wg.C():
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
tests/test_tutorial/test_body_fields/test_tutorial001.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.2K bytes - Viewed (0) -
tests/test_tutorial/test_body_fields/test_tutorial001_py310.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.3K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
// Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) // Convert local messages to JSON and send to mergeCh go func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
tests/test_tutorial/test_body_fields/test_tutorial001_an.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.2K bytes - Viewed (0) -
tests/test_tutorial/test_body_fields/test_tutorial001_an_py39.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
"Payload size must be less than or equal to 125", ) } } @Test fun pongTooLongThrows() { assertFailsWith<IllegalArgumentException> { serverWriter.writePong((binaryData(1000))) }.also { expected -> assertThat(expected.message).isEqualTo( "Payload size must be less than or equal to 125", ) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0)