1 files changed, 69 insertions, 61 deletions
diff --git a/balancer.go b/balancer.go
index 29fcd8d5..16418d55 100644
--- a/balancer.go
+++ b/balancer.go
@@ -1,63 +1,71 @@
 package roadrunner
 
-import (
-	"os/exec"
-	"sync"
-)
-
-// Balancer provides ability to perform hot-swap between 2 worker pools.
-type Balancer struct {
-	mu   sync.Mutex // protects pool hot swapping
-	pool *Pool      // pool to work for user commands
-}
-
-// Spawn initiates underlying pool of workers and replaced old one.
-func (b *Balancer) Spawn(cmd func() *exec.Cmd, factory Factory, cfg Config) error {
-	b.mu.Lock()
-	defer b.mu.Unlock()
-
-	var (
-		err error
-		old *Pool
-	)
-
-	old = b.pool
-	if b.pool, err = NewPool(cmd, factory, cfg); err != nil {
-		return err
-	}
-
-	if old != nil {
-		go func() {
-			old.Close()
-		}()
-	}
-
-	return nil
-}
-
-// Execute one task with given payload and context, returns result and context or error. Must not be used once pool is
-// being destroyed.
-func (b *Balancer) Execute(payload []byte, ctx interface{}) (resp []byte, rCtx []byte, err error) {
-	b.mu.Lock()
-	pool := b.pool
-	b.mu.Unlock()
-
-	return pool.Execute(payload, ctx)
-}
-
-// Workers return list of active workers.
-func (b *Balancer) Workers() []*Worker {
-	b.mu.Lock()
-	defer b.mu.Unlock()
-
-	return b.pool.Workers()
-}
-
-// Close closes underlying pool.
-func (b *Balancer) Close() {
-	b.mu.Lock()
-	defer b.mu.Unlock()
-
-	b.pool.Close()
-	b.pool = nil
-}
+//
+//import (
+//	"os/exec"
+//	"sync"
+//)
+//
+//// Swapper provides ability to perform hot-swap between 2 worker pools.
+//type Swapper struct {
+//	mu   sync.Mutex // protects pool hot swapping
+//	pool *Pool      // pool to work for user commands
+//}
+//
+//// Swap initiates underlying pool of workers and replaces old one.
+//func (b *Swapper) Swap(cmd func() *exec.Cmd, factory Factory, cfg Config) error {
+//	var (
+//		err  error
+//		prev *Pool
+//		pool *Pool
+//	)
+//
+//	prev = b.pool
+//	if pool, err = NewPool(cmd, factory, cfg); err != nil {
+//		return err
+//	}
+//
+//	if prev != nil {
+//		go func() {
+//			prev.Close()
+//		}()
+//	}
+//
+//	b.mu.Lock()
+//	b.pool = pool
+//	b.mu.Unlock()
+//
+//	return nil
+//}
+//
+//// Exec one task with given payload and context, returns result and context
+//// or error. Must not be used once pool is being destroyed.
+//func (b *Swapper) Exec(payload []byte, ctx interface{}) (resp []byte, rCtx []byte, err error) {
+//	b.mu.Lock()
+//	pool := b.pool
+//	b.mu.Unlock()
+//
+//	if pool == nil {
+//		panic("what")
+//	}
+//
+//	return pool.Exec(payload, ctx)
+//}
+//
+//// Workers return list of active workers.
+//func (b *Swapper) Workers() []*Worker {
+//	b.mu.Lock()
+//	pool := b.pool
+//	b.mu.Unlock()
+//
+//	return pool.Workers()
+//}
+//
+//// Close closes underlying pool.
+//func (b *Swapper) Close() {
+//	b.mu.Lock()
+//	defer b.mu.Unlock()
+//
+//	b.pool.Close()
+//	b.pool = nil
+//}