Lines Matching refs:of
605 struct _meta_flags *of, char **errstr) { in _meta_flag_preparse() argument
639 of->locked = 1; in _meta_flag_preparse()
640 of->vivify = 1; in _meta_flag_preparse()
643 of->has_error = 1; in _meta_flag_preparse()
645 of->autoviv_exptime = realtime(EXPTIME_TO_POSITIVE_TIME(tmp_int)); in _meta_flag_preparse()
649 of->locked = 1; in _meta_flag_preparse()
652 of->has_error = 1; in _meta_flag_preparse()
654 of->exptime = realtime(EXPTIME_TO_POSITIVE_TIME(tmp_int)); in _meta_flag_preparse()
655 of->new_ttl = true; in _meta_flag_preparse()
659 of->locked = 1; in _meta_flag_preparse()
662 of->has_error = 1; in _meta_flag_preparse()
664 of->recache_time = realtime(EXPTIME_TO_POSITIVE_TIME(tmp_int)); in _meta_flag_preparse()
668 of->la = 1; in _meta_flag_preparse()
669 of->locked = 1; // need locked to delay LRU bump in _meta_flag_preparse()
682 of->value = 1; in _meta_flag_preparse()
685 of->locked = 1; // need locked to delay LRU bump in _meta_flag_preparse()
688 of->no_update = 1; in _meta_flag_preparse()
691 of->no_reply = 1; in _meta_flag_preparse()
694 of->remove_val = 1; in _meta_flag_preparse()
698 if (!safe_strtoflags(&pr->request[pr->tokens[i]+1], &of->client_flags)) { in _meta_flag_preparse()
699 of->has_error = true; in _meta_flag_preparse()
703 if (!safe_strtoull(&pr->request[pr->tokens[i]+1], &of->req_cas_id)) { in _meta_flag_preparse()
705 of->has_error = true; in _meta_flag_preparse()
707 of->has_cas = true; in _meta_flag_preparse()
711 if (!safe_strtoull(&pr->request[pr->tokens[i]+1], &of->cas_id_in)) { in _meta_flag_preparse()
713 of->has_error = true; in _meta_flag_preparse()
715 of->has_cas_in = true; in _meta_flag_preparse()
721 of->mode = pr->request[pr->tokens[i]+1]; in _meta_flag_preparse()
724 if (!safe_strtoull(&pr->request[pr->tokens[i]+1], &of->initial)) { in _meta_flag_preparse()
726 of->has_error = 1; in _meta_flag_preparse()
730 if (!safe_strtoull(&pr->request[pr->tokens[i]+1], &of->delta)) { in _meta_flag_preparse()
732 of->has_error = 1; in _meta_flag_preparse()
736 of->set_stale = 1; in _meta_flag_preparse()
744 return of->has_error ? -1 : 0; in _meta_flag_preparse()
752 struct _meta_flags of = {0}; // option bitflags. in process_mget_cmd() local
779 if (_meta_flag_preparse(pr, 2, &of, &errstr) != 0) { in process_mget_cmd()
785 if (!of.locked) { in process_mget_cmd()
786 it = limited_get(key, nkey, t, 0, false, !of.no_update, &overflow); in process_mget_cmd()
801 if (it == NULL && of.vivify) { in process_mget_cmd()
813 do_item_link(it, hv, of.has_cas_in ? of.cas_id_in : get_cas_id()); in process_mget_cmd()
821 if (of.value) { in process_mget_cmd()
833 it->exptime = of.exptime; in process_mget_cmd()
837 it->exptime = of.autoviv_exptime; in process_mget_cmd()
847 && it->exptime < of.recache_time) { in process_mget_cmd()
937 if (of.value) { in process_mget_cmd()
964 if ((it->it_flags & ITEM_HDR) != 0 && of.value) { in process_mget_cmd()
972 if (of.locked) { in process_mget_cmd()
985 if (of.locked) { in process_mget_cmd()
987 if (!of.no_update && it != NULL) { in process_mget_cmd()
1017 if (of.no_reply) in process_mget_cmd()
1035 META_KEY(p, key, nkey, of.key_binary); in process_mget_cmd()
1048 if (of.locked) { in process_mget_cmd()
1062 struct _meta_flags of = {0}; // option bitflags. in process_mset_cmd() local
1086 if (_meta_flag_preparse(pr, 3, &of, &errstr) != 0) { in process_mset_cmd()
1090 rel_time_t exptime = of.exptime; in process_mset_cmd()
1092 switch (of.mode) { in process_mset_cmd()
1099 if (of.vivify) { in process_mset_cmd()
1101 exptime = of.autoviv_exptime; in process_mset_cmd()
1107 if (of.vivify) { in process_mset_cmd()
1109 exptime = of.autoviv_exptime; in process_mset_cmd()
1130 if (of.has_cas && (comm == NREAD_SET || comm == NREAD_REPLACE)) { in process_mset_cmd()
1134 it = item_alloc(key, nkey, of.client_flags, exptime, vlen); in process_mset_cmd()
1137 if (! item_size_ok(nkey, of.client_flags, vlen)) { in process_mset_cmd()
1161 ITEM_set_cas(it, of.req_cas_id); in process_mset_cmd()
1166 if (of.key_binary) { in process_mset_cmd()
1171 if (of.set_stale && comm == NREAD_CAS) { in process_mset_cmd()
1190 …int ret = store_item(it, comm, t, &nbytes, &cas, of.has_cas_in ? of.cas_id_in : get_cas_id(), set_… in process_mset_cmd()
1195 if (of.no_reply) { in process_mset_cmd()
1271 struct _meta_flags of = {0}; // option bitflags. in process_mdelete_cmd() local
1294 if (_meta_flag_preparse(pr, 2, &of, &errstr) != 0) { in process_mdelete_cmd()
1313 META_KEY(p, key, nkey, of.key_binary); in process_mdelete_cmd()
1321 if (of.has_cas && ITEM_get_cas(it) != of.req_cas_id) { in process_mdelete_cmd()
1331 if (of.remove_val) { in process_mdelete_cmd()
1332 item *new_it = item_alloc(key, nkey, of.client_flags, of.exptime, 2); in process_mdelete_cmd()
1336 of.has_cas_in ? of.cas_id_in : ITEM_get_cas(it), CAS_NO_STALE)) { in process_mdelete_cmd()
1353 if (of.set_stale) { in process_mdelete_cmd()
1354 if (of.new_ttl) { in process_mdelete_cmd()
1355 it->exptime = of.exptime; in process_mdelete_cmd()
1361 ITEM_set_cas(it, of.has_cas_in ? of.cas_id_in : get_cas_id()); in process_mdelete_cmd()
1362 if (of.no_reply) in process_mdelete_cmd()
1372 if (!of.remove_val) { in process_mdelete_cmd()
1376 if (of.no_reply) in process_mdelete_cmd()
1414 struct _meta_flags of = {0}; // option bitflags. in process_marithmetic_cmd() local
1422 of.delta = 1; in process_marithmetic_cmd()
1423 of.initial = 0; // redundant, for clarity. in process_marithmetic_cmd()
1444 if (_meta_flag_preparse(pr, 2, &of, &errstr) != 0) { in process_marithmetic_cmd()
1451 switch (of.mode) { in process_marithmetic_cmd()
1479 switch(do_add_delta(t, key, nkey, incr, of.delta, tmpbuf, &of.req_cas_id, hv, &it)) { in process_marithmetic_cmd()
1484 if (of.has_cas_in) { in process_marithmetic_cmd()
1487 ITEM_set_cas(it, of.cas_id_in); in process_marithmetic_cmd()
1500 if (of.vivify) { in process_marithmetic_cmd()
1501 itoa_u64(of.initial, tmpbuf); in process_marithmetic_cmd()
1509 of.has_cas_in ? of.cas_id_in : get_cas_id(), CAS_NO_STALE)) { in process_marithmetic_cmd()
1544 if (of.value) { in process_marithmetic_cmd()
1569 it->exptime = of.exptime; in process_marithmetic_cmd()
1573 it->exptime = of.autoviv_exptime; in process_marithmetic_cmd()
1587 META_KEY(p, key, nkey, of.key_binary); in process_marithmetic_cmd()
1592 if (of.value) { in process_marithmetic_cmd()
1616 META_KEY(p, key, nkey, of.key_binary); in process_marithmetic_cmd()