@@ -0,0 +1,42 @@
+Please keep this module independent from the outside code, so that it can be reused in other applications.

@@ -0,0 +90,4 @@
+        self.currentTaskID = None
+
+    def notifyStatus(self):
+        if self.statusUpdated is None:

@@ -0,0 +154,4 @@
+
+        self.notifyStatus()
+
+    def addTask(self, ID, headlessPayload, TTL, expiryTime, byteDifficulty, lengthExtension):

@@ -0,0 +223,4 @@
+
+        task = self.tasks[self.currentTaskID]
+
+        if task.expiryTime is None:

@@ -0,0 +234,4 @@
+        appendedSeed = self.seed + struct.pack(">Q", self.roundsCounter)
+        self.roundsCounter += 1
+
+        try:

@@ -0,0 +2,4 @@
+import os.path
+import platform
+import subprocess
+import sys

@@ -0,0 +13,4 @@
+
+        if platform.architecture()[0] == "64bit":
+            suffix = "-64"
+

@@ -0,0 +1,117 @@
+import multiprocessing
+import os

@@ -0,0 +1,42 @@
+Please keep this module independent from the outside code, so that it can be reused in other applications.

@@ -0,0 +90,4 @@
+        self.currentTaskID = None
+
+    def notifyStatus(self):
+        if self.statusUpdated is None:

@@ -13,2 +13,4 @@
+import socket
+import threading
 import time
 from binascii import hexlify, unhexlify

@@ -56,3 +51,3 @@
-from statusbar import BMStatusBar
 from network.asyncore_pollchoose import set_rates
 import sound
+import re

@@ -52,8 +52,8 @@ else:
 	arch=64
 

@@ -37,1 +37,4 @@
 
+def resendStaleMessages():
+    staleMessages = sqlQuery("""
+        SELECT "toaddress", "ackdata", "status" FROM "sent"

@@ -161,0 +195,4 @@
+            stream, readLength = addresses.decodeVarint(payload[readPosition: readPosition + 9])
+            readPosition += readLength
+
+            tag = buffer(payload[readPosition: readPosition + 32]) # May be shorter than 32 bytes for getpubkeys

@@ -0,0 +1,262 @@
+import Queue