[FEATURE] Add thread-safe info to responses

This commit is contained in:
Gravita 2024-02-03 17:11:36 +07:00
parent 7060697bad
commit 35bdf1607f
8 changed files with 40 additions and 0 deletions

View file

@ -81,4 +81,9 @@ public AuthContext(Client client, String login, String profileName, String ip, C
this.pair = pair; this.pair = pair;
} }
} }
@Override
public ThreadSafeStatus getThreadSafeStatus() {
return ThreadSafeStatus.READ_WRITE;
}
} }

View file

@ -79,4 +79,9 @@ public void execute(ChannelHandlerContext ctx, Client client) {
sendResult(new ExitRequestEvent(ExitRequestEvent.ExitReason.NO_EXIT)); sendResult(new ExitRequestEvent(ExitRequestEvent.ExitReason.NO_EXIT));
} }
} }
@Override
public ThreadSafeStatus getThreadSafeStatus() {
return ThreadSafeStatus.READ_WRITE;
}
} }

View file

@ -105,4 +105,9 @@ public void execute(ChannelHandlerContext ctx, Client client) throws Exception {
public interface ExtendedTokenProvider { public interface ExtendedTokenProvider {
boolean accept(Client client, AuthProviderPair pair, String extendedToken); boolean accept(Client client, AuthProviderPair pair, String extendedToken);
} }
@Override
public ThreadSafeStatus getThreadSafeStatus() {
return ThreadSafeStatus.READ_WRITE;
}
} }

View file

@ -40,4 +40,9 @@ public void execute(ChannelHandlerContext ctx, Client client) {
} }
sendError("Profile not found"); sendError("Profile not found");
} }
@Override
public ThreadSafeStatus getThreadSafeStatus() {
return ThreadSafeStatus.READ_WRITE;
}
} }

View file

@ -31,4 +31,9 @@ public void execute(ChannelHandlerContext ctx, Client client) {
response.enabled = true; response.enabled = true;
sendResult(secureProtectHandler.onGetSecureLevelInfo(response)); sendResult(secureProtectHandler.onGetSecureLevelInfo(response));
} }
@Override
public ThreadSafeStatus getThreadSafeStatus() {
return ThreadSafeStatus.READ_WRITE;
}
} }

View file

@ -31,4 +31,9 @@ public void execute(ChannelHandlerContext ctx, Client client) {
sendResult(new HardwareReportRequestEvent()); sendResult(new HardwareReportRequestEvent());
} }
} }
@Override
public ThreadSafeStatus getThreadSafeStatus() {
return ThreadSafeStatus.READ_WRITE;
}
} }

View file

@ -44,4 +44,9 @@ public void execute(ChannelHandlerContext ctx, Client client) {
} }
} }
@Override
public ThreadSafeStatus getThreadSafeStatus() {
return ThreadSafeStatus.READ_WRITE;
}
} }

View file

@ -110,4 +110,9 @@ public boolean accept(Client client, AuthProviderPair pair, String extendedToken
} }
} }
@Override
public ThreadSafeStatus getThreadSafeStatus() {
return ThreadSafeStatus.READ_WRITE;
}
} }