[FAB-1358] Convert all batchSize refs to uint32

https://jira.hyperledger.org/browse/FAB-1358

There is some mismatch between the batchSize type as expressed in the
localconfig package versus the sharedconfig package and the orderer
configuration proto. This changeset fixes that.

This changeset also defines the precision for the integers in the
localconfig package, for symmetry.

Change-Id: I01d86ff80fff4498f683ad960dd443e189bd1599
Signed-off-by: Kostas Christidis <[email protected]>

Author: kchristidis

orderer/common/blockcutter/blockcutter.go

@@ -90,7 +90,7 @@ func (r *receiver) Ordered(msg *cb.Envelope) ([][]*cb.Envelope, [][]filter.Commi
 	r.curBatch = append(r.curBatch, msg)
 	r.batchComs = append(r.batchComs, committer)
 
-	if len(r.curBatch) < r.sharedConfigManager.BatchSize() {
+	if uint32(len(r.curBatch)) < r.sharedConfigManager.BatchSize() {
 		return nil, nil, true
 	}
 

orderer/common/blockcutter/blockcutter_test.go

@@ -73,7 +73,7 @@ var unmatchedTx = &cb.Envelope{Payload: []byte("UNMATCHED")}
 
 func TestNormalBatch(t *testing.T) {
 	filters := getFilters()
-	batchSize := 2
+	batchSize := uint32(2)
 	r := NewReceiverImpl(&mocksharedconfig.Manager{BatchSizeVal: batchSize}, filters)
 
 	batches, committers, ok := r.Ordered(goodTx)
@@ -100,7 +100,7 @@ func TestNormalBatch(t *testing.T) {
 
 func TestBadMessageInBatch(t *testing.T) {
 	filters := getFilters()
-	batchSize := 2
+	batchSize := uint32(2)
 	r := NewReceiverImpl(&mocksharedconfig.Manager{BatchSizeVal: batchSize}, filters)
 
 	batches, committers, ok := r.Ordered(badTx)
@@ -136,7 +136,7 @@ func TestBadMessageInBatch(t *testing.T) {
 
 func TestUnmatchedMessageInBatch(t *testing.T) {
 	filters := getFilters()
-	batchSize := 2
+	batchSize := uint32(2)
 	r := NewReceiverImpl(&mocksharedconfig.Manager{BatchSizeVal: batchSize}, filters)
 
 	batches, committers, ok := r.Ordered(unmatchedTx)
@@ -172,7 +172,7 @@ func TestUnmatchedMessageInBatch(t *testing.T) {
 
 func TestIsolatedEmptyBatch(t *testing.T) {
 	filters := getFilters()
-	batchSize := 2
+	batchSize := uint32(2)
 	r := NewReceiverImpl(&mocksharedconfig.Manager{BatchSizeVal: batchSize}, filters)
 
 	batches, committers, ok := r.Ordered(isolatedTx)
@@ -196,7 +196,7 @@ func TestIsolatedEmptyBatch(t *testing.T) {
 
 func TestIsolatedPartialBatch(t *testing.T) {
 	filters := getFilters()
-	batchSize := 2
+	batchSize := uint32(2)
 	r := NewReceiverImpl(&mocksharedconfig.Manager{BatchSizeVal: batchSize}, filters)
 
 	batches, committers, ok := r.Ordered(goodTx)

orderer/common/bootstrap/static/static.go

@@ -38,7 +38,7 @@ type bootstrapper struct {
 	lastModified  uint64
 	epoch         uint64
 	consensusType string
-	batchSize     int32
+	batchSize     uint32
 }
 
 const (

orderer/common/sharedconfig/sharedconfig.go

@@ -50,7 +50,7 @@ type Manager interface {
 	ConsensusType() string
 
 	// BatchSize returns the maximum number of messages to include in a block
-	BatchSize() int
+	BatchSize() uint32
 
 	// ChainCreators returns the policy names which are allowed for chain creation
 	// This field is only set for the system ordering chain
@@ -59,7 +59,7 @@ type Manager interface {
 
 type ordererConfig struct {
 	consensusType string
-	batchSize     int
+	batchSize     uint32
 	chainCreators []string
 }
 
@@ -83,7 +83,7 @@ func (pm *ManagerImpl) ConsensusType() string {
 }
 
 // BatchSize returns the maximum number of messages to include in a block
-func (pm *ManagerImpl) BatchSize() int {
+func (pm *ManagerImpl) BatchSize() uint32 {
 	return pm.config.batchSize
 }
 
@@ -148,7 +148,7 @@ func (pm *ManagerImpl) ProposeConfig(configItem *cb.ConfigurationItem) error {
 			return fmt.Errorf("Attempted to set the batch size to %d which is less than or equal to  0", batchSize.Messages)
 		}
 
-		pm.pendingConfig.batchSize = int(batchSize.Messages)
+		pm.pendingConfig.batchSize = batchSize.Messages
 	case ChainCreatorsKey:
 		chainCreators := &ab.ChainCreators{}
 		err := proto.Unmarshal(configItem.Value, chainCreators)

orderer/common/sharedconfig/sharedconfig_test.go

@@ -127,7 +127,7 @@ func TestConsensusType(t *testing.T) {
 }
 
 func TestBatchSize(t *testing.T) {
-	endBatchSize := 10
+	endBatchSize := uint32(10)
 	invalidMessage :=
 		&cb.ConfigurationItem{
 			Type:  cb.ConfigurationItem_Orderer,
@@ -139,15 +139,10 @@ func TestBatchSize(t *testing.T) {
 		Key:   BatchSizeKey,
 		Value: utils.MarshalOrPanic(&ab.BatchSize{Messages: 0}),
 	}
-	negativeBatchSize := &cb.ConfigurationItem{
-		Type:  cb.ConfigurationItem_Orderer,
-		Key:   BatchSizeKey,
-		Value: utils.MarshalOrPanic(&ab.BatchSize{Messages: -1}),
-	}
 	validMessage := &cb.ConfigurationItem{
 		Type:  cb.ConfigurationItem_Orderer,
 		Key:   BatchSizeKey,
-		Value: utils.MarshalOrPanic(&ab.BatchSize{Messages: int32(endBatchSize)}),
+		Value: utils.MarshalOrPanic(&ab.BatchSize{Messages: endBatchSize}),
 	}
 	m := NewManagerImpl()
 	m.BeginConfig()
@@ -167,11 +162,6 @@ func TestBatchSize(t *testing.T) {
 		t.Fatalf("Should have rejected batch size of 0")
 	}
 
-	err = m.ProposeConfig(negativeBatchSize)
-	if err == nil {
-		t.Fatalf("Should have rejected negative batch size")
-	}
-
 	m.CommitConfig()
 
 	if nowBatchSize := m.BatchSize(); nowBatchSize != endBatchSize {

orderer/kafka/broadcast.go

@@ -109,7 +109,7 @@ func (b *broadcasterImpl) sendBlock() error {
 	return b.producer.Send(blockBytes)
 }
 
-func (b *broadcasterImpl) cutBlock(period time.Duration, maxSize uint) {
+func (b *broadcasterImpl) cutBlock(period time.Duration, maxSize uint32) {
 	timer := time.NewTimer(period)
 
 	for {

orderer/localconfig/config.go

@@ -42,9 +42,9 @@ type General struct {
 	OrdererType   string
 	LedgerType    string
 	BatchTimeout  time.Duration
-	BatchSize     uint
-	QueueSize     uint
-	MaxWindowSize uint
+	BatchSize     uint32
+	QueueSize     uint32
+	MaxWindowSize uint32
 	ListenAddress string
 	ListenPort    uint16
 	GenesisMethod string

orderer/mocks/sharedconfig/sharedconfig.go

@@ -21,7 +21,7 @@ type Manager struct {
 	// ConsensusTypeVal is returned as the result of ConsensusType()
 	ConsensusTypeVal string
 	// BatchSizeVal is returned as the result of BatchSize()
-	BatchSizeVal int
+	BatchSizeVal uint32
 	// ChainCreatorsVal is returned as the result of ChainCreators()
 	ChainCreatorsVal []string
 }
@@ -32,7 +32,7 @@ func (scm *Manager) ConsensusType() string {
 }
 
 // BatchSize returns the BatchSizeVal
-func (scm *Manager) BatchSize() int {
+func (scm *Manager) BatchSize() uint32 {
 	return scm.BatchSizeVal
 }
 

orderer/multichain/systemchain_test.go

@@ -54,7 +54,7 @@ func (msc *mockSharedConfig) ConsensusType() string {
 	panic("Unimplemented")
 }
 
-func (msc *mockSharedConfig) BatchSize() int {
+func (msc *mockSharedConfig) BatchSize() uint32 {
 	panic("Unimplemented")
 }
 

protos/orderer/configuration.pb.go

@@ -35,7 +35,7 @@ message ConsensusType {
 
 message BatchSize {
     // Simply specified as messages for now, in the future we may want to allow this to be specified by size in bytes
-    int32 messages = 1;
+    uint32 messages = 1;
 }
 
 // When submitting a new chain configuration transaction to create a new chain, the first configuration