Add grpc thread for pulsar subscribe info

[luyaoluo]

This PR contains:

1. Add a separate gRPC thread to get pulsar subscribe info.
2. Add a test case in gs_tests.

A sample output:

[zzxgzgz]

Hi @lly00 , thank you for the PR.

I looked at the files, and one thing I noticed is that, some of the newly added files, for example,

• include/aca_async_grpc_subscribe_server.h
• include/aca_grpc_subscribe.h
• src/comm/aca_grpc_subscribe.cpp

are very similar, if not identical to the existing files.

It looks like that you are trying to add a new gRPC service to ACA. If so, you should consider utilizing the existing gRPC server/client, rather than creating new ones that serves the same purpose. With your current code, I believe it will create two gRPC servers and clients, which is not what we want.

I believe some modifications in src/comm/aca_grpc_client.cpp, src/comm/aca_grpc.cpp and their header files should be able to achieve your purpose. Could you please give it a try?

Thank you.

[luyaoluo]

Got, I'll try it.

[xieus]

@zzxgzgz @lfu-ps Could you pls review this update, which include quite a few new commits? Thanks.

[zzxgzgz]

@lly00

I noticed that you pushed some updates recently, was the previous concerns addressed?

Also, could you please resolve the conflicts so that the checks can be run?

Thank you.

[luyaoluo]

@lly00

I noticed that you pushed some updates recently, was the previous concerns addressed?

Also, could you please resolve the conflicts so that the checks can be run?

Thank you.

We added some updates to differentiate messages from gRPC and pulsar for easier debugging. I might also need to make some other updates for testing. After this, I will resolve the conflict for review.
Thanks for your comment.