Skip to content

Commit

Permalink
Removed dead code + add FIXME
Browse files Browse the repository at this point in the history
  • Loading branch information
kozlovic committed Feb 2, 2016
1 parent b5cb0e5 commit 85d3e0d
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 17 deletions.
15 changes: 0 additions & 15 deletions nats.go
Expand Up @@ -538,21 +538,6 @@ const (
okProto = _OK_OP_ + _CRLF_
)

/*
// Commenting this out since it is not used for now and reduce test coverage
func (nc *Conn) debugPool(str string) {
_, cur := nc.currentServer()
fmt.Printf("%s\n", str)
for i, s := range nc.srvPool {
if s == cur {
fmt.Printf("\t*%d: %v\n", i+1, s.url)
} else {
fmt.Printf("\t%d: %v\n", i+1, s.url)
}
}
}
*/

// Return the currently selected server
func (nc *Conn) currentServer() (int, *srv) {
for i, s := range nc.srvPool {
Expand Down
4 changes: 2 additions & 2 deletions test/basic_test.go
Expand Up @@ -122,8 +122,8 @@ func TestSimplePublishNoData(t *testing.T) {
}

func TestPublishFailOnSlowConsumer(t *testing.T) {
// This whole test should be removed when/if we decide to fix the fact
// that the publish should not fail because of an async error.
// FIXME(dlc): Remove this test when preventing failure to Publish()
// because of async error.

s := RunDefaultServer()
defer s.Shutdown()
Expand Down

0 comments on commit 85d3e0d

Please sign in to comment.