Better logging
This commit is contained in:
parent
4d599e017b
commit
d681df8aff
|
@ -303,14 +303,14 @@ class Connection extends Session
|
||||||
*/
|
*/
|
||||||
public function connect(ConnectionContext $ctx): \Generator
|
public function connect(ConnectionContext $ctx): \Generator
|
||||||
{
|
{
|
||||||
//$this->API->logger->logger("Trying connection ({$this->id}) via $ctx", \danog\MadelineProto\Logger::WARNING);
|
|
||||||
|
|
||||||
$ctx->setReadCallback([$this, 'haveRead']);
|
|
||||||
|
|
||||||
$this->ctx = $ctx->getCtx();
|
$this->ctx = $ctx->getCtx();
|
||||||
$this->datacenter = $ctx->getDc();
|
$this->datacenter = $ctx->getDc();
|
||||||
$this->datacenterId = $this->datacenter.'.'.$this->id;
|
$this->datacenterId = $this->datacenter.'.'.$this->id;
|
||||||
|
$this->API->logger->logger("Connecting to DC {$this->datacenterId}", \danog\MadelineProto\Logger::WARNING);
|
||||||
|
|
||||||
|
$ctx->setReadCallback([$this, 'haveRead']);
|
||||||
$this->stream = yield $ctx->getStream();
|
$this->stream = yield $ctx->getStream();
|
||||||
|
|
||||||
if (isset($this->old)) {
|
if (isset($this->old)) {
|
||||||
unset($this->old);
|
unset($this->old);
|
||||||
}
|
}
|
||||||
|
@ -470,7 +470,7 @@ class Connection extends Session
|
||||||
*/
|
*/
|
||||||
public function disconnect()
|
public function disconnect()
|
||||||
{
|
{
|
||||||
//$this->API->logger->logger("Disconnecting from DC {$this->datacenterId}");
|
$this->API->logger->logger("Disconnecting from DC {$this->datacenterId}");
|
||||||
$this->old = true;
|
$this->old = true;
|
||||||
foreach (['reader', 'writer', 'checker', 'waiter', 'updater'] as $loop) {
|
foreach (['reader', 'writer', 'checker', 'waiter', 'updater'] as $loop) {
|
||||||
if (isset($this->{$loop}) && $this->{$loop}) {
|
if (isset($this->{$loop}) && $this->{$loop}) {
|
||||||
|
@ -484,7 +484,7 @@ class Connection extends Session
|
||||||
$this->API->logger->logger($e);
|
$this->API->logger->logger($e);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
//$this->API->logger->logger("Disconnected from DC {$this->datacenterId}");
|
$this->API->logger->logger("Disconnected from DC {$this->datacenterId}");
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -494,7 +494,7 @@ class Connection extends Session
|
||||||
*/
|
*/
|
||||||
public function reconnect(): \Generator
|
public function reconnect(): \Generator
|
||||||
{
|
{
|
||||||
//$this->API->logger->logger("Reconnecting DC {$this->datacenterId}");
|
$this->API->logger->logger("Reconnecting DC {$this->datacenterId}");
|
||||||
$this->disconnect();
|
$this->disconnect();
|
||||||
yield $this->API->datacenter->dcConnectAsync($this->ctx->getDc(), $this->id);
|
yield $this->API->datacenter->dcConnectAsync($this->ctx->getDc(), $this->id);
|
||||||
if ($this->API->hasAllAuth() && !$this->hasPendingCalls()) {
|
if ($this->API->hasAllAuth() && !$this->hasPendingCalls()) {
|
||||||
|
|
|
@ -326,7 +326,7 @@ class DataCenterConnection implements JsonSerializable
|
||||||
*/
|
*/
|
||||||
public function connect(ConnectionContext $ctx, int $id = -1): \Generator
|
public function connect(ConnectionContext $ctx, int $id = -1): \Generator
|
||||||
{
|
{
|
||||||
$this->API->logger->logger("Trying shared connection via $ctx");
|
$this->API->logger->logger("Trying shared connection via $ctx ($id)");
|
||||||
|
|
||||||
$this->ctx = $ctx->getCtx();
|
$this->ctx = $ctx->getCtx();
|
||||||
$this->datacenter = $ctx->getDc();
|
$this->datacenter = $ctx->getDc();
|
||||||
|
|
Loading…
Reference in New Issue
Block a user