Search Options

Results per page
Sort
Preferred Languages
Advance

Results 671 - 680 of 845 for CLOSE (0.08 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

                    clientEventsList.add(parameters.first().toString())
                  }
                }
              }
            }
          }
    
          override fun flush() {
          }
    
          override fun close() {
          }
        }.apply {
          level = Level.FINEST
        }
    
      private fun applyLogger(fn: Logger.() -> Unit) {
        Logger.getLogger(OkHttpClient::class.java.`package`.name).fn()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        val candidate = connectionUser.candidateConnection() ?: return null
    
        // Make sure this connection is healthy & eligible for new exchanges. If it's no longer needed
        // then we're on the hook to close it.
        val healthy = candidate.isHealthy(connectionUser.doExtensiveHealthChecks())
        var noNewExchangesEvent = false
        val toClose: Socket? =
          candidate.withLock {
            when {
              !healthy -> {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. guava/src/com/google/common/hash/BloomFilterStrategies.java

          return (long) data.length() * Long.SIZE;
        }
    
        /**
         * Number of set bits (1s).
         *
         * <p>Note that because of concurrent set calls and uses of atomics, this bitCount is a (very)
         * close *estimate* of the actual number of bits set. It's not possible to do better than an
         * estimate without locking. Note that the number, if not exactly accurate, is *always*
         * underestimating, never overestimating.
         */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 10 19:45:10 UTC 2022
    - 10.7K bytes
    - Viewed (0)
  4. src/main/java/jcifs/dcerpc/DcerpcHandle.java

    
        protected abstract int doSendReceiveFragment ( byte[] out, int off, int length, byte[] inB ) throws IOException;
    
    
        @Override
        public void close () throws IOException {
            this.state = 0;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jun 30 10:11:57 UTC 2019
    - 12.9K bytes
    - Viewed (0)
  5. cni/pkg/install/install.go

    	watcher, err := util.CreateFileWatcher(targets...)
    	if err != nil {
    		return err
    	}
    	defer func() {
    		setNotReady(in.isReady)
    		watcher.Close()
    	}()
    
    	// Before we process whether any file events have been triggered, we must check that the file is correct
    	// at this moment, and if not, yield. This is to catch other CNIs which might have mutated the file between
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

                        throw new DictionaryException("Failed to write: " + item, e);
                    }
                }
                return null;
            }
    
            @Override
            public void close() {
                try {
                    writer.flush();
                } catch (final IOException e) {
                    // ignore
                }
                CloseableUtil.closeQuietly(writer);
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  7. callbacks/query.go

    			rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    			if err != nil {
    				db.AddError(err)
    				return
    			}
    			defer func() {
    				db.AddError(rows.Close())
    			}()
    			gorm.Scan(rows, db, 0)
    		}
    	}
    }
    
    func BuildQuerySQL(db *gorm.DB) {
    	if db.Statement.Schema != nil {
    		for _, c := range db.Statement.Schema.QueryClauses {
    			db.Statement.AddClause(c)
    		}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:03:42 UTC 2024
    - 10.1K bytes
    - Viewed (1)
  8. docs/de/docs/tutorial/request-files.md

        * Z. B. würde `await myfile.seek(0)` zum Anfang der Datei gehen.
        * Das ist besonders dann nützlich, wenn Sie `await myfile.read()` einmal ausführen und dann diese Inhalte erneut auslesen müssen.
    * `close()`: Schließt die Datei.
    
    Da alle diese Methoden `async`hron sind, müssen Sie sie `await`en („erwarten“).
    
    Zum Beispiel können Sie innerhalb einer `async` *Pfadoperation-Funktion* den Inhalt wie folgt auslesen:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  9. docs/pt/docs/tutorial/request_files.md

        * E.g., `await myfile.seek(0)` navegaria para o ínicio do arquivo.
        * Isso é especialmente útil se você executar `await myfile.read()` uma vez e depois precisar ler os conteúdos do arquivo de novo.
    * `close()`: Fecha o arquivo.
    
    Como todos esses métodos são assíncronos (`async`) você precisa esperar ("await") por eles.
    
    Por exemplo, dentro de uma *função de operação de rota* assíncrona você pode obter os conteúdos com:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  10. src/test/java/jcifs/tests/TimeoutTest.java

                          SmbTransportInternal trans = session.getTransport().unwrap(SmbTransportInternal.class) ) {
                        t = trans;
                    }
                    f.close();
    
                    Thread.sleep(2 * soTimeout);
    
                    // connection should be closed by now
                    assertTrue("Transport is still connected", t.isDisconnected());
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 12.4K bytes
    - Viewed (0)
Back to top