Grpc Async Client Call

include/aca_arp_responder.h

@@ -24,52 +24,52 @@ using namespace std;
 
 namespace aca_arp_responder
 {
-
-#define ARP_ENTRY_DATA_SET(pData,pConfig)                           \
-  do {                                                              \
-    (pData)->ipv4_address = (pConfig)->ipv4_address;                \
-    (pData)->vlan_id = (pConfig)->vlan_id;                          \
-  } while (0)                                                       
-
-#define ARP_TABLE_DATA_SET(pData,pConfig)                           \
-  do {                                                              \
-    (pData)->mac_address = (pConfig)->mac_address;                  \
-  } while (0)  
-
-
-struct arp_config{
+#define ARP_ENTRY_DATA_SET(pData, pConfig)                                     \
+  do {                                                                         \
+    (pData)->ipv4_address = (pConfig)->ipv4_address;                           \
+    (pData)->vlan_id = (pConfig)->vlan_id;                                     \
+  } while (0)
+
+#define ARP_TABLE_DATA_SET(pData, pConfig)                                     \
+  do {                                                                         \
+    (pData)->mac_address = (pConfig)->mac_address;                             \
+  } while (0)
+
+struct arp_config {
   string mac_address;
   string ipv4_address;
-  string ipv6_address; 
+  string ipv6_address;
   uint16_t vlan_id;
   string port_host_name;
 };
 
-struct arp_entry_data{
+struct arp_entry_data {
   string ipv4_address;
-  string ipv6_address; 
+  string ipv6_address;
   uint16_t vlan_id;
-  bool operator==(const arp_entry_data &p) const{
-    return ipv4_address==p.ipv4_address && vlan_id==p.vlan_id;
+  bool operator==(const arp_entry_data &p) const
+  {
+    return ipv4_address == p.ipv4_address && vlan_id == p.vlan_id;
   }
 
-  bool operator!=(const arp_entry_data &p) const{
-    return ipv4_address!=p.ipv4_address || vlan_id!=p.vlan_id;
+  bool operator!=(const arp_entry_data &p) const
+  {
+    return ipv4_address != p.ipv4_address || vlan_id != p.vlan_id;
   }
 };
 
-
-struct arp_hash{
-  size_t operator() (const arp_entry_data &p) const{
+struct arp_hash {
+  size_t operator()(const arp_entry_data &p) const
+  {
     return hash<string>()(p.ipv4_address) ^ (hash<uint16_t>()(p.vlan_id) << 1);
   }
 };
 
-struct arp_table_data{
+struct arp_table_data {
   string mac_address;
 };
 
-struct arp_message{
+struct arp_message {
   uint16_t hrd;
   uint16_t pro;
   uint8_t hln;
@@ -79,9 +79,9 @@ struct arp_message{
   uint32_t spa;
   uint8_t tha[6];
   uint32_t tpa;
-} __attribute__ ((__packed__));
+} __attribute__((__packed__));
 
-struct vlan_message{
+struct vlan_message {
   uint16_t vlan_proto; //should always be 0x8100
   uint16_t vlan_tci;
 };
@@ -96,51 +96,48 @@ struct vlan_message{
 #define ARP_MSG_HRD_LEN (0x6)
 #define ARP_MSG_PRO_LEN (0x4)
 
-class ACA_ARP_Responder{
-  public:  
-    static ACA_ARP_Responder &get_instance();
+class ACA_ARP_Responder {
+  public:
+  static ACA_ARP_Responder &get_instance();
 
-    /* Managemet Plane Ops*/
-    int add_arp_entry(arp_config *arp_config_in);
-    int create_or_update_arp_entry(arp_config *arp_config_in);
-    int delete_arp_entry(arp_config *arp_config_in);
+  bool does_arp_entry_exist(arp_entry_data stData);
 
-    /* Data plane Ops */
-    int arp_recv(uint32_t in_port, void *vlanmsg, void *message);
-    void arp_xmit(uint32_t in_port, void *vlanmsg, void *message, int is_find);
-    string _get_requested_ip(arp_message *arpmsg);
-    string _get_source_ip(arp_message *arpmsg);
-    int _parse_arp_request(uint32_t in_port, vlan_message *vlanmsg, arp_message *arpmsg);
-
-  private:
-    ACA_ARP_Responder();
-    ~ACA_ARP_Responder();
-
-    CTSL::HashMap<arp_entry_data,arp_table_data *,arp_hash> _arp_db;
-
+  /* Managemet Plane Ops*/
+  int add_arp_entry(arp_config *arp_config_in);
+  int create_or_update_arp_entry(arp_config *arp_config_in);
+  int delete_arp_entry(arp_config *arp_config_in);
 
+  /* Data plane Ops */
+  int arp_recv(uint32_t in_port, void *vlanmsg, void *message);
+  void arp_xmit(uint32_t in_port, void *vlanmsg, void *message, int is_find);
+  string _get_requested_ip(arp_message *arpmsg);
+  string _get_source_ip(arp_message *arpmsg);
+  int _parse_arp_request(uint32_t in_port, vlan_message *vlanmsg, arp_message *arpmsg);
 
+  private:
+  ACA_ARP_Responder();
+  ~ACA_ARP_Responder();
 
-    /*************** Initialization and De-initialization ***********************/
-    void _init_arp_db();
-    void _deinit_arp_db();
-    void _init_arp_ofp();
-    void _deinit_arp_ofp();
+  CTSL::HashMap<arp_entry_data, arp_table_data *, arp_hash> _arp_db;
 
-    /*************** Management plane operations ***********************/
-    void _validate_mac_address(const char *mac_string);
-    void _validate_ipv4_address(const char *ip_address);
-    void _validate_ipv6_address(const char *ip_address);
-    int _validate_arp_entry(arp_config *arp_cfg_in);
+  /*************** Initialization and De-initialization ***********************/
+  void _init_arp_db();
+  void _deinit_arp_db();
+  void _init_arp_ofp();
+  void _deinit_arp_ofp();
 
-    /**************** Data plane operations *********************/
-    int _validate_arp_message(arp_message *arpmsg);
+  /*************** Management plane operations ***********************/
+  void _validate_mac_address(const char *mac_string);
+  void _validate_ipv4_address(const char *ip_address);
+  void _validate_ipv6_address(const char *ip_address);
+  int _validate_arp_entry(arp_config *arp_cfg_in);
 
-    arp_message *_pack_arp_reply(arp_message *arpreq, string mac_address);
+  /**************** Data plane operations *********************/
+  int _validate_arp_message(arp_message *arpmsg);
 
-    string _serialize_arp_message(vlan_message *vlanmsg, arp_message *arpmsg);
+  arp_message *_pack_arp_reply(arp_message *arpreq, string mac_address);
 
+  string _serialize_arp_message(vlan_message *vlanmsg, arp_message *arpmsg);
 };
 } // namespace aca_arp_responder
 #endif // #ifndef ACA_ARP_RESPONDER_H
-

include/aca_config.h

@@ -27,6 +27,13 @@
 
 #define DEFAULT_MTU 9000
 
-#define USLEEPTIME_IN_MICROSECONDS 15000
+#define ON_DEMAND_ENTRY_CLEANUP_FREQUENCY_IN_MICROSECONDS 10000000 // 10 seconds
+
+#define ON_DEMAND_ENTRY_EXPIRATION_IN_MICROSECONDS 10000000 // 10 seconds
+
+#define REQUEST_UUID_ON_DEMAND_PAYLOAD_MAP_MAX_SIZE 1000000 // one million
+
+#define REQUEST_UUID_ON_DEMAND_PAYLOAD_MAP_SIZE_CHECK_FREQUENCY_IN_MICROSECONDS \
+  1000 // 10 microsecond, which is 1 millisecond
 
 #endif // #ifndef ACA_CONFIG_H

include/aca_grpc.h

@@ -31,7 +31,9 @@ class GoalStateProvisionerImpl final : public GoalStateProvisioner::Service {
   public:
   std::unique_ptr<GoalStateProvisioner::Stub> stub_;
   std::shared_ptr<grpc_impl::Channel> chan_;
-  HostRequestReply RequestGoalStates(HostRequest *request);
+
+  void RequestGoalStates(HostRequest *request, grpc::CompletionQueue *cq);
+
   // ~GoalStateProvisionerImpl();
   explicit GoalStateProvisionerImpl(){};
   Status PushNetworkResourceStates(ServerContext *context, const GoalState *goalState,
@@ -50,3 +52,10 @@ class GoalStateProvisionerImpl final : public GoalStateProvisioner::Service {
   private:
   std::unique_ptr<Server> server;
 };
+
+struct AsyncClientCall {
+  alcor::schema::HostRequestReply reply;
+  grpc::ClientContext context;
+  grpc::Status status;
+  std::unique_ptr<grpc::ClientAsyncResponseReader<alcor::schema::HostRequestReply> > response_reader;
+};