Further refactoring into TxPortal/TxAlgorithm. (#132)

txportal.go

@@ -1,32 +1,40 @@
 package dilithium
 
 import (
-	"github.com/emirpasic/gods/trees/btree"
 	"sync"
 )
 
+// TxAlgorithm is an abstraction of an extensible flow-control implementation, which can be plugged into a TxPortal
+// instance.
+//
+type TxAlgorithm interface {
+	Ready()
+	Tx(int)
+	Success(int)
+	DuplicateAck()
+	Retransmission(int)
+}
+
 // TxPortal manages the outgoing data transmitted by a communication instance. It is one half of a TxPortal->RxPortal
 // communication pair. TxPortal is primarily concerned with optimizing the transmission rate over lossy Transport
 // implementations, while ensuring reliability.
 //
 type TxPortal struct {
-	lock         *sync.Mutex
-	tree         *btree.Tree
-	capacity     int
-	ready        *sync.Cond
-	txPortalSize int
-	rxPortalSize int
-	alg          TxAlgorithm
-	monitor      *TxMonitor
-	closer       *Closer
-	transport    Transport
+	lock      *sync.Mutex
+	transport Transport
+	alg       TxAlgorithm
+	monitor   *TxMonitor
+	closer    *Closer
+	pool      *Pool
 }
 
-// TxAlgorithm is an abstraction of an extensible flow-control implementation, which can be plugged into a TxPortal
-// instance.
-//
-type TxAlgorithm interface {
-	Success()
-	DuplicateAck()
-	Retransmission()
+func newTxPortal(transport Transport, alg TxAlgorithm, closer *Closer, pool *Pool) *TxPortal {
+	txp := &TxPortal{
+		lock:      new(sync.Mutex),
+		transport: transport,
+		alg:       alg,
+		closer:    closer,
+	}
+	// txp.monitor =
+	return txp
 }

westworld.go

@@ -11,13 +11,19 @@ func NewWestworldAlgorithm(pf *WestworldProfile, txPortal *TxPortal) TxAlgorithm
 	return &WestworldAlgorithm{pf, txPortal}
 }
 
-func (self *WestworldAlgorithm) Success() {
+func (self *WestworldAlgorithm) Ready() {
+}
+
+func (self *WestworldAlgorithm) Tx(size int) {
+}
+
+func (self *WestworldAlgorithm) Success(size int) {
 }
 
 func (self *WestworldAlgorithm) DuplicateAck() {
 }
 
-func (self *WestworldAlgorithm) Retransmission() {
+func (self *WestworldAlgorithm) Retransmission(size int) {
 }
 
 type WestworldProfile struct {