- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Runnable (0.19 sec)
-
src/main/java/jcifs/smb1/util/transport/Transport.java
* disconnecting, sending, and receiving can be syncronized * properly. Apparatus is provided to send and receive requests * concurrently. */ public abstract class Transport implements Runnable { static int id = 0; static LogStream log = LogStream.getInstance(); public static int readn( InputStream in, byte[] b, int off,
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 9K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
* disconnecting, sending, and receiving can be syncronized * properly. Apparatus is provided to send and receive requests * concurrently. */ public abstract class Transport implements Runnable, AutoCloseable { private static int id = 0; private static final Logger log = LoggerFactory.getLogger(Transport.class); /** * Read bytes from the input stream into a buffer *
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Nov 01 18:12:21 GMT 2020 - 24.1K bytes - Viewed (0) -
src/test/java/jcifs/tests/ConcurrencyTest.java
List<MutiThreadTestCase> runnables = new ArrayList<>(); for ( int i = 0; i < 20; i++ ) { runnables.add(new MutiThreadTestCase()); } runMultiTestCase(runnables, 60); } private void runMultiTestCase ( List<? extends MultiTestCase> testcases, int timeoutSecs ) throws InterruptedException { for ( Runnable r : testcases ) { this.executor.submit(r);
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Nov 14 17:40:50 GMT 2021 - 17.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/http/Handler.java
if (handler != null) break; } } if (handler == null) { throw new IOException( "Unable to find default handler for protocol: " + protocol); } PROTOCOL_HANDLERS.put(protocol, handler); return handler; } }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 6.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/http/NtlmHttpURLConnection.java
reconnect(); } else { break; } } throw new IOException("Unable to negotiate NTLM authentication."); } finally { cachedOutput = null; } } private NtlmMessage attemptNegotiation(int response) throws IOException {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 20.4K bytes - Viewed (0) -
src/main/java/jcifs/http/Handler.java
} if ( handler != null ) break; } } if ( handler == null ) { throw new IOException("Unable to find default handler for protocol: " + protocol); } PROTOCOL_HANDLERS.put(protocol, handler); return handler; } }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 6.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TestLocking.java
package jcifs.smb1.smb1; import java.io.InputStream; import java.io.IOException; public class TestLocking implements Runnable { int numThreads = 1; int numIter = 1; long delay = 100; String url = null; int numComplete = 0; long ltime = 0L; public void run() { try { SmbFile f = new SmbFile(url); SmbFile d = new SmbFile(f.getParent());
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 3.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NameServiceClient.java
import java.io.IOException; import java.util.HashMap; import java.util.StringTokenizer; import jcifs.smb1.Config; import jcifs.smb1.util.Hexdump; import jcifs.smb1.util.LogStream; class NameServiceClient implements Runnable { static final int DEFAULT_SO_TIMEOUT = 5000; static final int DEFAULT_RCV_BUF_SIZE = 576; static final int DEFAULT_SND_BUF_SIZE = 576; static final int NAME_SERVICE_UDP_PORT = 137;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 17.4K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
import jcifs.ResolverType; import jcifs.RuntimeCIFSException; import jcifs.SmbConstants; import jcifs.util.Hexdump; /** * * @author mbechler * */ public class NameServiceClientImpl implements Runnable, NameServiceClient { private static final int NAME_SERVICE_UDP_PORT = 137; static final byte[] UNKNOWN_MAC_ADDRESS = new byte[] { (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Aug 14 14:26:22 GMT 2022 - 38.2K bytes - Viewed (0) -
src/main/java/jcifs/http/NtlmHttpURLConnection.java
reconnect(); } else { break; } } throw new IOException("Unable to negotiate NTLM authentication."); } finally { this.cachedOutput = null; } }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 25.5K bytes - Viewed (0)