- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,957 for closeFn (0.13 sec)
-
src/runtime/testdata/testprogcgo/eintr.go
return } log.Fatal(err) } wg.Add(2) go func() { defer wg.Done() defer ln.Close() c, err := ln.Accept() if err != nil { log.Fatal(err) } defer c.Close() cf, err := c.(*net.TCPConn).File() if err != nil { log.Fatal(err) } defer cf.Close() if err := syscall.SetNonblock(int(cf.Fd()), false); err != nil { log.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 5.2K bytes - Viewed (0) -
src/runtime/chan.go
if c == nil { panic(plainError("close of nil channel")) } lock(&c.lock) if c.closed != 0 { unlock(&c.lock) panic(plainError("close of closed channel")) } if raceenabled { callerpc := getcallerpc() racewritepc(c.raceaddr(), callerpc, abi.FuncPCABIInternal(closechan)) racerelease(c.raceaddr()) } c.closed = 1 var glist gList
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ContiguousSet.java
* (inclusive) to {@code upper} (inclusive). (These are the same values contained in {@code * Range.closed(lower, upper)}.) * * @throws IllegalArgumentException if {@code lower} is greater than {@code upper} * @since 23.0 */ public static ContiguousSet<Integer> closed(int lower, int upper) { return create(Range.closed(lower, upper), DiscreteDomain.integers()); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Nov 30 21:54:06 UTC 2023 - 9.9K bytes - Viewed (0) -
src/internal/fuzz/sys_windows.go
sys: sharedMemSys{mapObj: mapObj}, }, nil } // Close unmaps the shared memory and closes the temporary file. If this // sharedMem was created with sharedMemTempFile, Close also removes the file. func (m *sharedMem) Close() error { // Attempt all operations, even if we get an error for an earlier operation. // os.File.Close may fail due to I/O errors, but we still want to delete // the temporary file.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 18:35:25 UTC 2023 - 4.5K bytes - Viewed (0) -
src/net/http/transfer.go
mu sync.Mutex // guards following, and calls to Read and Close sawEOF bool closed bool earlyClose bool // Close called and we didn't read to the end of src onHitEOF func() // if non-nil, func to call when EOF is Read } // ErrBodyReadAfterClose is returned when reading a [Request] or [Response] // Body after the body has been closed. This typically happens when the body is
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 22:14:00 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/scheduler/profile/profile.go
func (m Map) HandlesSchedulerName(name string) bool { _, ok := m[name] return ok } // Close closes all frameworks registered in this map. func (m Map) Close() error { var errs []error for name, f := range m { err := f.Close() if err != nil { errs = append(errs, fmt.Errorf("framework %s failed to close: %w", name, err)) } } return errors.Join(errs...) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 06 01:11:19 UTC 2024 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/streaming/streaming.go
type Decoder interface { // Decode will return io.EOF when no more objects are available. Decode(defaults *schema.GroupVersionKind, into runtime.Object) (runtime.Object, *schema.GroupVersionKind, error) // Close closes the underlying stream. Close() error } // Serializer is a factory for creating encoders and decoders that work over streams. type Serializer interface { NewEncoder(w io.Writer) Encoder NewDecoder(r io.ReadCloser) Decoder }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 25 14:51:36 UTC 2023 - 3.7K bytes - Viewed (0) -
test/typeparam/orderedmap.go
// The value will not be sent if the context is closed or the receiver // is freed. func (s *_Sender[Elem]) Send(ctx context.Context, v Elem) bool { select { case <-ctx.Done(): return false case s.values <- v: return true case <-s.done: return false } } // Close tells the receiver that no more values will arrive. // After Close is called, the _Sender may no longer be used.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 19:45:34 UTC 2022 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/net/util_test.go
} defer resp.Body.Close() data, err := io.ReadAll(resp.Body) if err != nil { t.Fatalf("unexpected error: %+v", err) } if string(data) != "Hello, HTTP/2.0" { t.Fatalf("unexpected response: %s", data) } // Deliberately let the LB stop proxying traffic for the current // connection. This mimics a broken TCP connection that's not properly // closed. close(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait.go
// when the provided parentCh is closed. The implementation returns // context.Canceled for Err() if and only if the parentCh is closed. func ContextForChannel(parentCh <-chan struct{}) context.Context { return channelContext{stopCh: parentCh} } var _ context.Context = channelContext{} // channelContext will behave as if the context were cancelled when stopCh is // closed. type channelContext struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 7.1K bytes - Viewed (0)