- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 77 for Conn (0.25 sec)
-
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
path: String, responseCode: AtomicInteger, ): Thread { return Thread { val url = mockWebServer.url(path).toUrl() val conn: HttpURLConnection try { conn = url.openConnection() as HttpURLConnection responseCode.set(conn.responseCode) // Force the connection to hit the "server". } catch (ignored: IOException) { } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
api/go1.9.txt
pkg database/sql, method (*Conn) BeginTx(context.Context, *TxOptions) (*Tx, error) pkg database/sql, method (*Conn) Close() error pkg database/sql, method (*Conn) ExecContext(context.Context, string, ...interface{}) (Result, error) pkg database/sql, method (*Conn) PingContext(context.Context) error pkg database/sql, method (*Conn) PrepareContext(context.Context, string) (*Stmt, error)
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 04 20:20:20 GMT 2021 - 10.7K bytes - Viewed (0) -
cmd/peer-rest-client.go
conn := client.gridConn() if conn == nil { return nil } _, err := reloadPoolMetaRPC.Call(ctx, conn, grid.NewMSSWith(map[string]string{})) return err } func (client *peerRESTClient) StopRebalance(ctx context.Context) error { conn := client.gridConn() if conn == nil { return nil } _, err := stopRebalanceRPC.Call(ctx, conn, grid.NewMSSWith(map[string]string{}))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/event/target/amqp.go
// close when we know this is a network error. target.conn.Close() } conn, err = amqp091.Dial(target.args.URL.String()) if err != nil { if xnet.IsConnRefusedErr(err) { return nil, nil, store.ErrNotConnected } return nil, nil, err } ch, err = conn.Channel() if err != nil { return nil, nil, err } target.conn = conn if target.args.PublisherConfirms {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
prepare_stmt.go
// Reason why cannot lock conn.PrepareContext // suppose the maxopen is 1, g1 is creating record and g2 is querying record. // 1. g1 begin tx, g1 is requeue because of waiting for the system call, now `db.ConnPool` db.numOpen == 1. // 2. g2 select lock `conn.PrepareContext(ctx, query)`, now db.numOpen == db.maxOpen , wait for release. // 3. g1 tx exec insert, wait for unlock `conn.PrepareContext(ctx, query)` to finish tx and release.
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 28 08:47:39 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/http/dial_dnscache.go
baseDialCtx = (&net.Dialer{ Timeout: 30 * time.Second, KeepAlive: 30 * time.Second, }).DialContext } return func(ctx context.Context, network, addr string) (conn net.Conn, err error) { host, port, err := net.SplitHostPort(addr) if err != nil { return nil, err } if net.ParseIP(host) != nil { // For IP only setups there is no need for DNS lookups.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 03 19:30:51 GMT 2023 - 2.6K bytes - Viewed (0) -
internal/grid/README.md
} err := manager.RegisterSingleHandler(grid.HandlerDiskInfo, handler) ``` Sample call: ```go // Get a connection to the remote host conn := manager.Connection(host) payload := []byte("request") response, err := conn.SingleRequest(ctx, grid.HandlerDiskInfo, payload) ``` If the error type is `*RemoteErr`, then the error was returned by the remote server. Otherwise it is a local error.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
tests/test_http_connection_injection.py
from fastapi.testclient import TestClient from starlette.websockets import WebSocket app = FastAPI() app.state.value = 42 async def extract_value_from_http_connection(conn: HTTPConnection): return conn.app.state.value @app.get("/http") async def get_value_by_http(value: int = Depends(extract_value_from_http_connection)): return value @app.websocket("/ws") async def get_value_by_ws(
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sun Aug 09 13:56:41 GMT 2020 - 972 bytes - Viewed (0) -
cmd/peer-s3-client.go
conn := client.gridConn() if conn == nil { return madmin.HealResultItem{}, nil } mss := grid.NewMSSWith(map[string]string{ peerS3Bucket: bucket, peerS3BucketDeleted: strconv.FormatBool(opts.Remove), }) _, err := healBucketRPC.Call(ctx, conn, mss) // Initialize heal result info return madmin.HealResultItem{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
internal/grid/benchmark_test.go
if src == dst { dst = (dst + 1) % len(managers) } local := managers[src] conn := local.Connection(hosts[dst]) if conn == nil { b.Fatal("No connection") } // Send the payload. t := time.Now() resp, err := conn.Request(ctx, handlerTest, payload) latency += time.Since(t).Nanoseconds() if err != nil { if debugReqs {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0)