Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

make some methods private

pull/2632/head
Cory LaNou 2015-05-22 15:08:28 -06:00
parent 888b2cbecb
commit cf02c342d9
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tcp/listener.go
View File

@ -135,11 +135,11 @@ func (s *Server) handleConnection(conn net.Conn) {
case messageType := <-messageChannel: case messageType := <-messageChannel:
switch messageType { switch messageType {
case writeShardRequestMessage: case writeShardRequestMessage:
if err := s.WriteShardRequest(conn); err != nil { if err := s.writeShardRequest(conn); err != nil {
s.WriteShardResponse(conn, err) s.writeShardResponse(conn, err)
return return
} }
s.WriteShardResponse(conn, nil) s.writeShardResponse(conn, nil)
} }
default: default:
} }
@ -147,7 +147,7 @@ func (s *Server) handleConnection(conn net.Conn) {
} }
func (s *Server) WriteShardRequest(conn net.Conn) error { func (s *Server) writeShardRequest(conn net.Conn) error {
messageChannel := make(chan data.WriteShardRequest) messageChannel := make(chan data.WriteShardRequest)
errChan := make(chan error) errChan := make(chan error)
@ -191,7 +191,7 @@ func (s *Server) WriteShardRequest(conn net.Conn) error {
} }
} }
func (s *Server) WriteShardResponse(conn net.Conn, e error) { func (s *Server) writeShardResponse(conn net.Conn, e error) {
s.Logger.Println("writing shard response") s.Logger.Println("writing shard response")
var mt byte = writeShardResponseMessage var mt byte = writeShardResponseMessage
if err := binary.Write(conn, binary.LittleEndian, &mt); err != nil { if err := binary.Write(conn, binary.LittleEndian, &mt); err != nil {