- Pharo-dev - lists.pharo.org

Re: [Pharo-dev] Suspending a Process

by Nicolai Hess

2014-07-09 2:07 GMT+02:00 Eliot Miranda <eliot.miranda(a)gmail.com>: > Hi Nicolai, > > > On Tue, Jul 8, 2014 at 7:19 AM, Nicolai Hess <nicolaihess(a)web.de> wrote: > >> I want to create a process doing some work and call #changed on a Morph. >> I want to start/suspend/resume or stop this process. >> But sometimes, suspending the process locks the UI-Process, >> and I don't know why. Did I miss something or do I have to care when to >> call suspend? >> >> Wrapping the "morph changed" call in >> UIManager default defer:[ morph changed]. >> Does not change anything. >> >> Here is an example to reproduce it. >> Create the process, >> call resume, call supsend. It works, most of the time, >> but sometimes, calling suspend locks the ui. >> >> p:=[[true] whileTrue:[ Transcript crShow: (DateAndTime now asString). 30 >> milliSeconds asDelay wait]] newProcess. >> > p resume. >> p suspend. >> > > If you simply suspend this process at random form a user-priority process > you'll never be able to damage the Delay machinery you're using, but > chances are you'll suspend the process inside the critical section that > Transcript uses to make itself thread-safe, and that'll lock up the > Transcript. > Thank you Eliot yes I guessed it locks up the critical section, but I hoped with would not happen if I the use UIManager defer call. > > ThreadSafeTranscript>>nextPutAll: value > accessSemaphore > critical: [stream nextPutAll: value]. > ^value > > So instead you need to use a semaphore. e.g. > > | p s wait | > s := Semaphore new. > p:=[[true] whileTrue:[wait ifTrue: [s wait]. Transcript crShow: > (DateAndTime now asString). 30 milliSeconds asDelay wait]] newProcess. > wait := true. > 30 milliSeconds asDelay wait. > wait := false. > s signal > > etc... > Is this a common pattern I can find in pharos classes. Or I need some help understanding this. The semaphore wait/signal is used instead of process resume/suspend? What I want is a process doing repeatly some computation, calls or triggers an update on a morph, and I want to suspend and resume this process. I would stop this discussion if someone tells me, "No your are doing it wrong, go this way ..", BUT what strikes me: in this example, that reproduces my problem more closely: |p m s running| running:=false. m:=Morph new color:Color red. s:= StringMorph new. m addMorphBack:s. p:=[[true]whileTrue:[20 milliSeconds asDelay wait. s contents:(DateAndTime now asString). m changed]] newProcess. m on:#mouseUp send:#value to:[ running ifTrue:[p suspend. m color:Color red.] ifFalse:[p resume.m color:Color green.]. running := running not]. m extent:(300@50). m openInWorld clicking on the morph will stop or resume the process, if it locks up I can still press alt+dot -> - a Debugger opens but the UI is still not responsive. I can click with the mouse on the debuggers close icon. - nothing happens, as the UI is still blocked. - pressing alt+Dot again, the mouse click on the close icon is processed and the first debugger window closes - maybe other debuggers open. Repeating this steps, at some time the system is *fully* responsive again! And miraculously, it works after that without further blockages. What's happening here? Nicolai > > HTH > > regards >> Nicolai >> > > > > -- > best, > Eliot >

July 9, 2014

[pharo-project/pharo-core] dbd690: 40076

by GitHub

Branch: refs/heads/4.0 Home: https://github.com/pharo-project/pharo-core Commit: dbd690425c1115802a093e934ad52f4a4e0208f5 https://github.com/pharo-project/pharo-core/commit/dbd690425c1115802a093e93… Author: Jenkins Build Server <board(a)pharo-project.org> Date: 2014-07-09 (Wed, 09 Jul 2014) Changed paths: R Morphic-Base.package/MatrixTransformMorph.class/README.md R Morphic-Base.package/MatrixTransformMorph.class/definition.st R Morphic-Base.package/MatrixTransformMorph.class/instance/accessing/transform_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/change reporting/invalidRect_from_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/drawing/drawOn_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/drawing/drawSubmorphsOn_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/drawing/visible_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/event handling/transformFrom_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/changeRotationCenter_with_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/hasNoScaleOrRotation.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/innerAngle.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/lastRotationDegrees.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/lastRotationDegrees_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/removeFlexShell.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/rotateBy_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/rotationDegrees_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/flexing/transform.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry etoy/heading.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry etoy/rotationCenter.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry etoy/rotationCenter_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry etoy/setDirectionFrom_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry testing/containsPoint_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry testing/fullContainsPoint_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry/boundsChangedFrom_to_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry/computeBounds.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry/extent_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry/handleBoundsChange_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/geometry/transformedBy_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/halos and balloon help/balloonHelpTextForHandle_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/initialization/initialize.st R Morphic-Base.package/MatrixTransformMorph.class/instance/initialize/asFlexOf_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/layout/fullBounds.st R Morphic-Base.package/MatrixTransformMorph.class/instance/menus/setRotationCenterFrom_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/private/privateFullMoveBy_.st R Morphic-Base.package/MatrixTransformMorph.class/instance/rotate scale and flex/addFlexShell.st R Morphic-Base.package/MatrixTransformMorph.class/instance/updating/changed.st A ScriptLoader40.package/ScriptLoader.class/instance/pharo - scripts/script76.st A ScriptLoader40.package/ScriptLoader.class/instance/pharo - updates/update40076.st M ScriptLoader40.package/ScriptLoader.class/instance/public/commentForCurrentUpdate.st M Spec-Inspector.package/EyeInspector.class/instance/list/limit1.st M Spec-Inspector.package/EyeInspector.class/instance/list/limit2.st Log Message: ----------- 40076 13501 EyeInspector has a slow refresh time (part 1) https://pharo.fogbugz.com/f/cases/13501 13510 MatrixTransformMorph is not used https://pharo.fogbugz.com/f/cases/13510 13514 delete empty packages KeyChain and Settings-Compiler https://pharo.fogbugz.com/f/cases/13514 http://files.pharo.org/image/40/40076.zip

July 9, 2014

[pharo-project/pharo-core]

by GitHub

Branch: refs/tags/40076 Home: https://github.com/pharo-project/pharo-core

July 9, 2014

Re: [Pharo-dev] [Article] Elegant Pharo Code

by Hilaire

Thanks Sven, It is nice and helpful, I would look at it if I have the opportunity to give a talk about Pharo while in Taiwan this summer. Hilaire Le 08/07/2014 06:21, Sven Van Caekenberghe a Ã©crit : > Hi, > > I have written a new article presenting Pharo using a list of 23 short examples. > > Elegant Pharo Code > > Beautiful & Powerful One-liners, Expressions and Snippets > > https://medium.com/@svenvc/elegant-pharo-code-bb590f0856d0 > > As mentioned at the end of the article, I welcome feedback, remarks, comments, alternative solutions and other examples. The idea is to create yet another way to lure people into exploring Pharo while explaining by example why we like Pharo. > > Enjoy! > > Sven > > -- > Sven Van Caekenberghe > Proudly supporting Pharo > http://pharo.org > http://association.pharo.org > http://consortium.pharo.org > > > > > > -- Dr. Geo - http://drgeo.eu iStoa - http://launchpad.net/istoa

July 9, 2014

Re: [Pharo-dev] [Vm-dev] [DEV] Systemd socket activation patch for the VM

by Chris Muller

On Tue, Jul 8, 2014 at 9:08 AM, Max Leske <maxleske(a)gmail.com> wrote: > > Hi folks > > As promised a long time ago my colleague Nik Lutz has finalized the patch > for the VM that enables socket activation with Systemd. I will quickly go > over what the patch is supposed to achieve, how we plan to use socket > activation and what (minimal) changes are necessary. > > > Systemd Socket Activation: > Systemd opens a (network-) socket and waits for connections. When the > first client connects the assotiated service (VM) is started. Systemd > indicates via environment variable (LISTEN_FDS) that it opened a network > socket. > > Detailed documentation on socket activation with Systemd can be found > here: http://0pointer.de/blog/projects/socket-activation.html > > > Our scenario for socket activation: > At Cmsbox we have hundereds of images running on a server, all of which > listen on a dedicated network port for incoming connections. The server is > powerful enough to run all these processes concurrently, especially since > not every image receives requests all the time. > With socket activation we could further lower the server load and free up > resources for images with a high request rate. Images that donât receive > any requests for a specified amount of time can be suspended automatically > and reactivated when a request comes in. > OMG, I want that!

July 9, 2014

Re: [Pharo-dev] [DEV] Systemd socket activation patch for the VM

by Sebastian Sastre

this is really good! sebastian o/ > On 08/07/2014, at 11:08, Max Leske <maxleske(a)gmail.com> wrote: > > Hi folks > > As promised a long time ago my colleague Nik Lutz has finalized the patch for the VM that enables socket activation with Systemd. I will quickly go over what the patch is supposed to achieve, how we plan to use socket activation and what (minimal) changes are necessary. > > > Systemd Socket Activation: > Systemd opens a (network-) socket and waits for connections. When the first client connects the assotiated service (VM) is started. Systemd indicates via environment variable (LISTEN_FDS) that it opened a network socket. > > Detailed documentation on socket activation with Systemd can be found here: http://0pointer.de/blog/projects/socket-activation.html > > > Our scenario for socket activation: > At Cmsbox we have hundereds of images running on a server, all of which listen on a dedicated network port for incoming connections. The server is powerful enough to run all these processes concurrently, especially since not every image receives requests all the time. > With socket activation we could further lower the server load and free up resources for images with a high request rate. Images that donât receive any requests for a specified amount of time can be suspended automatically and reactivated when a request comes in. > > > > The VM Patch: > The attached patch tries hard to be minimal. It defines a new socket type (ProvidedTCPSocketType) which you will also find in the image (Socket>>newSystemd). ProvidedTCPSocketType is special in that it can refer to an existing TCPSocket and does not necessarily entail the creation of a new socket. > > > The changes in the image: > - Socket>>newSystemd tries to open a new Systemd socket. > - TCPListener>>haveSystemdAssignedPort tests if the LISTEN_FDS environment variable has been set by Systemd for the current process. > - TCPListener>>primEnvironmentAtSymbol is a utility method that we need to check for the environment variable (IMPORTANT: copied from OSProcess; uses the OSProcess plugin) > - TCPListener>>pvtNewListener: has been modified to include the check for the Systemd port. If the socket has been assigned by Systemd, use a Systemd socket, a TCP socket otherwise > > Quick Howto: > - Adapt path to vm and image in pharo@.service > - Take a Seaside image and FileIn systemd.cs (tested with http://seaside.st/distributions/Seaside-2.8.4.zip) > - Save as 9999.image > - Copy pharo@.service and pharo@.socket to /etc/systemd/system > - As root run: > systemctl daemon-reload > systemctl start pharo(a)9999.socket > - Open http://localhost:9999/seaside/config > > [- systemctl stop pharo(a)9999.socket] > > -> Upon connection pharo(a)9999.socket starts: pharo(a)9999.service (which would start .../9999.image) > > You can see this in action in the following screencast: http://youtu.be/MVPLZNKg5j8 > > > We hope that this patch (or some version of it) will find its way into the VM. If you have any questions please feel free to ask. > > > Cheers, > Max (on behalf of Nik and the rest of Netstyle.ch) > > > <systemd.cs> > <pharo@.service> > <squeak-svn.diff> > <pharo@.socket> >

July 9, 2014

Re: [Pharo-dev] Smalltalk Syntax in a Postcard contest

by HernÃ¡n Morales Durand

I forgot to add each ast allChildren anySatisfy: [ : node | node isCascade ] which in that case, there is no method in the Pharo 3 image. Maybe a package out there... Anyway, who can load all packages? :) HernÃ¡n PS: One problem with StackExchange is there are very few smalltalkers registered. 2014-07-08 21:20 GMT-03:00 HernÃ¡n Morales Durand <hernan.morales(a)gmail.com>: > Hello Martin, > > I have refined the search a little bit, and we have a new winner with > Stephane Ducasse as author in annotations. > > PSMCMergeMorph>>model: aMerger > "Set the model and update the window." > > |grouped sorted| > super model: aMerger. > grouped := aMerger operations > groupBy: [:o | o targetClassName ifNil: [o shortSummary]] > having: [:g | true]. > sorted := OrderedCollection new. > grouped keys asSortedCollection do: [:k | > sorted addAll: ((grouped at: k) asSortedCollection: [:a :b | a > shortSummary <= b shortSummary])]. > self patchMorph model: sorted > > This is the code I have used: > > | allMethods | > allMethods := SystemNavigation default allMethods. > UIManager default displayProgress: 'Scanning all methods...' > from: 1 > to: allMethods size > during: [ : bar | | current | > current := 0. > allMethods select: [ : each | > current := current + 1. > bar value: current. > each ast arguments notEmpty and: [ > (each ast allChildren anySatisfy: #isAssignment) and: [ > (each ast allChildren anySatisfy: #isBlock) and: [ > each ast temporaries notEmpty and: [ > each ast superMessages notEmpty and: [ > (each ast allChildren anySatisfy: [ : node | node isMessage > and: [ node selector isUnary ] ]) and: [ > (each ast allChildren anySatisfy: [ : node | node isMessage > and: [ node selector isBinary ] ]) and: [ > (each ast allChildren anySatisfy: [ : node | node isBlock and: > [ node arguments size = 2] ]) and: [ > (each ast allChildren anySatisfy: [ : node | node isBlock and: > [ node arguments size = 1] ]) > ] ] ] ] ] ] ] ] ] ]. > > Cheers, > > HernÃ¡n > > > > 2014-07-08 18:48 GMT-03:00 MartinW <wm(a)fastmail.fm>: > > I removed the question, but only after it was already marked to be closed >> by >> several people. Their argument was, that the question was "to broad". >> Once a >> discussion like this starts on Stackexchange sites there's always a herd >> behavior that's hard to stop. >> >> Can you share the code you used for your search, HernÃ¡n? >> >> >> HernÃ¡n Morales Durand wrote >> > The contest is gone? >> > >> > Anyway, the closest useful method I have found by iterating all ASTs in >> > standard 3.0 image : >> > >> > - Declares arguments >> > - Has assignment >> > - Has sequence >> > - Has blocks with 0 and 2 arguments >> > - Declares temporaries >> > - Has binary messages >> > - Has unary messages >> > - Has keyword messages >> > - Has super messages >> > - Has cascade >> > - Has return >> > - Uses String and Integer >> >> >> >> >> >> -- >> View this message in context: >> http://forum.world.st/Smalltalk-Syntax-in-a-Postcard-contest-tp4766793p4767… >> Sent from the Pharo Smalltalk Developers mailing list archive at >> Nabble.com. >> >> >

July 9, 2014

Re: [Pharo-dev] Smalltalk Syntax in a Postcard contest

by HernÃ¡n Morales Durand

Hello Martin, I have refined the search a little bit, and we have a new winner with Stephane Ducasse as author in annotations. PSMCMergeMorph>>model: aMerger "Set the model and update the window." |grouped sorted| super model: aMerger. grouped := aMerger operations groupBy: [:o | o targetClassName ifNil: [o shortSummary]] having: [:g | true]. sorted := OrderedCollection new. grouped keys asSortedCollection do: [:k | sorted addAll: ((grouped at: k) asSortedCollection: [:a :b | a shortSummary <= b shortSummary])]. self patchMorph model: sorted This is the code I have used: | allMethods | allMethods := SystemNavigation default allMethods. UIManager default displayProgress: 'Scanning all methods...' from: 1 to: allMethods size during: [ : bar | | current | current := 0. allMethods select: [ : each | current := current + 1. bar value: current. each ast arguments notEmpty and: [ (each ast allChildren anySatisfy: #isAssignment) and: [ (each ast allChildren anySatisfy: #isBlock) and: [ each ast temporaries notEmpty and: [ each ast superMessages notEmpty and: [ (each ast allChildren anySatisfy: [ : node | node isMessage and: [ node selector isUnary ] ]) and: [ (each ast allChildren anySatisfy: [ : node | node isMessage and: [ node selector isBinary ] ]) and: [ (each ast allChildren anySatisfy: [ : node | node isBlock and: [ node arguments size = 2] ]) and: [ (each ast allChildren anySatisfy: [ : node | node isBlock and: [ node arguments size = 1] ]) ] ] ] ] ] ] ] ] ] ]. Cheers, HernÃ¡n 2014-07-08 18:48 GMT-03:00 MartinW <wm(a)fastmail.fm>: > I removed the question, but only after it was already marked to be closed > by > several people. Their argument was, that the question was "to broad". Once > a > discussion like this starts on Stackexchange sites there's always a herd > behavior that's hard to stop. > > Can you share the code you used for your search, HernÃ¡n? > > > HernÃ¡n Morales Durand wrote > > The contest is gone? > > > > Anyway, the closest useful method I have found by iterating all ASTs in > > standard 3.0 image : > > > > - Declares arguments > > - Has assignment > > - Has sequence > > - Has blocks with 0 and 2 arguments > > - Declares temporaries > > - Has binary messages > > - Has unary messages > > - Has keyword messages > > - Has super messages > > - Has cascade > > - Has return > > - Uses String and Integer > > > > > > -- > View this message in context: > http://forum.world.st/Smalltalk-Syntax-in-a-Postcard-contest-tp4766793p4767… > Sent from the Pharo Smalltalk Developers mailing list archive at > Nabble.com. > >

July 9, 2014

Re: [Pharo-dev] Suspending a Process

by Eliot Miranda

Hi Nicolai, On Tue, Jul 8, 2014 at 7:19 AM, Nicolai Hess <nicolaihess(a)web.de> wrote: > I want to create a process doing some work and call #changed on a Morph. > I want to start/suspend/resume or stop this process. > But sometimes, suspending the process locks the UI-Process, > and I don't know why. Did I miss something or do I have to care when to > call suspend? > > Wrapping the "morph changed" call in > UIManager default defer:[ morph changed]. > Does not change anything. > > Here is an example to reproduce it. > Create the process, > call resume, call supsend. It works, most of the time, > but sometimes, calling suspend locks the ui. > > p:=[[true] whileTrue:[ Transcript crShow: (DateAndTime now asString). 30 > milliSeconds asDelay wait]] newProcess. > p resume. > p suspend. > If you simply suspend this process at random form a user-priority process you'll never be able to damage the Delay machinery you're using, but chances are you'll suspend the process inside the critical section that Transcript uses to make itself thread-safe, and that'll lock up the Transcript. ThreadSafeTranscript>>nextPutAll: value accessSemaphore critical: [stream nextPutAll: value]. ^value So instead you need to use a semaphore. e.g. | p s wait | s := Semaphore new. p:=[[true] whileTrue:[wait ifTrue: [s wait]. Transcript crShow: (DateAndTime now asString). 30 milliSeconds asDelay wait]] newProcess. wait := true. 30 milliSeconds asDelay wait. wait := false. s signal etc... HTH regards > Nicolai > -- best, Eliot

July 9, 2014

Re: [Pharo-dev] Smalltalk Syntax in a Postcard contest

by MartinW

I removed the question, but only after it was already marked to be closed by several people. Their argument was, that the question was "to broad". Once a discussion like this starts on Stackexchange sites there's always a herd behavior that's hard to stop. Can you share the code you used for your search, HernÃ¡n? HernÃ¡n Morales Durand wrote > The contest is gone? > > Anyway, the closest useful method I have found by iterating all ASTs in > standard 3.0 image : > > - Declares arguments > - Has assignment > - Has sequence > - Has blocks with 0 and 2 arguments > - Declares temporaries > - Has binary messages > - Has unary messages > - Has keyword messages > - Has super messages > - Has cascade > - Has return > - Uses String and Integer -- View this message in context: http://forum.world.st/Smalltalk-Syntax-in-a-Postcard-contest-tp4766793p4767… Sent from the Pharo Smalltalk Developers mailing list archive at Nabble.com.

July 8, 2014