Class: SekkaServer::Server
- Inherits:
-
Object
- Object
- SekkaServer::Server
- Defined in:
- lib/sekkaserver.rb
Instance Method Summary collapse
- #call(env) ⇒ Object
-
#initialize ⇒ Server
constructor
A new instance of Server.
Constructor Details
#initialize ⇒ Server
Returns a new instance of Server.
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 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 |
# File 'lib/sekkaserver.rb', line 49 def initialize $LOAD_PATH.push( File.dirname(__FILE__) + "/../lib" ) @core = Nendo::Core.new() @core.loadInitFile @core.evalStr( "(use debug.syslog)" ) @core.evalStr( "(use sekka.henkan)" ) @core.evalStr( '(define (writeToString sexp) (write-to-string sexp))' ) @core.evalStr( '(export-to-ruby writeToString)' ) (@kvs,@cachesv) = @core.openSekkaJisyo( SekkaServer::Config.dictType, SekkaServer::Config.dictSource, SekkaServer::Config.cacheSource ) @queue = EM::Queue.new @mutex = Mutex.new STDERR.puts( "----- Sekka Server Started -----" ) STDERR.printf( " Sekka version : %s\n", SekkaVersion.version ) STDERR.printf( " Nendo version : %s\n", Nendo::Core.version ) STDERR.printf( " dict-type : %s\n", SekkaServer::Config.dictType ) STDERR.printf( " dict-db : %s\n", SekkaServer::Config.dictSource ) STDERR.printf( " memcached : %s\n", SekkaServer::Config.cacheSource ) STDERR.printf( " listenPort : %s\n", SekkaServer::Config.listenPort ) STDERR.printf( " proxyHost : %s\n", SekkaServer::Config.proxyHost ) STDERR.printf( " proxyPort : %s\n", SekkaServer::Config.proxyPort ) STDERR.puts( "--------------------------------" ) begin @thread = Thread.new do Thread.pass EventMachine::run { d = DateTime.now EventMachine::PeriodicTimer.new( 1 ) do if not @queue.empty? @queue.pop { |word| arr = word.split( /[ ]+/ ) command = arr[0] userid = arr[1] @mutex.synchronize { case command when 'r' # register dictline = if 4 == arr.size arr[2] + " " + arr[3] else ";; comment" end STDERR.print "Info: processing [register(" + dictline + ") on " + userid + "] batch command... " begin registered = @core.registerUserJisyo(userid, @kvs, dictline) rescue RuntimeError "Info: missing [register(" + dictline + ")] batch command..." end if registered str = d.strftime( "%D %X" ) STDERR.puts "ADDED " + str @core.flushCacheServer( @cachesv ) else STDERR.puts "ignored" end when 'k' # kakutei arr = word.split( /[ ]+/ ) _key = arr[2] _tango = arr[3] STDERR.puts "Info: processing [kakutei(" + _tango + ")] batch command..." begin @core.sekkaKakutei( userid, @kvs, @cachesv, _key, _tango ) rescue RuntimeError STDERR.puts "Info: missing [kakutei(" + _tango + ")] batch command..." end STDERR.printf( "Info: kakutei [%s:%s] \n", _key, _tango ) when 'f' # flush STDERR.puts "Info: processing [flush] batch command..." begin n = @core.flushUserJisyo( userid, @kvs ) rescue RuntimeError STDERR.puts "Info: missing [flush] batch command..." end @core.flushCacheServer( @cachesv ) STDERR.printf( "info : flush [%s] user's dict %d entries. \n", userid, n ) end } } end end } end @thread.run rescue p $! # => "unhandled exception" end end |
Instance Method Details
#call(env) ⇒ Object
141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 |
# File 'lib/sekkaserver.rb', line 141 def call(env) req = Rack::Request.new(env) body = case req.request_method when 'POST' userid = URI.decode( req.params['userid'].force_encoding("UTF-8") ) format = URI.decode( req.params['format'].force_encoding("UTF-8") ) case req.path when "/henkan" _yomi = URI.decode( req.params[ 'yomi'].force_encoding("UTF-8") ) _limit = URI.decode( req.params[ 'limit'].force_encoding("UTF-8") ) _method = URI.decode( req.params['method'].force_encoding("UTF-8") ) _orRedis = if :redis == SekkaServer::Config.dictType then "or Redis-server" else "" end @mutex.synchronize { begin @core.writeToString( @core.sekkaHenkan( userid, @kvs, @cachesv, _yomi, _limit.to_i, _method )) rescue MemCache::MemCacheError "sekka-server: memcached server is down (or may be offline)" rescue Timeout result = "sekka-server: Timeout to request memcached server #{_orRedis} (may be offline)" rescue SocketError result = "sekka-server: SocketError to request memcached server #{_orRedis} (may be offline)" rescue Errno::ECONNREFUSED result = "sekka-server: ConnectionRefused to request memcached server #{_orRedis} (may be offline)" end } when "/kakutei" _key = URI.decode( req.params[ 'key'].force_encoding("UTF-8") ) _tango = URI.decode( req.params[ 'tango'].force_encoding("UTF-8") ) @queue.push( 'k ' + userid + " " + _key + " " + _tango ) when "/register" dict = URI.decode( req.params['dict'].force_encoding( "UTF-8" ) ).split( "\n" ) dict.each { |x| @queue.push( 'r ' + userid + " " + x ) } sprintf( "sekka-server:register request (%s) words added, current-queue-size (%s)", dict.size, @queue.size ) when "/flush" @queue.push( 'f ' + userid ) sprintf( "sekka-server:flush request successful." ) when "/googleime" _yomi = URI.decode( req.params[ 'yomi'].force_encoding("UTF-8") ) printf( "info : google-ime request [%s]\n", _yomi ) result = "sekka-server: google-ime error" begin result = @core.googleIme( _yomi, SekkaServer::Config.proxyHost, SekkaServer::Config.proxyPort ) rescue Timeout result = "sekka-server: Timeout to request google-ime (may be offline)" rescue SocketError result = "sekka-server: SocketError to request google-ime (may be offline)" rescue Errno::ECONNREFUSED result = "sekka-server: ConnectionRefused to request google-ime (or may be offline)" end @core.writeToString( result ) else sprintf( "sekka-server:unknown path name. [%s]", req.path ) end else "no message." end res = Rack::Response.new { |r| r.status = 200 r['Content-Type'] = "text/plain" r.write body } res.finish end |