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));
1437 struct hmdfs_peer *peer = to_peer(kobj);
1439 return fill_features(buf, peer->features);
1445 struct hmdfs_peer *peer = to_peer(kobj);
1457 to_sysfs_fmt_evt(peer->cur_evt[0]),
1458 peer->cur_evt_seq[0],
1459 to_sysfs_fmt_evt(peer->cur_evt[1]),
1460 peer->cur_evt_seq[1],
1461 to_sysfs_fmt_evt(peer->pending_evt),
1462 peer->pending_evt_seq,
1463 peer->merged_evt,
1464 peer->dup_evt[RAW_NODE_EVT_OFF],
1465 peer->dup_evt[RAW_NODE_EVT_ON],
1466 peer->waiting_evt[RAW_NODE_EVT_OFF],
1467 peer->waiting_evt[RAW_NODE_EVT_ON],
1468 peer->seq_tbl[0], peer->seq_tbl[1], peer->seq_tbl[2],
1469 peer->seq_tbl[3],
1470 peer->seq_rd_idx % RAW_NODE_EVT_MAX_NR,
1471 peer->seq_wr_idx % RAW_NODE_EVT_MAX_NR);
1477 struct hmdfs_peer *peer = to_peer(kobj);
1488 peer->stats.stash.cur_ok,
1489 peer->stats.stash.cur_nothing,
1490 peer->stats.stash.cur_fail,
1491 peer->stats.stash.total_ok,
1492 peer->stats.stash.total_nothing,
1493 peer->stats.stash.total_fail,
1494 peer->stats.stash.ok_pages,
1495 peer->stats.stash.fail_pages);
1501 struct hmdfs_peer *peer = to_peer(kobj);
1512 peer->stats.restore.cur_ok,
1513 peer->stats.restore.cur_fail,
1514 peer->stats.restore.cur_keep,
1515 peer->stats.restore.total_ok,
1516 peer->stats.restore.total_fail,
1517 peer->stats.restore.total_keep,
1518 peer->stats.restore.ok_pages,
1519 peer->stats.restore.fail_pages);
1525 struct hmdfs_peer *peer = to_peer(kobj);
1535 peer->stats.rebuild.cur_ok,
1536 peer->stats.rebuild.cur_fail,
1537 peer->stats.rebuild.cur_invalid,
1538 peer->stats.rebuild.total_ok,
1539 peer->stats.rebuild.total_fail,
1540 peer->stats.rebuild.total_invalid,
1541 peer->stats.rebuild.time);
1586 struct hmdfs_peer *peer = to_peer(kobj);
1588 complete(&peer->kobj_unregister);
1598 struct hmdfs_peer *peer)
1602 init_completion(&peer->kobj_unregister);
1603 err = kobject_init_and_add(&peer->kobj, &peer_ktype, &sbi->kobj,
1604 "peer_%llu", peer->device_id);
1608 void hmdfs_release_peer_sysfs(struct hmdfs_peer *peer)
1610 kobject_del(&peer->kobj);
1611 kobject_put(&peer->kobj);
1612 wait_for_completion(&peer->kobj_unregister);