|
 |
da27375 |
diff -up serf-0.9.5/client/rpc_client.go.orig serf-0.9.5/client/rpc_client.go
|
|
|
da27375 |
--- serf-0.9.5/client/rpc_client.go.orig 2020-10-07 18:07:27.000000000 +0200
|
|
|
da27375 |
+++ serf-0.9.5/client/rpc_client.go 2021-01-03 10:33:26.898222569 +0100
|
|
|
da27375 |
@@ -142,9 +142,9 @@ func ClientFromConfig(c *Config) (*RPCCl
|
|
|
da27375 |
shutdownCh: make(chan struct{}),
|
|
|
da27375 |
}
|
|
|
da27375 |
client.dec = codec.NewDecoder(client.reader,
|
|
|
da27375 |
- &codec.MsgpackHandle{RawToString: true, WriteExt: true})
|
|
|
da27375 |
+ &codec.MsgpackHandle{WriteExt: true})
|
|
|
da27375 |
client.enc = codec.NewEncoder(client.writer,
|
|
|
da27375 |
- &codec.MsgpackHandle{RawToString: true, WriteExt: true})
|
|
|
da27375 |
+ &codec.MsgpackHandle{WriteExt: true})
|
|
|
da27375 |
go client.listen()
|
|
|
da27375 |
|
|
|
da27375 |
// Do the initial handshake
|
|
|
da27375 |
diff -up serf-0.9.5/cmd/serf/command/agent/ipc.go.orig serf-0.9.5/cmd/serf/command/agent/ipc.go
|
|
|
da27375 |
--- serf-0.9.5/cmd/serf/command/agent/ipc.go.orig 2020-10-07 18:07:27.000000000 +0200
|
|
|
da27375 |
+++ serf-0.9.5/cmd/serf/command/agent/ipc.go 2021-01-03 10:34:42.280742669 +0100
|
|
|
da27375 |
@@ -387,9 +387,9 @@ func (i *AgentIPC) listen() {
|
|
|
da27375 |
pendingQueries: make(map[uint64]*serf.Query),
|
|
|
da27375 |
}
|
|
|
da27375 |
client.dec = codec.NewDecoder(client.reader,
|
|
|
da27375 |
- &codec.MsgpackHandle{RawToString: true, WriteExt: true})
|
|
|
da27375 |
+ &codec.MsgpackHandle{WriteExt: true})
|
|
|
da27375 |
client.enc = codec.NewEncoder(client.writer,
|
|
|
da27375 |
- &codec.MsgpackHandle{RawToString: true, WriteExt: true})
|
|
|
da27375 |
+ &codec.MsgpackHandle{WriteExt: true})
|
|
|
da27375 |
|
|
|
da27375 |
// Register the client
|
|
|
da27375 |
i.Lock()
|