return 'wrong password'
-def clear_cache(_,__,pw):
- if password == pw:
- store.tx_cache = {}
- return 'ok'
- else:
- return 'wrong password'
-
-def get_cache(_,__,pw,addr):
- if password == pw:
- return store.tx_cache.get(addr)
- else:
- return 'wrong password'
-
ret = {}
k = 0
for addr in addresses:
- if store.tx_cache.get( addr ) is not None: k += 1
status = get_address_status( addr )
msg_id, last_status = addresses.get( addr )
if last_status != status:
def get_peers_json(_,__):
return peer_list.values()
-def http_server_thread(store):
+def http_server_thread():
# see http://code.google.com/p/jsonrpclib/
from SocketServer import ThreadingMixIn
from StratumJSONRPCServer import StratumJSONRPCServer
server.register_function(get_peers_json, 'server.peers')
server.register_function(cmd_stop, 'stop')
server.register_function(cmd_load, 'load')
- server.register_function(clear_cache, 'clear_cache')
- server.register_function(get_cache, 'get_cache')
server.register_function(get_banner, 'server.banner')
server.register_function(lambda a,b,c: send_tx(c), 'transaction.broadcast')
server.register_function(address_get_history_json, 'address.get_history')
# supported protocols
thread.start_new_thread(native_server_thread, ())
thread.start_new_thread(tcp_server_thread, ())
- thread.start_new_thread(http_server_thread, (store,))
+ thread.start_new_thread(http_server_thread, ())
thread.start_new_thread(clean_session_thread, ())
if (config.get('server','irc') == 'yes' ):