pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-05-31 15:41:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix telemetry (#231)

Browse Source 
* Fix telemetry

* Correct default telemetry

* Extra logging
This commit is contained in:
Gav Wood
2018-06-22 18:26:22 +02:00
committed by GitHub
parent 4082d660ba
commit d8acd4a1eb
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/polkadot/cli/src/lib.rs
+1 -1
View File
@@ -84,7 +84,7 @@ use futures::sync::mpsc;
use futures::{Sink, Future, Stream}; use futures::{Sink, Future, Stream};
use tokio_core::reactor; use tokio_core::reactor;
const DEFAULT_TELEMETRY_URL: &str = "wss://telemetry.polkadot.io:443"; const DEFAULT_TELEMETRY_URL: &str = "ws://telemetry.polkadot.io:1024";
#[derive(Clone)] #[derive(Clone)]
struct SystemConfiguration { struct SystemConfiguration {
substrate/substrate/telemetry/src/lib.rs
+4 -1
View File
@@ -25,6 +25,8 @@ extern crate parking_lot;
extern crate websocket as ws; extern crate websocket as ws;
extern crate slog_async; extern crate slog_async;
extern crate slog_json; extern crate slog_json;
#[macro_use]
extern crate log;
#[macro_use(o, kv)] #[macro_use(o, kv)]
extern crate slog; extern crate slog;
extern crate slog_scope; extern crate slog_scope;
@@ -77,6 +79,7 @@ struct TelemetryWriter {
impl TelemetryWriter { impl TelemetryWriter {
fn ensure_connected(&mut self) { fn ensure_connected(&mut self) {
if self.first_time { if self.first_time {
info!("Connected to telemetry server: {}", self.config.url);
(self.config.on_connect)(); (self.config.on_connect)();
self.first_time = false; self.first_time = false;
} }
@@ -105,7 +108,7 @@ impl io::Write for TelemetryWriter {
let mut l = self.out.lock(); let mut l = self.out.lock();
let socket_closed = if let Some(ref mut socket) = *l { let socket_closed = if let Some(ref mut socket) = *l {
if let Ok(s) = ::std::str::from_utf8(&self.buffer[..]) { if let Ok(s) = ::std::str::from_utf8(&self.buffer[..]) {
socket.send_message(&ws::Message::text(s)).is_ok() socket.send_message(&ws::Message::text(s)).is_err()
} else { false } } else { false }
} else { false }; } else { false };
if socket_closed { if socket_closed {