On Wed, Jun 3, 2015 at 10:07 AM, Julian Atkinson <[email protected] > wrote:
> Thanks for your help Andrea, > > >> - As soon as the InputStream is returned to the WPS executor, the job > is marked as complete, even though it may take many hours to process and > stream all the data. Additionally, any new WPS jobs are run immediately > without respecting queue limits. > > > > The queue is just for the "execute" phase. If you can change the code so > that it also does also the encoding in the execute thread, that would be > appreciated. > > > We re-arranged our code to block in the execute phase with our second > implementation (generating the complete response and writing it to file > storage, before returning from execute). > > The apparent limitation is that the execute() method is also responsible > for returning the RawData interface that supplies the InputStream which the > wps extension code uses to return the response back to the client. > > This prevents any streaming of buffered content while it is being > generated in a synchronous context - even if we use separate producer and > consumer threads. Instead the wps execution IO workflow seems to be > organized around discreet jobs. Is that an accurate description of the > behavior? > If it is, I don't understand it :-) As far as I know streaming is possible, but it will happen in a thread other than the ones in the pool, thus dodging the concurrent execution limits Cheers Andrea -- == GeoServer Professional Services from the experts! Visit http://goo.gl/it488V for more information. == Ing. Andrea Aime @geowolf Technical Lead GeoSolutions S.A.S. Via Poggio alle Viti 1187 55054 Massarosa (LU) Italy phone: +39 0584 962313 fax: +39 0584 1660272 mob: +39 339 8844549 http://www.geo-solutions.it http://twitter.com/geosolutions_it *AVVERTENZE AI SENSI DEL D.Lgs. 196/2003* Le informazioni contenute in questo messaggio di posta elettronica e/o nel/i file/s allegato/i sono da considerarsi strettamente riservate. Il loro utilizzo è consentito esclusivamente al destinatario del messaggio, per le finalità indicate nel messaggio stesso. Qualora riceviate questo messaggio senza esserne il destinatario, Vi preghiamo cortesemente di darcene notizia via e-mail e di procedere alla distruzione del messaggio stesso, cancellandolo dal Vostro sistema. Conservare il messaggio stesso, divulgarlo anche in parte, distribuirlo ad altri soggetti, copiarlo, od utilizzarlo per finalità diverse, costituisce comportamento contrario ai principi dettati dal D.Lgs. 196/2003. The information in this message and/or attachments, is intended solely for the attention and use of the named addressee(s) and may be confidential or proprietary in nature or covered by the provisions of privacy act (Legislative Decree June, 30 2003, no.196 - Italy's New Data Protection Code).Any use not in accord with its purpose, any disclosure, reproduction, copying, distribution, or either dissemination, either whole or partial, is strictly forbidden except previous formal approval of the named addressee(s). If you are not the intended recipient, please contact immediately the sender by telephone, fax or e-mail and delete the information in this message that has been received in error. The sender does not give any warranty or accept liability as the content, accuracy or completeness of sent messages and accepts no responsibility for changes made after they were sent or for other risks which arise as a result of e-mail transmission, viruses, etc. -------------------------------------------------------
------------------------------------------------------------------------------
_______________________________________________ Geoserver-devel mailing list [email protected] https://lists.sourceforge.net/lists/listinfo/geoserver-devel
