Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 887 for closure (0.05 sec)

  1. 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)
  2. 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)
  3. 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">&times;</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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/main/java/jcifs/smb1/netbios/SocketInputStream.java

        }
        public int available() throws IOException {
            if( bip > 0 ) {
                return bip;
            }
            return in.available();
        }
        public void close() throws IOException {
            in.close();
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 3.3K bytes
    - Viewed (0)
  10. 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)
Back to top