- Sort Score
- Result 10 results
- Languages All
Results 461 - 470 of 1,091 for closes (0.1 sec)
-
cmd/sftp-server-driver.go
} // TransferError will catch network errors during transfer. // When TransferError() is called Close() will also // be called, so we do not need to Wait() here. func (w *writerAt) TransferError(err error) { _ = w.w.CloseWithError(err) _ = w.r.CloseWithError(err) w.err = err } func (w *writerAt) Close() (err error) { switch { case len(w.buffer) > 0:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0) -
docs_src/sql_databases_peewee/sql_app/main.py
from fastapi import Depends, FastAPI, HTTPException from . import crud, database, models, schemas from .database import db_state_default database.db.connect() database.db.create_tables([models.User, models.Item]) database.db.close() app = FastAPI() sleep_time = 10 async def reset_db_state(): database.db._state._state.set(db_state_default.copy()) database.db._state.reset()
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Mar 26 19:09:53 UTC 2020 - 2.2K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java
} @Override public int available() throws IOException { return fileInputStream.available(); } @Override public void close() throws IOException { try { fileInputStream.close(); } finally { FileUtil.deleteInBackground(tempFile); } } @Override public synchronized void mark(final int readlimit) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
* {@inheritDoc} * * @see java.lang.AutoCloseable#close() */ @Override public synchronized void close () { SmbTreeHandleImpl th = this.treeHandle; if ( th != null ) { this.treeHandle = null; if ( this.transportContext.getConfig().isStrictResourceLifecycle() ) { th.close(); } } } /**
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Thu May 23 01:50:13 UTC 2024 - 82.3K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/collect/PowerSetBenchmark.java
/** * Very simple powerSet iteration benchmark. * * @author Kevin Bourrillion */ public class PowerSetBenchmark { @Param({"2", "4", "8", "16"}) int elements; Set<Set<Integer>> powerSet; @BeforeExperiment void setUp() { Set<Integer> set = ContiguousSet.create(Range.closed(1, elements), integers()); powerSet = Sets.powerSet(set); } @Benchmark int iteration(int reps) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.4K bytes - Viewed (0) -
internal/event/target/mqtt.go
_, err := target.isActive() if err != nil { return err } return target.send(eventData) } // Close - does nothing and available for interface compatibility. func (target *MQTTTarget) Close() error { if target.client != nil { target.client.Disconnect(100) } close(target.quitCh) return nil } func (target *MQTTTarget) init() error { return target.initOnce.Do(target.initMQTT) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
stream = http2Connection.newStream(requestHeaders, hasRequestBody) // We may have been asked to cancel while creating the new stream and sending the request // headers, but there was still no stream to close. if (canceled) { stream!!.closeLater(ErrorCode.CANCEL) throw IOException("Canceled") } stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* `server_max_window_bits`. This harms our ability to support these parameters: * * * If `client_max_window_bits` is less than 15, OkHttp must close the web socket with code 1010. * Otherwise it would compress values in a way that servers could not decompress. * * If `server_max_window_bits` is less than 15, OkHttp will waste memory on an oversized buffer. *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 8.1K bytes - Viewed (0) -
docs_src/dependencies/tutorial010.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Mar 26 19:09:53 UTC 2020 - 292 bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex.go
// SetBase sets the position base. SetBase(*src.PosBase) // Line reports the source line number of the token. Line() int // Col reports the source column number of the token. Col() int // Close does any teardown required. Close() } // A Token is a scan token plus its string value. // A macro is stored as a sequence of Tokens with spaces stripped. type Token struct { ScanToken text string }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Aug 29 18:31:05 UTC 2023 - 4.1K bytes - Viewed (0)