Home
last modified time | relevance | path

Searched full:epoch (Results 1 – 25 of 103) sorted by relevance

12345

/linux/include/linux/ceph/
H A Dmon_client.h20 u32 epoch; member
98 u32 have; /* epoch */
125 * epoch @epoch, and also call in when we receive a map. We will
129 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,
131 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch);
134 extern int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch,
/linux/net/sched/
H A Dsch_plug.c17 * next epoch speculatively.
20 * 1.At epoch i, start_buffer(i)
21 * 2. At end of epoch i (i.e. after 50ms):
24 * 3. While speculatively executing epoch(i+1), asynchronously replicate
28 * TCQ_PLUG_BUFFER (epoch i)
29 * .. TCQ_PLUG_BUFFER (epoch i+1)
30 * ....TCQ_PLUG_RELEASE_ONE (epoch i)
31 * ......TCQ_PLUG_BUFFER (epoch i+2)
69 * executing epoch.
74 * epoch
[all...]
/linux/net/ceph/
H A Dmon_client.c78 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 %u\n", __func__, &fsid, epoch, in ceph_monmap_decode()
126 monmap->epoch = epoch; in ceph_monmap_decode()
420 * @epoch: X for "every map since X", or 0 for "just the latest"
423 u32 epoch, bool continuous) in __ceph_monc_want_map() argument
425 __le64 start = cpu_to_le64(epoch); in __ceph_monc_want_map()
428 dout("%s %s epoch %u continuous %d\n", __func__, ceph_sub_str[sub], in __ceph_monc_want_map()
429 epoch, continuous); in __ceph_monc_want_map()
443 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch, in ceph_monc_want_map() argument
[all …]
H A Ddebugfs.c43 seq_printf(s, "epoch %d\n", client->monc.monmap->epoch); in monmap_show()
71 seq_printf(s, "epoch %u barrier %u flags 0x%x\n", map->epoch, in osdmap_show()
201 seq_printf(s, "]/%d\te%u\t", t->acting.primary, t->epoch); in dump_target()
/linux/net/rxrpc/
H A Dconn_service.c15 * attacker as the client gets to pick the epoch and cid values and would know
30 k.epoch = sp->hdr.epoch; in rxrpc_find_service_conn_rcu()
107 /* The old connection is from an outdated epoch. */ in rxrpc_publish_service_conn()
157 conn->proto.epoch = sp->hdr.epoch; in rxrpc_new_incoming_connection()
H A Drxgk.c358 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()
495 hdr->epoch = htonl(call->conn->proto.epoch); in rxgk_verify_packet_integrity()
563 if (ntohl(hdr->epoch) != call->conn->proto.epoch || in rxgk_verify_packet_encrypted()
669 whdr->epoch = htonl(conn->proto.epoch); in rxgk_issue_challenge()
849 __be32 epoch; rxgk_construct_authenticator() member
1093 u32 app_len, call_count, level, epoch, cid, i; rxgk_verify_authenticator() local
[all...]
H A Dnet_ns.c40 get_random_bytes(&rxnet->epoch, sizeof(rxnet->epoch)); in rxrpc_init_net()
41 rxnet->epoch |= RXRPC_RANDOM_EPOCH; in rxrpc_init_net()
H A Doutput.c172 whdr->epoch = htonl(call->conn->proto.epoch); in rxrpc_fill_out_ack()
392 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()
H A Dlocal_event.c56 whdr.epoch = htonl(sp->hdr.epoch); in rxrpc_send_version_request()
H A Drxkad.c194 tmpbuf[0] = htonl(conn->proto.epoch); in rxkad_prime_packet_security()
532 whdr.epoch = htonl(conn->proto.epoch); in rxkad_verify_packet_2()
655 h.whdr.epoch = htonl(conn->proto.epoch); in rxkad_issue_challenge()
668 h.resp.encrypted.epoch = htonl(conn->proto.epoch); in rxkad_issue_challenge()
1020 if (ntohl(response->encrypted.epoch) != conn->proto.epoch || in rxkad_decrypt_ticket()
H A Drxgk_kdf.c53 * epoch || cid || start_time || key_number))
80 info[0] = htonl(conn->proto.epoch); in rxgk_derive_transport_key()
/linux/arch/sh/boards/mach-dreamcast/
H A Drtc.c16 /* The AICA RTC has an Epoch of 1/1/1950, so we must subtract 20 years (in
17 seconds) to get the standard Unix Epoch when getting the time, and add
31 * Grabs the current RTC seconds counter and adjusts it to the Unix Epoch.
59 * Adjusts the given @tv to the AICA Epoch and sets the RTC seconds counter.
/linux/fs/fuse/
H A Dreaddir.c166 int epoch; in fuse_direntplus_link() local
196 epoch = atomic_read(&fc->epoch); in fuse_direntplus_link()
263 fuse_dentry_set_epoch(dentry, epoch); in fuse_direntplus_link()
491 fi->rdc.epoch = 0; in fuse_rdc_reset()
533 fi->rdc.epoch = atomic_read(&fc->epoch); in fuse_readdir_cached()
548 fi->rdc.epoch != atomic_read(&fc->epoch)) { in fuse_readdir_cached()
/linux/Documentation/ABI/testing/
H A Dsysfs-class-rtc51 Valid time range for the RTC, as seconds from epoch, formatted
59 (RO) RTC-provided time as the number of seconds since the epoch
89 epoch by default, or if there's a leading +, seconds in the
/linux/drivers/xen/xen-pciback/
H A Dconf_space_quirks.h5 * Ryan Wilson <hap9@epoch.ncsc.mil>
6 * Chris Bookholt <hap10@epoch.ncsc.mil>
H A Dconf_space_quirks.c5 * Author: Ryan Wilson <hap9@epoch.ncsc.mil>
6 * Author: Chris Bookholt <hap10@epoch.ncsc.mil>
/linux/fs/smb/server/
H A Doplock.h30 __le16 epoch; member
51 unsigned short epoch; member
88 __le16 epoch; member
/linux/drivers/block/drbd/
H A Ddrbd_req.c38 req->epoch = 0; in drbd_req_new()
167 /* no point closing an epoch, if it is empty, anyways. */ in start_new_tl_epoch()
237 * we may need to close the current transfer log epoch. in drbd_req_complete()
239 * the request epoch number with the current transfer log in drbd_req_complete()
240 * epoch number. If they match, increase the current_tle_nr, in drbd_req_complete()
241 * and reset the transfer log epoch write_cnt. in drbd_req_complete()
244 req->epoch == atomic_read(&first_peer_device(device)->connection->current_tle_nr)) in drbd_req_complete()
684 * again ourselves to close the current epoch. in __req_mod()
686 * Add req to the (now) current epoch (barrier). */ in __req_mod()
700 /* close the epoch, in case it outgrew the limit */ in __req_mod()
[all …]
H A Ddrbd_worker.c1383 static void re_init_if_first_write(struct drbd_connection *connection, unsigned int epoch) in re_init_if_first_write() argument
1387 connection->send.current_epoch_nr = epoch; in re_init_if_first_write()
1393 static void maybe_send_barrier(struct drbd_connection *connection, unsigned int epoch) in maybe_send_barrier() argument
1398 if (connection->send.current_epoch_nr != epoch) { in maybe_send_barrier()
1401 connection->send.current_epoch_nr = epoch; in maybe_send_barrier()
1421 * replicated epoch, before we went into AHEAD mode. in w_send_out_of_sync()
1423 maybe_send_barrier(connection, req->epoch); in w_send_out_of_sync()
1451 re_init_if_first_write(connection, req->epoch); in w_send_dblock()
1452 maybe_send_barrier(connection, req->epoch); in w_send_dblock()
1484 /* Even read requests may close a write epoch, in w_send_read_req()
[all …]
H A Ddrbd_receiver.c1166 * drbd_may_finish_epoch() - Applies an epoch_event to the epoch's state, eventually finishes it.
1168 * @epoch: Epoch object.
1169 * @ev: Epoch event.
1172 struct drbd_epoch *epoch, in drbd_may_finish_epoch() argument
1183 epoch_size = atomic_read(&epoch->epoch_size); in drbd_may_finish_epoch()
1187 atomic_dec(&epoch->active); in drbd_may_finish_epoch()
1190 set_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags); in drbd_may_finish_epoch()
1198 atomic_read(&epoch->active) == 0 && in drbd_may_finish_epoch()
1199 (test_bit(DE_HAVE_BARRIER_NUMBER, &epoch->flags) || ev & EV_CLEANUP)) { in drbd_may_finish_epoch()
1202 drbd_send_b_ack(epoch->connection, epoch->barrier_nr, epoch_size); in drbd_may_finish_epoch()
[all …]
/linux/tools/testing/selftests/bpf/libarena/selftests/
H A Dtest_parallel_spmc.bpf.c154 int spmc_quiesce_on_owner(u64 epoch) in spmc_quiesce_on_owner() argument
161 if (smp_load_acquire(&owner_epoch) >= epoch) in spmc_quiesce_on_owner()
171 int spmc_quiesce_on_stealer(u64 epoch) in spmc_quiesce_on_stealer() argument
177 target = STEALER_EPOCH(epoch); in spmc_quiesce_on_stealer()
/linux/net/netfilter/
H A Dxt_time.c68 * Each network packet has a (nano)seconds-since-the-epoch (SSTE) timestamp.
92 * by seconds-per-day to get the number of _days_ since the epoch. in localtime_2()
108 * In each year, a certain number of days-since-the-epoch have passed. in localtime_3()
/linux/include/uapi/linux/
H A Drtc.h101 #define RTC_EPOCH_READ _IOR('p', 0x0d, unsigned long) /* Read epoch */
102 #define RTC_EPOCH_SET _IOW('p', 0x0e, unsigned long) /* Set epoch */
H A Dvm_sockets.h157 /* The epoch (first) component of the vSockets version. A single byte
158 * representing the epoch component of the vSockets version.
/linux/fs/smb/client/
H A Dsmb2ops.c1492 server->ops->set_oplock_level(cinode, oplock, fid->epoch, in smb2_set_fid()
4342 __u16 epoch, bool *purge_cache) in smb2_downgrade_oplock() argument
4350 __u16 epoch, bool *purge_cache);
4355 __u16 epoch, bool *purge_cache) in smb3_downgrade_oplock() argument
4358 __u16 old_epoch = cinode->epoch; in smb3_downgrade_oplock()
4361 if (epoch > old_epoch) { in smb3_downgrade_oplock()
4363 cinode->epoch = epoch; in smb3_downgrade_oplock()
4372 else if (old_state == new_state && (epoch - old_epoch > 1)) in smb3_downgrade_oplock()
4378 __u16 epoch, bool *purge_cache) in smb2_set_oplock_level() argument
4402 __u16 epoch, bool *purge_cache) in smb21_set_oplock_level() argument
[all …]

12345