"

"

"{ Package: 'stx:libscm/mercurial' }"

Object subclass:#HGCommandServer

	instanceVariableNames:'repository pid input output state readerwriter encoder channel_o

		channel_e channel_r channel_d channel_I channel_L channel_M

		command'

	classVariableNames:'IdleTimeout'

	poolDictionaries:'HGDebugFlags'

	category:'SCM-Mercurial-Internal'

!

ReadStream subclass:#InputChannel

	instanceVariableNames:'server id lock rlock binary closed'

	classVariableNames:''

	poolDictionaries:''

	privateIn:HGCommandServer

!

WriteStream subclass:#OutputChannel

	instanceVariableNames:'server id lock rlock'

	classVariableNames:''

	poolDictionaries:''

	privateIn:HGCommandServer

!

!HGCommandServer class methodsFor:'documentation'!

copyright

"

"

! !

!HGCommandServer class methodsFor:'initialization'!

initialize

    "Invoked at system start or when the class is dynamically loaded."

    "/ please change as required (and remove this comment)

    IdleTimeout"[ms]":= 1000 * 60   "= 1min"

    "Modified: / 09-03-2013 / 22:25:53 / Jan Vrany <jan.vrany@fit.cvut.cz>"

! !

!HGCommandServer class methodsFor:'instance creation'!

new

    "return an initialized instance"

    ^ self basicNew initialize.

! !

!HGCommandServer methodsFor:'accessing'!

repository:anHGRepository

    repository := anHGRepository.

    "Modified: / 05-03-2013 / 19:35:02 / Jan Vrany <jan.vrany@fit.cvut.cz>"

! !

!HGCommandServer methodsFor:'executing'!

execute: anHGCommand

    "Executes an HG command"

    | spin status result |

    state ~~ #connected ifTrue:[

        "/spin-lock wait...

        [ #(disconnected connected) includes: state ] whileFalse:[

            Delay waitForMilliseconds: 15.

        ].

        state == #disconnected ifTrue:[

            self start

        ]

    ].

    repository synchronized:[

        command := anHGCommand.

        anHGCommand initialize.

        self runcommand: command.

        spin := SemaphoreSet with: channel_r readSemaphore with: anHGCommand errors readSemaphore.

        status := [

            [ spin wait ~~ channel_r readSemaphore ] whileTrue:[ anHGCommand signal ].

            OperatingSystem osProcessStatusClass pid:nil status: #exit code: channel_r nextLongNet core:false.

        ] ensure:[

            "/Close channels

            channel_o close.

            channel_e close.

            "/Command terminated - this match signaling in HGCommand>>execute

            command blocker signal. 

            "/Signal blockers if workers hasn't been at all spawned...

            command outputReader isNil ifTrue:[command blocker signal].

            command errorReader isNil ifTrue:[command blocker signal].

            "/Wait for eventual workers to finish"

            command blocker wait.

            "/Reset streams...

            Trace ifTrue:[

                Logger log: 'cmdsrv: channel o content: ' , channel_o contents printString severity: #trace facility: 'HG'.

            ].

            channel_e reset.

            Trace ifTrue:[

               Logger log: 'cmdsrv: channel e content: ' , channel_e contents printString severity: #trace facility: 'HG'.

            ].

            channel_o reset.

            Trace ifTrue:[

                Logger log: 'cmdsrv: runcommand finished' severity: #trace facility: 'HG'.

            ].

            channel_r reset.

        ].

        anHGCommand signal.

        command := nil.

        result := anHGCommand status: status result: anHGCommand result.

    ].

    ^result.

    "Created: / 24-02-2013 / 15:10:10 / Jan Vrany <jan.vrany@fit.cvut.cz>"

    "Modified (format): / 06-03-2013 / 00:34:38 / Jan Vrany <jan.vrany@fit.cvut.cz>"

!

old_execute: anHGCommand

    "Executes an HG command"

    | spin status blocker result |

    state ~~ #connected ifTrue:[

        "/spin-lock wait...

        [ #(disconnected connected) includes: state ] whileFalse:[

            Delay waitForMilliseconds: 15.

        ].

        state == #disconnected ifTrue:[

            self start

        ]

    ].

    repository synchronized:[

        command := anHGCommand.

        anHGCommand initialize.

        blocker := command blocker.

        self runcommand: command.

        anHGCommand spawn: [ 

            status := OperatingSystem osProcessStatusClass pid:nil status: #exit code: channel_r nextLongNet core:false.

            channel_e close.

            channel_o close.

            command outputReader isNil ifTrue:[

                Trace ifTrue:[

                    Logger log: 'cmdsrv: no output reader, signalling blocker' severity: #trace facility: 'HG'.

                ].

                blocker signal

            ].

            command errorReader isNil ifTrue:[

                Trace ifTrue:[

                    Logger log: 'cmdsrv: no error reader, signalling blocker' severity: #trace facility: 'HG'.

                ].

                blocker signal

            ].

        ] name: 'command server result reader'.

        spin := SemaphoreSet with: blocker with: anHGCommand errors readSemaphore.

        [

            [ spin wait ~~ blocker ] whileTrue:[ anHGCommand signal ]

        ] ensure:[

            Trace ifTrue:[

                Logger log: 'cmdsrv: channel o content: ' , channel_o contents printString severity: #trace facility: 'HG'.

            ].

            Trace ifTrue:[

                Logger log: 'cmdsrv: reseting channel o' severity: #trace facility: 'HG'.

            ].

            channel_e reset.

            Trace ifTrue:[

                Logger log: 'cmdsrv: channel e content: ' , channel_o contents printString severity: #trace facility: 'HG'.

            ].

            Trace ifTrue:[

                Logger log: 'cmdsrv: reseting channel e' severity: #trace facility: 'HG'.

            ].

            channel_o reset.

            Trace ifTrue:[

                Logger log: 'cmdsrv: runcommand finished' severity: #trace facility: 'HG'.

            ].

            command outputReader notNil ifTrue:[command outputReader terminate].

            command errorReader notNil ifTrue:[command errorReader terminate].

        ].

        anHGCommand signal.

        command := nil.

        result := anHGCommand status: status result: anHGCommand result.

    ].

    ^result.

    "Created: / 05-03-2013 / 23:49:45 / Jan Vrany <jan.vrany@fit.cvut.cz>"

! !

!HGCommandServer methodsFor:'initialization'!

initialize

    "Invoked when a new instance is created."

    "/ please change as required (and remove this comment)

    "/ repository := nil.

    "/ pid := nil.

    "/ input := nil.

    "/ output := nil.

    state := #disconnected.

    "/ readerwriter := nil.

    "/ encoder := nil.

    "/ channel_o := nil.

    "/ channel_e := nil.

    "/ channel_r := nil.

    "/ channel_d := nil.

    "/ channel_I := nil.

    "/ channel_L := nil.

    "/ super initialize.   -- commented since inherited method does nothing

    "Modified: / 24-02-2013 / 14:55:56 / Jan Vrany <jan.vrany@fit.cvut.cz>"

! !

!HGCommandServer methodsFor:'private'!

arguments

    ^{

        HGCommand hgCommand .

"/        '--debug' . '--verbose'.

        '--cwd' . repository pathName  .

        '--config' . 'ui.interactive=True' .

        'serve' .

        '--cmdserver' . 'pipe' .

    }

    "Created: / 24-02-2013 / 12:02:06 / Jan Vrany <jan.vrany@fit.cvut.cz>"

    "Modified: / 05-03-2013 / 19:37:58 / Jan Vrany <jan.vrany@fit.cvut.cz>"

!

channelWithId: channelId

    channelId == $o codePoint ifTrue:[

        ^ channel_o

    ].

    channelId == $e codePoint ifTrue:[

        ^ channel_e

    ].

    channelId == $r codePoint ifTrue:[

        ^ channel_r

    ].

    channelId == $d codePoint ifTrue:[

        ^ channel_d

    ].

    channelId == $I codePoint  ifTrue:[

        ^ channel_I

    ] .

    channelId == $L codePoint  ifTrue:[

        ^ channel_L

    ].

    channelId == $M codePoint ifTrue:[

        ^ channel_M

    ].

    self error: 'Invalid channel: ', channelId

    "Created: / 24-02-2013 / 12:59:04 / Jan Vrany <jan.vrany@fit.cvut.cz>"

    "Modified: / 03-03-2013 / 14:14:30 / Jan Vrany <jan.vrany@fit.cvut.cz>"

!

connect

    | label |

    state := #connecting.

    Trace ifTrue:[

        Logger log: 'cmdsrv: connecting...' severity: #trace facility: 'HG'.

    ].

    label := channel_o next: 13.

    label = 'capabilities:' ifFalse:[

        HGCommandError raiseErrorString: 'Invalid hello message: ', label.

    ].

    channel_o nextLine.

    label := channel_o next: 9.

    label = 'encoding:' ifFalse:[

        HGCommandError raiseErrorString: 'Expected ''encoding:'' message, got: ''', label , ''''.

    ].

    encoder := CharacterEncoder encoderFor: (channel_o nextAvailable: 1000).

    channel_o reset.

    state := #connected.

    Trace ifTrue:[

        Logger log: 'cmdsrv: connected...' severity: #trace facility: 'HG'.

    ].

    "Created: / 24-02-2013 / 12:19:50 / Jan Vrany <jan.vrany@fit.cvut.cz>"

    "Modified: / 06-03-2013 / 00:05:03 / Jan Vrany <jan.vrany@fit.cvut.cz>"

!

runcommand: anHGCommand

    "Issue runcommand command to the server"

    | args argslen |

    args := OrderedCollection streamContents:[:s|

        anHGCommand workingDirectory notNil ifTrue:[

            s nextPut: '--cwd'; nextPut: anHGCommand workingDirectory.

        ].

        anHGCommand argumentsGlobalOn:s.

        s nextPut:anHGCommand command.

        anHGCommand argumentsCommandOn:s.

    ].

    Trace ifTrue:[

        Logger log: 'cmdsrv: runcommand: ' , (args asStringWith:Character space)  severity: #trace facility: 'HG'.

    ].

    args := String streamContents:[:s|

        args 

            do:[:e|s nextPutAll: (encoder encodeString: e)]

            separatedBy:[s nextPut: (Character codePoint: 0)]].

    argslen := args size.

    output 

        nextPutLine:'runcommand';

        nextPutLongNet: argslen;

        nextPutAll: args

    "Created: / 03-03-2013 / 16:38:15 / Jan Vrany <jan.vrany@fit.cvut.cz>"

    "Modified: / 06-03-2013 / 02:30:45 / Jan Vrany <jan.vrany@fit.cvut.cz>"

!

startReaderWriter

    "Initialize channels"

    channel_o := InputChannel id: $o server: self.

    channel_e := InputChannel id: $e server: self.

    channel_r := InputChannel id: $r server: self.

    channel_r binary.

    channel_d := InputChannel id: $d server: self.

    channel_I := OutputChannel id: $I server: self.

    channel_L := OutputChannel id: $L server: self.

    channel_M := OutputChannel id: $M server: self.

    readerwriter := [

        [ state ~~ #disconnecting and:[ input isOpen ] ] whileTrue:[

            (input readWaitWithTimeoutMs: IdleTimeout) ifTrue:[

                "Timeouted. Stop the readwrite process, but only if no command is

                 running!!"

                command isNil ifTrue:[

                    Trace ifTrue:[

                        Logger log: 'cmdsrv: inactive for too long' severity: #trace facility: 'HG'.

                    ].

                    self stop

                ]

            ] ifFalse:[

                "Data available"

                input isOpen not ifFalse:[

                    self update

                ].

            ].

        ].

    ] newProcess.

    readerwriter addExitAction:[

        input := nil.

        output := nil.

        readerwriter := nil.

        state := #disconnected.

    ].

    readerwriter name: 'HG Reader/Writer: ', repository pathName.

    readerwriter resume.

    "Created: / 24-02-2013 / 12:47:35 / Jan Vrany <jan.vrany@fit.cvut.cz>"

    "Modified: / 06-03-2013 / 02:08:22 / Jan Vrany <jan.vrany@fit.cvut.cz>"

!

update

    "Reads from input stream and updates corresponding channel"

    | channel len data id |

    input readWait.

    id := input next.

    channel := self channelWithId: id.

    (channel == channel_I or:[channel == channel_L]) ifTrue:[

        self shouldImplement.

    ].

    len := input nextUnsignedLongNet.

    data := input next: len.

    channel update: data encoder: encoder.

    command notNil ifTrue:[

        channel == channel_o ifTrue:[

            command spawnOutputReaderOn: channel_o

        ] ifFalse:[channel == channel_e ifTrue:[

            command spawnErrorReaderOn: channel_e

        ]].

    ].

    "Created: / 24-02-2013 / 14:06:09 / Jan Vrany <jan.vrany@fit.cvut.cz>"

    "Modified: / 04-03-2013 / 00:02:55 / Jan Vrany <jan.vrany@fit.cvut.cz>"

! !

!HGCommandServer methodsFor:'start & stop'!

start

    "Starts the server and returns"

    | inputPipe outputPipe environment args |

    state := #starting.

    inputPipe := NonPositionableExternalStream makePipe.

    input := inputPipe first.

    input binary.

    OperatingSystem isMSWINDOWSlike ifTrue:[

        input lineEndTransparent.

    ].

    outputPipe := NonPositionableExternalStream makePipe.

    output := outputPipe second.

    OperatingSystem isMSWINDOWSlike ifTrue:[

        output lineEndTransparent.

    ].

"/    output binary.

    args := self arguments.

    OperatingSystem isMSWINDOWSlike ifTrue:[

        args := String streamContents:[:s|

            args

                do:[:each | s nextPut:$"; nextPutAll: each; nextPut: $"]

                separatedBy: [ s space ]

        ]

    ].

    environment := OperatingSystem isUNIXlike

                    ifTrue:[OperatingSystem getEnvironment copy]

                    ifFalse:[environment := Dictionary new].

    environment at: 'HGEDITOR' put: 'true'.

    environment at:'LANG' put:'C'.

    Processor monitor:[

        pid := OperatingSystem exec:(HGCommand hgCommand) withArguments: args

                environment:environment

                fileDescriptors:{outputPipe first fileDescriptor . inputPipe second fileDescriptor . 3}

                fork:true

                newPgrp:false

                inDirectory: Filename currentDirectory pathName.

        Trace ifTrue:[

            Logger log: 'cmdsrv: server started' severity: #trace facility: 'HG'.

        ].

        pid.

    ] action:[:stat |

        Trace ifTrue:[

            Logger log: 'cmdsrv: server terminated' severity: #trace facility: 'HG'.

        ].

    ].

    inputPipe second close.

    outputPipe first close.

    pid isNil ifTrue:[