Search Options

Results per page
Sort
Preferred Languages
Advance

Results 981 - 990 of 1,667 for byte1 (0.03 sec)

  1. cmd/metacache-set.go

    		// if the block is 0 bytes and its a first block skip it.
    		// skip only this for Transient caches.
    		if len(b.data) == 0 && b.n == 0 && o.Transient {
    			return nil
    		}
    		o.debugln(color.Green("saveMetaCacheStream:")+" saving block", b.n, "to", o.objectPath(b.n))
    		r, err := hash.NewReader(ctx, bytes.NewReader(b.data), int64(len(b.data)), "", "", int64(len(b.data)))
    		bugLogIf(ctx, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbFile.java

        }
    
    /**
     * Returns the length of this <tt>SmbFile</tt> in bytes. If this object
     * is a <tt>TYPE_SHARE</tt> the total capacity of the disk shared in
     * bytes is returned. If this object is a directory or a type other than
     * <tt>TYPE_SHARE</tt>, 0L is returned.
     *
     * @return The length of the file in bytes or 0 if this
     * <code>SmbFile</code> is not a file.
     * @throws SmbException
     */
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Mar 13 12:00:57 UTC 2023
    - 107.9K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SID.java

                        policyHandle.close();
                    }
                    handle.close();
                }
            }
    }
        }
        public static byte[] toByteArray(rpc.sid_t sid) {
            byte[] dst = new byte[1 + 1 + 6 + sid.sub_authority_count * 4];
            int di = 0;
            dst[di++] = sid.revision;
            dst[di++] = sid.sub_authority_count;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 26.6K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    }
    
    // getServerPoolsAvailableSpace will return the available space of each pool after storing the content.
    // If there is not enough space the pool will return 0 bytes available.
    // The size of each will be multiplied by the number of sets.
    // Negative sizes are seen as 0 bytes.
    func (z *erasureServerPools) getServerPoolsAvailableSpace(ctx context.Context, bucket, object string, size int64) serverPoolsAvailableSpace {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  5. docs/debugging/s3-check-md5/main.go

    	debug                          bool
    	versions                       bool
    	insecure                       bool
    )
    
    // getMD5Sum returns MD5 sum of given data.
    func getMD5Sum(data []byte) []byte {
    	hash := md5.New()
    	hash.Write(data)
    	return hash.Sum(nil)
    }
    
    func main() {
    	flag.StringVar(&endpoint, "endpoint", "https://play.min.io", "S3 endpoint URL")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/nego/Smb2NegotiateResponse.java

        private int dialectRevision;
        private byte[] serverGuid = new byte[16];
        private int capabilities;
        private int commonCapabilities;
        private int maxTransactSize;
        private int maxReadSize;
        private int maxWriteSize;
        private long systemTime;
        private long serverStartTime;
        private NegotiateContextResponse[] negotiateContexts;
        private byte[] securityBuffer;
        private DialectVersion selectedDialect;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Mar 22 10:09:46 UTC 2020
    - 17.6K bytes
    - Viewed (0)
  7. cmd/etcd.go

    	default:
    		return fmt.Errorf("unexpected error %w from etcd, please check your endpoints %s", err, etcdEndpoints)
    	}
    }
    
    func saveKeyEtcdWithTTL(ctx context.Context, client *etcd.Client, key string, data []byte, ttl int64) error {
    	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    	lease, err := client.Grant(timeoutCtx, ttl)
    	if err != nil {
    		return etcdErrToErr(err, client.Endpoints())
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      @Throws(IOException::class)
      override fun onReadMessage(text: String) {
        listener.onMessage(this, text)
      }
    
      @Throws(IOException::class)
      override fun onReadMessage(bytes: ByteString) {
        listener.onMessage(this, bytes)
      }
    
      @Synchronized override fun onReadPing(payload: ByteString) {
        // Don't respond to pings after we've failed or sent the close frame.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/core/io/InputStreamUtil.java

                throw new IORuntimeException(e);
            }
        }
    
        /**
         * {@link InputStream}からbyteの配列を取得します。
         * <p>
         * 入力ストリームはクローズされません。
         * </p>
         *
         * @param is
         *            入力ストリーム。{@literal null}であってはいけません
         * @return byteの配列
         */
        public static final byte[] getBytes(final InputStream is) {
            assertArgumentNotNull("is", is);
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. internal/s3select/json/preader_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package json
    
    import (
    	"bytes"
    	"io"
    	"os"
    	"path/filepath"
    	"testing"
    
    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    func TestNewPReader(t *testing.T) {
    	files, err := os.ReadDir("testdata")
    	if err != nil {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
Back to top