- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 77 for Conn (0.14 sec)
-
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
req.start() return completableFuture } @Test fun urlConnection() { val conn = engine.openConnection(URL("https://google.com/robots.txt")) as HttpURLConnection val text = conn.inputStream.use { it.bufferedReader().readText() } assertEquals(200, conn.responseCode) assertTrue(text.contains("Disallow")) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 24 13:19:43 GMT 2024 - 6.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeConnectionTrace.java
* */ class SmbTreeConnectionTrace extends SmbTreeConnection { SmbTreeConnectionTrace ( CIFSContext ctx ) { super(ctx); } SmbTreeConnectionTrace ( SmbTreeConnection conn ) { super(conn); } @Override protected void finalize () throws Throwable { checkRelease(); }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sat Jul 20 08:41:19 GMT 2019 - 1.1K bytes - Viewed (0) -
internal/event/target/nats.go
} // NATSTarget - NATS target. type NATSTarget struct { initOnce once.Init id event.TargetID args NATSArgs natsConn *nats.Conn stanConn stan.Conn jstream nats.JetStream store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID.
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/main/java/jcifs/smb1/smb1/SmbTransport.java
return conn; } } } conn = new SmbTransport( address, port, localAddr, localPort ); CONNECTIONS.add( 0, conn ); } return conn; } class ServerData { byte flags; int flags2; int maxMpxCount; int maxBufferSize;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 31.2K bytes - Viewed (0) -
internal/grid/manager.go
Payload: b, } if b, err := msg.MarshalMsg(nil); err == nil { wsutil.WriteMessage(conn, ws.StateServerSide, ws.OpBinary, b) } } } defer conn.Close() if debugPrint { fmt.Printf("grid: Upgraded request: %v\n", req.URL) } msg, _, err := wsutil.ReadClientData(conn) if err != nil { writeErr(fmt.Errorf("reading connect: %w", err)) w.WriteHeader(http.StatusForbidden)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
tests/prepared_stmt_test.go
tx.Create(&user) var result User tx.First(&result) wg.Done() }() } wg.Wait() conn, ok := tx.ConnPool.(*gorm.PreparedStmtDB) AssertEqual(t, ok, true) AssertEqual(t, len(conn.Stmts), 2) for _, stmt := range conn.Stmts { if stmt == nil { t.Fatalf("stmt cannot bee nil") } } AssertEqual(t, sqlDB.Stats().InUse, 0) }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 21 07:55:43 GMT 2024 - 4K bytes - Viewed (0) -
internal/http/dial_others.go
type DialContext func(ctx context.Context, network, address string) (net.Conn, error) // NewInternodeDialContext configures a custom dialer for internode communications func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 1.6K bytes - Viewed (0) -
cmd/server-main.go
Usage: "custom connection READ deadline", Hidden: true, Value: 10 * time.Minute, EnvVar: "MINIO_CONN_READ_DEADLINE", }, cli.DurationFlag{ Name: "conn-write-deadline", Usage: "custom connection WRITE deadline", Hidden: true, Value: 10 * time.Minute, EnvVar: "MINIO_CONN_WRITE_DEADLINE", }, cli.DurationFlag{ Name: "conn-user-timeout",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
interfaces.go
RollbackTo(tx *DB, name string) error } // TxBeginner tx beginner type TxBeginner interface { BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) } // ConnPoolBeginner conn pool beginner type ConnPoolBeginner interface { BeginTx(ctx context.Context, opts *sql.TxOptions) (ConnPool, error) } // TxCommitter tx committer type TxCommitter interface { Commit() error Rollback() error
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Sat Aug 19 13:33:31 GMT 2023 - 2.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTree.java
import java.io.IOException; import java.net.UnknownHostException; import jcifs.smb1.Config; import jcifs.smb1.UniAddress; import jcifs.smb1.netbios.NbtAddress; class SmbTree { private static int tree_conn_counter; /* 0 - not connected * 1 - connecting * 2 - connected * 3 - disconnecting */ int connectionState; int tid; String share; String service = "?????";
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 8K bytes - Viewed (0)