- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 155 for pings (0.06 sec)
-
tests/connpool_test.go
return c.Tx.QueryRowContext(ctx, query, args...) } type wrapperConnPool struct { db *sql.DB got []string expect []string } func (c *wrapperConnPool) Ping() error { return c.db.Ping() } // If you use BeginTx returned *sql.Tx as shown below then you can't record queries in a transaction. // // func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Feb 06 02:54:40 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/grid/msg.go
const ( // OpConnect is a connect request. OpConnect Op = iota + 1 // OpConnectResponse is a response to a connect request. OpConnectResponse // OpPing is a ping request. // If a mux id is specified that mux is pinged. // Clients send ping requests. OpPing // OpPong is a OpPing response returned by the server. OpPong // OpConnectMux will connect a new mux with optional payload. OpConnectMux
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 28 19:22:29 UTC 2023 - 7.3K bytes - Viewed (0) -
internal/event/target/nsq.go
producer, err := nsq.NewProducer(target.args.NSQDAddress.String(), target.config) if err != nil { return false, err } target.producer = producer } if err := target.producer.Ping(); err != nil { // To treat "connection refused" errors as errNotConnected. if xnet.IsConnRefusedErr(err) { return false, store.ErrNotConnected } return false, err } return true, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/cors_test.go
// and end of the host. // The CVE should not occur in a real kubernetes cluster since we // validate the regular expression specified in --cors-allowed-origins // to ensure that it pins to the start and end of the host name. name: "regex does not pin, CVE-2022-1996 is not prevented", allowedOrigins: []string{"example.com"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 20 19:15:51 UTC 2023 - 7.9K bytes - Viewed (0) -
internal/grid/muxclient.go
return } } } } // doPing checks last ping time and sends another ping. func (m *muxClient) doPing(respHandler chan<- Response) (ok bool) { m.respMu.Lock() if m.closed { m.respMu.Unlock() // Already closed. This is not an error state; // we may just be delivering the last responses. return true } // Only check ping when not closed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractorTest.java
// Unix extention = ".sh"; content = "#!/bin/bash\nsleep " + sleep + ";cp $1 $2"; } else { // Windows extention = ".bat"; content = "ping localhost -n " + sleep + "\r\ncopy %1 %2"; } File file; try { file = File.createTempFile("script", extention); file.deleteOnExit();
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 9.8K bytes - Viewed (0) -
src/container/ring/example_test.go
r.Do(func(p any) { fmt.Println(p.(int)) }) // Output: // 3 // 4 // 0 // 1 // 2 } func ExampleRing_Link() { // Create two rings, r and s, of size 2 r := ring.New(2) s := ring.New(2) // Get the length of the ring lr := r.Len() ls := s.Len() // Initialize r with 0s for i := 0; i < lr; i++ { r.Value = 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 2.9K bytes - Viewed (0) -
hack/make-rules/test-e2e-node.sh
"${timeout_arg}" \ 2>&1 | tee -i "${artifacts}/build-log.txt" exit $? else # Refresh sudo credentials if needed if ping -c 1 -q metadata.google.internal &> /dev/null; then echo 'Running on GCE, not asking for sudo credentials' elif ping -c 1 -q 169.254.169.254 &> /dev/null; then echo 'Running on AWS, not asking for sudo credentials'
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 09:46:28 UTC 2024 - 10.7K bytes - Viewed (0) -
gorm.go
ConnPool: db.ConnPool, Context: context.Background(), Clauses: map[string]clause.Clause{}, } if err == nil && !config.DisableAutomaticPing { if pinger, ok := db.ConnPool.(interface{ Ping() error }); ok { err = pinger.Ping() } } if err != nil { config.Logger.Error(context.Background(), "failed to initialize database, got error %v", err) } return } // Session create new db session
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Sun Aug 20 11:46:56 UTC 2023 - 11.6K bytes - Viewed (0) -
internal/event/target/mysql.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.5K bytes - Viewed (0)