- Sort Score
- Result 10 results
- Languages All
Results 471 - 480 of 613 for Bucket (0.05 sec)
-
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
serverSocketChannel.configureBlocking(true); serverSocketChannel.socket().bind(address); } @Override public int getLocalPort() { return 1; // A white lie. There is no local port. } @Override public SocketAddress getLocalSocketAddress() { return endpoint; } @Override public Socket accept() throws IOException { try {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Feb 12 16:33:52 UTC 2019 - 3.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/witness/MockWitnessService.java
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.internal.witness; import java.io.IOException; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 8.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/SessionServicePacket.java
* Creates a new session service packet instance. */ public SessionServicePacket() { // Default constructor } // session service packet types static final int SESSION_MESSAGE = 0x00; static final int SESSION_REQUEST = 0x81; /** * NetBIOS positive session response packet type. */ public static final int POSITIVE_SESSION_RESPONSE = 0x82;Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 5.2K bytes - Viewed (0) -
src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java
assertThrows(IOException.class, () -> sis.read()); } @Test @DisplayName("Unknown packet type is handled by continuing to next packet") void unknownPacketTypeHandled() throws IOException { // According to the SocketInputStream implementation, unknown packet types // are handled in the switch statement's default case which continues the loop byte[] data = new byte[] { 1, 2 };
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.2K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
integrity sha512-V4GrkLy+HeF1F/en3SpUaM+7XxYXpuMUWLGde1kSSh5nQMN4hLrbPIkD+otwh6q9R6NOQBN4AMaOZ2zVjui82g== dependencies: "@socket.io/component-emitter" "~3.1.0" debug "~4.3.1" socket.io@^4.4.1: version "4.5.4" resolved "https://registry.yarnpkg.com/socket.io/-/socket.io-4.5.4.tgz#a4513f06e87451c17013b8d13fdfaf8da5a86a90"Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 87.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
): RealConnection { val result = RealConnection.newTestConnection( taskRunner = taskRunner, connectionPool = pool, route = route, socket = Socket(), idleAtNs = idleAtNanos, ) result.withLock { pool.put(result) } return result } fun newConnectionPool( taskRunner: TaskRunner = this.taskRunner,Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 7.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt
fun upgradeToSocket(): Socket { call.timeoutEarlyExit() (codec.carrier as RealConnection).useAsSocket() eventListener.requestBodyStart(call) return object : Socket { override fun cancel() { ******@****.***() } override val sink = RequestBodySink(codec.socket.sink, -1L)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaProvider.java
*/ Set<RdmaCapability> getSupportedCapabilities(); /** * Create RDMA connection to remote endpoint * * @param remote remote socket address * @param local local socket address, may be null for auto-binding * @return new RDMA connection instance * @throws IOException if connection creation fails */Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 3K bytes - Viewed (0) -
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/Android10Platform.kt
hostname: String?, protocols: List<Protocol>, ) { // No TLS extensions if the socket class is custom. socketAdapters .find { it.matchesSocket(sslSocket) } ?.configureTlsExtensions(sslSocket, hostname, protocols) } override fun getSelectedProtocol(sslSocket: SSLSocket): String? = // No TLS extensions if the socket class is custom.Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Jul 20 11:25:50 UTC 2025 - 4.5K bytes - Viewed (0) -
docs/sts/dex.md
> username: ******@****.*** > password: password and then click "Grant access" On the browser now you shall see the list of buckets output, along with your temporary credentials obtained from MinIO. ``` { "buckets": [ "dl.minio.equipment", "dl.minio.service-fulfillment", "testbucket" ], "credentials": { "AccessKeyID": "Q31CVS1PSCJ4OTK2YVEM",
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 3.8K bytes - Viewed (0)