Lines Matching refs:peer
51 hmdfs_err("failed to update ctrl node: cannot get peer");
88 hmdfs_err("failed to update devsl: cannot get peer");
91 hmdfs_info("Found peer: device_id = %llu", node->device_id);
119 hmdfs_info("Found peer: device_id = %llu", node->device_id);
199 struct hmdfs_peer *peer = NULL;
207 list_for_each_entry(peer, &sbi->connections.node_list, list) {
209 peer->cid, peer->status);
214 mutex_lock(&peer->conn_impl_list_lock);
215 list_for_each_entry(conn_impl, &peer->conn_impl_list, list) {
222 mutex_unlock(&peer->conn_impl_list_lock);
243 struct hmdfs_peer *peer = NULL;
249 list_for_each_entry(peer, &sbi->connections.node_list, list) {
251 mutex_lock(&peer->conn_impl_list_lock);
252 list_for_each_entry(conn_impl, &peer->conn_impl_list, list) {
265 mutex_unlock(&peer->conn_impl_list_lock);
275 struct hmdfs_peer *peer = NULL;
280 list_for_each_entry(peer, &sbi->connections.node_list, list) {
282 mutex_lock(&peer->conn_impl_list_lock);
283 list_for_each_entry(conn_impl, &peer->conn_impl_list, list) {
289 mutex_unlock(&peer->conn_impl_list_lock);
992 struct hmdfs_peer *peer = NULL;
998 list_for_each_entry(peer, &sbi->connections.node_list, list) {
999 idr = showmsg ? &peer->msg_idr : &peer->file_id_idr;
1003 peer->device_id, count, idr_get_cursor(idr));
1439 struct hmdfs_peer *peer = to_peer(kobj);
1441 return fill_features(buf, peer->features);
1447 struct hmdfs_peer *peer = to_peer(kobj);
1459 to_sysfs_fmt_evt(peer->cur_evt[0]),
1460 peer->cur_evt_seq[0],
1461 to_sysfs_fmt_evt(peer->cur_evt[1]),
1462 peer->cur_evt_seq[1],
1463 to_sysfs_fmt_evt(peer->pending_evt),
1464 peer->pending_evt_seq,
1465 peer->merged_evt,
1466 peer->dup_evt[RAW_NODE_EVT_OFF],
1467 peer->dup_evt[RAW_NODE_EVT_ON],
1468 peer->waiting_evt[RAW_NODE_EVT_OFF],
1469 peer->waiting_evt[RAW_NODE_EVT_ON],
1470 peer->seq_tbl[0], peer->seq_tbl[1], peer->seq_tbl[2],
1471 peer->seq_tbl[3],
1472 peer->seq_rd_idx % RAW_NODE_EVT_MAX_NR,
1473 peer->seq_wr_idx % RAW_NODE_EVT_MAX_NR);
1479 struct hmdfs_peer *peer = to_peer(kobj);
1490 peer->stats.stash.cur_ok,
1491 peer->stats.stash.cur_nothing,
1492 peer->stats.stash.cur_fail,
1493 peer->stats.stash.total_ok,
1494 peer->stats.stash.total_nothing,
1495 peer->stats.stash.total_fail,
1496 peer->stats.stash.ok_pages,
1497 peer->stats.stash.fail_pages);
1503 struct hmdfs_peer *peer = to_peer(kobj);
1514 peer->stats.restore.cur_ok,
1515 peer->stats.restore.cur_fail,
1516 peer->stats.restore.cur_keep,
1517 peer->stats.restore.total_ok,
1518 peer->stats.restore.total_fail,
1519 peer->stats.restore.total_keep,
1520 peer->stats.restore.ok_pages,
1521 peer->stats.restore.fail_pages);
1527 struct hmdfs_peer *peer = to_peer(kobj);
1537 peer->stats.rebuild.cur_ok,
1538 peer->stats.rebuild.cur_fail,
1539 peer->stats.rebuild.cur_invalid,
1540 peer->stats.rebuild.total_ok,
1541 peer->stats.rebuild.total_fail,
1542 peer->stats.rebuild.total_invalid,
1543 peer->stats.rebuild.time);
1560 ATTRIBUTE_GROUPS(peer);
1589 struct hmdfs_peer *peer = to_peer(kobj);
1591 complete(&peer->kobj_unregister);
1601 struct hmdfs_peer *peer)
1605 init_completion(&peer->kobj_unregister);
1606 err = kobject_init_and_add(&peer->kobj, &peer_ktype, &sbi->kobj,
1607 "peer_%llu", peer->device_id);
1611 void hmdfs_release_peer_sysfs(struct hmdfs_peer *peer)
1613 kobject_del(&peer->kobj);
1614 kobject_put(&peer->kobj);
1615 wait_for_completion(&peer->kobj_unregister);