- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for closing (0.14 sec)
-
internal/grid/muxclient.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
src/cmd/asm/internal/asm/expr_test.go
{"3>>(1<<63)", "negative right shift count"}, {"(1<<63)>>2", "right shift of value with high bit set"}, {"(1<<62)>>2", ""}, {`'\x80'`, "illegal UTF-8 encoding for character constant"}, {"(23*4", "missing closing paren"}, {")23*4", "unexpected ) evaluating expression"}, {"18446744073709551616", "value out of range"}, } func TestBadExpr(t *testing.T) { for i, test := range badExprTests { err := runBadTest(i, test, t)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 3.2K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
failedMessages int64 wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cni/pkg/nodeagent/fakes_test.go
} // Fd returns the file descriptor func (f *fakeNs) Fd() uintptr { return f.fd } func (f *fakeNs) Inode() uint64 { return f.inode } // Close simulates closing the file descriptor and returns nil for no error func (f *fakeNs) Close() error { f.closed.Store(true) return nil } func fakeFs() fs.FS { subFs, err := fs.Sub(fakeProc, "testdata") if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
src/archive/zip/zip_test.go
p = p[n:] ss.start += n if ss.start == ss.keep { ss.start = 0 } } return } // generatesZip64 reports whether f wrote a zip64 file. // f is also responsible for closing w. func generatesZip64(t *testing.T, f func(w *Writer)) bool { ss := &suffixSaver{keep: 10 << 20} w := NewWriter(ss) f(w) return suffixIsZip64(t, ss) } type sizedReaderAt interface { io.ReaderAt
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Mar 27 18:23:49 GMT 2024 - 19.5K bytes - Viewed (0) -
internal/grid/connection.go
defer c.connMu.Unlock() if c.debugInConn != nil { if debugPrint { fmt.Println("debug: closing inbound connection") } c.debugInConn.Close() } case debugKillOutbound: c.connMu.Lock() defer c.connMu.Unlock() if c.debugInConn != nil { if debugPrint { fmt.Println("debug: closing outgoing connection") } c.debugInConn.Close() } case debugWaitForExit:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// nolint: unparam func (z *ztunnelServer) handleConn(ctx context.Context, conn *ZtunnelConnection) error { defer conn.Close() context.AfterFunc(ctx, func() { log.Debug("context cancelled - closing conn") conn.Close() }) // before doing anything, add the connection to the list of active connections z.conns.addConn(conn) defer z.conns.deleteConn(conn) // get hello message from ztunnel
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/event/target/nats.go
return target.store.Del(key.Name) } // Close - closes underneath connections to NATS server. func (target *NATSTarget) Close() (err error) { close(target.quitCh) if target.stanConn != nil { // closing the streaming connection does not close the provided NATS connection. if target.stanConn.NatsConn() != nil { target.stanConn.NatsConn().Close() } return target.stanConn.Close() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 36.9K bytes - Viewed (0) -
cmd/object-api-utils.go
type GetObjectReader struct { io.Reader ObjInfo ObjectInfo cleanUpFns []func() once sync.Once } // WithCleanupFuncs sets additional cleanup functions to be called when closing // the GetObjectReader. func (g *GetObjectReader) WithCleanupFuncs(fns ...func()) *GetObjectReader { g.cleanUpFns = append(g.cleanUpFns, fns...) return g }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1)