- Sort Score
- Result 10 results
- Languages All
Results 231 - 240 of 887 for closure (0.11 sec)
-
internal/s3select/parquet/reader.go
type Reader struct { io.Closer r *parquetgo.FileReader } // NewParquetReader creates a Reader2 from a io.ReadSeekCloser. func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) { fr, err := parquetgo.NewFileReader(rsc) if err != nil { return nil, errParquetParsingError(err) } return &Reader{Closer: rsc, r: fr}, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 4.5K bytes - Viewed (0) -
android/guava/src/com/google/common/math/ToDoubleRounder.java
X deltaToCeiling = minus(roundCeiling, x); int diff = deltaToFloor.compareTo(deltaToCeiling); if (diff < 0) { // closer to floor return roundFloorAsDouble; } else if (diff > 0) { // closer to ceiling return roundCeilingAsDouble; } // halfway between the representable values; do the half-whatever logic switch (mode) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Feb 07 17:50:39 UTC 2024 - 5.8K bytes - Viewed (0) -
src/main/webapp/js/admin/adminlte.min.js
.append(n.default("<strong />").addClass("mr-auto").html(this._config.title)),null!=this._config.subtitle&&t.append(n.default("<small />").html(this._config.subtitle)),1==this._config.close){var i=n.default('<button data-dismiss="toast" />').attr("type","button").addClass("ml-2 mb-1 close").attr("aria-label","Close").append('<span aria-hidden="true">×</span>');null==this._config.title&&i.toggleClass("ml-2 ml-auto"),t.append(i)}e.append(t),null!=this._config.body&&e.append(n.default('<div class="toast-body"...
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 26 01:49:09 UTC 2024 - 45.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileHandleImpl.java
return this.open && this.tree_num == this.tree.getTreeId() && this.tree.isConnected(); } /** * {@inheritDoc} * * @see jcifs.SmbFileHandle#close(long) */ @Override public synchronized void close ( long lastWriteTime ) throws CIFSException { closeInternal(lastWriteTime, true); } /** * @param lastWriteTime * @throws SmbException
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.6K bytes - Viewed (1) -
cni/pkg/nodeagent/pod_cache.go
func (p *podNetnsCache) UpsertPodCacheWithNetns(uid string, workload WorkloadInfo) Netns { // lock current snapshot pod map p.mu.Lock() defer p.mu.Unlock() if existing := p.currentPodCache[uid]; existing.Netns != nil { if existing.Netns.Inode() == workload.Netns.Inode() { workload.Netns.Close() // Replace the workload, but keep the old Netns
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri May 31 17:18:11 UTC 2024 - 4.3K bytes - Viewed (0) -
internal/http/check_port_others.go
l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks. return l.Close()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/MessageDeflater.kt
deflatedBytes.writeByte(0x00) } buffer.write(deflatedBytes, deflatedBytes.size) } @Throws(IOException::class) override fun close() = deflaterSink.close() private fun Buffer.endsWith(suffix: ByteString): Boolean = rangeEquals(size - suffix.size, suffix)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/secret_test.go
} defer configDumpFile.Close() configDump, err := io.ReadAll(configDumpFile) if err != nil { t.Errorf("error reading test data file: %v", err) } outFile, err := os.Open(fmt.Sprintf("testdata/secret/%s/output", tc.sds)) if err != nil { t.Errorf("error opening test data output file: %v", err) } defer outFile.Close() expectedOut, err := io.ReadAll(outFile)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Oct 28 19:52:53 UTC 2024 - 1.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/SocketInputStream.java
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 3.3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java
for (int i = 2; i <= 997; i++) { System.out.println(i); Thread.sleep(10); sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i))); } sink.close(); } catch (IOException | InterruptedException e) { e.printStackTrace(); } } private String factor(int n) { for (int i = 2; i < n; i++) { int x = n / i;
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Jul 06 03:18:15 UTC 2018 - 3.1K bytes - Viewed (0)