- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for unixpacket (0.18 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
if err != nil { panic(err) } go ztun.Run(ctx) // now as a client connect confirm we and get snapshot resolvedAddr, err := net.ResolveUnixAddr("unixpacket", addr) if err != nil { panic(err) } ztunClient, err := net.DialUnix("unixpacket", nil, resolvedAddr) if err != nil { panic(err) } // send hello sendHello(ztunClient) return struct { ztunClient *net.UnixConn
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
func newZtunnelServer(addr string, pods PodNetnsCache) (*ztunnelServer, error) { if addr == "" { return nil, fmt.Errorf("addr cannot be empty") } resolvedAddr, err := net.ResolveUnixAddr("unixpacket", addr) if err != nil { return nil, fmt.Errorf("failed to resolve unix addr: %w", err) } // remove potentially existing address // Remove unix socket before use, if one is leftover from previous CNI restart
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java
import java.net.SocketAddress; import jnr.unixsocket.UnixSocket; import jnr.unixsocket.UnixSocketAddress; import jnr.unixsocket.UnixSocketChannel; /** * Subtype UNIX socket for a higher-fidelity impersonation of TCP sockets. This is named "tunneling" * because it assumes the ultimate destination has a hostname and port. */ final class TunnelingUnixSocket extends UnixSocket { private final File path;
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Feb 12 16:33:52 GMT 2019 - 1.9K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
import java.net.SocketAddress; import java.net.SocketException; import java.nio.channels.ClosedChannelException; import javax.net.ServerSocketFactory; import jnr.unixsocket.UnixServerSocketChannel; import jnr.unixsocket.UnixSocketAddress; import jnr.unixsocket.UnixSocketChannel; /** Impersonate TCP-style ServerSocketFactory over UNIX domain sockets. */ public final class UnixDomainServerSocketFactory extends ServerSocketFactory {
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Feb 12 16:33:52 GMT 2019 - 3.1K bytes - Viewed (0) -
samples/unixdomainsockets/build.gradle.kts
plugins { kotlin("jvm") } dependencies { implementation(projects.okhttp) implementation(projects.mockwebserver) implementation(libs.jnr.unixsocket)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Feb 15 23:38:32 GMT 2022 - 159 bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java
package okhttp3.unixdomainsockets; import java.io.File; import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.Socket; import javax.net.SocketFactory; import jnr.unixsocket.UnixSocketChannel; /** Impersonate TCP-style SocketFactory over UNIX domain sockets. */ public final class UnixDomainSocketFactory extends SocketFactory { private final File path;
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Dec 03 21:33:52 GMT 2023 - 2.1K bytes - Viewed (0) -
gradle/libs.versions.toml
hamcrestLibrary = "org.hamcrest:hamcrest-library:2.2" httpClient5 = "org.apache.httpcomponents.client5:httpclient5:5.3" jettyClient = "org.eclipse.jetty:jetty-client:9.4.54.v20240208" jnr-unixsocket = "com.github.jnr:jnr-unixsocket:0.38.22" jsoup = "org.jsoup:jsoup:1.17.2" junit = "junit:junit:4.13.2" junit-ktx = "androidx.test.ext:junit-ktx:1.1.5"
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 22 19:34:32 GMT 2024 - 7.2K bytes - Viewed (0)