On Mon, 2023-03-06 at 20:20 +0530, sreenivas somavarapu wrote:
> Hi Oleg,
>
> It looks like some issue with SharedOutputBuffer implementation and
> it is
> also not expandable as we have to allocate complete size during
> initialization itself. If I change below two lines from my program it
> proceeds further and completes the request (Basically
> SharedOutputBuffer is
> not able to write 1024 or above bytes of data at single go (If we
> declare
> temp block size as 1023 also it works)). It looks like there is an
> explicit 1024 length check in SharedOutputBuffer which is causing
> this
> behavior.
>
> SharedOutputBuffer buffer = new
> SharedOutputBuffer(req.contentLength() +
> 1024);
What you are doing is _completely_ wrong. SharedOutputBuffer is not
meant to be expandable.
You cannot just write into the buffer and expect it to work by magic.
You also must flush the buffer.
Oleg
>
> byte[] tmp = new byte[512];
>
> Earlier those 2 lines were as below
>
> SharedOutputBuffer buffer = new SharedOutputBuffer(1024);
>
> byte[] tmp = new byte[4 * 1024];
>
> Below is my sample program on SharedOutputBuffer which demonstrated
> this
> behavior
>
> final StringBuilder sbuffer = new StringBuilder("123");
> System.out.println("O/P: " + sbuffer.toString());
> for (long i = 0; i < (64 * 1000); ++i) {
> sbuffer.append('A');
> }
>
> String postData = sbuffer.toString();
> System.out.println("O/P1: " + postData);
>
> byte[] inputData = postData.getBytes(StandardCharsets.UTF_8);
> ByteArrayInputStream inputStream = new
> ByteArrayInputStream(inputData);
> SharedOutputBuffer outputStream = new SharedOutputBuffer(100
> *
> 1024); *<-- If we keep this as 4 * 1024 also it hangs.*
> *byte[] tmp = new byte[1024]; <-- If we change this to 1023
> then
> it works*
> int l = -1;
> while ((l = inputStream.read(tmp)) != -1) {
> System.out.println("Writing Data");
> System.out.println(l);
> outputStream.write(tmp, 0, l);
> System.out.println("Wrote Data");
> }
>
> System.out.println("Done Writing Data");
> outputStream.writeCompleted();
> System.out.println(outputStream.toString());
>
> Regards,
> Sreenivas
>
> On Mon, Mar 6, 2023 at 7:17 PM Oleg Kalnichevski <[email protected]>
> wrote:
>
> > On Mon, 2023-03-06 at 16:26 +0530, sreenivas somavarapu wrote:
> > > Hi Team,
> > >
> > > We are using AbstractClassicEntityProducer with a customization
> > > of
> > > storing
> > > / computing contentLength as well which works fine if we have
> > > small
> > > POST
> > > data, but when POST data is big (for example 64 KB), it seems
> > > OutPutstream
> > > (internally using ContentOutputStream a wrapper over
> > > SharedOutputBuffer of
> > > initial size 1024) is not able to write data (We are using
> > > temporary
> > > buffer
> > > block of 4kb but still it is not able to write 4KB of data). Is
> > > there
> > > any
> > > limitation or some configuration problem?
> > >
> > > *Code being used*
> > > SharedOutputBuffer buffer = new SharedOutputBuffer(1024);
> > >
> > > produceData(contentType, new
> > > ContentOutputStream(buffer));
> > >
> > > protected void produceData(ContentType contentType, OutputStream
> > > outputStream) throws IOException {
> > > byte[] tmp = new byte[4 * 1024];
> > > int l = -1;
> > > while ((l = inputStream.read(tmp)) != -1) {
> > > * outputStream.write(tmp, 0, l); <---- This is where
> > > request
> > > hangs / waits*
> >
> > This is likely due to a bug in your code that prevents the shared
> > buffer from being flushed.
> >
> > Oleg
> >
> >
> > -------------------------------------------------------------------
> > --
> > To unsubscribe, e-mail: [email protected]
> > For additional commands, e-mail:
> > [email protected]
> >
> >
>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
