| /dports/net/storj/storj-1.45.3/satellite/metainfo/pointerverification/ |
| H A D | service.go | 81 PieceNum int32 member
103 if int(piece.PieceNum) >= len(originalLimits) {
107 limit := originalLimits[piece.PieceNum]
116 PieceNum: piece.PieceNum,
146 PieceNum: piece.PieceNum,
165 return Error.New("no piece hash. NodeID: %v, PieceNum: %d", piece.NodeId, piece.PieceNum)
172 timestamp, piece.NodeId, piece.PieceNum,
179 piece.Hash.PieceId, limit.PieceId, piece.NodeId, piece.PieceNum,
186 piece.Hash.PieceSize, limit.Limit, piece.NodeId, piece.PieceNum,
|
| /dports/net/storj/storj-1.45.3/satellite/gracefulexit/ |
| H A D | endpoint.go | 331 …DeleteTransferQueueItem(ctx, nodeID, incomplete.StreamID, incomplete.Position, incomplete.PieceNum)
342 …DeleteTransferQueueItem(ctx, nodeID, incomplete.StreamID, incomplete.Position, incomplete.PieceNum)
366 …DeleteTransferQueueItem(ctx, nodeID, incomplete.StreamID, incomplete.Position, incomplete.PieceNum)
401 zap.Int32("piece num", incomplete.PieceNum))
403 pieceID := segment.RootPieceID.Derive(nodeID, incomplete.PieceNum)
436 PieceNum: uint16(incomplete.PieceNum), // TODO
556 zap.Uint16("piece num", transfer.PieceNum))
566 if piece.StorageNode == nodeID && piece.Number == transfer.PieceNum {
571 …eleteTransferQueueItem(ctx, nodeID, transfer.StreamID, transfer.Position, int32(transfer.PieceNum))
588 …eleteTransferQueueItem(ctx, nodeID, transfer.StreamID, transfer.Position, int32(transfer.PieceNum))
[all …]
|
| H A D | db_test.go | 77 PieceNum: 1,
85 PieceNum: 2,
93 PieceNum: 2,
101 PieceNum: 1,
114 … item, err := geDB.GetTransferQueueItem(ctx, tqi.NodeID, tqi.StreamID, tqi.Position, tqi.PieceNum)
126 …stItem, err := geDB.GetTransferQueueItem(ctx, tqi.NodeID, tqi.StreamID, tqi.Position, tqi.PieceNum)
|
| H A D | validation.go | 74 …culatedNewPieceID := transfer.OriginalRootPieceID.Derive(receivingNodeID, int32(transfer.PieceNum))
76 …ngNodeID %s, PieceNum %d: %q != %q", receivingNodeID.String(), transfer.PieceNum, calculatedNewPie…
|
| H A D | pending_test.go | 35 PieceNum: 1,
113 PieceNum: 1,
|
| H A D | db.go | 29 PieceNum int32 member
|
| H A D | pending.go | 59 PieceNum uint16 member
|
| H A D | pathcollector.go | 90 PieceNum: int32(piece.Number),
|
| H A D | chore_test.go | 268 PieceNum: 0,
|
| H A D | gracefulexit_test.go | 462 PieceNum: rand.Int31(),
|
| /dports/net/storj/storj-1.45.3/satellite/audit/ |
| H A D | verifier_unit_test.go | 56 PieceNum: modifiedShares[i].Number,
98 PieceNum: shares[i].Number,
|
| H A D | verifier.go | 47 PieceNum int member
310 PieceNum: i,
322 shares[share.PieceNum] = *share
646 PieceNum: pieceNum,
717 Number: original.PieceNum})
|
| /dports/net/storj/storj-1.45.3/satellite/satellitedb/ |
| H A D | gracefulexit.go | 116 pieceNums = append(pieceNums, item.PieceNum)
165 dbx.GracefulExitSegmentTransfer_PieceNum(int(item.PieceNum)),
546 …ransferQueueItem.StreamID, &transferQueueItem.Position, &transferQueueItem.PieceNum, &pieceIDBytes,
582 PieceNum: int32(dbxSegmentTransfer.PieceNum),
|
| /dports/net/storj/storj-1.45.3/satellite/metainfo/ |
| H A D | endpoint_test.go | 509 PieceNum: 10,
528 PieceNum: 0,
555 PieceNum: 0,
571 PieceNum: 0,
|
| H A D | metainfo_test.go | 701 PieceNum: num,
1674 PieceNum: num,
|
| H A D | metainfo.go | 1845 errMsg, p.NodeID, p.PieceNum, p.Reason,
1855 Number: uint16(result.PieceNum),
|
| /dports/net/rclone/rclone-1.57.0/vendor/storj.io/common/pb/ |
| H A D | pointerdb.pb.go | 156 …PieceNum int32 `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:… member
190 return m.PieceNum
|
| H A D | metainfo.pb.go | 2781 …PieceNum int32 `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:"p… member
2814 return m.PieceNum
3049 …PieceNum int32 `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:… member
3083 return m.PieceNum
3378 …PieceNum int32 `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:… member
3412 return m.PieceNum
|
| /dports/net/storj/storj-1.45.3/vendor/storj.io/common/pb/ |
| H A D | pointerdb.pb.go | 156 …PieceNum int32 `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:… member
190 return m.PieceNum
|
| H A D | metainfo.pb.go | 2791 …PieceNum int32 `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:"p… member
2824 return m.PieceNum
3059 …PieceNum int32 `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:… member
3093 return m.PieceNum
3388 …PieceNum int32 `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:… member
3422 return m.PieceNum
|
| /dports/net/storj/storj-1.45.3/satellite/repair/checker/ |
| H A D | checker.go | 240 PieceNum: int32(piece.Number),
|
| /dports/net/storj/storj-1.45.3/vendor/storj.io/uplink/private/ecclient/ |
| H A D | client.go | 79 PieceNum: int32(i),
|
| /dports/net/storj/storj-1.45.3/docs/blueprints/ |
| H A D | trusted-delegated-repair.md | 60 * signed PUT orders for all new pieces to be written, along with the PieceNum to use with each
69 * a list of ``(PieceNum, NodeID)`` pairs, indicating pieces which should be _removed_ from the poin…
|
| /dports/net/rclone/rclone-1.57.0/vendor/storj.io/uplink/private/ecclient/ |
| H A D | client.go | 81 PieceNum: int32(i),
|
| /dports/net/storj/storj-1.45.3/satellite/satellitedb/dbx/ |
| H A D | satellitedb.dbx.go | 3044 PieceNum int member
13323 …raceful_exit_segment_transfer.Position, &graceful_exit_segment_transfer.PieceNum, &graceful_exit_s…
19331 …raceful_exit_segment_transfer.Position, &graceful_exit_segment_transfer.PieceNum, &graceful_exit_s…
|