- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 322 for conj (0.18 sec)
-
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
for ( 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;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Dec 20 14:09:34 GMT 2020 - 12.5K bytes - Viewed (0) -
internal/http/listener.go
} // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same. func (listener *httpListener) Accept() (conn net.Conn, err error) { select { case result, ok := <-listener.acceptCh: if ok { return deadlineconn.New(result.conn). WithReadDeadline(listener.opts.ClientReadTimeout). WithWriteDeadline(listener.opts.ClientWriteTimeout), result.err } case <-listener.ctx.Done(): }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/net/JarURLConnectionUtil.java
* {@link JarURLConnection#getJarFile()}の例外処理をラップするメソッドです。 * * @param conn * {@link JarURLConnection}。{@literal null}であってはいけません * @return {@link JarFile} */ public static JarFile getJarFile(final JarURLConnection conn) { assertArgumentNotNull("conn", conn); try { return conn.getJarFile(); } catch (final IOException e) {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 1.5K 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})) if err != nil { t.Fatalf("Should open db success, but got %v", err) } tx := db.Begin()
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Feb 06 02:54:40 GMT 2024 - 5.5K 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) -
cni/pkg/plugin/plugin.go
} return pluginResponse(conf) } func doAddRun(args *skel.CmdArgs, conf *Config, kClient kubernetes.Interface, rulesMgr InterceptRuleMgr) error { setupLogging(conf) var loggedPrevResult any if conf.PrevResult == nil { loggedPrevResult = "none" } else { loggedPrevResult = conf.PrevResult } log.WithLabels("if", args.IfName).Debugf("istio-cni CmdAdd config: %+v", conf)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/warm-backend-s3.go
case conf.AccessKey == "" && conf.SecretKey != "" || conf.AccessKey != "" && conf.SecretKey == "": return nil, errors.New("both the access and secret keys are required") case conf.AWSRole && (conf.AWSRoleWebIdentityTokenFile != "" || conf.AWSRoleARN != "" || conf.AccessKey != "" || conf.SecretKey != ""): return nil, errors.New("AWS Role cannot be activated with static credentials or the web identity token file") case conf.Bucket == "":
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.5K bytes - Viewed (0) -
cni/test/install_k8s_test.go
resultFileName: "YYY-istio-cni.conf", expectedOutputFile: testDataDir + "/expected/YYY-istio-cni.conf", }, { name: "standalone plugin user defined name", preConfFile: "user-defined.conf", resultFileName: "user-defined.conf", expectedOutputFile: testDataDir + "/expected/YYY-istio-cni.conf", }, } for _, tc := range cases {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Jul 27 18:01:48 GMT 2022 - 8K bytes - Viewed (0)