test

kaldigstserver/decoder.py

@@ -73,7 +73,7 @@ class DecoderPipeline(object):
            #self.tee,
            #self.queue1, 
            #self.filesink,
-            self.queue2, 
+           #self.queue2, 
            #self.cutter, 
             self.asr, 
             self.fakesink]:
@@ -88,11 +88,32 @@ class DecoderPipeline(object):
         if self.use_cutter:
             self.cutter.link(self.audioconvert)
               
-              
-        self.audioconvert.link(self.queue2)
-        self.queue2.link(self.asr)
-        self.asr.link(self.fakesink)
 
+        self.audioconvert.link(self.asr)
+        self.asr.link(self.fakesink)   
+
+#        self.audioconvert.link(self.queue2)
+#        self.queue2.link(self.asr)
+#        self.asr.link(self.fakesink)
+
+
+
+
+#        self.audioconvert.link(self.audioresample)
+#
+#        self.audioresample.link(self.tee)
+#        #self.audioresample.link(self.cutter)
+#        #self.cutter.link(self.tee)
+#
+#        self.tee.link(self.queue1)
+#        self.queue1.link(self.filesink)
+#
+#        self.tee.link(self.queue2)
+#        self.queue2.link(self.asr)
+#
+#
+#        self.asr.link(self.fakesink)
+#
         # Create bus and connect several handlers
         self.bus = self.pipeline.get_bus()
         self.bus.add_signal_watch()

kaldigstserver/master_server.py

@@ -166,6 +166,7 @@ class HttpChunkedRecognizeHandler(tornado.web.RequestHandler):
         if self.error_status == 0:
             logging.info("%s: #########################Final hyp: %s" % (self.id, hyp))
             response = {"status" : 0, "id": self.id, "hypotheses": [{"utterance" : self}]}
+            logging.info("___##############___###########Final hyp: %s" % (response))
             self.write(response)
         else:
             logging.info("%s: Error (status=%d) processing HTTP request: %s" % (self.id, self.error_status, self.error_message))