- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for conns (0.02 sec)
-
docs/bigdata/README.md
fs.s3a.endpoint=http://minio:9000 fs.s3a.impl=org.apache.hadoop.fs.s3a.S3AFileSystem fs.s3a.committer.threads=2048 # Number of threads writing to MinIO fs.s3a.connection.maximum=8192 # Maximum number of concurrent conns fs.s3a.fast.upload.active.blocks=2048 # Number of parallel uploads fs.s3a.fast.upload.buffer=disk # Use disk as the buffer for uploads fs.s3a.fast.upload=true # Turn on fast upload mode
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 14.7K bytes - Viewed (0) -
cmd/server-main.go
Value: func() time.Duration { if orchestrated { return 30 * time.Second } return 10 * time.Minute }(), EnvVar: "MINIO_DNS_CACHE_TTL", }, cli.IntFlag{ Name: "max-idle-conns-per-host", Usage: "set a custom max idle connections per host value", Hidden: true, Value: 2048, EnvVar: "MINIO_MAX_IDLE_CONNS_PER_HOST", }, cli.StringSliceFlag{ Name: "ftp",
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4) -
finisher_api.go
// First finds the first record ordered by primary key, matching given conditions conds func (db *DB) First(dest interface{}, conds ...interface{}) (tx *DB) { tx = db.Limit(1).Order(clause.OrderByColumn{ Column: clause.Column{Table: clause.CurrentTable, Name: clause.PrimaryKey}, }) if len(conds) > 0 { if exprs := tx.Statement.BuildCondition(conds[0], conds[1:]...); len(exprs) > 0 { tx.Statement.AddClause(clause.Where{Exprs: exprs})
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Tue Aug 26 06:24:29 UTC 2025 - 22.9K bytes - Viewed (0) -
tests/connpool_test.go
}, } defer func() { if !reflect.DeepEqual(conn.got, conn.expect) { t.Errorf("expect %#v but got %#v", conn.expect, conn.got) } }() db, err := gorm.Open(mysql.New(mysql.Config{Conn: conn, DisableWithReturning: true})) db.Logger = DB.Logger if err != nil { t.Fatalf("Should open db success, but got %v", err) }
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Sun May 25 07:40:40 UTC 2025 - 5.5K bytes - Viewed (0) -
chainable_api.go
// // [docs]: https://gorm.io/docs/query.html#Conditions func (db *DB) Where(query interface{}, args ...interface{}) (tx *DB) { tx = db.getInstance() if conds := tx.Statement.BuildCondition(query, args...); len(conds) > 0 { tx.Statement.AddClause(clause.Where{Exprs: conds}) } return } // Not add NOT conditions // // Not works similarly to where, and has the same syntax. //
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Sun May 25 07:40:40 UTC 2025 - 14.8K bytes - Viewed (0) -
statement.go
where.Exprs[0] = clause.AndConditions(orConds) } } } conds = append(conds, clause.And(where.Exprs...)) } else if cs.Expression != nil { conds = append(conds, cs.Expression) } } case map[interface{}]interface{}: for i, j := range v { conds = append(conds, clause.Eq{Column: i, Value: j}) } case map[string]string: keys := make([]string, 0, len(v))
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Thu Sep 04 13:13:16 UTC 2025 - 20.8K bytes - Viewed (0) -
cmd/peer-s3-client.go
defer cancel() resp, err := healBucketRPC.Call(ctx, conn, mss) return resp.ValueOrZero(), toStorageErr(err) } // GetBucketInfo returns bucket stat info from a peer func (client *remotePeerS3Client) GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error) { conn := client.gridConn() if conn == nil { return BucketInfo{}, nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
for (final SmbTransportImpl conn : this.connections) { if (conn.matches(address, port, localAddr, localPort, hostName) && (tc.getConfig().getSessionLimit() == 0 || conn.getNumSessions() < tc.getConfig().getSessionLimit())) { try { if (conn.isFailed() || connectedOnly && conn.isDisconnected()) { continue;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
path: String, responseCode: AtomicInteger, ): Thread = 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) { } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 3.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/net/JarURLConnectionUtil.java
* * @param conn * {@link JarURLConnection}. Must not be {@literal null}. * @return {@link JarFile} */ public static JarFile getJarFile(final JarURLConnection conn) { assertArgumentNotNull("conn", conn); try { return conn.getJarFile(); } catch (final IOException e) {
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 1.6K bytes - Viewed (0)