Hi Simon,
Simon Trudeau wrote:
> I want to test the performance of my application. To do so, I intend on
> building an Echo server with delay. Basically, once my request reaches
> my server, I want to delay (simulate response processing) the sending of
> a response. My first guess is to wrap the content of the execute method
> of the EchoFilter inside a callable and have it executed by a scheduled
> executor. Is that thread safe?
Yes you can, but make sure you call:
ctx.setKeyRegistrationState(
Context.KeyRegistrationState.NONE);
// Store those values somewhere:
SelectionKey key = ctx.getSelectionKey();
Selectorhandler sl = ctx.getSelectorHandler();
inside you Filter, because if not, the key will be registered back and
it will gives unexpected result. Once you have flushed the response,
just do:
sl.getSelectionKeyHandler().register(key);
So you can get other requests that are coming.
>
>
>
> What happens to the context object if another packet arrives from the
> same connection while my server is waiting to send back the response?
>
>
>
> The issue I want to simulate is a fast producer (client), slow consumer
> (server).
Right. Try the above :-)
Thanks
-- Jeanfrancois
>
>
>
> Can I just wrap
>
>
>
> *public* *boolean* execute(Context ctx) *throws* IOException {
>
> *final* WorkerThread workerThread =
> ((WorkerThread)Thread./currentThread/());
>
> ByteBuffer buffer = workerThread.getByteBuffer();
>
> buffer.flip();
>
> *if* (buffer.hasRemaining()) {
>
> // Depending on protocol perform echo
>
> SelectableChannel channel = ctx.getSelectionKey().channel();
>
> *try* {
>
> *if* (ctx.getProtocol() == Controller.Protocol./TCP/) {
> // TCP case
>
> OutputWriter./flushChannel/(channel, buffer);
>
> } *else* *if* (ctx.getProtocol() ==
> Controller.Protocol./UDP/) { // UDP case
>
> DatagramChannel datagramChannel = (DatagramChannel)
> channel;
>
> SocketAddress address = (SocketAddress)
>
>
> ctx.getAttribute(ReadFilter./UDP_SOCKETADDRESS/);
>
> OutputWriter./flushChannel/(datagramChannel,
> address, buffer);
>
> }
>
> } *catch* (IOException ex) {
>
> // Store incoming data in byte[]
>
> *byte*[] data = *new* *byte*[buffer.remaining()];
>
> *int* position = buffer.position();
>
> buffer.get(data);
>
> buffer.position(position);
>
>
>
> Controller./logger/().log(Level./WARNING/,
>
> "Exception. Echo \"" + *new* String(data) + "\"");
>
> *throw* ex;
>
> }
>
> }
>
>
>
> buffer.clear();
>
> *return* *false*;
>
> }
>
>
>
> Inside a callable and execute it from a Schedule Executor or are there
> states that will be messed up (the context maybe…?). What do you think?
>
>
>
> Thanks,
>
>
>
> Simon
>
>
>