Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 96 for Msgsize (0.18 sec)

  1. cmd/erasure-server-pool-decom.go

    		}
    		return true, nil
    	}
    	return false, nil
    }
    
    func (p poolMeta) save(ctx context.Context, pools []*erasureSets) error {
    	if p.dontSave {
    		return nil
    	}
    	data := make([]byte, 4, p.Msgsize()+4)
    
    	// Initialize the header.
    	binary.LittleEndian.PutUint16(data[0:2], poolMetaFormat)
    	binary.LittleEndian.PutUint16(data[2:4], poolMetaVersion)
    
    	buf, err := p.MarshalMsg(data)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    	return brs, nil
    }
    
    // save resync status to resync.bin
    func saveResyncStatus(ctx context.Context, bucket string, brs BucketReplicationResyncStatus, objectAPI ObjectLayer) error {
    	data := make([]byte, 4, brs.Msgsize()+4)
    
    	// Initialize the resync meta header.
    	binary.LittleEndian.PutUint16(data[0:2], resyncMetaFormat)
    	binary.LittleEndian.PutUint16(data[2:4], resyncMetaVersion)
    
    	buf, err := brs.MarshalMsg(data)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    func saveSiteResyncMetadata(ctx context.Context, ss SiteResyncStatus, objectAPI ObjectLayer) error {
    	if objectAPI == nil {
    		return errSRObjectLayerNotReady
    	}
    	data := make([]byte, 4, ss.Msgsize()+4)
    
    	// Initialize the resync meta header.
    	binary.LittleEndian.PutUint16(data[0:2], siteResyncMetaFormat)
    	binary.LittleEndian.PutUint16(data[2:4], siteResyncMetaVersion)
    
    	buf, err := ss.MarshalMsg(data)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/asm/asm.go

    		p.errorf("TEXT %q: ABIInternal requires NOSPLIT", name)
    	}
    
    	// Next operand is the frame and arg size.
    	// Bizarre syntax: $frameSize-argSize is two words, not subtraction.
    	// Both frameSize and argSize must be simple integers; only frameSize
    	// can be negative.
    	// The "-argSize" may be missing; if so, set it to objabi.ArgsSizeUnknown.
    	// Parse left to right.
    	op := operands[next]
    	if len(op) < 2 || op[0].ScanToken != '$' {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 21 14:11:44 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  5. tensorflow/c/eager/c_api.cc

        case tensorflow::AttrValue::kList: {
          // String
          if (const int s_size = default_value.list().s_size()) {
            absl::InlinedVector<const void*, 4> values_vector;
            values_vector.reserve(s_size);
            absl::InlinedVector<size_t, 4> lengths_vector;
            lengths_vector.reserve(s_size);
            for (int i = 0; i < s_size; ++i) {
              const string& v = default_value.list().s(i);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 43.9K bytes
    - Viewed (0)
  6. cmd/server-main.go

    	lgDir := ctx.String("log-dir")
    	if lgDir == "" {
    		return os.Stderr, nil
    	}
    	lgDirAbs, err := filepath.Abs(lgDir)
    	if err != nil {
    		return nil, err
    	}
    	lgSize := ctx.Int("log-size")
    
    	var fileNameFunc func() string
    	if ctx.IsSet("log-prefix") {
    		fileNameFunc = func() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  7. tensorflow/c/c_api.cc

        break;                                            \
      }
    
          LIST_CASE(
              s, TF_ATTR_STRING, metadata.total_size = 0;
              for (int i = 0; i < attr->list().s_size();
                   ++i) { metadata.total_size += attr->list().s(i).size(); });
          LIST_CASE(i, TF_ATTR_INT);
          LIST_CASE(f, TF_ATTR_FLOAT);
          LIST_CASE(b, TF_ATTR_BOOL);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

          return null;
        }
        return entry.getValue();
      }
    
      @SuppressWarnings("unchecked")
      final Segment<K, V, E, S>[] newSegmentArray(int ssize) {
        return (Segment<K, V, E, S>[]) new Segment<?, ?, ?, ?>[ssize];
      }
    
      // Inner Classes
    
      /**
       * Segments are specialized versions of hash tables. This subclass inherits from ReentrantLock
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/MapMakerInternalMap.java

          return null;
        }
        return entry.getValue();
      }
    
      @SuppressWarnings("unchecked")
      final Segment<K, V, E, S>[] newSegmentArray(int ssize) {
        return (Segment<K, V, E, S>[]) new Segment<?, ?, ?, ?>[ssize];
      }
    
      // Inner Classes
    
      /**
       * Segments are specialized versions of hash tables. This subclass inherits from ReentrantLock
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/cache/LocalCache.java

            logger.log(Level.WARNING, "Exception thrown by removal listener", e);
          }
        }
      }
    
      @SuppressWarnings("unchecked")
      final Segment<K, V>[] newSegmentArray(int ssize) {
        return (Segment<K, V>[]) new Segment<?, ?>[ssize];
      }
    
      // Inner Classes
    
      /**
       * Segments are specialized versions of hash tables. This subclass inherits from ReentrantLock
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
Back to top