| /dports/net/rclone/rclone-1.57.0/vendor/storj.io/common/signing/ |
| H A D | encode.go | 30 signing.PieceId = limit.PieceId
77 signing.PieceId = hash.PieceId
|
| /dports/net/storj/storj-1.45.3/vendor/storj.io/common/signing/ |
| H A D | encode.go | 30 signing.PieceId = limit.PieceId
77 signing.PieceId = hash.PieceId
|
| /dports/net/storj/storj-1.45.3/storagenode/piecestore/ |
| H A D | endpoint.go | 150 if err := endpoint.store.Delete(ctx, delete.Limit.SatelliteId, delete.Limit.PieceId); err != nil {
157 …ite ID", delete.Limit.SatelliteId), zap.Stringer("Piece ID", delete.Limit.PieceId), zap.Error(err))
159 …Stringer("Satellite ID", delete.Limit.SatelliteId), zap.Stringer("Piece ID", delete.Limit.PieceId))
295 zap.Stringer("Piece ID", limit.PieceId),
301 pieceWriter, err = endpoint.store.Writer(ctx, limit.SatelliteId, limit.PieceId)
410 … err := endpoint.store.SetExpiration(ctx, limit.SatelliteId, limit.PieceId, limit.PieceExpiration)
418 PieceId: limit.PieceId,
494 …endpoint.log.Info("download started", zap.Stringer("Piece ID", limit.PieceId), zap.Stringer("Satel…
537 …endpoint.log.Info("downloaded", zap.Stringer("Piece ID", limit.PieceId), zap.Stringer("Satellite I…
541 pieceReader, err = endpoint.store.Reader(ctx, limit.SatelliteId, limit.PieceId)
[all …]
|
| H A D | verification.go | 54 case limit.PieceId.IsZero():
116 if limit.PieceId != hash.PieceId {
|
| H A D | endpoint_test.go | 433 require.Equal(t, originHash.PieceId, hash.PieceId)
438 require.Equal(t, originLimit.PieceId, ulOrderLimit.PieceId)
699 PieceId: pieceID,
|
| /dports/net/storj/storj-1.45.3/satellite/metainfo/pointerverification/ |
| H A D | service.go | 177 if limit.PieceId != piece.Hash.PieceId {
179 piece.Hash.PieceId, limit.PieceId, piece.NodeId, piece.PieceNum,
|
| /dports/net/storj/storj-1.45.3/satellite/gracefulexit/ |
| H A D | validation.go | 69 if originalOrderLimit.PieceId != message.Succeeded.OriginalPieceId {
75 if calculatedNewPieceID != replacementPieceHash.PieceId {
76 ….String(), transfer.PieceNum, calculatedNewPieceID.String(), replacementPieceHash.PieceId.String())
|
| H A D | endpoint_test.go | 80 PieceId: orderLimit.PieceId,
88 PieceId: m.TransferPiece.AddressedOrderLimit.Limit.PieceId,
343 PieceId: orderLimit.PieceId,
351 PieceId: m.TransferPiece.AddressedOrderLimit.Limit.PieceId,
471 PieceId: orderLimit.PieceId,
550 PieceId: orderLimit.PieceId,
558 PieceId: m.TransferPiece.AddressedOrderLimit.Limit.PieceId,
670 PieceId: orderLimit.PieceId,
758 PieceId: orderLimit.PieceId,
766 PieceId: m.TransferPiece.AddressedOrderLimit.Limit.PieceId,
[all …]
|
| /dports/net/rclone/rclone-1.57.0/vendor/storj.io/uplink/private/piecestore/ |
| H A D | verification.go | 37 if limit.PieceId != hash.PieceId {
|
| H A D | upload.go | 182 PieceId: client.limit.PieceId,
|
| /dports/net/storj/storj-1.45.3/vendor/storj.io/uplink/private/piecestore/ |
| H A D | verification.go | 37 if limit.PieceId != hash.PieceId {
|
| H A D | upload.go | 182 PieceId: client.limit.PieceId,
|
| /dports/net/storj/storj-1.45.3/private/testuplink/ |
| H A D | client_planet_test.go | 88 assert.Equal(t, limits[i].GetLimit().PieceId, results[i].Hash.PieceId)
109 …eAction_GET, planet.Satellites[0], piecePublicKey, planet.StorageNodes[i], results[i].Hash.PieceId)
147 PieceId: pieceID,
|
| /dports/net/storj/storj-1.45.3/storagenode/pieces/ |
| H A D | db_test.go | 44 PieceId: pieceid0,
64 PieceId: pieceid0,
84 PieceId: pieceid0,
|
| H A D | store_test.go | 352 PieceId: piece.pieceID,
482 PieceId: pieceID,
542 PieceId: pieceID,
577 PieceId: pieceID,
615 PieceId: v1Header.OrderLimit.PieceId,
|
| /dports/net/storj/storj-1.45.3/storagenode/piecetransfer/ |
| H A D | service.go | 161 if pieceHash.PieceId != addrLimit.Limit.PieceId {
|
| /dports/net/storj/storj-1.45.3/satellite/metainfo/ |
| H A D | endpoint_test.go | 513 PieceId: response.Limits[0].Limit.PieceId,
532 PieceId: response.Limits[0].Limit.PieceId,
544 PieceId: response.Limits[0].Limit.PieceId,
|
| H A D | validation.go | 309 if limit.PieceId.IsZero() || limit.PieceId != derivedPieceID {
|
| /dports/net/rclone/rclone-1.57.0/vendor/storj.io/common/pb/ |
| H A D | orders.pb.go | 108 …PieceId PieceID `protobuf:"bytes,5,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:… member
230 …PieceId PieceID `protobuf:"bytes,5,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:… member
443 …PieceId PieceID `protobuf:"bytes,1,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:… member
517 …PieceId PieceID `protobuf:"bytes,1,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:… member
|
| /dports/net/storj/storj-1.45.3/satellite/orders/ |
| H A D | endpoint_test.go | 90 PieceId: storj.NewPieceID(),
113 PieceId: storj.NewPieceID(),
236 PieceId: storj.NewPieceID(),
348 PieceId: storj.NewPieceID(),
|
| /dports/net/storj/storj-1.45.3/vendor/storj.io/common/pb/ |
| H A D | orders.pb.go | 108 …PieceId PieceID `protobuf:"bytes,5,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:… member
230 …PieceId PieceID `protobuf:"bytes,5,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:… member
443 …PieceId PieceID `protobuf:"bytes,1,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:… member
517 …PieceId PieceID `protobuf:"bytes,1,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:… member
|
| /dports/net/storj/storj-1.45.3/satellite/repair/repairer/ |
| H A D | ec.go | 319 if limit.PieceId != hash.PieceId {
480 pieceID := limit.GetLimit().PieceId
|
| /dports/net/storj/storj-1.45.3/satellite/satellitedb/ |
| H A D | containment.go | 115 pieceID, err := storj.PieceIDFromBytes(info.PieceId)
|
| /dports/net/storj/storj-1.45.3/storagenode/storagenodedb/storagenodedbtest/ |
| H A D | run_test.go | 167 PieceId: piece,
|
| /dports/net/storj/storj-1.45.3/storagenode/retain/ |
| H A D | retain_test.go | 87 PieceId: id,
|