- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 1,693 for connections (0.06 seconds)
-
internal/event/target/mysql.go
if IsConnErr(err) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key) } // Close - closes underneath connections to MySQL database. func (target *MySQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil { // FIXME: log returned error. ignore time being. _ = target.updateStmt.Close() }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 11.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java
DISCONNECTED, /** Connection is being established */ CONNECTING, /** Connection is established but not ready for RDMA operations */ CONNECTED, /** Connection is fully established and ready for RDMA operations */ ESTABLISHED, /** Connection encountered an error */ ERROR, /** Connection is being closed */ CLOSING,Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 8.2K bytes - Click Count (0) -
internal/http/listener.go
// When the net.Conn is a remote drive this value is honored, we close the connection to remote peer proactively. DriveOPTimeout func() time.Duration SendBufSize int // SO_SNDBUF size for the socket connection, NOTE: this sets server and client connection RecvBufSize int // SO_RECVBUF size for the socket connection, NOTE: this sets server and client connection
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/srvsvc.java
/** * The share permissions. */ public int permissions; /** * The maximum number of concurrent connections. */ public int max_uses; /** * The current number of connections. */ public int current_uses; /** * The local path of the share. */ public String path;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 26.3K bytes - Click Count (0) -
docs/features/events.md
.url("https://publicobject.com/helloworld.txt") .build(); System.out.println("REQUEST 1 (new connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } System.out.println("REQUEST 2 (pooled connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 7.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
assertThat(result0).isEqualTo(plan1.connection) } taskFaker.runTasks() assertEvents( "take plan 0", "plan 0 TCP connecting...", "plan 0 TCP connected", "plan 0 TLS connecting...", "plan 0 needs follow-up", "plan 1 TCP connecting...", "plan 1 TCP connected", "plan 1 TLS connecting...", "plan 1 TLS connected", )
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 20.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt
import okhttp3.internal.canParseAsIpAddress import okhttp3.internal.immutableListOf import okhttp3.internal.toImmutableList /** * Selects routes to connect to an origin server. Each connection requires a choice of proxy server, * IP address, and TLS mode. Connections may also be recycled. */ class RouteSelector internal constructor( private val address: Address, private val routeDatabase: RouteDatabase, private val call: RealCall,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Oct 08 03:50:05 GMT 2025 - 7.3K bytes - Click Count (2) -
src/main/java/jcifs/smb/SmbTreeConnection.java
} } /** * Use a exclusive connection for this tree * * If an exclusive connection is used the caller must make sure that the tree handle is kept alive, * otherwise the connection will be disconnected once the usage drops to zero. * * @param np * whether to use an exclusive connection */ void setNonPooled(final boolean np) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 30.4K bytes - Click Count (1) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpAuthentication.java
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; /** * FtpAuthentication class holds the authentication information for FTP connections. * It includes server address, port number, username, and password. * It also provides a method to check if the authentication matches a given FTP path. *
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Jan 04 09:30:17 GMT 2026 - 4.7K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
if (newTransport == null) { throw new IOException("Failed to create new transport"); } // Reconnect channel.setState(ChannelState.CONNECTING); // Connection would be ensured through proper transport interface // Re-establish channel binding manager.performChannelBinding(channel); // Update channel with new transport
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 11.6K bytes - Click Count (0)