Home
last modified time | relevance | path

Searched refs:ErasureShareSize (Results 1 – 23 of 23) sorted by relevance

/dports/net/rclone/rclone-1.57.0/vendor/storj.io/uplink/private/eestream/
H A Dstripe.go52 bufSize -= bufSize % es.ErasureShareSize()
53 if bufSize < es.ErasureShareSize() {
54 bufSize = es.ErasureShareSize()
58 r.inbufs[i] = make([]byte, es.ErasureShareSize())
59 r.bufs[i] = NewPieceBuffer(make([]byte, bufSize), es.ErasureShareSize(), r.cond)
H A Dunsafe_rs.go37 stripe := make([]byte, s.RequiredCount()*s.ErasureShareSize())
39 copy(stripe[share.Number*s.ErasureShareSize():], share.Data)
48 func (s *unsafeRSScheme) ErasureShareSize() int { func
H A Dencode.go41 ErasureShareSize() int methodSpec
174 shareBuf: make([]byte, rs.ErasureShareSize()),
225 ep.available = ep.er.rs.ErasureShareSize()
268 return blocks * int64(er.rs.ErasureShareSize())
277 offset, length, er.rs.ErasureShareSize())
293 offset-firstBlock*int64(er.rs.ErasureShareSize()))
H A Ddecode.go175 if size%int64(es.ErasureShareSize()) != 0 {
178 size, es.ErasureShareSize())
191 blocks := dr.inSize / int64(dr.es.ErasureShareSize())
206 …, err := rr.Range(ctx, firstBlock*int64(dr.es.ErasureShareSize()), blockCount*int64(dr.es.ErasureS…
H A Drs.go39 func (s *rsScheme) ErasureShareSize() int { func
/dports/net/storj/storj-1.45.3/vendor/storj.io/uplink/private/eestream/
H A Dstripe.go52 bufSize -= bufSize % es.ErasureShareSize()
53 if bufSize < es.ErasureShareSize() {
54 bufSize = es.ErasureShareSize()
58 r.inbufs[i] = make([]byte, es.ErasureShareSize())
59 r.bufs[i] = NewPieceBuffer(make([]byte, bufSize), es.ErasureShareSize(), r.cond)
H A Dunsafe_rs.go37 stripe := make([]byte, s.RequiredCount()*s.ErasureShareSize())
39 copy(stripe[share.Number*s.ErasureShareSize():], share.Data)
48 func (s *unsafeRSScheme) ErasureShareSize() int { func
H A Dencode.go40 ErasureShareSize() int methodSpec
173 shareBuf: make([]byte, rs.ErasureShareSize()),
224 ep.available = ep.er.rs.ErasureShareSize()
265 return blocks * int64(er.rs.ErasureShareSize())
274 offset, length, er.rs.ErasureShareSize())
290 offset-firstBlock*int64(er.rs.ErasureShareSize()))
H A Ddecode.go170 if size%int64(es.ErasureShareSize()) != 0 {
173 size, es.ErasureShareSize())
185 blocks := dr.inSize / int64(dr.es.ErasureShareSize())
200 …, err := rr.Range(ctx, firstBlock*int64(dr.es.ErasureShareSize()), blockCount*int64(dr.es.ErasureS…
H A Drs.go39 func (s *rsScheme) ErasureShareSize() int { func
/dports/net/storj/storj-1.45.3/satellite/metainfo/
H A Dconfig_test.go26 ErasureShareSize: 256 * memory.B, Min: 4, Repair: 8, Success: 10, Total: 20,
91 require.EqualValues(t, tt.expectedConfig.ErasureShareSize, rsConfig.ErasureShareSize)
H A Dconfig.go27 ErasureShareSize memory.Size member
44 rs.ErasureShareSize.String())
84 rs.ErasureShareSize = shareSize
H A Dmetainfo.go115 ErasureShareSize: config.RS.ErasureShareSize.Int32(),
570 BlockSize: int64(rs.ErasureShareSize * rs.MinReq),
855 ErasureShareSize: segment.Redundancy.ShareSize,
1049 ErasureShareSize: segment.Redundancy.ShareSize,
1806 ShareSize: endpoint.defaultRS.ErasureShareSize,
2274 ErasureShareSize: segment.Redundancy.ShareSize,
/dports/net/storj/storj-1.45.3/satellite/accounting/nodetally/
H A Dnode_tally_test.go78 ShareSize: rs.ErasureShareSize.Int32(),
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/common/pb/
H A Dpointerdb.pb.go83 …ErasureShareSize int32 `protobuf:"varint,6,opt,name=erasure_share_size,json=erasureShareSiz… member
150 return m.ErasureShareSize
/dports/net/storj/storj-1.45.3/vendor/storj.io/common/pb/
H A Dpointerdb.pb.go83 …ErasureShareSize int32 `protobuf:"varint,6,opt,name=erasure_share_size,json=erasureShareSiz… member
150 return m.ErasureShareSize
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/uplink/private/metainfo/
H A Dclient.go140 ErasureShareSize: defaultRS.ShareSize,
380 ErasureShareSize: params.Redundancy.ShareSize,
548 ShareSize: pbRS.ErasureShareSize,
1340 ShareSize: response.RedundancyScheme.ErasureShareSize,
/dports/net/storj/storj-1.45.3/vendor/storj.io/uplink/private/metaclient/
H A Dclient.go144 ErasureShareSize: defaultRS.ShareSize,
404 ErasureShareSize: params.Redundancy.ShareSize,
581 ShareSize: pbRS.ErasureShareSize,
1460 ShareSize: response.RedundancyScheme.ErasureShareSize,
/dports/net/storj/storj-1.45.3/vendor/storj.io/uplink/private/ecclient/
H A Dclient.go94 "erasure:"+strconv.Itoa(rs.ErasureShareSize()),
/dports/net/rclone/rclone-1.57.0/vendor/storj.io/uplink/private/ecclient/
H A Dclient.go112 zap.Int("Erasure Share Size", rs.ErasureShareSize()),
/dports/net/storj/storj-1.45.3/satellite/repair/repairer/
H A Dsegments.go153 ErasureShareSize: segment.Redundancy.ShareSize,
H A Dec.go213 esScheme := eestream.NewUnsafeRSScheme(fec, es.ErasureShareSize())
/dports/net/storj/storj-1.45.3/satellite/accounting/
H A Dprojectusage_test.go863 ShareSize: sat.Config.Metainfo.RS.ErasureShareSize.Int32(),