tdlight-team/tdlight-java
tdlight-team/tdlight-java
1
2
Fork 0
Code Issues Releases Wiki Activity

Add logging marker

Browse Source
This commit is contained in:
Andrea Cavalli 2021-10-02 16:35:53 +02:00
parent 2f50d407d7
commit 4f9405225d
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/it/tdlight/common/internal/InternalReactiveClient.java
View File

@ -154,7 +154,7 @@ public final class InternalReactiveClient implements ClientEventsHandler, Reacti
if (isClosed.get()) {
if (alreadyCompleted.compareAndSet(false, true)) {
subscriber.onComplete();
logger.info("Client closed {}", clientId);
logger.info(TG_MARKER, "Client closed {}", clientId);
}
}
}
@ -198,9 +198,9 @@ public final class InternalReactiveClient implements ClientEventsHandler, Reacti
@SuppressWarnings("ReactiveStreamsSubscriberImplementation")
public void createAndRegisterClient() {
if (clientId != null) throw new UnsupportedOperationException("Can't initialize the same client twice!");
logger.debug("Creating new client");
logger.debug(TG_MARKER, "Creating new client");
clientId = NativeClientAccess.create();
logger.debug("Registering new client {}", clientId);
logger.debug(TG_MARKER, "Registering new client {}", clientId);
clientManager.registerClient(clientId, this);
CountDownLatch registeredClient = new CountDownLatch(1);
@ -233,7 +233,7 @@ public final class InternalReactiveClient implements ClientEventsHandler, Reacti
} catch (InterruptedException e) {
throw new IllegalStateException(e);
}
logger.debug("Registered new client {}", clientId);
logger.debug(TG_MARKER, "Registered new client {}", clientId);
}
@Override
@ -248,11 +248,11 @@ public final class InternalReactiveClient implements ClientEventsHandler, Reacti
public void request(long n) {
if (n > 0 && alreadyRequested.compareAndSet(false, true)) {
if (isClosedAndMaybeThrow(query)) {
logger.trace("Client {} is already closed, sending \"Ok\" to: {}", clientId, query);
logger.trace(TG_MARKER, "Client {} is already closed, sending \"Ok\" to: {}", clientId, query);
subscriber.onNext(new TdApi.Ok());
subscriber.onComplete();
} else if (clientId == null) {
logger.trace("Can't send a request to TDLib before calling \"createAndRegisterClient\" function!");
logger.trace(TG_MARKER, "Can't send a request to TDLib before calling \"createAndRegisterClient\" function!");
subscriber.onError(
new IllegalStateException("Can't send a request to TDLib before calling \"createAndRegisterClient\" function!")
);
@ -285,12 +285,12 @@ public final class InternalReactiveClient implements ClientEventsHandler, Reacti
subscriber.onError(t);
}
}));
logger.trace("Client {} is requesting with query id {}: {}", clientId, queryId, query);
logger.trace(TG_MARKER, "Client {} is requesting with query id {}: {}", clientId, queryId, query);
NativeClientAccess.send(clientId, queryId, query);
logger.trace("Client {} requested with query id {}: {}", clientId, queryId, query);
logger.trace(TG_MARKER, "Client {} requested with query id {}: {}", clientId, queryId, query);
}
} else {
logger.debug("Client {} tried to request again the same request, ignored: {}", clientId, query);
logger.debug(TG_MARKER, "Client {} tried to request again the same request, ignored: {}", clientId, query);
}
}