Lines Matching refs:of
932 struct _meta_flags *of, char **errstr) { in _meta_flag_preparse() argument
955 of->has_error = 1; in _meta_flag_preparse()
958 of->key_binary = 1; in _meta_flag_preparse()
964 of->locked = 1; in _meta_flag_preparse()
965 of->vivify = 1; in _meta_flag_preparse()
968 of->has_error = 1; in _meta_flag_preparse()
970 of->autoviv_exptime = realtime(EXPTIME_TO_POSITIVE_TIME(tmp_int)); in _meta_flag_preparse()
974 of->locked = 1; in _meta_flag_preparse()
977 of->has_error = 1; in _meta_flag_preparse()
979 of->exptime = realtime(EXPTIME_TO_POSITIVE_TIME(tmp_int)); in _meta_flag_preparse()
980 of->new_ttl = true; in _meta_flag_preparse()
984 of->locked = 1; in _meta_flag_preparse()
987 of->has_error = 1; in _meta_flag_preparse()
989 of->recache_time = realtime(EXPTIME_TO_POSITIVE_TIME(tmp_int)); in _meta_flag_preparse()
993 of->la = 1; in _meta_flag_preparse()
994 of->locked = 1; // need locked to delay LRU bump in _meta_flag_preparse()
1007 of->value = 1; in _meta_flag_preparse()
1010 of->locked = 1; // need locked to delay LRU bump in _meta_flag_preparse()
1013 of->no_update = 1; in _meta_flag_preparse()
1016 of->no_reply = 1; in _meta_flag_preparse()
1019 of->remove_val = 1; in _meta_flag_preparse()
1023 if (!safe_strtoflags(tokens[i].value+1, &of->client_flags)) { in _meta_flag_preparse()
1024 of->has_error = true; in _meta_flag_preparse()
1028 if (!safe_strtoull(tokens[i].value+1, &of->req_cas_id)) { in _meta_flag_preparse()
1030 of->has_error = true; in _meta_flag_preparse()
1032 of->has_cas = true; in _meta_flag_preparse()
1036 if (!safe_strtoull(tokens[i].value+1, &of->cas_id_in)) { in _meta_flag_preparse()
1038 of->has_error = true; in _meta_flag_preparse()
1040 of->has_cas_in = true; in _meta_flag_preparse()
1046 of->has_error = 1; in _meta_flag_preparse()
1048 of->mode = tokens[i].value[1]; in _meta_flag_preparse()
1052 if (!safe_strtoull(tokens[i].value+1, &of->initial)) { in _meta_flag_preparse()
1054 of->has_error = 1; in _meta_flag_preparse()
1058 if (!safe_strtoull(tokens[i].value+1, &of->delta)) { in _meta_flag_preparse()
1060 of->has_error = 1; in _meta_flag_preparse()
1064 of->set_stale = 1; in _meta_flag_preparse()
1072 return of->has_error ? -1 : 0; in _meta_flag_preparse()
1080 struct _meta_flags of = {0}; // option bitflags. in process_mget_command() local
1110 if (_meta_flag_preparse(tokens, 2, &of, &errstr) != 0) { in process_mget_command()
1114 c->noreply = of.no_reply; in process_mget_command()
1123 if (!of.locked) { in process_mget_command()
1124 it = limited_get(key, nkey, c->thread, 0, false, !of.no_update, &overflow); in process_mget_command()
1139 if (it == NULL && of.vivify) { in process_mget_command()
1151 do_item_link(it, hv, of.has_cas_in ? of.cas_id_in : get_cas_id()); in process_mget_command()
1159 if (of.value) { in process_mget_command()
1171 it->exptime = of.exptime; in process_mget_command()
1175 it->exptime = of.autoviv_exptime; in process_mget_command()
1185 && it->exptime < of.recache_time) { in process_mget_command()
1274 if (of.value) { in process_mget_command()
1301 if ((it->it_flags & ITEM_HDR) != 0 && of.value) { in process_mget_command()
1309 if (of.locked) { in process_mget_command()
1322 if (of.locked) { in process_mget_command()
1324 if (!of.no_update && it != NULL) { in process_mget_command()
1374 META_KEY(p, key, nkey, of.key_binary); in process_mget_command()
1388 if (of.locked) { in process_mget_command()
1401 struct _meta_flags of = {0}; // option bitflags. in process_mset_command() local
1446 if (_meta_flag_preparse(tokens, 3, &of, &errstr) != 0) { in process_mset_command()
1454 c->noreply = of.no_reply; in process_mset_command()
1456 c->cas = of.has_cas_in ? of.cas_id_in : get_cas_id(); in process_mset_command()
1457 exptime = of.exptime; in process_mset_command()
1488 switch (of.mode) { in process_mset_command()
1495 if (of.vivify) { in process_mset_command()
1497 exptime = of.autoviv_exptime; in process_mset_command()
1503 if (of.vivify) { in process_mset_command()
1505 exptime = of.autoviv_exptime; in process_mset_command()
1526 if (of.has_cas && (comm == NREAD_SET || comm == NREAD_REPLACE)) { in process_mset_command()
1535 it = item_alloc(key, nkey, of.client_flags, exptime, vlen); in process_mset_command()
1541 if (! item_size_ok(nkey, of.client_flags, vlen)) { in process_mset_command()
1570 ITEM_set_cas(it, of.req_cas_id); in process_mset_command()
1586 if (of.key_binary) { in process_mset_command()
1590 if (of.set_stale && comm == NREAD_CAS) { in process_mset_command()
1616 struct _meta_flags of = {0}; // option bitflags. in process_mdelete_command() local
1639 if (_meta_flag_preparse(tokens, 2, &of, &errstr) != 0) { in process_mdelete_command()
1644 c->noreply = of.no_reply; in process_mdelete_command()
1662 META_KEY(p, key, nkey, of.key_binary); in process_mdelete_command()
1672 if (of.has_cas && ITEM_get_cas(it) != of.req_cas_id) { in process_mdelete_command()
1682 if (of.remove_val) { in process_mdelete_command()
1683 item *new_it = item_alloc(key, nkey, of.client_flags, of.exptime, 2); in process_mdelete_command()
1687 of.has_cas_in ? of.cas_id_in : ITEM_get_cas(it), CAS_NO_STALE)) { in process_mdelete_command()
1704 if (of.set_stale) { in process_mdelete_command()
1705 if (of.new_ttl) { in process_mdelete_command()
1706 it->exptime = of.exptime; in process_mdelete_command()
1712 ITEM_set_cas(it, of.has_cas_in ? of.cas_id_in : get_cas_id()); in process_mdelete_command()
1724 if (!of.remove_val) { in process_mdelete_command()
1766 struct _meta_flags of = {0}; // option bitflags. in process_marithmetic_command() local
1774 of.delta = 1; in process_marithmetic_command()
1775 of.initial = 0; // redundant, for clarity. in process_marithmetic_command()
1796 if (_meta_flag_preparse(tokens, 2, &of, &errstr) != 0) { in process_marithmetic_command()
1801 c->noreply = of.no_reply; in process_marithmetic_command()
1807 switch (of.mode) { in process_marithmetic_command()
1834 switch(do_add_delta(c->thread, key, nkey, incr, of.delta, tmpbuf, &of.req_cas_id, hv, &it)) { in process_marithmetic_command()
1839 if (of.has_cas_in) { in process_marithmetic_command()
1842 ITEM_set_cas(it, of.cas_id_in); in process_marithmetic_command()
1854 if (of.vivify) { in process_marithmetic_command()
1855 itoa_u64(of.initial, tmpbuf); in process_marithmetic_command()
1863 of.has_cas_in ? of.cas_id_in : get_cas_id(), CAS_NO_STALE)) { in process_marithmetic_command()
1898 if (of.value) { in process_marithmetic_command()
1923 it->exptime = of.exptime; in process_marithmetic_command()
1927 it->exptime = of.autoviv_exptime; in process_marithmetic_command()
1941 META_KEY(p, key, nkey, of.key_binary); in process_marithmetic_command()
1946 if (of.value) { in process_marithmetic_command()
1970 META_KEY(p, key, nkey, of.key_binary); in process_marithmetic_command()