dyn_response_mgr.h

#ifndef _DYN_RESPONSE_MGR_H_
#define _DYN_RESPONSE_MGR_H_
#define MAX_REPLICAS_PER_DC 3
struct response_mgr {
  bool is_read;
  bool done;
  /* we could use the dynamic array
     here. But we have only 3 ASGs */
  struct msg *responses[MAX_REPLICAS_PER_DC];
  uint32_t checksums[MAX_REPLICAS_PER_DC];
  uint8_t
      good_responses;     // non-error responses received. (nil) is not an error
  uint8_t max_responses;  // max responses expected.
  uint8_t quorum_responses;  // responses expected to form a quorum
  uint8_t error_responses;   // error responses received
  struct msg *err_rsp;       // first error response
  struct conn *conn;
  struct msg *msg;  // corresponding request
};

void init_response_mgr(struct response_mgr *rspmgr, struct msg *, bool is_read,
                       uint8_t max_responses, struct conn *conn);
// DN_OK if response was accepted
rstatus_t rspmgr_submit_response(struct response_mgr *rspmgr, struct msg *rsp);
bool rspmgr_check_is_done(struct response_mgr *rspmgr);
struct msg *rspmgr_get_response(struct response_mgr *rspmgr);
void rspmgr_free_response(struct response_mgr *rspmgr, struct msg *dont_free);
void rspmgr_free_other_responses(struct response_mgr *rspmgr,
                                 struct msg *dont_free);
rstatus_t msg_local_one_rsp_handler(struct msg *req, struct msg *rsp);
rstatus_t rspmgr_clone_responses(struct response_mgr *src,
                                 struct array *responses);

#endif