| /net/ceph/ |
| D | mon_client.c | 78 u32 epoch; in ceph_monmap_decode() local
91 ceph_decode_32_safe(p, end, epoch, e_inval); in ceph_monmap_decode()
115 dout("%s fsid %pU epoch %u num_mon %d\n", __func__, &fsid, epoch, in ceph_monmap_decode()
126 monmap->epoch = epoch; in ceph_monmap_decode()
421 u32 epoch, bool continuous) in __ceph_monc_want_map() argument
423 __le64 start = cpu_to_le64(epoch); in __ceph_monc_want_map()
427 epoch, continuous); in __ceph_monc_want_map()
441 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, in ceph_monc_want_map() argument
447 need_request = __ceph_monc_want_map(monc, sub, epoch, continuous); in ceph_monc_want_map()
460 u32 epoch) in __ceph_monc_got_map() argument
[all …]
|
| D | osd_client.c | 454 dest->epoch = src->epoch; in target_copy()
1477 (osdc->osdmap->epoch < osdc->epoch_barrier); in target_should_be_paused()
1543 t->epoch = osdc->osdmap->epoch; in calc_target()
1551 if (osdc->osdmap->epoch == pi->last_force_request_resend) { in calc_target()
2100 ceph_encode_32(&p, req->r_osdc->osdmap->epoch); in encode_request_partial()
2172 __le32 epoch; in encode_request_finish() member
2212 ceph_encode_copy(&p, &head.epoch, sizeof(head.epoch)); in encode_request_finish()
2281 req->r_t.spgid.shard, osd->o_osd, req->r_t.epoch, req->r_flags, in send_request()
2298 WARN_ON(!osdc->osdmap->epoch); in maybe_request_map()
2310 osdc->osdmap->epoch + 1, continuous)) in maybe_request_map()
[all …]
|
| D | debugfs.c | 42 seq_printf(s, "epoch %d\n", client->monc.monmap->epoch); in monmap_show()
66 seq_printf(s, "epoch %u barrier %u flags 0x%x\n", map->epoch, in osdmap_show()
195 seq_printf(s, "]/%d\te%u\t", t->acting.primary, t->epoch); in dump_target()
|
| D | osdmap.c | 1654 u32 epoch = 0; in osdmap_decode() local
1670 epoch = map->epoch = ceph_decode_32(p); in osdmap_decode()
1784 dout("full osdmap epoch %d max_osd %d\n", map->epoch, map->max_osd); in osdmap_decode()
1791 err, epoch, (int)(*p - start), *p, start, end); in osdmap_decode()
1953 u32 epoch = 0; in osdmap_apply_incremental() local
1973 epoch = ceph_decode_32(p); in osdmap_apply_incremental()
1974 BUG_ON(epoch != map->epoch+1); in osdmap_apply_incremental()
2011 map->epoch++; in osdmap_apply_incremental()
2088 dout("inc osdmap epoch %d max_osd %d\n", map->epoch, map->max_osd); in osdmap_apply_incremental()
2095 err, epoch, (int)(*p - start), *p, start, end); in osdmap_apply_incremental()
|
| D | ceph_common.c | 813 return client->monc.monmap && client->monc.monmap->epoch && in have_mon_and_osd_map()
814 client->osdc.osdmap && client->osdc.osdmap->epoch; in have_mon_and_osd_map()
878 if (client->osdc.osdmap->epoch >= newest_epoch) in ceph_wait_for_latest_osdmap()
|
| /net/rxrpc/ |
| D | conn_service.c | 36 k.epoch = sp->hdr.epoch; in rxrpc_find_service_conn_rcu()
166 conn->proto.epoch = sp->hdr.epoch; in rxrpc_new_incoming_connection()
|
| D | output.c | 207 pkt->whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_ack_packet()
316 pkt.whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_abort_packet()
373 whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_data_packet()
605 whdr.epoch = htonl(sp->hdr.epoch); in rxrpc_reject_packets()
648 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
|
| D | net_ns.c | 49 get_random_bytes(&rxnet->epoch, sizeof(rxnet->epoch)); in rxrpc_init_net()
50 rxnet->epoch |= RXRPC_RANDOM_EPOCH; in rxrpc_init_net()
|
| D | protocol.h | 22 __be32 epoch; /* client boot timestamp */ member
173 __be32 epoch; /* current epoch */ member
|
| D | local_event.c | 47 whdr.epoch = htonl(sp->hdr.epoch); in rxrpc_send_version_request()
|
| D | conn_object.c | 94 k.epoch = sp->hdr.epoch; in rxrpc_find_connection_rcu()
122 if (conn->proto.epoch != k.epoch || in rxrpc_find_connection_rcu()
|
| D | rxkad.c | 211 tmpbuf[0] = htonl(conn->proto.epoch); in rxkad_prime_packet_security()
754 whdr.epoch = htonl(conn->proto.epoch); in rxkad_issue_challenge()
814 whdr.epoch = htonl(hdr->epoch); in rxkad_send_response()
947 resp->encrypted.epoch = htonl(conn->proto.epoch); in rxkad_respond_to_challenge()
1250 if (ntohl(response->encrypted.epoch) != conn->proto.epoch) in rxkad_verify_response()
|
| D | conn_event.c | 76 pkt.whdr.epoch = htonl(conn->proto.epoch); in rxrpc_conn_retransmit_call()
230 whdr.epoch = htonl(conn->proto.epoch); in rxrpc_abort_connection()
|
| D | conn_client.c | 70 conn->proto.epoch = rxnet->epoch; in rxrpc_get_client_connection_id()
236 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
|
| D | ar-internal.h | 61 u32 epoch; /* Local epoch for detecting local-end reset */ member
160 u32 epoch; /* client boot timestamp */ member
338 u32 epoch; /* epoch of this connection */ member
|
| D | input.c | 1217 sp->hdr.epoch = ntohl(whdr.epoch); in rxrpc_extract_header()
|
| D | af_rxrpc.c | 396 return call->conn->proto.epoch; in rxrpc_kernel_get_epoch()
|