| /net/rxrpc/ |
| A D | rxgk.c | 358 hdr->epoch = htonl(call->conn->proto.epoch); in rxgk_secure_packet_integrity()
401 hdr->epoch = htonl(call->conn->proto.epoch); in rxgk_secure_packet_encrypted()
490 hdr->epoch = htonl(call->conn->proto.epoch); in rxgk_verify_packet_integrity()
553 if (ntohl(hdr.epoch) != call->conn->proto.epoch || in rxgk_verify_packet_encrypted()
659 whdr->epoch = htonl(conn->proto.epoch); in rxgk_issue_challenge()
796 h.whdr.epoch = htonl(conn->proto.epoch); in rxgk_insert_response_header()
839 __be32 epoch; in rxgk_construct_authenticator() member
871 b.epoch = htonl(conn->proto.epoch); in rxgk_construct_authenticator()
1082 u32 app_len, call_count, level, epoch, cid, i; in rxgk_do_verify_authenticator() local
1102 epoch = ntohl(*p++); in rxgk_do_verify_authenticator()
[all …]
|
| A D | conn_service.c | 30 k.epoch = sp->hdr.epoch; in rxrpc_find_service_conn_rcu()
157 conn->proto.epoch = sp->hdr.epoch; in rxrpc_new_incoming_connection()
|
| A D | protocol.h | 22 __be32 epoch; /* client boot timestamp */ member
171 __be32 epoch; /* current epoch */ member
188 __be32 epoch; member
|
| A D | net_ns.c | 40 get_random_bytes(&rxnet->epoch, sizeof(rxnet->epoch)); in rxrpc_init_net()
41 rxnet->epoch |= RXRPC_RANDOM_EPOCH; in rxrpc_init_net()
|
| A D | output.c | 174 whdr->epoch = htonl(call->conn->proto.epoch); in rxrpc_fill_out_ack()
394 pkt.whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_abort_packet()
551 whdr->epoch = htonl(call->conn->proto.epoch); in rxrpc_prepare_data_packet()
766 whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_conn_abort()
833 .epoch = htonl(sp->hdr.epoch), in rxrpc_reject_packet()
892 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
|
| A D | local_event.c | 56 whdr.epoch = htonl(sp->hdr.epoch); in rxrpc_send_version_request()
|
| A D | rxkad.c | 219 tmpbuf[0] = htonl(conn->proto.epoch); in rxkad_prime_packet_security()
667 whdr.epoch = htonl(conn->proto.epoch); in rxkad_issue_challenge()
825 h.whdr.epoch = htonl(conn->proto.epoch); in rxkad_insert_response_header()
838 h.resp.encrypted.epoch = htonl(conn->proto.epoch); in rxkad_insert_response_header()
1199 if (ntohl(response->encrypted.epoch) != conn->proto.epoch || in rxkad_verify_response()
|
| A D | conn_client.c | 174 conn->proto.epoch = local->rxnet->epoch; in rxrpc_alloc_client_connection()
220 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
|
| A D | conn_object.c | 116 if (conn->proto.epoch != sp->hdr.epoch || in rxrpc_find_client_connection_rcu()
|
| A D | conn_event.c | 139 pkt.whdr.epoch = htonl(conn->proto.epoch); in rxrpc_conn_retransmit_call()
|
| A D | io_thread.c | 154 sp->hdr.epoch = ntohl(whdr.epoch); in rxrpc_extract_header()
|
| A D | rxgk_kdf.c | 80 info[0] = htonl(conn->proto.epoch); in rxgk_derive_transport_key()
|
| A D | ar-internal.h | 69 u32 epoch; /* Local epoch for detecting local-end reset */ member
190 u32 epoch; /* client boot timestamp */ member
424 u32 epoch; /* epoch of this connection */ member
|
| /net/ceph/ |
| A 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()
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()
460 u32 epoch) in __ceph_monc_got_map() argument
471 monc->subs[sub].have = epoch; in __ceph_monc_got_map()
477 __ceph_monc_got_map(monc, sub, epoch); in ceph_monc_got_map()
503 while (monc->subs[CEPH_SUB_OSDMAP].have < epoch) { in ceph_monc_wait_osdmap()
[all …]
|
| A D | osd_client.c | 458 dest->epoch = src->epoch; in target_copy()
1602 t->epoch = osdc->osdmap->epoch; in calc_target()
2232 __le32 epoch; in encode_request_finish() member
2272 ceph_encode_copy(&p, &head.epoch, sizeof(head.epoch)); in encode_request_finish()
3655 u32 epoch; member
3782 m.epoch, m.retry_attempt, le32_to_cpu(m.replay_version.epoch), in handle_reply()
4043 osdc->osdmap->epoch + 1 < newmap->epoch) { in handle_one_map()
4088 if (req->r_t.epoch < osdc->osdmap->epoch) { in kick_requests()
4135 u32 epoch; in ceph_osdc_handle_map() local
4167 osdc->osdmap->epoch + 1 == epoch) { in ceph_osdc_handle_map()
[all …]
|
| A D | osdmap.c | 25 map->epoch, &vaf); in osdmap_info()
1670 u32 epoch = 0; in osdmap_decode() local
1686 epoch = map->epoch = ceph_decode_32(p); in osdmap_decode()
1800 dout("full osdmap epoch %d max_osd %d\n", map->epoch, map->max_osd); in osdmap_decode()
1807 err, epoch, (int)(*p - start), *p, start, end); in osdmap_decode()
1969 u32 epoch = 0; in osdmap_apply_incremental() local
1989 epoch = ceph_decode_32(p); in osdmap_apply_incremental()
1990 BUG_ON(epoch != map->epoch+1); in osdmap_apply_incremental()
2027 map->epoch++; in osdmap_apply_incremental()
2104 dout("inc osdmap epoch %d max_osd %d\n", map->epoch, map->max_osd); in osdmap_apply_incremental()
[all …]
|
| A 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()
|
| A D | ceph_common.c | 793 return client->monc.monmap && client->monc.monmap->epoch && in have_mon_and_osd_map()
794 client->osdc.osdmap && client->osdc.osdmap->epoch; in have_mon_and_osd_map()
858 if (client->osdc.osdmap->epoch >= newest_epoch) in ceph_wait_for_latest_osdmap()
|