uint8_t data[ACM_SEND_SIZE];
};
-struct acm_client {
+struct acmc_client {
lock_t lock; /* acquire ep lock first */
SOCKET sock;
int index;
static SOCKET listen_socket;
static SOCKET ip_mon_socket;
-static struct acm_client client_array[FD_SETSIZE - 1];
+static struct acmc_client client_array[FD_SETSIZE - 1];
static FILE *flog;
static lock_t log_lock;
acm_resolve_response(uint64_t id, struct acm_msg *req_msg,
struct acmp_dest *dest, uint8_t status)
{
- struct acm_client *client = &client_array[id];
+ struct acmc_client *client = &client_array[id];
struct acm_msg msg;
int ret;
static int acm_query_response(uint64_t id, struct acm_msg *msg, uint8_t status)
{
- struct acm_client *client = &client_array[id];
+ struct acmc_client *client = &client_array[id];
int ret;
acm_log(2, "status 0x%x\n", status);
return 0;
}
-static void acm_disconnect_client(struct acm_client *client)
+static void acm_disconnect_client(struct acmc_client *client)
{
lock_acquire(&client->lock);
shutdown(client->sock, SHUT_RDWR);
}
static int
-acm_svr_query_path(struct acm_client *client, struct acm_msg *msg)
+acm_svr_query_path(struct acmc_client *client, struct acm_msg *msg)
{
struct acmc_ep *ep;
}
static int
-acm_svr_resolve_dest(struct acm_client *client, struct acm_msg *msg)
+acm_svr_resolve_dest(struct acmc_client *client, struct acm_msg *msg)
{
struct acmc_ep *ep;
struct acm_ep_addr_data *saddr, *daddr;
* lookup the destination by either LID or GID.
*/
static int
-acm_svr_resolve_path(struct acm_client *client, struct acm_msg *msg)
+acm_svr_resolve_path(struct acmc_client *client, struct acm_msg *msg)
{
struct acmc_ep *ep;
struct ibv_path_record *path;
return acmp_resolve_dest(ep, msg, id);
}
-static int acm_svr_resolve(struct acm_client *client, struct acm_msg *msg)
+static int acm_svr_resolve(struct acmc_client *client, struct acm_msg *msg)
{
(void) atomic_inc(&client->refcnt);
}
}
-static int acm_svr_perf_query(struct acm_client *client, struct acm_msg *msg)
+static int acm_svr_perf_query(struct acmc_client *client, struct acm_msg *msg)
{
int ret, i;
uint16_t len;
msg->hdr.length : ntohs(msg->hdr.length);
}
-static void acm_svr_receive(struct acm_client *client)
+static void acm_svr_receive(struct acmc_client *client)
{
struct acm_msg msg;
int ret;