Search Options

Results per page
Sort
Preferred Languages
Advance

Results 461 - 470 of 887 for closure (0.1 sec)

  1. guava-testlib/src/com/google/common/testing/TestLogHandler.java

        synchronized (lock) {
          if (record != null) {
            list.add(record);
          }
        }
      }
    
      @Override
      public void flush() {}
    
      @Override
      public void close() {}
    
      public void clear() {
        synchronized (lock) {
          list.clear();
        }
      }
    
      /** Returns a snapshot of the logged records. */
      /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 21 20:53:25 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbComReadAndX.java

     */
    
    package jcifs.smb1.smb1;
    
    import jcifs.smb1.Config;
    
    class SmbComReadAndX extends AndXServerMessageBlock {
    
        private static final int BATCH_LIMIT = Config.getInt( "jcifs.smb1.smb.client.ReadAndX.Close", 1 );
    
        private long offset;
        private int fid,
            openTimeout;
    int maxCount, minCount, remaining;
    
        SmbComReadAndX() {
            super( null );
            command = SMB_COM_READ_ANDX;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 3.1K bytes
    - Viewed (0)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/ClingSupport.java

                System.err.println(e.getMessage());
                return 1;
            } catch (InvokerException e) {
                return 1;
            } finally {
                if (classWorldManaged) {
                    classWorld.close();
                }
            }
        }
    
        protected abstract Invoker<R> createInvoker();
    
        protected abstract R parseArguments(String[] args) throws ParserException, IOException;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  4. lib/time/mkzip.go

    		if err != nil {
    			log.Fatal(err)
    		}
    		if _, err := w.Write(data); err != nil {
    			log.Fatal(err)
    		}
    		seen[name] = true
    		return nil
    	})
    	if err != nil {
    		log.Fatal(err)
    	}
    	if err := zw.Close(); err != nil {
    		log.Fatal(err)
    	}
    	if len(seen) == 0 {
    		log.Fatalf("did not find any files to add")
    	}
    	if !seen["US/Eastern"] {
    		log.Fatalf("did not find US/Eastern to add")
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 17:32:07 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. src/main/java/jcifs/dcerpc/msrpc/SamrDomainHandle.java

            handle.sendrecv(rpc);
            if ( rpc.retval != 0 ) {
                throw new SmbException(rpc.retval, false);
            }
            this.opened = true;
        }
    
    
        @Override
        public synchronized void close () throws IOException {
            if ( this.opened ) {
                this.opened = false;
                MsrpcSamrCloseHandle rpc = new MsrpcSamrCloseHandle(this);
                this.handle.sendrecv(rpc);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.9K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

        assertFailsWith<IOException> {
          while (responseBody.read(buffer) != -1) {
          }
        }.also { expected ->
          assertEquals(cancelMode == INTERRUPT, Thread.interrupted())
        }
        responseBody.close()
        assertEquals(if (connectionType == H2) 1 else 0, client.connectionPool.connectionCount())
      }
    
      @ParameterizedTest
      @ArgumentsSource(CancelModelParamProvider::class)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/ContainerCapsule.java

         * The {@link Lookup} service backed by container in this capsule.
         */
        @Nonnull
        Lookup getLookup();
    
        /**
         * Performs a clean shutdown of backing container.
         */
        @Override
        void close() throws InvokerException;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

                    props.store(Channels.newOutputStream(channel), "Last modified on: " + new Date());
    
                    lock.release();
                    lock = null;
    
                    channel.close();
                    channel = null;
                } catch (IOException e) {
                    getLogger()
                            .debug(
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/UtilTest.kt

        val socket = Socket()
        socket.connect(serverSocket.localSocketAddress)
        val socketSource = socket.source().buffer()
    
        assertThat(socket.isHealthy(socketSource)).isTrue()
    
        serverSocket.close()
        assertThat(socket.isHealthy(socketSource)).isFalse()
      }
    
      @Test
      fun testDurationTimeUnit() {
        assertThat(checkDuration("timeout", 0, TimeUnit.MILLISECONDS)).isEqualTo(0)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/authenticator/JavaNetAuthenticatorTest.kt

            dns = fakeDns
          }
    
      @BeforeEach
      fun setup() {
        Authenticator.setDefault(recordingAuthenticator)
      }
    
      @AfterEach
      fun tearDown() {
        Authenticator.setDefault(null)
        factory.close()
      }
    
      @Test
      fun testBasicAuth() {
        fakeDns["server"] = listOf(InetAddress.getLocalHost())
    
        val route = factory.newRoute()
    
        val request =
          Request.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.7K bytes
    - Viewed (0)
Back to top