Lines Matching defs:conn

51 	struct ptlrpc_connection *conn, *conn2;
53 conn = cfs_hash_lookup(conn_hash, &peer);
54 if (conn)
57 OBD_ALLOC_PTR(conn);
58 if (!conn)
61 conn->c_peer = peer;
62 conn->c_self = self;
63 INIT_HLIST_NODE(&conn->c_hash);
64 atomic_set(&conn->c_refcount, 1);
66 obd_str2uuid(&conn->c_remote_uuid, uuid->uuid);
69 * Add the newly created conn to the hash, on key collision we
77 conn2 = cfs_hash_findadd_unique(conn_hash, &peer, &conn->c_hash);
78 if (conn != conn2) {
79 OBD_FREE_PTR(conn);
80 conn = conn2;
83 CDEBUG(D_INFO, "conn=%p refcount %d to %s\n",
84 conn, atomic_read(&conn->c_refcount),
85 libcfs_nid2str(conn->c_peer.nid));
86 return conn;
90 int ptlrpc_connection_put(struct ptlrpc_connection *conn)
94 if (!conn)
97 LASSERT(atomic_read(&conn->c_refcount) > 1);
115 if (atomic_dec_return(&conn->c_refcount) == 1)
118 CDEBUG(D_INFO, "PUT conn=%p refcount %d to %s\n",
119 conn, atomic_read(&conn->c_refcount),
120 libcfs_nid2str(conn->c_peer.nid));
127 ptlrpc_connection_addref(struct ptlrpc_connection *conn)
129 atomic_inc(&conn->c_refcount);
130 CDEBUG(D_INFO, "conn=%p refcount %d to %s\n",
131 conn, atomic_read(&conn->c_refcount),
132 libcfs_nid2str(conn->c_peer.nid));
134 return conn;
172 struct ptlrpc_connection *conn;
177 conn = hlist_entry(hnode, struct ptlrpc_connection, c_hash);
179 return conn_key->nid == conn->c_peer.nid &&
180 conn_key->pid == conn->c_peer.pid;
186 struct ptlrpc_connection *conn;
187 conn = hlist_entry(hnode, struct ptlrpc_connection, c_hash);
188 return &conn->c_peer;
200 struct ptlrpc_connection *conn;
202 conn = hlist_entry(hnode, struct ptlrpc_connection, c_hash);
203 atomic_inc(&conn->c_refcount);
209 struct ptlrpc_connection *conn;
211 conn = hlist_entry(hnode, struct ptlrpc_connection, c_hash);
212 atomic_dec(&conn->c_refcount);
218 struct ptlrpc_connection *conn;
220 conn = hlist_entry(hnode, struct ptlrpc_connection, c_hash);
226 LASSERTF(atomic_read(&conn->c_refcount) == 0,
228 atomic_read(&conn->c_refcount));
229 OBD_FREE_PTR(conn);