blob: 6ec75ef8a24368e5e2a855c03f35e6b2b73431ac (
plain)
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
|
#!/usr/bin/env python
#
# Copyright (c) 2008-2012 WiredTiger, Inc.
# All rights reserved.
#
# See the file LICENSE for redistribution information.
#
# WiredTiger Python RPC server for testing and tutorials.
import sys
from wiredtiger.service import WiredTiger
from wiredtiger.service.ttypes import *
from wiredtiger.impl import *
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from thrift.server import TServer
class WiredTigerHandler:
handler = WiredTigerHandler()
processor = WiredTiger.Processor(handler)
transport = TSocket.TServerSocket(9090)
tfactory = TTransport.TBufferedTransportFactory()
pfactory = TBinaryProtocol.TBinaryProtocolFactory()
server = TServer.TSimpleServer(processor, transport, tfactory, pfactory)
# We could do one of these for a multithreaded server
#server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)
#server = TServer.TThreadPoolServer(processor, transport, tfactory, pfactory)
print 'Starting the server...'
server.serve()
print 'done.'
|
