Lines Matching defs:cn
64 struct cache_ftfw *cn = data;
65 cn->obj = obj;
67 queue_node_init(&cn->qnode, Q_ELEM_OBJ);
72 struct cache_ftfw *cn = data;
73 queue_del(&cn->qnode);
174 struct cache_ftfw *cn = cache_get_extra(obj);
176 if (queue_in(rs_queue, &cn->qnode)) {
177 queue_del(&cn->qnode);
178 queue_add(STATE_SYNC(tx_queue), &cn->qnode);
180 if (queue_add(STATE_SYNC(tx_queue), &cn->qnode) > 0)
200 struct cache_ftfw *cn = (struct cache_ftfw *) n;
201 size = sprintf(buf, "object -> seq:%u\n", cn->seq);
266 struct cache_ftfw *cn;
268 cn = (struct cache_ftfw *) n;
269 if (before(cn->seq, nack->from))
271 else if (after(cn->seq, nack->to))
274 dp("resending nack'ed (oldseq=%u)\n", cn->seq);
308 struct cache_ftfw *cn;
310 cn = (struct cache_ftfw *) n;
313 cache_object_put(cn->obj);
316 if (before(cn->seq, h->from))
318 else if (after(cn->seq, h->to))
321 dp("queue: deleting from queue (seq=%u)\n", cn->seq);
323 cache_object_put(cn->obj);
471 struct cache_ftfw *cn;
473 cn = (struct cache_ftfw *)n;
474 cache_object_put(cn->obj);
515 struct cache_ftfw *cn;
519 cn = (struct cache_ftfw *)n;
520 type = object_status_to_network_type(cn->obj);
521 net = cn->obj->cache->ops->build_msg(cn->obj, type);
528 cn->seq = ntohl(net->seq);
529 if (queue_add(rs_queue, &cn->qnode) < 0) {
532 queue_add(rs_queue, &cn->qnode);
553 struct cache_ftfw *cn = cache_get_extra(obj);
554 if (queue_in(rs_queue, &cn->qnode)) {
555 queue_del(&cn->qnode);
556 queue_add(STATE_SYNC(tx_queue), &cn->qnode);
558 if (queue_add(STATE_SYNC(tx_queue), &cn->qnode) > 0)