Merge pull request #248 from alibaba-damo-academy/dev_grpc

zhifu gao

2023-03-16 5cb70f01026755fdcb3346997be74d82357269f2

 funasr/runtime/grpc/paraformer_server.h

@@ -31,6 +31,12 @@
using paraformer::Response;
using paraformer::ASR;

typedef struct
{
    std::string msg;
    float  snippet_time;
}RPASR_RECOG_RESULT;


class ASRServicer final : public ASR::Service {
  private:
@@ -39,13 +45,12 @@
    std::unordered_map<std::string, std::string> client_transcription;

  public:
    ASRServicer();
    ASRServicer(const char* model_path, int thread_num);
    void clear_states(const std::string& user);
    void clear_buffers(const std::string& user);
    void clear_transcriptions(const std::string& user);
    void disconnect(const std::string& user);
    grpc::Status Recognize(grpc::ServerContext* context, grpc::ServerReaderWriter<Response, Request>* stream);
    int nThreadNum = 4;
    RPASR_HANDLE AsrHanlde=RapidAsrInit("/data/asrmodel/speech_paraformer-large_asr_nat-zh-cn-16k-common-vocab8404-pytorch/", nThreadNum);
    RPASR_HANDLE AsrHanlde;
   
};