Windows XMLRPC Service

[half.italian]

Hi,

I'm trying to serve up a simple XMLRPC server as a windows service. I
got it to run properly, I'm just not sure how to stop it properly.
Most of the documentation/examples I found for this was from forums,
so I'd love some links to relevant info also. Here's what I
have...taken from the cookbook with the xmlrpc server added:

import win32serviceuti l
import win32service
import win32event

import SimpleXMLRPCSer ver

class MyClass(object) :
def hello(self):
return "Hello World!"

class SmallestPythonS ervice(win32ser viceutil.Servic eFramework):
_svc_name_ = "PythonXMLR PC"
_svc_display_na me_ = "PythonXMLR PC"

def __init__(self, args):
win32serviceuti l.ServiceFramew ork.__init__(se lf, args)
# Create an event which we will use to wait on.
# The "service stop" request will set this event.
self.hWaitStop = win32event.Crea teEvent(None, 0, 0, None)

def SvcStop(self):
# Before we do anything, tell the SCM we are starting the stop
process.
self.ReportServ iceStatus(win32 service.SERVICE _STOP_PENDING)

# quit the xmlrpc sever
self.server.qui t()

# And set my event.
win32event.SetE vent(self.hWait Stop)

def SvcDoRun(self):
# Serve up the XMLRPC forever
self.server =
SimpleXMLRPCSer ver.SimpleXMLRP CServer(("10.0. 1.6", 8000))
self.server.reg ister_instance( MyClass())
self.server.ser ve_forever()

win32event.Wait ForSingleObject (self.hWaitStop )
if __name__=='__ma in__':
win32serviceuti l.HandleCommand Line(SmallestPy thonService)

~Sean

[Gabriel Genellina]

En Mon, 18 Jun 2007 00:25:25 -0300, <ha**********@g mail.comescribi ó:

I'm trying to serve up a simple XMLRPC server as a windows service. I
got it to run properly, I'm just not sure how to stop it properly.
Most of the documentation/examples I found for this was from forums,
so I'd love some links to relevant info also. Here's what I
have...taken from the cookbook with the xmlrpc server added:

def __init__(self, args):
win32serviceuti l.ServiceFramew ork.__init__(se lf, args)
# Create an event which we will use to wait on.
# The "service stop" request will set this event.
self.hWaitStop = win32event.Crea teEvent(None, 0, 0, None)

def SvcStop(self):
# Before we do anything, tell the SCM we are starting the stop
process.
self.ReportServ iceStatus(win32 service.SERVICE _STOP_PENDING)

# quit the xmlrpc sever
self.server.qui t()

What is quit()? As the server may be processing a request I'd move any
finalization code below, after exiting the while loop.

>
# And set my event.
win32event.SetE vent(self.hWait Stop)

def SvcDoRun(self):
# Serve up the XMLRPC forever
self.server =
SimpleXMLRPCSer ver.SimpleXMLRP CServer(("10.0. 1.6", 8000))
self.server.reg ister_instance( MyClass())
self.server.ser ve_forever()

win32event.Wait ForSingleObject (self.hWaitStop )

The simplest solution is to replace serve_forever with a loop waiting on
hWaitStop:

while WaitForSingleOb ject(self.hWait Stop, 0)==WAIT_TIMEOU T:
self.server.han dle_request()

Set the socket timeout to a reasonable value (you'll have to wait that
time before exiting). Also, a ThreadingTCPSer ver may be better if you
expect more than a request at a time. If you search past messages you may
find other ways.

--
Gabriel Genellina

[half.italian]

On Jun 18, 2:16 am, "Gabriel Genellina" <[e-mail].a r>
wrote:

En Mon, 18 Jun 2007 00:25:25 -0300, <half.ital...@g mail.comescribi ó:

I'm trying to serve up a simple XMLRPC server as a windows service. I
got it to run properly, I'm just not sure how to stop it properly.
Most of the documentation/examples I found for this was from forums,
so I'd love some links to relevant info also. Here's what I
have...taken from the cookbook with the xmlrpc server added:

def __init__(self, args):
win32serviceuti l.ServiceFramew ork.__init__(se lf, args)
# Create an event which we will use to wait on.
# The "service stop" request will set this event.
self.hWaitStop = win32event.Crea teEvent(None, 0, 0, None)

def SvcStop(self):
# Before we do anything, tell the SCM we are starting the stop
process.
self.ReportServ iceStatus(win32 service.SERVICE _STOP_PENDING)

# quit the xmlrpc sever
self.server.qui t()

What is quit()? As the server may be processing a request I'd move any
finalization code below, after exiting the while loop.

# And set my event.
win32event.SetE vent(self.hWait Stop)

def SvcDoRun(self):
# Serve up the XMLRPC forever
self.server =
SimpleXMLRPCSer ver.SimpleXMLRP CServer(("10.0. 1.6", 8000))
self.server.reg ister_instance( MyClass())
self.server.ser ve_forever()

win32event.Wait ForSingleObject (self.hWaitStop )

The simplest solution is to replace serve_forever with a loop waiting on
hWaitStop:

while WaitForSingleOb ject(self.hWait Stop, 0)==WAIT_TIMEOU T:
self.server.han dle_request()

Set the socket timeout to a reasonable value (you'll have to wait that
time before exiting). Also, a ThreadingTCPSer ver may be better if you
expect more than a request at a time. If you search past messages you may
find other ways.

--
Gabriel Genellina- Hide quoted text -

- Show quoted text -

I can't quite figure out where to set the "socket timeout". I tried
setting win32event.WAIT _TIMEOUT, but I'm pretty sure that's not the
variable you were talking about. I did manage to make it multi-
threaded by incorporating a different recipe, and I'm beginning to
understand the control flow a bit better, but it doesn't seem to be
doing what I expect. When SvcStop() is executed and calls
win32event.SetE vent(self.hWait Stop), the while loop should break as
win32event.Wait ForSingleObject (self.hWaitStop , 0) returns zero at this
point. But it doesn't do that. What am I missing?

import win32serviceuti l
import win32service
import win32event

import SocketServer
from SimpleXMLRPCSer ver import
SimpleXMLRPCSer ver,SimpleXMLRP CRequestHandler

# Threaded mix-in
class
AsyncXMLRPCServ er(SocketServer .ThreadingMixIn ,SimpleXMLRPCSe rver):
pass
class MyClass(object) :
def hello(self):
return "Hello World"

class SmallestPythonS ervice(win32ser viceutil.Servic eFramework):
_svc_name_ = "PythonXMLR PC"
_svc_display_na me_ = "PythonXMLR PC"

def __init__(self, args):
win32serviceuti l.ServiceFramew ork.__init__(se lf, args)
# Create an event which we will use to wait on.
self.hWaitStop = win32event.Crea teEvent(None, 0, 0, None)
import socket
localhost = socket.gethostb yname(socket.ge thostname())
self.server = AsyncXMLRPCServ er((localhost, 8000),
SimpleXMLRPCReq uestHandler)

def SvcStop(self):
self.ReportServ iceStatus(win32 service.SERVICE _STOP_PENDING)
win32event.SetE vent(self.hWait Stop)
#print "EVENT:",
win32event.Wait ForSingleObject (self.hWaitStop , 0) # returns 0 here

def SvcDoRun(self):
self.server.reg ister_instance( MyClass())

#win32event.WAI T_TIMEOUT = 2 --- This just makes the loop
never execute because
# the WaitFor... part always returns 258

while win32event.Wait ForSingleObject (self.hWaitStop , 0) ==
win32event.WAIT _TIMEOUT:
self.server.han dle_request()

if __name__ == '__main__':
win32serviceuti l.HandleCommand Line(SmallestPy thonService)

Thanks for any help!

~Sean

[Gabriel Genellina]

En Tue, 19 Jun 2007 03:45:19 -0300, <ha**********@g mail.comescribi ó:

I can't quite figure out where to set the "socket timeout". I tried
setting win32event.WAIT _TIMEOUT, but I'm pretty sure that's not the
variable you were talking about. I did manage to make it multi-
threaded by incorporating a different recipe, and I'm beginning to
understand the control flow a bit better, but it doesn't seem to be
doing what I expect. When SvcStop() is executed and calls
win32event.SetE vent(self.hWait Stop), the while loop should break as
win32event.Wait ForSingleObject (self.hWaitStop , 0) returns zero at this
point. But it doesn't do that. What am I missing?

May be because you didn't set correctly the socket timeout. See the
comments below.

>
def SvcStop(self):
self.ReportServ iceStatus(win32 service.SERVICE _STOP_PENDING)
win32event.SetE vent(self.hWait Stop)
#print "EVENT:",
win32event.Wait ForSingleObject (self.hWaitStop , 0) # returns 0 here

That's OK, since you have set the event.

def SvcDoRun(self):
self.server.reg ister_instance( MyClass())

#win32event.WAI T_TIMEOUT = 2 --- This just makes the loop
never execute because
# the WaitFor... part always returns 258

WAIT_TIMEOUT is 258. How do you see it is 2?
For example, see <http://msdn2.microsoft .com/en-us/library/ms681382.aspx>.
Python 2.5.1 + pywin32 210 prints this on my PC:
pyimport win32event
pywin32event.WA IT_TIMEOUT
258

while win32event.Wait ForSingleObject (self.hWaitStop , 0) ==
win32event.WAIT _TIMEOUT:
self.server.han dle_request()

The loop above should keep running until hWaitStop is set, with a maximum
wait time (inside handle_request) corresponding to the socket timeout
value.
You can either:
- use socket.setdefau lttimeout() (in __init__, by example) before anything
else. This will set a global timeout for all sockets.
- modify the socket instance. Just add this method to your AsyncServer:
def server_activate (self):
SimpleXMLRPCSer ver.server_acti vate(self)
self.socket.set timeout(15) # for 15 secs
--
Gabriel Genellina

[half.italian]

On Jun 19, 10:21 am, "Gabriel Genellina" <[e-mail].a r>
wrote:

En Tue, 19 Jun 2007 03:45:19 -0300, <half.ital...@g mail.comescribi ó:

I can't quite figure out where to set the "socket timeout". I tried
setting win32event.WAIT _TIMEOUT, but I'm pretty sure that's not the
variable you were talking about. I did manage to make it multi-
threaded by incorporating a different recipe, and I'm beginning to
understand the control flow a bit better, but it doesn't seem to be
doing what I expect. When SvcStop() is executed and calls
win32event.SetE vent(self.hWait Stop), the while loop should break as
win32event.Wait ForSingleObject (self.hWaitStop , 0) returns zero at this
point. But it doesn't do that. What am I missing?

May be because you didn't set correctly the socket timeout. See the
comments below.

def SvcStop(self):
self.ReportServ iceStatus(win32 service.SERVICE _STOP_PENDING)
win32event.SetE vent(self.hWait Stop)
#print "EVENT:",
win32event.Wait ForSingleObject (self.hWaitStop , 0) # returns 0 here

That's OK, since you have set the event.

def SvcDoRun(self):
self.server.reg ister_instance( MyClass())

#win32event.WAI T_TIMEOUT = 2 --- This just makes the loop
never execute because
# the WaitFor... part always returns 258

WAIT_TIMEOUT is 258. How do you see it is 2?
For example, see <http://msdn2.microsoft .com/en-us/library/ms681382.aspx>.
Python 2.5.1 + pywin32 210 prints this on my PC:
pyimport win32event
pywin32event.WA IT_TIMEOUT
258

while win32event.Wait ForSingleObject (self.hWaitStop , 0) ==
win32event.WAIT _TIMEOUT:
self.server.han dle_request()

The loop above should keep running until hWaitStop is set, with a maximum
wait time (inside handle_request) corresponding to the socket timeout
value.
You can either:
- use socket.setdefau lttimeout() (in __init__, by example) before anything
else. This will set a global timeout for all sockets.
- modify the socket instance. Just add this method to your AsyncServer:
def server_activate (self):
SimpleXMLRPCSer ver.server_acti vate(self)
self.socket.set timeout(15) # for 15 secs

--
Gabriel Genellina

def SvcDoRun(self):
self.server.reg ister_instance( MyClass())

#win32event.WAI T_TIMEOUT = 2 --- This just makes the loop
never execute because
# the WaitFor... part always returns 258

WAIT_TIMEOUT is 258. How do you see it is 2?
For example, see <http://msdn2.microsoft .com/en-us/library/ms681382.aspx>.
Python 2.5.1 + pywin32 210 prints this on my PC:
pyimport win32event
pywin32event.WA IT_TIMEOUT
258

I meant here that *if* I set the WAIT_TIMEOUT to 2, then I see that
behavior.

- use socket.setdefau lttimeout() (in __init__, by example) before anything
else. This will set a global timeout for all sockets.

That was the one that did it.

Thank you again Gabriel. I'll post back with something complete.

~Sean

[Gabriel Genellina]

En Tue, 19 Jun 2007 14:57:10 -0300, <ha**********@g mail.comescribi ó:

#win32event.WAI T_TIMEOUT = 2 --- This just makes the loop
never execute because
# the WaitFor... part always returns 258

WAIT_TIMEOUT is 258. How do you see it is 2?
pyimport win32event
pywin32event.W AIT_TIMEOUT
258

I meant here that *if* I set the WAIT_TIMEOUT to 2, then I see that
behavior.

Ah, ok! I should have stated clearly that WAIT_TIMEOUT is a Windows
predefined constant, not your desired timeout value.

Thank you again Gabriel. I'll post back with something complete.

Yes, please, a working example would be nice for future readers...

--
Gabriel Genellina

[half.italian]

On Jun 19, 12:32 pm, "Gabriel Genellina" <[e-mail].a r>
wrote:

En Tue, 19 Jun 2007 14:57:10 -0300, <half.ital...@g mail.comescribi ó:

#win32event.WAI T_TIMEOUT = 2 --- This just makes the loop
never execute because
# the WaitFor... part always returns 258

WAIT_TIMEOUT is 258. How do you see it is 2?
pyimport win32event
pywin32event.WA IT_TIMEOUT
258

I meant here that *if* I set the WAIT_TIMEOUT to 2, then I see that
behavior.

Ah, ok! I should have stated clearly that WAIT_TIMEOUT is a Windows
predefined constant, not your desired timeout value.

Thank you again Gabriel. I'll post back with something complete.

Yes, please, a working example would be nice for future readers...

--
Gabriel Genellina

For posterity...

import sys
import win32serviceuti l
import win32service
import win32event
import win32evtlogutil
import servicemanager

import SocketServer, socket
from SimpleXMLRPCSer ver import
SimpleXMLRPCSer ver,SimpleXMLRP CRequestHandler

# Threaded mix-in
class
AsyncXMLRPCServ er(SocketServer .ThreadingMixIn ,SimpleXMLRPCSe rver):
pass

import XMLRPC_funcs # module containing the functions wrapped in a
class

class XMLRPCservice(w in32serviceutil .ServiceFramewo rk):
_svc_name_ = "PythonXMLR PC"
_svc_display_na me_ = "PythonXMLR PC"
_svc_descriptio n_ = "Multi-threaded Python XMLRPC Server"

def __init__(self, args):
# set the timeout so the service can stop...Otherwis e it hangs
forever
socket.setdefau lttimeout(15)

win32evtlogutil .AddSourceToReg istry(self._svc _display_name_,
sys.executable, "Applicatio n")
win32serviceuti l.ServiceFramew ork.__init__(se lf, args)

# Create an event which we will use to wait on.
self.hWaitStop = win32event.Crea teEvent(None, 0, 0, None)
localhost = socket.gethostb yname(socket.ge thostname())
self.server = AsyncXMLRPCServ er((localhost, 8000),
SimpleXMLRPCReq uestHandler)

def SvcStop(self):
self.ReportServ iceStatus(win32 service.SERVICE _STOP_PENDING)
#send the stop event
win32event.SetE vent(self.hWait Stop)

def SvcDoRun(self):
# log a start msg

servicemanager. LogMsg(servicem anager.EVENTLOG _INFORMATION_TY PE,
servicemanager. PYS_SERVICE_STA RTED,
(self._svc_name _, ' (%s)' %
self._svc_name_ ))

self.server.reg ister_instance( XMLRPC_funcs.XM LRPC_funcs())

# handle requests until the stop event is received
while win32event.Wait ForSingleObject (self.hWaitStop , 0) ==
win32event.WAIT _TIMEOUT:
self.server.han dle_request()

# log a stopped msg
win32evtlogutil .ReportEvent(se lf._svc_name_,
servicemanager. PYS_SERVICE_STO PPED,
0,

servicemanager. EVENTLOG_INFORM ATION_TYPE,
(self._svc_name _,""))

if __name__ == '__main__':
win32serviceuti l.HandleCommand Line(XMLRPCserv ice)