- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 887 for closure (0.05 sec)
-
internal/config/identity/ldap/ldap.go
// username. func (l *Config) LookupUserDN(username string) (*xldap.DNSearchResult, []string, error) { conn, err := l.LDAP.Connect() if err != nil { return nil, nil, err } defer conn.Close() // Bind to the lookup user account if err = l.LDAP.LookupBind(conn); err != nil { return nil, nil, err } // Lookup user DN lookupRes, err := l.LDAP.LookupUsername(conn, username) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 01:04:53 UTC 2024 - 12.4K bytes - Viewed (0) -
internal/ioutil/wait_pipe.go
done func() } // CloseWithError close with supplied error the writer end. func (w *PipeWriter) CloseWithError(err error) error { err = w.PipeWriter.CloseWithError(err) w.once.Do(func() { w.done() }) return err } // PipeReader is similar to io.PipeReader with wait group type PipeReader struct { *io.PipeReader wait func() } // CloseWithError close with supplied error the reader end
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 27 14:55:36 UTC 2023 - 1.7K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java
Socket result = createSocket(); try { result.connect(new InetSocketAddress(host, port)); } catch (IOException e) { result.close(); throw e; } return result; } @Override public Socket createSocket( String host, int port, InetAddress localHost, int localPort) throws IOException { return createSocket(host, port);
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Dec 03 21:33:52 UTC 2023 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Platform.kt
* should be used specifically for [java.io.Closeable] objects and in conjunction with * [logCloseableLeak]. */ open fun getStackTraceForCloseable(closer: String): Any? { return when { logger.isLoggable(Level.FINE) -> Throwable(closer) // These are expensive to allocate. else -> null } } open fun logCloseableLeak( message: String, stackTrace: Any?, ) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.8K bytes - Viewed (0) -
guava/src/com/google/common/base/FinalizableReferenceQueue.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Jul 11 20:51:36 UTC 2024 - 13.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
this.nonPooledConnections.remove(trans); } } } /** * {@inheritDoc} * * @see jcifs.SmbTransportPool#close() */ @Override public boolean close () throws CIFSException { boolean inUse = false; List<SmbTransportImpl> toClose; synchronized ( this.connections ) { cleanup();
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Dec 20 14:09:34 UTC 2020 - 12.5K bytes - Viewed (0) -
internal/event/target/webhook.go
return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key) } // Close - does nothing and available for interface compatibility. func (target *WebhookTarget) Close() error { target.cancel() return nil } func (target *WebhookTarget) init() error { return target.initOnce.Do(target.initWebhook) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java
import org.apache.maven.artifact.ArtifactScopeEnum; /** * Default conflict resolver.Implements closer newer first policy by default, but could be configured via plexus * */ @Named @Singleton @Deprecated public class DefaultGraphConflictResolver implements GraphConflictResolver { /** * artifact, closer to the entry point, is selected */ @Inject protected GraphConflictResolutionPolicy policy;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/ResultSetUtil.java
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.9K bytes - Viewed (0) -
cni/pkg/nodeagent/healthServer_test.go
installReady, watchReady := initRouter(router) assert.Equal(t, installReady.Load(), false) assert.Equal(t, watchReady.Load(), false) server := httptest.NewServer(router) defer server.Close() makeReq(t, server.URL, constants.LivenessEndpoint, http.StatusOK) makeReq(t, server.URL, constants.ReadinessEndpoint, http.StatusServiceUnavailable) installReady.Store(true) watchReady.Store(true)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 2K bytes - Viewed (0)