- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 78 for Conn (0.23 sec)
-
internal/config/identity/ldap/ldap.go
func (l *Config) GetValidatedUserDN(conn *ldap.Conn, userDN string) (string, error) { return l.GetValidatedDNUnderBaseDN(conn, userDN, l.LDAP.UserDNSearchBaseDistNames) } // GetValidatedGroupDN validates the given group DN. If conn is nil, creates a // connection. func (l *Config) GetValidatedGroupDN(conn *ldap.Conn, groupDN string) (string, error) { if conn == nil { var err error
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 18 15:15:02 GMT 2024 - 9.2K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener_test.go
} defer l.Close() conn, err := connect(f) if err != nil { t.Fatalf("failed to connect %v", err) } conn.Close() } func connect(socket string) (*grpc.ClientConn, error) { var opts []grpc.DialOption opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) { var d net.Dialer
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0) -
internal/event/target/redis.go
Dial: func() (redis.Conn, error) { conn, err := redis.Dial("tcp", args.Addr.String()) if err != nil { return nil, err } if args.Password != "" { if args.User != "" { if _, err = conn.Do("AUTH", args.User, args.Password); err != nil { conn.Close() return nil, err } } else { if _, err = conn.Do("AUTH", args.Password); err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
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 Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Dec 20 14:09:34 GMT 2020 - 12.5K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
return c } // WithWriteDeadline sets a new write side net.Conn deadline. func (c *DeadlineConn) WithWriteDeadline(d time.Duration) *DeadlineConn { c.writeDeadline = d return c } // New - creates a new connection object wrapping net.Conn with deadlines. func New(c net.Conn) *DeadlineConn { return &DeadlineConn{ Conn: c, }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K bytes - Viewed (0) -
internal/grid/connection.go
} // monitorState will monitor the state of the connection and close the net.Conn if it changes. func (c *Connection) monitorState(conn net.Conn, cancel context.CancelCauseFunc) { c.connChange.L.Lock() defer c.connChange.L.Unlock() for { newState := c.State() if newState != StateConnected { conn.Close() cancel(ErrDisconnected) return } // Unlock and wait for state change.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.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 Apr 19 20:58:09 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 1.5K 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 Apr 21 09:35:09 GMT 2024 - Last Modified: Thu Mar 28 08:47:39 GMT 2024 - 6.4K 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 23 11:13:09 GMT 2024 - Last Modified: Mon Oct 04 20:20:20 GMT 2021 - 10.7K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
defer conn.Close() context.AfterFunc(ctx, func() { log.Debug("context cancelled - closing conn") conn.Close() }) // before doing anything, add the connection to the list of active connections z.conns.addConn(conn) defer z.conns.deleteConn(conn) // get hello message from ztunnel m, _, err := readProto[zdsapi.ZdsHello](conn.u, readWriteDeadline, nil) if err != nil { return err }
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0)