1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
#!/usr/bin/env python
import sys, os, signal
import gobject
import dbus.service
import dbus.mainloop.glib
from olpc.datastore import DataStore, DS_LOG_CHANNEL, backingstore
import logging
# Path handling
profile = os.environ.get('SUGAR_PROFILE', 'default')
base_dir = os.path.join(os.path.expanduser('~'), '.sugar', profile)
repo_dir = os.path.join(base_dir, 'datastore')
# operate from the repo directory
if not os.path.exists(repo_dir): os.makedirs(repo_dir)
log_dir = os.path.join(base_dir, "logs")
if not os.path.exists(log_dir): os.makedirs(log_dir)
os.chdir(repo_dir)
# setup logger
filename = None
if not sys.stdin.isatty():
filename = os.path.join(log_dir, "datastore.log")
logging.basicConfig(level=logging.DEBUG,
format="%(asctime)-15s %(levelname)s: %(message)s",
filename = filename,
)
# disable subsystem logging except where critical
logger = logging.getLogger(DS_LOG_CHANNEL)
# check for old lockfiles, the rules here are that we can't be
# connected to a tty. If we are not then in all likelyhood the process
# was started automatically, which hopefully implies a single instance
if not sys.stdin.isatty():
lf = os.path.join(repo_dir, 'fulltext', 'flintlock')
if os.path.exists(lf):
logging.warning("Old lock file found -- removing.")
os.unlink(lf)
# build the datastore
dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)
bus = dbus.SessionBus()
ds = DataStore()
ds.registerBackend(backingstore.FileBackingStore)
ds.registerBackend(backingstore.InplaceFileBackingStore)
ds.mount(repo_dir)
# and run it
logger.info("Starting Datastore %s" % (repo_dir))
mainloop = gobject.MainLoop()
def handle_shutdown(signum, frame):
ds.stop()
print "shutdown cleanly"
raise SystemExit("Shutting down on signal %s" % signum)
signal.signal(signal.SIGHUP, handle_shutdown)
signal.signal(signal.SIGTERM, handle_shutdown)
def main():
try: mainloop.run()
except KeyboardInterrupt:
ds.stop()
logger.info("DataStore shutdown by user")
except:
ds.stop()
logger.debug("Datastore shutdown with error",
exc_info=sys.exc_info())
#main()
import hotshot
p = hotshot.Profile('hs.prof')
p.run('main()')
|
