| /6.6.0/kv_engine/daemon/protocol/mcbp/ |
| H A D | stats_context.cc | 25 #include <daemon/cookie.h>
49 void add_stat(Cookie& cookie, in add_stat() argument
58 &cookie); in add_stat()
63 void add_stat(Cookie& cookie, in add_stat() argument
73 name, uint16_t(strlen(name)), buf, uint32_t(len), &cookie); in add_stat()
77 void add_stat(Cookie& cookie, in add_stat() argument
87 name, uint16_t(strlen(name)), buf, uint32_t(len), &cookie); in add_stat()
91 void add_stat(Cookie& cookie, in add_stat() argument
101 name, uint16_t(strlen(name)), buf, uint32_t(len), &cookie); in add_stat()
105 void add_stat(Cookie& cookie, in add_stat() argument
119 add_stat(Cookie& cookie, const AddStatFn& add_stat_callback, const char* name, const std::string& value) add_stat() argument
130 add_stat(Cookie& cookie, const AddStatFn& add_stat_callback, const char* name, const char* value) add_stat() argument
141 add_stat(Cookie& cookie, const AddStatFn& add_stat_callback, const char* name, const bool value) add_stat() argument
153 server_stats(const AddStatFn& add_stat_callback, Cookie& cookie) server_stats() argument
298 append_bin_stats(const char* key, const uint16_t klen, const char* val, const uint32_t vlen, Cookie& cookie) append_bin_stats() argument
330 auto& cookie = *const_cast<Cookie*>( append_stats() local
351 process_bucket_details(Cookie& cookie) process_bucket_details() argument
388 stat_reset_executor(const std::string& arg, Cookie& cookie) stat_reset_executor() argument
412 stat_sched_executor(const std::string& arg, Cookie& cookie) stat_sched_executor() argument
452 stat_audit_executor(const std::string& arg, Cookie& cookie) stat_audit_executor() argument
469 stat_bucket_details_executor(const std::string& arg, Cookie& cookie) stat_bucket_details_executor() argument
486 stat_aggregate_executor(const std::string& arg, Cookie& cookie) stat_aggregate_executor() argument
503 stat_connections_executor(const std::string& arg, Cookie& cookie) stat_connections_executor() argument
531 stat_topkeys_executor(const std::string& arg, Cookie& cookie) stat_topkeys_executor() argument
552 stat_topkeys_json_executor(const std::string& arg, Cookie& cookie) stat_topkeys_json_executor() argument
588 stat_subdoc_execute_executor(const std::string& arg, Cookie& cookie) stat_subdoc_execute_executor() argument
616 stat_responses_json_executor(const std::string& arg, Cookie& cookie) stat_responses_json_executor() argument
645 stat_tracing_executor(const std::string& arg, Cookie& cookie) stat_tracing_executor() argument
649 MemcachedCallback(Cookie& cookie) stat_tracing_executor() argument
711 stat_all_stats(const std::string& arg, Cookie& cookie) stat_all_stats() argument
721 stat_bucket_stats(const std::string& arg, Cookie& cookie) stat_bucket_stats() argument
[all...] |
| H A D | engine_wrapper.cc | 20 #include <daemon/cookie.h>
32 ENGINE_ERROR_CODE bucket_unknown_command(Cookie& cookie, in bucket_unknown_command() argument
34 auto& c = cookie.getConnection(); in bucket_unknown_command()
36 &cookie, cookie.getRequest(Cookie::PacketContent::Full), response); in bucket_unknown_command()
38 const auto request = cookie.getRequest(); in bucket_unknown_command()
58 void bucket_reset_stats(Cookie& cookie) { in bucket_reset_stats() argument
59 auto& c = cookie.getConnection(); in bucket_reset_stats()
60 c.getBucketEngine()->reset_stats(&cookie); in bucket_reset_stats()
79 cb::EngineErrorMetadataPair bucket_get_meta(Cookie& cookie, in bucket_get_meta() argument
94 bucket_store( Cookie& cookie, gsl::not_null<item*> item_, uint64_t& cas, ENGINE_STORE_OPERATION operation, boost::optional<cb::durability::Requirements> durability, DocumentState document_state) bucket_store() argument
130 bucket_store_if( Cookie& cookie, gsl::not_null<item*> item_, uint64_t cas, ENGINE_STORE_OPERATION operation, cb::StoreIfPredicate predicate, boost::optional<cb::durability::Requirements> durability, DocumentState document_state) bucket_store_if() argument
161 bucket_remove( Cookie& cookie, const DocKey& key, uint64_t& cas, Vbid vbucket, boost::optional<cb::durability::Requirements> durability, mutation_descr_t& mut_info) bucket_remove() argument
183 bucket_get(Cookie& cookie, const DocKey& key, Vbid vbucket, DocStateFilter documentStateFilter) bucket_get() argument
205 bucket_get_compression_mode(Cookie& cookie) bucket_get_compression_mode() argument
210 bucket_min_compression_ratio(Cookie& cookie) bucket_min_compression_ratio() argument
215 bucket_get_if( Cookie& cookie, const DocKey& key, Vbid vbucket, std::function<bool(const item_info&)> filter) bucket_get_if() argument
232 bucket_get_and_touch( Cookie& cookie, const DocKey& key, Vbid vbucket, uint32_t expiration, boost::optional<cb::durability::Requirements> durability) bucket_get_and_touch() argument
251 bucket_get_locked(Cookie& cookie, const DocKey& key, Vbid vbucket, uint32_t lock_timeout) bucket_get_locked() argument
270 bucket_get_max_item_size(Cookie& cookie) bucket_get_max_item_size() argument
275 bucket_unlock(Cookie& cookie, const DocKey& key, Vbid vbucket, uint64_t cas) bucket_unlock() argument
290 bucket_allocate_ex( Cookie& cookie, const DocKey& key, const size_t nbytes, const size_t priv_nbytes, const int flags, const rel_time_t exptime, uint8_t datatype, Vbid vbucket) bucket_allocate_ex() argument
347 bucket_flush(Cookie& cookie) bucket_flush() argument
359 bucket_get_stats(Cookie& cookie, cb::const_char_buffer key, cb::const_byte_buffer value, const AddStatFn& add_stat) bucket_get_stats() argument
378 dcpAddStream(Cookie& cookie, uint32_t opaque, Vbid vbid, uint32_t flags) dcpAddStream() argument
394 dcpBufferAcknowledgement(Cookie& cookie, uint32_t opaque, Vbid vbid, uint32_t ackSize) dcpBufferAcknowledgement() argument
411 dcpCloseStream(Cookie& cookie, uint32_t opaque, Vbid vbid, cb::mcbp::DcpStreamId sid) dcpCloseStream() argument
427 dcpControl(Cookie& cookie, uint32_t opaque, cb::const_char_buffer key, cb::const_char_buffer val) dcpControl() argument
443 dcpDeletion(Cookie& cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t privilegedPoolSize, uint8_t datatype, uint64_t cas, Vbid vbid, uint64_t bySeqno, uint64_t revSeqno, cb::const_byte_buffer meta) dcpDeletion() argument
476 dcpDeletionV2(Cookie& cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t privilegedPoolSize, uint8_t datatype, uint64_t cas, Vbid vbid, uint64_t bySeqno, uint64_t revSeqno, uint32_t deleteTime) dcpDeletionV2() argument
509 dcpExpiration(Cookie& cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t privilegedPoolSize, uint8_t datatype, uint64_t cas, Vbid vbid, uint64_t bySeqno, uint64_t revSeqno, uint32_t deleteTime) dcpExpiration() argument
542 dcpGetFailoverLog(Cookie& cookie, uint32_t opaque, Vbid vbucket, dcp_add_failover_log callback) dcpGetFailoverLog() argument
558 dcpMutation(Cookie& cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t privilegedPoolSize, uint8_t datatype, uint64_t cas, Vbid vbid, uint32_t flags, uint64_t bySeqno, uint64_t revSeqno, uint32_t expiration, uint32_t lockTime, cb::const_byte_buffer meta, uint8_t nru) dcpMutation() argument
599 dcpNoop(Cookie& cookie, uint32_t opaque) dcpNoop() argument
612 dcpOpen(Cookie& cookie, uint32_t opaque, uint32_t seqno, uint32_t flags, cb::const_char_buffer name, cb::const_char_buffer value) dcpOpen() argument
630 dcpSetVbucketState(Cookie& cookie, uint32_t opaque, Vbid vbid, vbucket_state_t state) dcpSetVbucketState() argument
646 dcpSnapshotMarker( Cookie& cookie, uint32_t opaque, Vbid vbid, uint64_t startSeqno, uint64_t endSeqno, uint32_t flags, boost::optional<uint64_t> highCompletedSeqno, boost::optional<uint64_t> maxVisibleSeqno) dcpSnapshotMarker() argument
674 dcpStreamEnd(Cookie& cookie, uint32_t opaque, Vbid vbucket, uint32_t flags) dcpStreamEnd() argument
690 dcpStreamReq(Cookie& cookie, uint32_t flags, uint32_t opaque, Vbid vbucket, uint64_t startSeqno, uint64_t endSeqno, uint64_t vbucketUuid, uint64_t snapStartSeqno, uint64_t snapEndSeqno, uint64_t* rollbackSeqno, dcp_add_failover_log callback, boost::optional<cb::const_char_buffer> json) dcpStreamReq() argument
725 dcpSystemEvent(Cookie& cookie, uint32_t opaque, Vbid vbucket, mcbp::systemevent::id eventId, uint64_t bySeqno, mcbp::systemevent::version version, cb::const_byte_buffer key, cb::const_byte_buffer eventData) dcpSystemEvent() argument
752 dcpPrepare(Cookie& cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint32_t flags, uint64_t by_seqno, uint64_t rev_seqno, uint32_t expiration, uint32_t lock_time, uint8_t nru, DocumentState document_state, cb::durability::Level level) dcpPrepare() argument
795 dcpSeqnoAcknowledged(Cookie& cookie, uint32_t opaque, Vbid vbucket, uint64_t prepared_seqno) dcpSeqnoAcknowledged() argument
812 dcpCommit(Cookie& cookie, uint32_t opaque, Vbid vbucket, const DocKey& key, uint64_t prepared_seqno, uint64_t commit_seqno) dcpCommit() argument
831 dcpAbort(Cookie& cookie, uint32_t opaque, Vbid vbucket, const DocKey& key, uint64_t prepared_seqno, uint64_t abort_seqno) dcpAbort() argument
[all...] |
| H A D | select_bucket_executor.cc | 21 #include <daemon/cookie.h>
27 ENGINE_ERROR_CODE select_bucket(Cookie& cookie, const std::string& bucketname) { in select_bucket() argument
28 auto& connection = cookie.getConnection(); in select_bucket()
30 cookie.setErrorContext("Not authenticated"); in select_bucket()
36 ntohl(cookie.getRequest().getOpaque()), in select_bucket()
43 cookie.setErrorContext("DCP connections cannot change bucket"); in select_bucket()
49 ntohl(cookie.getRequest().getOpaque()), in select_bucket()
71 cookie.setErrorContext( in select_bucket()
91 ntohl(cookie.getRequest().getOpaque()), in select_bucket()
98 void select_bucket_executor(Cookie& cookie) { in select_bucket_executor() argument
[all...] |
| H A D | cluster_config_executor.cc | 21 #include <daemon/cookie.h>
31 static bool check_access_to_global_config(Cookie& cookie) { in check_access_to_global_config() argument
35 auto& conn = cookie.getConnection(); in check_access_to_global_config()
38 switch (conn.checkPrivilege(Privilege::SystemSettings, cookie)) { in check_access_to_global_config()
47 audit_command_access_failed(cookie); in check_access_to_global_config()
49 cookie.sendResponse(cb::mcbp::Status::Eaccess); in check_access_to_global_config()
61 cookie.sendResponse(cb::mcbp::Status::AuthStale); in check_access_to_global_config()
75 void get_cluster_config_executor(Cookie& cookie) { in get_cluster_config_executor() argument
76 auto& connection = cookie.getConnection(); in get_cluster_config_executor()
80 !check_access_to_global_config(cookie)) { in get_cluster_config_executor()
99 set_cluster_config_executor(Cookie& cookie) set_cluster_config_executor() argument
[all...] |
| H A D | gat_context.cc | 22 #include <daemon/cookie.h>
31 uint32_t GatCommandContext::getExptime(Cookie& cookie) { in getExptime() argument
32 auto extras = cookie.getRequest(Cookie::PacketContent::Full).getExtdata(); in getExptime()
40 GatCommandContext::GatCommandContext(Cookie& cookie) in GatCommandContext() argument
41 : SteppableCommandContext(cookie), in GatCommandContext()
42 vbucket(cookie.getRequest().getVBucket()), in GatCommandContext()
43 exptime(getExptime(cookie)), in GatCommandContext()
50 bucket_get_and_touch(cookie, in getAndTouchItem()
51 cookie.getRequestKey(), in getAndTouchItem()
54 cookie in getAndTouchItem()
[all...] |
| H A D | dcp_get_failover_log_executor.cc | 23 #include <daemon/cookie.h>
27 void dcp_get_failover_log_executor(Cookie& cookie) { in dcp_get_failover_log_executor() argument
28 auto ret = cookie.swapAiostat(ENGINE_SUCCESS); in dcp_get_failover_log_executor()
30 auto& connection = cookie.getConnection(); in dcp_get_failover_log_executor()
32 auto& header = cookie.getHeader().getRequest(); in dcp_get_failover_log_executor()
33 ret = dcpGetFailoverLog(cookie, in dcp_get_failover_log_executor()
42 if (cookie.getDynamicBuffer().getRoot() != nullptr) { in dcp_get_failover_log_executor()
43 cookie.sendDynamicBuffer(); in dcp_get_failover_log_executor()
45 cookie.sendResponse(cb::mcbp::Status::Success); in dcp_get_failover_log_executor()
54 cookie in dcp_get_failover_log_executor()
[all...] |
| H A D | dcp_stream_req_executor.cc | 23 #include <daemon/cookie.h>
28 void dcp_stream_req_executor(Cookie& cookie) { in dcp_stream_req_executor() argument
31 auto ret = cookie.swapAiostat(ENGINE_SUCCESS); in dcp_stream_req_executor()
33 auto& connection = cookie.getConnection(); in dcp_stream_req_executor()
44 const auto& request = cookie.getRequest(Cookie::PacketContent::Full); in dcp_stream_req_executor()
61 if (cookie.getConnection().isCollectionsSupported()) { in dcp_stream_req_executor()
67 ret = dcpStreamReq(cookie, in dcp_stream_req_executor()
84 if (cookie.getDynamicBuffer().getRoot() != nullptr) { in dcp_stream_req_executor()
85 cookie.sendDynamicBuffer(); in dcp_stream_req_executor()
87 cookie in dcp_stream_req_executor()
[all...] |
| /6.6.0/kv_engine/daemon/ |
| H A D | mcbp_validators.cc | 21 #include "cookie.h"
36 bool is_document_key_valid(Cookie& cookie) { in is_document_key_valid() argument
37 const auto& req = cookie.getRequest(Cookie::PacketContent::Header); in is_document_key_valid()
39 if (!cookie.getConnection().isCollectionsSupported()) { in is_document_key_valid()
46 cookie.setErrorContext("Key length must be >= 2"); in is_document_key_valid()
57 cookie.setErrorContext("No stop-byte found"); in is_document_key_valid()
61 cookie.setErrorContext("No logical key found"); in is_document_key_valid()
67 cookie.setErrorContext("Invalid collection-id:" + in is_document_key_valid()
78 cookie.setErrorContext("Logical key exceeds " + std::to_string(maxLen)); in is_document_key_valid()
83 static inline bool may_accept_dcp_deleteV2(const Cookie& cookie) { in may_accept_dcp_deleteV2() argument
87 get_peer_description(const Cookie& cookie) get_peer_description() argument
99 verify_header(Cookie& cookie, uint8_t expected_extlen, ExpectedKeyLen expected_keylen, ExpectedValueLen expected_valuelen, ExpectedCas expected_cas, uint8_t expected_datatype_mask) verify_header() argument
313 verify_common_dcp_restrictions(Cookie& cookie) verify_common_dcp_restrictions() argument
355 dcp_open_validator(Cookie& cookie) dcp_open_validator() argument
475 dcp_add_stream_validator(Cookie& cookie) dcp_add_stream_validator() argument
516 dcp_close_stream_validator(Cookie& cookie) dcp_close_stream_validator() argument
529 dcp_get_failover_log_validator(Cookie& cookie) dcp_get_failover_log_validator() argument
542 dcp_stream_req_validator(Cookie& cookie) dcp_stream_req_validator() argument
560 dcp_stream_end_validator(Cookie& cookie) dcp_stream_end_validator() argument
574 dcp_snapshot_marker_validator(Cookie& cookie) dcp_snapshot_marker_validator() argument
625 dcp_system_event_validator(Cookie& cookie) dcp_system_event_validator() argument
672 dcp_mutation_validator(Cookie& cookie) dcp_mutation_validator() argument
735 dcp_deletion_validator(Cookie& cookie) dcp_deletion_validator() argument
763 dcp_expiration_validator(Cookie& cookie) dcp_expiration_validator() argument
780 dcp_set_vbucket_state_validator(Cookie& cookie) dcp_set_vbucket_state_validator() argument
802 dcp_noop_validator(Cookie& cookie) dcp_noop_validator() argument
815 dcp_buffer_acknowledgement_validator(Cookie& cookie) dcp_buffer_acknowledgement_validator() argument
829 dcp_control_validator(Cookie& cookie) dcp_control_validator() argument
854 dcp_prepare_validator(Cookie& cookie) dcp_prepare_validator() argument
897 dcp_seqno_acknowledged_validator(Cookie& cookie) dcp_seqno_acknowledged_validator() argument
913 dcp_commit_validator(Cookie& cookie) dcp_commit_validator() argument
927 dcp_abort_validator(Cookie& cookie) dcp_abort_validator() argument
941 update_user_permissions_validator(Cookie& cookie) update_user_permissions_validator() argument
950 configuration_refresh_validator(Cookie& cookie) configuration_refresh_validator() argument
959 auth_provider_validator(Cookie& cookie) auth_provider_validator() argument
968 drop_privilege_validator(Cookie& cookie) drop_privilege_validator() argument
977 get_cluster_config_validator(Cookie& cookie) get_cluster_config_validator() argument
986 set_cluster_config_validator(Cookie& cookie) set_cluster_config_validator() argument
1022 verbosity_validator(Cookie& cookie) verbosity_validator() argument
1032 hello_validator(Cookie& cookie) hello_validator() argument
1053 version_validator(Cookie& cookie) version_validator() argument
1062 quit_validator(Cookie& cookie) quit_validator() argument
1071 sasl_list_mech_validator(Cookie& cookie) sasl_list_mech_validator() argument
1080 sasl_auth_validator(Cookie& cookie) sasl_auth_validator() argument
1089 noop_validator(Cookie& cookie) noop_validator() argument
1098 flush_validator(Cookie& cookie) flush_validator() argument
1129 add_validator(Cookie& cookie) add_validator() argument
1150 set_replace_validator(Cookie& cookie) set_replace_validator() argument
1171 append_prepend_validator(Cookie& cookie) append_prepend_validator() argument
1191 get_validator(Cookie& cookie) get_validator() argument
1208 gat_validator(Cookie& cookie) gat_validator() argument
1228 delete_validator(Cookie& cookie) delete_validator() argument
1245 stat_validator(Cookie& cookie) stat_validator() argument
1278 arithmetic_validator(Cookie& cookie) arithmetic_validator() argument
1296 get_cmd_timer_validator(Cookie& cookie) get_cmd_timer_validator() argument
1305 set_ctrl_token_validator(Cookie& cookie) set_ctrl_token_validator() argument
1327 get_ctrl_token_validator(Cookie& cookie) get_ctrl_token_validator() argument
1336 ioctl_get_validator(Cookie& cookie) ioctl_get_validator() argument
1354 ioctl_set_validator(Cookie& cookie) ioctl_set_validator() argument
1380 audit_put_validator(Cookie& cookie) audit_put_validator() argument
1389 audit_config_reload_validator(Cookie& cookie) audit_config_reload_validator() argument
1398 config_reload_validator(Cookie& cookie) config_reload_validator() argument
1407 config_validate_validator(Cookie& cookie) config_validate_validator() argument
1427 observe_seqno_validator(Cookie& cookie) observe_seqno_validator() argument
1444 get_adjusted_time_validator(Cookie& cookie) get_adjusted_time_validator() argument
1453 set_drift_counter_state_validator(Cookie& cookie) set_drift_counter_state_validator() argument
1469 create_bucket_validator(Cookie& cookie) create_bucket_validator() argument
1487 list_bucket_validator(Cookie& cookie) list_bucket_validator() argument
1496 delete_bucket_validator(Cookie& cookie) delete_bucket_validator() argument
1505 select_bucket_validator(Cookie& cookie) select_bucket_validator() argument
1523 get_all_vb_seqnos_validator(Cookie& cookie) get_all_vb_seqnos_validator() argument
1570 shutdown_validator(Cookie& cookie) shutdown_validator() argument
1579 get_meta_validator(Cookie& cookie) get_meta_validator() argument
1617 mutate_with_meta_validator(Cookie& cookie) mutate_with_meta_validator() argument
1658 get_errmap_validator(Cookie& cookie) get_errmap_validator() argument
1683 get_locked_validator(Cookie& cookie) get_locked_validator() argument
1709 unlock_validator(Cookie& cookie) unlock_validator() argument
1726 evict_key_validator(Cookie& cookie) evict_key_validator() argument
1742 collections_set_manifest_validator(Cookie& cookie) collections_set_manifest_validator() argument
1760 collections_get_manifest_validator(Cookie& cookie) collections_get_manifest_validator() argument
1778 collections_get_id_validator(Cookie& cookie) collections_get_id_validator() argument
1796 adjust_timeofday_validator(Cookie& cookie) adjust_timeofday_validator() argument
1824 ewb_validator(Cookie& cookie) ewb_validator() argument
1845 scrub_validator(Cookie& cookie) scrub_validator() argument
1854 get_random_key_validator(Cookie& cookie) get_random_key_validator() argument
1876 set_vbucket_validator(Cookie& cookie) set_vbucket_validator() argument
1932 del_vbucket_validator(Cookie& cookie) del_vbucket_validator() argument
1941 get_vbucket_validator(Cookie& cookie) get_vbucket_validator() argument
1950 start_stop_persistence_validator(Cookie& cookie) start_stop_persistence_validator() argument
1959 enable_disable_traffic_validator(Cookie& cookie) enable_disable_traffic_validator() argument
1968 get_keys_validator(Cookie& cookie) get_keys_validator() argument
1994 set_param_validator(Cookie& cookie) set_param_validator() argument
2016 return_meta_validator(Cookie& cookie) return_meta_validator() argument
2048 seqno_persistence_validator(Cookie& cookie) seqno_persistence_validator() argument
2057 last_closed_checkpoint_validator(Cookie& cookie) last_closed_checkpoint_validator() argument
2066 create_checkpoint_validator(Cookie& cookie) create_checkpoint_validator() argument
2075 chekpoint_persistence_validator(Cookie& cookie) chekpoint_persistence_validator() argument
2104 compact_db_validator(Cookie& cookie) compact_db_validator() argument
2128 observe_validator(Cookie& cookie) observe_validator() argument
2137 not_supported_validator(Cookie& cookie) not_supported_validator() argument
2152 validate(ClientOpcode command, Cookie& cookie) validate() argument
[all...] |
| H A D | mcbp_executors.cc | 66 void update_topkeys(const Cookie& cookie) { in update_topkeys() argument
67 const auto opcode = cookie.getHeader().getOpcode(); in update_topkeys()
69 const auto index = cookie.getConnection().getBucketIndex(); in update_topkeys()
70 const auto key = cookie.getRequestKey(); in update_topkeys()
78 static void process_bin_get(Cookie& cookie) { in process_bin_get() argument
79 cookie.obtainContext<GetCommandContext>(cookie).drive(); in process_bin_get()
82 static void process_bin_get_meta(Cookie& cookie) { in process_bin_get_meta() argument
83 cookie.obtainContext<GetMetaCommandContext>(cookie) in process_bin_get_meta()
86 get_locked_executor(Cookie& cookie) get_locked_executor() argument
90 unlock_executor(Cookie& cookie) unlock_executor() argument
94 gat_executor(Cookie& cookie) gat_executor() argument
120 process_bin_unknown_packet(Cookie& cookie) process_bin_unknown_packet() argument
160 process_bin_noop_response(Cookie& cookie) process_bin_noop_response() argument
164 add_set_replace_executor(Cookie& cookie, ENGINE_STORE_OPERATION store_op) add_set_replace_executor() argument
173 add_executor(Cookie& cookie) add_executor() argument
177 set_executor(Cookie& cookie) set_executor() argument
181 replace_executor(Cookie& cookie) replace_executor() argument
185 append_prepend_executor(Cookie& cookie) append_prepend_executor() argument
190 get_executor(Cookie& cookie) get_executor() argument
194 get_meta_executor(Cookie& cookie) get_meta_executor() argument
198 stat_executor(Cookie& cookie) stat_executor() argument
202 isasl_refresh_executor(Cookie& cookie) isasl_refresh_executor() argument
206 ssl_certs_refresh_executor(Cookie& cookie) ssl_certs_refresh_executor() argument
211 verbosity_executor(Cookie& cookie) verbosity_executor() argument
223 version_executor(Cookie& cookie) version_executor() argument
233 quit_executor(Cookie& cookie) quit_executor() argument
243 quitq_executor(Cookie& cookie) quitq_executor() argument
252 sasl_list_mech_executor(Cookie& cookie) sasl_list_mech_executor() argument
292 sasl_auth_executor(Cookie& cookie) sasl_auth_executor() argument
296 noop_executor(Cookie& cookie) noop_executor() argument
300 flush_executor(Cookie& cookie) flush_executor() argument
304 delete_executor(Cookie& cookie) delete_executor() argument
310 arithmetic_executor(Cookie& cookie) arithmetic_executor() argument
315 set_ctrl_token_executor(Cookie& cookie) set_ctrl_token_executor() argument
338 get_ctrl_token_executor(Cookie& cookie) get_ctrl_token_executor() argument
347 ioctl_get_executor(Cookie& cookie) ioctl_get_executor() argument
390 ioctl_set_executor(Cookie& cookie) ioctl_set_executor() argument
428 config_validate_executor(Cookie& cookie) config_validate_executor() argument
447 config_reload_executor(Cookie& cookie) config_reload_executor() argument
460 audit_config_reload_executor(Cookie& cookie) audit_config_reload_executor() argument
464 audit_put_executor(Cookie& cookie) audit_put_executor() argument
477 create_remove_bucket_executor(Cookie& cookie) create_remove_bucket_executor() argument
481 get_errmap_executor(Cookie& cookie) get_errmap_executor() argument
498 shutdown_executor(Cookie& cookie) shutdown_executor() argument
508 update_user_permissions_executor(Cookie& cookie) update_user_permissions_executor() argument
536 rbac_refresh_executor(Cookie& cookie) rbac_refresh_executor() argument
540 auth_provider_executor(Cookie& cookie) auth_provider_executor() argument
561 no_support_executor(Cookie& cookie) no_support_executor() argument
565 process_bin_dcp_response(Cookie& cookie) process_bin_dcp_response() argument
825 execute_client_request_packet(Cookie& cookie, const cb::mcbp::Request& request) execute_client_request_packet() argument
874 execute_request_packet(Cookie& cookie, const cb::mcbp::Request& request) execute_request_packet() argument
896 execute_client_response_packet(Cookie& cookie, const cb::mcbp::Response& response) execute_client_response_packet() argument
916 execute_server_response_packet(Cookie& cookie, const cb::mcbp::Response& response) execute_server_response_packet() argument
946 execute_response_packet(Cookie& cookie, const cb::mcbp::Response& response) execute_response_packet() argument
965 try_read_mcbp_command(Cookie& cookie) try_read_mcbp_command() argument
[all...] |
| H A D | subdocument_validators.cc | 25 #include "cookie.h"
33 static cb::mcbp::Status validate_basic_header_fields(Cookie& cookie) { in validate_basic_header_fields() argument
35 McbpValidator::verify_header(cookie, in validate_basic_header_fields()
36 cookie.getHeader().getExtlen(), in validate_basic_header_fields()
45 if (!is_document_key_valid(cookie)) { in validate_basic_header_fields()
80 * @param cookie The cookie representing the command context
91 Cookie& cookie, in validate_xattr_section()
100 cookie.setErrorContext( in validate_xattr_section()
108 if (!cookie in validate_xattr_section()
90 validate_xattr_section( Cookie& cookie, bool mutator, protocol_binary_subdoc_flag flags, cb::const_char_buffer path, cb::const_char_buffer value, cb::const_char_buffer& xattr_key) validate_xattr_section() argument
147 subdoc_validator(Cookie& cookie, const SubdocCmdTraits traits) subdoc_validator() argument
272 subdoc_get_validator(Cookie& cookie) subdoc_get_validator() argument
277 subdoc_exists_validator(Cookie& cookie) subdoc_exists_validator() argument
282 subdoc_dict_add_validator(Cookie& cookie) subdoc_dict_add_validator() argument
287 subdoc_dict_upsert_validator(Cookie& cookie) subdoc_dict_upsert_validator() argument
292 subdoc_delete_validator(Cookie& cookie) subdoc_delete_validator() argument
297 subdoc_replace_validator(Cookie& cookie) subdoc_replace_validator() argument
302 subdoc_array_push_last_validator(Cookie& cookie) subdoc_array_push_last_validator() argument
307 subdoc_array_push_first_validator(Cookie& cookie) subdoc_array_push_first_validator() argument
312 subdoc_array_insert_validator(Cookie& cookie) subdoc_array_insert_validator() argument
317 subdoc_array_add_unique_validator(Cookie& cookie) subdoc_array_add_unique_validator() argument
322 subdoc_counter_validator(Cookie& cookie) subdoc_counter_validator() argument
327 subdoc_get_count_validator(Cookie& cookie) subdoc_get_count_validator() argument
350 is_valid_multipath_spec( Cookie& cookie, const char* ptr, const SubdocMultiCmdTraits traits, size_t& spec_len, bool& xattr, cb::const_char_buffer& xattr_key, mcbp::subdoc::doc_flag doc_flags, bool& is_singleton) is_valid_multipath_spec() argument
469 subdoc_multi_validator( Cookie& cookie, const SubdocMultiCmdTraits traits) subdoc_multi_validator() argument
590 subdoc_multi_lookup_validator(Cookie& cookie) subdoc_multi_lookup_validator() argument
596 subdoc_multi_mutation_validator(Cookie& cookie) subdoc_multi_mutation_validator() argument
[all...] |
| H A D | ioctl.cc | 23 #include "cookie.h"
37 Cookie& cookie, const StrToStrMap& arguments, std::string& value)>;
43 std::function<ENGINE_ERROR_CODE(Cookie& cookie,
50 static ENGINE_ERROR_CODE setReleaseFreeMemory(Cookie& cookie, in setReleaseFreeMemory() argument
54 auto& c = cookie.getConnection(); in setReleaseFreeMemory()
59 static ENGINE_ERROR_CODE setJemallocProfActive(Cookie& cookie, in setJemallocProfActive() argument
73 auto& c = cookie.getConnection(); in setJemallocProfActive()
83 static ENGINE_ERROR_CODE setJemallocProfDump(Cookie& cookie, in setJemallocProfDump() argument
87 auto& c = cookie.getConnection(); in setJemallocProfDump()
96 ENGINE_ERROR_CODE ioctlGetMcbpSla(Cookie& cookie, in ioctlGetMcbpSla() argument
107 ioctlRbacDbDump(Cookie& cookie, const StrToStrMap& arguments, std::string& value) ioctlRbacDbDump() argument
147 ioctl_get_property(Cookie& cookie, const std::string& key, std::string& value) ioctl_get_property() argument
165 ioctlSetMcbpSla(Cookie& cookie, const StrToStrMap&, const std::string& value) ioctlSetMcbpSla() argument
195 ioctl_set_property(Cookie& cookie, const std::string& key, const std::string& value) ioctl_set_property() argument
[all...] |
| H A D | subdocument_validators.h | 63 cb::mcbp::Status subdoc_get_validator(Cookie& cookie);
64 cb::mcbp::Status subdoc_exists_validator(Cookie& cookie);
65 cb::mcbp::Status subdoc_dict_add_validator(Cookie& cookie);
66 cb::mcbp::Status subdoc_dict_upsert_validator(Cookie& cookie);
67 cb::mcbp::Status subdoc_delete_validator(Cookie& cookie);
68 cb::mcbp::Status subdoc_replace_validator(Cookie& cookie);
69 cb::mcbp::Status subdoc_array_push_last_validator(Cookie& cookie);
70 cb::mcbp::Status subdoc_array_push_first_validator(Cookie& cookie);
71 cb::mcbp::Status subdoc_array_insert_validator(Cookie& cookie);
72 cb::mcbp::Status subdoc_array_add_unique_validator(Cookie& cookie);
[all...] |
| /6.6.0/kv_engine/programs/engine_testapp/ |
| H A D | mock_server.cc | 75 MockCookie* cookie_to_mock_object(const void* cookie) { in cookie_to_mock_object() argument
76 auto* ret = reinterpret_cast<const MockCookie*>(cookie); in cookie_to_mock_object()
220 ENGINE_ERROR_CODE pre_link(gsl::not_null<const void*> cookie,
234 gsl::not_null<const void*> cookie,
250 const void* cookie) override {
251 mock_perform_callbacks(type, data, cookie);
256 void store_engine_specific(gsl::not_null<const void*> cookie,
258 auto* c = cookie_to_mock_object(cookie.get());
262 void* get_engine_specific(gsl::not_null<const void*> cookie) override {
263 const auto* c = cookie_to_mock_object(cookie
449 destroy_mock_cookie(const void *cookie) destroy_mock_cookie() argument
461 mock_set_ewouldblock_handling(const void *cookie, bool enable) mock_set_ewouldblock_handling() argument
466 mock_set_mutation_extras_handling(const void *cookie, bool enable) mock_set_mutation_extras_handling() argument
471 mock_set_datatype_support(const void* cookie, protocol_binary_datatype_t datatypes) mock_set_datatype_support() argument
477 mock_set_collections_support(const void *cookie, bool enable) mock_set_collections_support() argument
482 lock_mock_cookie(const void *cookie) lock_mock_cookie() argument
487 unlock_mock_cookie(const void *cookie) unlock_mock_cookie() argument
492 waitfor_mock_cookie(const void *cookie) waitfor_mock_cookie() argument
525 get_number_of_mock_cookie_references(const void *cookie) get_number_of_mock_cookie_references() argument
534 get_number_of_mock_cookie_io_notifications(const void* cookie) get_number_of_mock_cookie_io_notifications() argument
[all...] |
| H A D | engine_testapp.cc | 36 cb::EngineErrorItemPair allocate(gsl::not_null<const void*> cookie,
44 gsl::not_null<const void*> cookie,
54 gsl::not_null<const void*> cookie,
63 cb::EngineErrorItemPair get(gsl::not_null<const void*> cookie,
68 gsl::not_null<const void*> cookie,
73 cb::EngineErrorMetadataPair get_meta(gsl::not_null<const void*> cookie,
77 cb::EngineErrorItemPair get_locked(gsl::not_null<const void*> cookie,
82 ENGINE_ERROR_CODE unlock(gsl::not_null<const void*> cookie,
88 gsl::not_null<const void*> cookie,
96 gsl::not_null<const void*> cookie,
347 to_mock_connstruct(const void* cookie) to_mock_connstruct() argument
356 get_or_create_mock_connstruct(const void* cookie) get_or_create_mock_connstruct() argument
368 check_and_destroy_mock_connstruct(MockCookie* c, const void* cookie) check_and_destroy_mock_connstruct() argument
455 allocate(gsl::not_null<const void*> cookie, const DocKey& key, const size_t nbytes, const int flags, const rel_time_t exptime, uint8_t datatype, Vbid vbucket) allocate() argument
476 allocate_ex( gsl::not_null<const void*> cookie, const DocKey& key, const size_t nbytes, const size_t priv_nbytes, const int flags, const rel_time_t exptime, uint8_t datatype, Vbid vbucket) allocate_ex() argument
512 remove( gsl::not_null<const void*> cookie, const DocKey& key, uint64_t& cas, Vbid vbucket, const boost::optional<cb::durability::Requirements>& durability, mutation_descr_t& mut_info) remove() argument
535 get(gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, DocStateFilter documentStateFilter) get() argument
550 get_if( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, std::function<bool(const item_info&)> filter) get_if() argument
561 get_and_touch( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint32_t expiryTime, const boost::optional<cb::durability::Requirements>& durability) get_and_touch() argument
579 get_locked( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint32_t lock_timeout) get_locked() argument
595 get_meta( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket) get_meta() argument
605 unlock(gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint64_t cas) unlock() argument
616 get_stats(gsl::not_null<const void*> cookie, cb::const_char_buffer key, cb::const_char_buffer value, const AddStatFn& add_stat) get_stats() argument
627 store( gsl::not_null<const void*> cookie, gsl::not_null<item*> item, uint64_t& cas, ENGINE_STORE_OPERATION operation, const boost::optional<cb::durability::Requirements>& durability, DocumentState document_state) store() argument
648 store_if( gsl::not_null<const void*> cookie, gsl::not_null<item*> item, uint64_t cas, ENGINE_STORE_OPERATION operation, const cb::StoreIfPredicate& predicate, const boost::optional<cb::durability::Requirements>& durability, DocumentState document_state) store_if() argument
669 flush(gsl::not_null<const void*> cookie) flush() argument
676 reset_stats(gsl::not_null<const void*> cookie) reset_stats() argument
680 unknown_command(const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) unknown_command() argument
710 set_collection_manifest( gsl::not_null<const void*> cookie, cb::const_char_buffer json) set_collection_manifest() argument
715 step( gsl::not_null<const void*> cookie, gsl::not_null<dcp_message_producers*> producers) step() argument
721 open(gsl::not_null<const void*> cookie, uint32_t opaque, uint32_t seqno, uint32_t flags, cb::const_char_buffer name, cb::const_char_buffer value) open() argument
730 add_stream(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t flags) add_stream() argument
748 close_stream(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, cb::mcbp::DcpStreamId sid) close_stream() argument
755 stream_req( gsl::not_null<const void*> cookie, uint32_t flags, uint32_t opaque, Vbid vbucket, uint64_t start_seqno, uint64_t end_seqno, uint64_t vbucket_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno, uint64_t* rollback_seqno, dcp_add_failover_log callback, boost::optional<cb::const_char_buffer> json) stream_req() argument
782 get_failover_log( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, dcp_add_failover_log cb) get_failover_log() argument
790 stream_end(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t flags) stream_end() argument
797 snapshot_marker( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint64_t start_seqno, uint64_t end_seqno, uint32_t flags, boost::optional<uint64_t> high_completed_seqno, boost::optional<uint64_t> max_visible_seqno) snapshot_marker() argument
816 mutation(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint32_t flags, uint64_t by_seqno, uint64_t rev_seqno, uint32_t expiration, uint32_t lock_time, cb::const_byte_buffer meta, uint8_t nru) mutation() argument
856 deletion(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint64_t by_seqno, uint64_t rev_seqno, cb::const_byte_buffer meta) deletion() argument
888 expiration(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint64_t by_seqno, uint64_t rev_seqno, uint32_t deleteTime) expiration() argument
920 set_vbucket_state( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, vbucket_state_t state) set_vbucket_state() argument
928 noop(gsl::not_null<const void*> cookie, uint32_t opaque) noop() argument
933 control(gsl::not_null<const void*> cookie, uint32_t opaque, cb::const_char_buffer key, cb::const_char_buffer value) control() argument
940 buffer_acknowledgement( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t buffer_bytes) buffer_acknowledgement() argument
949 response_handler( gsl::not_null<const void*> cookie, const protocol_binary_response_header* response) response_handler() argument
955 system_event(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, mcbp::systemevent::id event, uint64_t bySeqno, mcbp::systemevent::version version, cb::const_byte_buffer key, cb::const_byte_buffer eventData) system_event() argument
967 prepare(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint32_t flags, uint64_t by_seqno, uint64_t rev_seqno, uint32_t expiration, uint32_t lock_time, uint8_t nru, DocumentState document_state, cb::durability::Level level) prepare() argument
1001 seqno_acknowledged( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint64_t prepared_seqno) seqno_acknowledged() argument
1010 commit(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, const DocKey& key, uint64_t prepared_seqno, uint64_t commit_seqno) commit() argument
1020 abort(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, const DocKey& key, uint64_t prepared_seqno, uint64_t abort_seqno) abort() argument
1173 destroy_mock_cookie(cookie); global() variable
1195 lock_mock_cookie(cookie); global() variable
1199 unlock_mock_cookie(cookie); global() variable
1203 waitfor_mock_cookie(cookie); global() variable
[all...] |
| /6.6.0/kv_engine/engines/ep/src/ |
| H A D | ep_engine.cc | 130 const void* cookie) { in sendResponse()
133 status, cas, cookie)) { in sendResponse()
152 const void* cookie) { in sendResponse()
163 cookie)) { in sendResponse()
197 gsl::not_null<const void*> cookie, in allocate()
224 EventuallyPersistentEngine::allocate_ex(gsl::not_null<const void*> cookie, in allocate_ex() argument
252 gsl::not_null<const void*> cookie, in remove()
273 cookie, key, cas, vbucket, durReqs, mut_info); in remove()
281 gsl::not_null<const void*> cookie, in get()
311 acquireEngine(this)->get(cookie, in get()
120 sendResponse(const AddResponseFn& response, const void* key, uint16_t keylen, const void* ext, uint8_t extlen, const void* body, uint32_t bodylen, uint8_t datatype, cb::mcbp::Status status, uint64_t cas, const void* cookie) sendResponse() argument
143 sendResponse(const AddResponseFn& response, const DocKey& key, const void* ext, uint8_t extlen, const void* body, uint32_t bodylen, uint8_t datatype, cb::mcbp::Status status, uint64_t cas, const void* cookie) sendResponse() argument
196 allocate( gsl::not_null<const void*> cookie, const DocKey& key, size_t nbytes, int flags, rel_time_t exptime, uint8_t datatype, Vbid vbucket) allocate() argument
251 remove( gsl::not_null<const void*> cookie, const DocKey& key, uint64_t& cas, Vbid vbucket, const boost::optional<cb::durability::Requirements>& durability, mutation_descr_t& mut_info) remove() argument
280 get( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, DocStateFilter documentStateFilter) get() argument
315 get_if( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, std::function<bool(const item_info&)> filter) get_if() argument
323 get_and_touch( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint32_t expiry_time, const boost::optional<cb::durability::Requirements>& durability) get_and_touch() argument
336 get_locked( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint32_t lock_timeout) get_locked() argument
347 unlock( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint64_t cas) unlock() argument
374 get_stats( gsl::not_null<const void*> cookie, cb::const_char_buffer key, cb::const_char_buffer value, const AddStatFn& add_stat) get_stats() argument
392 store( gsl::not_null<const void*> cookie, gsl::not_null<item*> itm, uint64_t& cas, ENGINE_STORE_OPERATION operation, const boost::optional<cb::durability::Requirements>& durability, DocumentState document_state) store() argument
412 store_if( gsl::not_null<const void*> cookie, gsl::not_null<item*> itm, uint64_t cas, ENGINE_STORE_OPERATION operation, const cb::StoreIfPredicate& predicate, const boost::optional<cb::durability::Requirements>& durability, DocumentState document_state) store_if() argument
435 reset_stats( gsl::not_null<const void*> cookie) reset_stats() argument
871 evictKey( const void* cookie, const cb::mcbp::Request& request, const char** msg) evictKey() argument
918 getVBucket(EventuallyPersistentEngine* e, const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) getVBucket() argument
942 setVBucket(EventuallyPersistentEngine* e, const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) setVBucket() argument
990 delVBucket(EventuallyPersistentEngine* e, const void* cookie, const cb::mcbp::Request& req, const AddResponseFn& response) delVBucket() argument
1015 getReplicaCmd( const cb::mcbp::Request& request, const AddResponseFn& response, const void* cookie) getReplicaCmd() argument
1055 compactDB(EventuallyPersistentEngine* e, const void* cookie, const cb::mcbp::Request& req, const AddResponseFn& response) compactDB() argument
1147 processUnknownCommand(EventuallyPersistentEngine* h, const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) processUnknownCommand() argument
1274 unknown_command( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) unknown_command() argument
1304 step( gsl::not_null<const void*> cookie, gsl::not_null<dcp_message_producers*> producers) step() argument
1316 open( gsl::not_null<const void*> cookie, uint32_t opaque, uint32_t seqno, uint32_t flags, cb::const_char_buffer name, cb::const_char_buffer value) open() argument
1327 add_stream( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t flags) add_stream() argument
1335 close_stream( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, cb::mcbp::DcpStreamId sid) close_stream() argument
1348 stream_req( gsl::not_null<const void*> cookie, uint32_t flags, uint32_t opaque, Vbid vbucket, uint64_t startSeqno, uint64_t endSeqno, uint64_t vbucketUuid, uint64_t snapStartSeqno, uint64_t snapEndSeqno, uint64_t* rollbackSeqno, dcp_add_failover_log callback, boost::optional<cb::const_char_buffer> json) stream_req() argument
1383 get_failover_log( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, dcp_add_failover_log callback) get_failover_log() argument
1433 stream_end( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t flags) stream_end() argument
1446 snapshot_marker( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint64_t start_seqno, uint64_t end_seqno, uint32_t flags, boost::optional<uint64_t> high_completed_seqno, boost::optional<uint64_t> max_visible_seqno) snapshot_marker() argument
1469 mutation( gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint32_t flags, uint64_t by_seqno, uint64_t rev_seqno, uint32_t expiration, uint32_t lock_time, cb::const_byte_buffer meta, uint8_t nru) mutation() argument
1501 deletion( gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint64_t by_seqno, uint64_t rev_seqno, cb::const_byte_buffer meta) deletion() argument
1522 deletion_v2( gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint64_t by_seqno, uint64_t rev_seqno, uint32_t delete_time) deletion_v2() argument
1551 expiration( gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint64_t by_seqno, uint64_t rev_seqno, uint32_t deleteTime) expiration() argument
1580 set_vbucket_state( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, vbucket_state_t state) set_vbucket_state() argument
1593 noop( gsl::not_null<const void*> cookie, uint32_t opaque) noop() argument
1603 buffer_acknowledgement( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t buffer_bytes) buffer_acknowledgement() argument
1616 control( gsl::not_null<const void*> cookie, uint32_t opaque, cb::const_char_buffer key, cb::const_char_buffer value) control() argument
1629 response_handler( gsl::not_null<const void*> cookie, const protocol_binary_response_header* response) response_handler() argument
1642 system_event( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, mcbp::systemevent::id event, uint64_t bySeqno, mcbp::systemevent::version version, cb::const_byte_buffer key, cb::const_byte_buffer eventData) system_event() argument
1660 prepare( gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint32_t flags, uint64_t by_seqno, uint64_t rev_seqno, uint32_t expiration, uint32_t lock_time, uint8_t nru, DocumentState document_state, cb::durability::Level level) prepare() argument
1699 seqno_acknowledged( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint64_t prepared_seqno) seqno_acknowledged() argument
1712 commit( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, const DocKey& key, uint64_t prepared_seqno, uint64_t commit_seqno) commit() argument
1727 abort( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, const DocKey& key, uint64_t preparedSeqno, uint64_t abortSeqno) abort() argument
1742 EvpHandleDisconnect(const void* cookie, ENGINE_EVENT_TYPE type, const void* event_data, const void* cb_data) EvpHandleDisconnect() argument
1823 get_meta( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket) get_meta() argument
1828 set_collection_manifest( gsl::not_null<const void*> cookie, cb::const_char_buffer json) set_collection_manifest() argument
1840 get_collection_manifest( gsl::not_null<const void*> cookie, const AddResponseFn& response) get_collection_manifest() argument
1858 get_collection_id(gsl::not_null<const void*> cookie, cb::const_char_buffer path) get_collection_id() argument
1872 get_scope_id( gsl::not_null<const void*> cookie, cb::const_char_buffer path) get_scope_id() argument
1918 reserveCookie(const void *cookie) reserveCookie() argument
1925 releaseCookie(const void *cookie) releaseCookie() argument
1932 storeEngineSpecific(const void* cookie, void* engine_data) storeEngineSpecific() argument
1938 getEngineSpecific(const void* cookie) getEngineSpecific() argument
1944 isDatatypeSupported( const void* cookie, protocol_binary_datatype_t datatype) isDatatypeSupported() argument
1952 isMutationExtrasSupported(const void* cookie) isMutationExtrasSupported() argument
1958 isXattrEnabled(const void* cookie) isXattrEnabled() argument
1962 isCollectionsSupported(const void* cookie) isCollectionsSupported() argument
1968 getOpcodeIfEwouldblockSet( const void* cookie) getOpcodeIfEwouldblockSet() argument
1994 setErrorContext( const void* cookie, cb::const_char_buffer message) setErrorContext() argument
2000 setErrorJsonExtras( const void* cookie, const nlohmann::json& json) setErrorJsonExtras() argument
2273 itemDelete( const void* cookie, const DocKey& key, uint64_t& cas, Vbid vbucket, boost::optional<cb::durability::Requirements> durability, mutation_descr_t& mut_info) itemDelete() argument
2337 get(const void* cookie, item** itm, const DocKey& key, Vbid vbucket, get_options_t options) get() argument
2363 getAndTouchInner( const void* cookie, const DocKey& key, Vbid vbucket, uint32_t exptime) getAndTouchInner() argument
2399 getIfInner( const void* cookie, const DocKey& key, Vbid vbucket, std::function<bool(const item_info&)> filter) getIfInner() argument
2480 getLockedInner( const void* cookie, item** itm, const DocKey& key, Vbid vbucket, uint32_t lock_timeout) getLockedInner() argument
2511 unlockInner(const void* cookie, const DocKey& key, Vbid vbucket, uint64_t cas) unlockInner() argument
2518 storeIfInner( const void* cookie, Item& item, uint64_t cas, ENGINE_STORE_OPERATION operation, const cb::StoreIfPredicate& predicate) storeIfInner() argument
2626 storeInner( const void* cookie, Item& itm, uint64_t& cas, ENGINE_STORE_OPERATION operation) storeInner() argument
2687 doEngineStats( const void* cookie, const AddStatFn& add_stat) doEngineStats() argument
3203 doMemoryStats( const void* cookie, const AddStatFn& add_stat) doMemoryStats() argument
3267 doVBucketStats( const void* cookie, const AddStatFn& add_stat, const char* stat_key, int nkey, VBucketStatsDetailLevel detail) doVBucketStats() argument
3286 addVBStats(const void* cookie, const AddStatFn& add_stat, VBucket& vb, KVBucketIface* store, VBucketStatsDetailLevel detail) doVBucketStats() argument
3311 const void *cookie; doVBucketStats() member in StatVBucketVisitor
3364 doHashStats( const void* cookie, const AddStatFn& add_stat) doHashStats() argument
3444 const void *cookie; doHashStats() member in StatVBucketVisitor
3469 AddStatsStream(std::string key, const AddStatFn& callback, const void* cookie) AddStatsStream() argument
3483 const void* cookie; global() member in AddStatsStream
3487 doHashDump( const void* cookie, const AddStatFn& addStat, cb::const_char_buffer keyArgs) doHashDump() argument
3502 doCheckpointDump( const void* cookie, const AddStatFn& addStat, cb::const_char_buffer keyArgs) doCheckpointDump() argument
3517 doDurabilityMonitorDump( const void* cookie, const AddStatFn& addStat, cb::const_char_buffer keyArgs) doDurabilityMonitorDump() argument
3543 addCheckpointStat(const void* cookie, const AddStatFn& add_stat, KVBucketIface* eps, VBucket& vb) addCheckpointStat() argument
3572 const void *cookie; global() member in StatCheckpointVisitor
3608 const void *cookie; global() member in StatCheckpointTask
3613 doCheckpointStats( const void* cookie, const AddStatFn& add_stat, const char* stat_key, int nkey) doCheckpointStats() argument
3647 doDurabilityMonitorStats( const void* cookie, const AddStatFn& add_stat, const char* stat_key, int nkey) doDurabilityMonitorStats() argument
3746 const void *cookie; global() member
3825 showConnAggStat(const std::string& prefix, ConnCounter* counter, const void* cookie, const AddStatFn& add_stat) showConnAggStat() argument
3860 doConnAggStats( const void* cookie, const AddStatFn& add_stat, const char* sepPtr, size_t sep_len) doConnAggStats() argument
3887 doDcpStats( const void* cookie, const AddStatFn& add_stat, cb::const_char_buffer value) doDcpStats() argument
3918 doEvictionStats( const void* cookie, const AddStatFn& add_stat) doEvictionStats() argument
3949 doKeyStats( const void* cookie, const AddStatFn& add_stat, Vbid vbid, const DocKey& key, bool validate) doKeyStats() argument
4007 doVbIdFailoverLogStats( const void* cookie, const AddStatFn& add_stat, Vbid vbid) doVbIdFailoverLogStats() argument
4017 doAllFailoverLogStats( const void* cookie, const AddStatFn& add_stat) doAllFailoverLogStats() argument
4031 const void *cookie; doAllFailoverLogStats() member in StatVBucketVisitor
4041 doTimingStats( const void* cookie, const AddStatFn& add_stat) doTimingStats() argument
4119 doSchedulerStats( const void* cookie, const AddStatFn& add_stat) doSchedulerStats() argument
4125 cookie); doSchedulerStats() local
4131 doRunTimeStats( const void* cookie, const AddStatFn& add_stat) doRunTimeStats() argument
4137 cookie); doRunTimeStats() local
4143 doDispatcherStats( const void* cookie, const AddStatFn& add_stat) doDispatcherStats() argument
4146 cookie, add_stat); doDispatcherStats() local
4150 doTasksStats( const void* cookie, const AddStatFn& add_stat) doTasksStats() argument
4153 ObjectRegistry::getCurrentEngine(), cookie, add_stat); doTasksStats() local
4157 doWorkloadStats( const void* cookie, const AddStatFn& add_stat) doWorkloadStats() argument
4209 cookie, add_stat); doWorkloadStats() local
4218 addSeqnoVbStats(const void* cookie, const AddStatFn& add_stat, const VBucketPtr& vb) addSeqnoVbStats() argument
4285 addLookupResult(const void* cookie, std::unique_ptr<Item> result) addLookupResult() argument
4301 fetchLookupResult(const void* cookie, std::unique_ptr<Item>& itm) fetchLookupResult() argument
4335 doSeqnoStats( const void* cookie, const AddStatFn& add_stat, const char* stat_key, int nkey) doSeqnoStats() argument
4374 addLookupAllKeys(const void *cookie, ENGINE_ERROR_CODE err) addLookupAllKeys() argument
4392 doCollectionStats( const void* cookie, const AddStatFn& add_stat, const std::string& statKey) doCollectionStats() argument
4400 doScopeStats( const void* cookie, const AddStatFn& add_stat, const std::string& statKey) doScopeStats() argument
4408 doKeyStats( const void* cookie, const AddStatFn& add_stat, cb::const_char_buffer statKey) doKeyStats() argument
4431 doVKeyStats( const void* cookie, const AddStatFn& add_stat, cb::const_char_buffer statKey) doVKeyStats() argument
4455 doDcpVbTakeoverStats( const void* cookie, const AddStatFn& add_stat, cb::const_char_buffer statKey) doDcpVbTakeoverStats() argument
4471 doFailoversStats( const void* cookie, const AddStatFn& add_stat, cb::const_char_buffer key) doFailoversStats() argument
4496 doDiskinfoStats( const void* cookie, const AddStatFn& add_stat, cb::const_char_buffer key) doDiskinfoStats() argument
4514 doPrivilegedStats( const void* cookie, const AddStatFn& add_stat, cb::const_char_buffer key) doPrivilegedStats() argument
4554 getStats( const void* cookie, cb::const_char_buffer key, cb::const_char_buffer value, const AddStatFn& add_stat) getStats() argument
4717 observe( const void* cookie, const cb::mcbp::Request& req, const AddResponseFn& response) observe() argument
4819 observe_seqno( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) observe_seqno() argument
4898 handleLastClosedCheckpoint( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) handleLastClosedCheckpoint() argument
4922 handleCreateCheckpoint( const void* cookie, const cb::mcbp::Request& req, const AddResponseFn& response) handleCreateCheckpoint() argument
4972 handleCheckpointPersistence( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) handleCheckpointPersistence() argument
5044 handleSeqnoPersistence( const void* cookie, const cb::mcbp::Request& req, const AddResponseFn& response) handleSeqnoPersistence() argument
5110 getMetaInner( const void* cookie, const DocKey& key, Vbid vbucket) getMetaInner() argument
5220 checkForDatatypeJson( const void* cookie, protocol_binary_datatype_t datatype, cb::const_char_buffer body) checkForDatatypeJson() argument
5238 makeDocKey(const void* cookie, cb::const_byte_buffer key) makeDocKey() argument
5247 setWithMeta( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) setWithMeta() argument
5368 setWithMeta( Vbid vbucket, DocKey key, cb::const_byte_buffer value, ItemMetaData itemMeta, bool isDeleted, protocol_binary_datatype_t datatype, uint64_t& cas, uint64_t* seqno, const void* cookie, PermittedVBStates permittedVBStates, CheckConflicts checkConflicts, bool allowExisting, GenerateBySeqno genBySeqno, GenerateCas genCas, cb::const_byte_buffer emd) setWithMeta() argument
5494 deleteWithMeta( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) deleteWithMeta() argument
5637 deleteWithMeta( Vbid vbucket, DocKey key, ItemMetaData itemMeta, uint64_t& cas, uint64_t* seqno, const void* cookie, PermittedVBStates permittedVBStates, CheckConflicts checkConflicts, GenerateBySeqno genBySeqno, GenerateCas genCas, cb::const_byte_buffer emd, DeleteSource deleteSource) deleteWithMeta() argument
5676 handleTrafficControlCmd( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) handleTrafficControlCmd() argument
5744 doDcpVbTakeoverStats(const void* cookie, const AddStatFn& add_stat, std::string& key, Vbid vbid) doDcpVbTakeoverStats() argument
5805 returnMeta(const void* cookie, const cb::mcbp::Request& req, const AddResponseFn& response) returnMeta() argument
6044 const void *cookie; global() member in FetchAllKeysTask
6054 getAllKeys(const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) getAllKeys() argument
6101 getDCPPriority(const void* cookie) getDCPPriority() argument
6107 setDCPPriority(const void* cookie, CONN_PRIORITY priority) setDCPPriority() argument
6113 notifyIOComplete(const void* cookie, ENGINE_ERROR_CODE status) notifyIOComplete() argument
6124 getRandomKey( const void* cookie, const AddResponseFn& response) getRandomKey() argument
6150 dcpOpen( const void* cookie, uint32_t opaque, uint32_t seqno, uint32_t flags, cb::const_char_buffer stream_name, cb::const_char_buffer value) dcpOpen() argument
6220 dcpAddStream(const void* cookie, uint32_t opaque, Vbid vbucket, uint32_t flags) dcpAddStream() argument
6232 getConnHandler(const void *cookie) getConnHandler() argument
6241 handleDisconnect(const void *cookie) handleDisconnect() argument
6303 deleteVBucket( Vbid vbucket, bool waitForCompletion, const void* cookie) deleteVBucket() argument
6361 compactDB( Vbid vbid, const CompactionConfig& c, const void* cookie) compactDB() argument
6366 getAllVBucketSequenceNumbers( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) getAllVBucketSequenceNumbers() argument
6515 sendErrorResponse( const AddResponseFn& response, cb::mcbp::Status status, uint64_t cas, const void* cookie) sendErrorResponse() argument
6534 sendMutationExtras( const AddResponseFn& response, Vbid vbucket, uint64_t bySeqno, cb::mcbp::Status status, uint64_t cas, const void* cookie) sendMutationExtras() argument
6578 setVBucketState( const void* cookie, const AddResponseFn& response, Vbid vbid, vbucket_state_t to, const nlohmann::json& meta, TransferVB transfer, uint64_t cas) setVBucketState() argument
[all...] |
| H A D | statwriter.h | 37 const void* cookie) { in add_casted_stat()
39 v, static_cast<uint32_t>(strlen(v)), cookie); in add_casted_stat()
46 const void* cookie) { in add_casted_stat()
49 add_casted_stat(k, vals.str().c_str(), add_stat, cookie); in add_casted_stat()
55 const void* cookie) { in add_casted_stat()
56 add_casted_stat(k, v ? "true" : "false", add_stat, cookie); in add_casted_stat()
63 const void* cookie) { in add_casted_stat()
64 add_casted_stat(k, v.load(), add_stat, cookie); in add_casted_stat()
71 const void* cookie) { in add_casted_stat()
72 add_stat(k, static_cast<uint16_t>(strlen(k)), v.data(), v.size(), cookie); in add_casted_stat()
34 add_casted_stat(const char* k, const char* v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
43 add_casted_stat(const char* k, const T& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
52 add_casted_stat(const char* k, const bool v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
60 add_casted_stat(const char* k, const std::atomic<T>& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
68 add_casted_stat(const char* k, const cb::const_char_buffer& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
76 add_casted_histo_stat(const char* k, const T& v, const AddStatFn& add_stat, const void* cookie) add_casted_histo_stat() argument
99 add_casted_stat(const char* k, const HdrHistogram& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
106 add_casted_stat(const char* k, const Hdr1sfMicroSecHistogram& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
113 add_casted_stat(const char* k, const Hdr2sfMicroSecHistogram& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
120 add_casted_stat(const char* k, const Hdr1sfInt32Histogram& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
127 add_casted_stat(const char* k, const HdrUint8Histogram& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
151 const void *cookie; global() member
167 add_casted_stat(const char* k, const Histogram<T, Limits>& v, const AddStatFn& add_stat, const void* cookie) add_casted_stat() argument
176 add_prefixed_stat(P prefix, const char* nm, T val, const AddStatFn& add_stat, const void* cookie) add_prefixed_stat() argument
188 add_prefixed_stat(P prefix, const char* nm, Histogram<T, Limits>& val, const AddStatFn& add_stat, const void* cookie) add_prefixed_stat() argument
[all...] |
| H A D | ep_engine.h | 106 cb::EngineErrorItemPair allocate(gsl::not_null<const void*> cookie,
114 gsl::not_null<const void*> cookie,
124 gsl::not_null<const void*> cookie,
133 cb::EngineErrorItemPair get(gsl::not_null<const void*> cookie,
138 gsl::not_null<const void*> cookie,
143 cb::EngineErrorMetadataPair get_meta(gsl::not_null<const void*> cookie,
147 cb::EngineErrorItemPair get_locked(gsl::not_null<const void*> cookie,
152 ENGINE_ERROR_CODE unlock(gsl::not_null<const void*> cookie,
158 gsl::not_null<const void*> cookie,
166 gsl::not_null<const void*> cookie,
[all...] |
| /6.6.0/kv_engine/include/memcached/ |
| H A D | server_cookie_iface.h | 31 * Commands to operate on a specific cookie.
37 * Store engine-specific session data on the given cookie.
44 * @param cookie The cookie provided by the frontend
47 virtual void store_engine_specific(gsl::not_null<const void*> cookie,
51 * Retrieve engine-specific session data for the given cookie.
53 * @param cookie The cookie provided by the frontend
58 virtual void* get_engine_specific(gsl::not_null<const void*> cookie) = 0;
63 * @param cookie Th
[all...] |
| /6.6.0/kv_engine/engines/ewouldblock_engine/ |
| H A D | ewouldblock_engine.cc | 183 const void* cookie) override {
184 wrapped->perform_callbacks(type, data, cookie);
246 * @param cookie The cookie for the user's request.
249 bool should_inject_error(Cmd cmd, const void* cookie, in should_inject_error() argument
252 if (is_connection_suspended(cookie)) { in should_inject_error()
257 uint64_t id = real_api->cookie->get_connection_id(cookie); in should_inject_error()
266 if (iter->second.first != cookie) { in should_inject_error()
267 // The cookie i in should_inject_error()
954 handle_disconnect(const void* cookie, ENGINE_EVENT_TYPE type, const void* event_data, const void* cb_data) handle_disconnect() argument
1052 const void* cookie; global() member
1349 suspend(const void* cookie, uint32_t id) suspend() argument
1363 const void* cookie = nullptr; resume() local
1378 is_connection_suspended(const void* cookie) is_connection_suspended() argument
1395 schedule_notification(const void* cookie, ENGINE_ERROR_CODE status) schedule_notification() argument
1431 step( gsl::not_null<const void*> cookie, gsl::not_null<struct dcp_message_producers*> producers) step() argument
1462 open(gsl::not_null<const void*> cookie, uint32_t opaque, uint32_t seqno, uint32_t flags, cb::const_char_buffer name, cb::const_char_buffer value) open() argument
1492 stream_req( gsl::not_null<const void*> cookie, uint32_t flags, uint32_t opaque, Vbid vbucket, uint64_t start_seqno, uint64_t end_seqno, uint64_t vbucket_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno, uint64_t* rollback_seqno, dcp_add_failover_log callback, boost::optional<cb::const_char_buffer> json) stream_req() argument
1535 add_stream(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t flags) add_stream() argument
1546 close_stream(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, cb::mcbp::DcpStreamId sid) close_stream() argument
1557 get_failover_log( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, dcp_add_failover_log callback) get_failover_log() argument
1570 stream_end(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t flags) stream_end() argument
1581 snapshot_marker( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint64_t start_seqno, uint64_t end_seqno, uint32_t flags, boost::optional<uint64_t> high_completed_seqno, boost::optional<uint64_t> max_visible_seqno) snapshot_marker() argument
1604 mutation(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint32_t flags, uint64_t by_seqno, uint64_t rev_seqno, uint32_t expiration, uint32_t lock_time, cb::const_byte_buffer meta, uint8_t nru) mutation() argument
1640 deletion(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint64_t by_seqno, uint64_t rev_seqno, cb::const_byte_buffer meta) deletion() argument
1668 deletion_v2(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint64_t by_seqno, uint64_t rev_seqno, uint32_t delete_time) deletion_v2() argument
1696 expiration(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint64_t by_seqno, uint64_t rev_seqno, uint32_t deleteTime) expiration() argument
1724 set_vbucket_state( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, vbucket_state_t state) set_vbucket_state() argument
1737 noop(gsl::not_null<const void*> cookie, uint32_t opaque) noop() argument
1746 buffer_acknowledgement( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint32_t buffer_bytes) buffer_acknowledgement() argument
1759 control(gsl::not_null<const void*> cookie, uint32_t opaque, cb::const_char_buffer key, cb::const_char_buffer value) control() argument
1770 response_handler( gsl::not_null<const void*> cookie, const protocol_binary_response_header* response) response_handler() argument
1780 system_event(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, mcbp::systemevent::id event, uint64_t bySeqno, mcbp::systemevent::version version, cb::const_byte_buffer key, cb::const_byte_buffer eventData) system_event() argument
1802 prepare(gsl::not_null<const void*> cookie, uint32_t opaque, const DocKey& key, cb::const_byte_buffer value, size_t priv_bytes, uint8_t datatype, uint64_t cas, Vbid vbucket, uint32_t flags, uint64_t by_seqno, uint64_t rev_seqno, uint32_t expiration, uint32_t lock_time, uint8_t nru, DocumentState document_state, cb::durability::Level level) prepare() argument
1839 seqno_acknowledged( gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, uint64_t prepared_seqno) seqno_acknowledged() argument
1851 commit(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, const DocKey& key, uint64_t prepared_seqno, uint64_t commit_seqno) commit() argument
1865 abort(gsl::not_null<const void*> cookie, uint32_t opaque, Vbid vbucket, const DocKey& key, uint64_t prepared_seqno, uint64_t abort_seqno) abort() argument
1958 handleBlockMonitorFile( const void* cookie, uint32_t id, const std::string& file, const AddResponseFn& response) handleBlockMonitorFile() argument
2014 handleSuspend(const void* cookie, uint32_t id, const AddResponseFn& response) handleSuspend() argument
2037 handleResume(const void* cookie, uint32_t id, const AddResponseFn& response) handleResume() argument
2062 setItemCas(const void* cookie, const std::string& key, uint32_t cas, const AddResponseFn& response) setItemCas() argument
2094 checkLogLevels(const void* cookie, uint32_t value, const AddResponseFn& response) checkLogLevels() argument
2113 set_collection_manifest( gsl::not_null<const void*> cookie, cb::const_char_buffer json) set_collection_manifest() argument
2118 get_collection_manifest( gsl::not_null<const void*> cookie, const AddResponseFn& response) get_collection_manifest() argument
2123 get_collection_id( gsl::not_null<const void*> cookie, cb::const_char_buffer path) get_collection_id() argument
2128 get_scope_id( gsl::not_null<const void*> cookie, cb::const_char_buffer path) get_scope_id() argument
[all...] |
| /6.6.0/kv_engine/testsuite/basic/ |
| H A D | basic_engine_testsuite.cc | 69 const auto* cookie = test_harness->create_cookie(); in allocate_test() local
71 cookie, key, 1, 1, 1, PROTOCOL_BINARY_RAW_BYTES, Vbid(0)); in allocate_test()
72 test_harness->destroy_cookie(cookie); in allocate_test()
86 const auto* cookie = test_harness->create_cookie(); in set_test() local
88 cookie, key, 1, 1, 0, PROTOCOL_BINARY_RAW_BYTES, Vbid(0)); in set_test()
93 cb_assert(h->store(cookie, in set_test()
102 test_harness->destroy_cookie(cookie); in set_test()
113 const auto* cookie = test_harness->create_cookie(); in add_test() local
115 cookie, key, 1, 1, 0, PROTOCOL_BINARY_RAW_BYTES, Vbid(0)); in add_test()
119 ENGINE_ERROR_CODE rv = h->store(cookie, in add_test()
147 const auto* cookie = test_harness->create_cookie(); replace_test() local
182 const auto* cookie = test_harness->create_cookie(); store_test() local
204 const auto* cookie = test_harness->create_cookie(); get_test() local
227 const auto* cookie = test_harness->create_cookie(); get_deleted_test() local
265 const auto* cookie = test_harness->create_cookie(); expiry_test() local
290 const auto* cookie = test_harness->create_cookie(); release_test() local
312 const auto* cookie = test_harness->create_cookie(); remove_test() local
341 const auto* cookie = test_harness->create_cookie(); flush_test() local
370 const auto* cookie = test_harness->create_cookie(); get_item_info_test() local
405 const auto* cookie = test_harness->create_cookie(); item_set_cas_test() local
443 const auto* cookie = test_harness->create_cookie(); lru_test() local
[all...] |
| /6.6.0/couchbase-cli/requests/ |
| H A D | cookies.py | 27 manage cookie policies, i.e., determine whether a cookie can be set, given the
28 domains of the request and the cookie.
141 """Unsets a cookie by name, by default over all domains and paths.
146 for cookie in cookiejar:
147 if cookie.name != name:
149 if domain is not None and domain != cookie.domain:
151 if path is not None and path != cookie.path:
153 clearables.append((cookie.domain, cookie
[all...] |
| /6.6.0/kv_engine/engines/ep/tests/module_tests/ |
| H A D | dcp_test.cc | 63 * we can't do that as the cookie interface contains virtual pointers.
67 * The constructor installs itself as the mock server cookie interface,
68 * and the destructor reinstalls the original server cookie interfa
72 WrappedServerCookieIface() : wrapped(get_mock_server_api()->cookie) { in WrappedServerCookieIface()
73 get_mock_server_api()->cookie = this; in WrappedServerCookieIface()
77 get_mock_server_api()->cookie = wrapped;
80 void store_engine_specific(gsl::not_null<const void*> cookie,
82 wrapped->store_engine_specific(cookie, engine_data);
84 void* get_engine_specific(gsl::not_null<const void*> cookie) override {
85 return wrapped->get_engine_specific(cookie);
764 const void* cookie = create_mock_cookie(); TEST_P() local
779 const void* cookie = create_mock_cookie(); TEST_P() local
809 const void* cookie = create_mock_cookie(); TEST_P() local
832 const void* cookie = create_mock_cookie(); TEST_P() local
874 const void* cookie = create_mock_cookie(); TEST_P() local
897 const void* cookie = create_mock_cookie(); TEST_P() local
922 const void *cookie = create_mock_cookie(); TEST_P() local
941 const void *cookie = create_mock_cookie(); TEST_P() local
1057 const void* cookie = create_mock_cookie(); TEST_P() local
1088 const void* cookie = create_mock_cookie(); TEST_P() local
1152 const void* cookie = create_mock_cookie(); TEST_P() local
1180 const void* cookie = create_mock_cookie(); TEST_P() local
1199 const void* cookie = create_mock_cookie(); TEST_P() local
1219 const void* cookie = create_mock_cookie(); TEST_P() local
1303 const void* cookie = create_mock_cookie(); TEST_P() local
1338 const void* cookie = create_mock_cookie(); TEST_P() local
1355 const void* cookie = create_mock_cookie(); TEST_P() local
1406 const void *cookie = create_mock_cookie(); TEST_P() local
1436 const void *cookie = create_mock_cookie(); TEST_P() local
1486 const void *cookie = create_mock_cookie(); TEST_P() local
1545 const void* cookie = create_mock_cookie(); TEST_P() local
1560 const void* cookie = create_mock_cookie(); TEST_P() local
1598 const void* cookie = create_mock_cookie(); testConsumerNegotiatesIncludeDeletedUserXattrs() local
1681 const void* cookie = create_mock_cookie(); testProducerNegotiatesIncludeDeletedUserXattrs() local
1790 const void* cookie = create_mock_cookie(); TEST_P() local
1901 const void *cookie = create_mock_cookie(); TEST_P() local
1969 fakeDcpAddFailoverLog( vbucket_failover_t* entry, size_t nentries, gsl::not_null<const void*> cookie) fakeDcpAddFailoverLog() argument
2218 const void* cookie = create_mock_cookie(); TEST_F() local
2267 const void* cookie = create_mock_cookie(); TEST_F() local
2317 const auto* cookie = create_mock_cookie(); testLockInversionInSetVBucketStateAndNewProducer() local
2442 dcp_test_notify_io_complete(gsl::not_null<const void*> cookie, ENGINE_ERROR_CODE status) dcp_test_notify_io_complete() argument
2456 const void* cookie = nullptr; global() member in ConnMapNotifyTest
2552 const void* cookie = create_mock_cookie(); TEST_P() local
2599 const void* cookie = create_mock_cookie(); TEST_P() local
2651 const void* cookie = create_mock_cookie(); sendConsumerMutationsNearThreshold() local
2790 const void* cookie = create_mock_cookie(); processConsumerMutationsNearThreshold() local
2927 const void* cookie = create_mock_cookie(); TEST_P() local
2973 destroy_mock_cookie(cookie); global() variable
2987 fakeDcpAddFailoverLog( vbucket_failover_t* entry, size_t nentries, gsl::not_null<const void*> cookie) fakeDcpAddFailoverLog() argument
2999 const void* cookie; global() member in ActiveStreamChkptProcessorTaskTest
[all...] |
| /6.6.0/kv_engine/engines/ep/tests/ |
| H A D | ep_testsuite_dcp.cc | 52 const void* cookie, in dcp_step()
55 ENGINE_ERROR_CODE err = dcp->step(cookie, &producers); in dcp_step()
64 const void* cookie, in dcpHandleResponse()
68 auto erroCode = dcp->response_handler(cookie, response); in dcpHandleResponse()
182 cookie(_cookie), in TestDcpConsumer()
281 /* Connection cookie */
282 const void *cookie; member in TestDcpConsumer
327 return dcp->control(cookie, ++opaque, name, value); in sendControlMessage()
350 cookie, in deleteOrExpireCase()
399 dcp->buffer_acknowledgement(cookie, in run()
51 dcp_step(EngineIface* h, const void* cookie, MockDcpMessageProducers& producers) dcp_step() argument
63 dcpHandleResponse(EngineIface* h, const void* cookie, protocol_binary_response_header* response, MockDcpMessageProducers& producers) dcpHandleResponse() argument
847 notifier_request(EngineIface* h, const void* cookie, uint32_t opaque, Vbid vbucket, uint64_t start, bool shouldSucceed) notifier_request() argument
899 dcp_stream_to_replica(EngineIface* h, const void* cookie, uint32_t opaque, Vbid vbucket, uint32_t flags, uint64_t start, uint64_t end, uint64_t snap_start_seqno, uint64_t snap_end_seqno, uint8_t cas = 0x1, uint8_t datatype = 1, uint32_t exprtime = 0, uint32_t lockTime = 0, uint64_t revSeqno = 0) dcp_stream_to_replica() argument
956 dcp_stream_from_producer_conn(EngineIface* h, const void* cookie, uint32_t opaque, uint64_t start, uint64_t end, uint64_t expSnapStart, MockDcpMessageProducers& producers) dcp_stream_from_producer_conn() argument
1038 dcp_stream_expiries_to_replica(EngineIface* h, const void* cookie, uint32_t opaque, Vbid vbucket, uint32_t flags, uint64_t start, uint64_t end, uint64_t snap_start_seqno, uint64_t snap_end_seqno, uint32_t delTime, uint64_t revSeqno = 0, uint8_t cas = 0x1) dcp_stream_expiries_to_replica() argument
1104 const void *cookie; global() member
1125 const void* cookie = testHarness->create_cookie(); dcp_thread_func() local
1252 dcp_waiting_step(EngineIface* h, const void* cookie, uint32_t opaque, uint64_t exp_mutations, MockDcpMessageProducers& producers) dcp_waiting_step() argument
1406 const auto* cookie = testHarness->create_cookie(); test_dcp_notifier() local
1497 const auto* cookie = testHarness->create_cookie(); test_dcp_notifier_equal_to_number_of_items() local
1685 const auto* cookie = testHarness->create_cookie(); test_dcp_consumer_flow_control_dynamic() local
1742 const void *cookie[max_conns]; test_dcp_consumer_flow_control_aggressive() local
1928 const auto* cookie = testHarness->create_cookie(); test_dcp_producer_open_same_cookie() local
1983 const auto* cookie = testHarness->create_cookie(); test_dcp_noop() local
2044 const auto* cookie = testHarness->create_cookie(); test_dcp_noop_fail() local
2095 const auto* cookie = testHarness->create_cookie(); test_dcp_consumer_noop() local
2142 const void* cookie = testHarness->create_cookie(); test_dcp_noop_mandatory_combo() local
2195 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_open() local
2283 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_partial() local
2333 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_full_merged_snapshots() local
2369 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_full() local
2404 const void* cookie = testHarness->create_cookie(); test_dcp_producer_deleted_item_backfill() local
2471 const void* cookie = testHarness->create_cookie(); testDcpProducerExpiredItemBackfill() local
2510 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_backfill() local
2557 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_diskonly() local
2583 const void* cookie = testHarness->create_cookie(); test_dcp_producer_disk_backfill_limits() local
2636 const void* cookie = testHarness->create_cookie(); test_dcp_producer_disk_backfill_buffer_limits() local
2664 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_mem() local
2693 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_dgm() local
2755 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_req_coldness() local
2810 const void* cookie = testHarness->create_cookie(); test_dcp_consumer_hotness_data() local
2909 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_latest() local
2937 const void* cookie = testHarness->create_cookie(); test_dcp_producer_keep_stream_open() local
2998 const void* cookie = testHarness->create_cookie(); test_dcp_producer_keep_stream_open_replica() local
3149 const void* cookie = testHarness->create_cookie(); test_dcp_producer_stream_cursor_movement() local
3247 const void *cookie[5]; test_dcp_agg_stats() local
3306 const void* cookie = testHarness->create_cookie(); test_dcp_cursor_dropping() local
3415 const void* cookie = testHarness->create_cookie(); test_dcp_cursor_dropping_backfill() local
3467 const void* cookie = testHarness->create_cookie(); test_dcp_takeover() local
3493 const void* cookie = testHarness->create_cookie(); test_dcp_takeover_no_items() local
3599 simulateProdRespToDcpControlBlockingNegotiation( EngineIface* engine, const void* cookie, MockDcpMessageProducers& producers) simulateProdRespToDcpControlBlockingNegotiation() argument
3611 add_stream_for_consumer(EngineIface* h, const void* cookie, uint32_t opaque, Vbid vbucket, uint32_t flags, cb::mcbp::Status response, uint64_t exp_snap_start, uint64_t exp_snap_end) add_stream_for_consumer() argument
3799 const void* cookie = testHarness->create_cookie(); test_dcp_reconnect() local
3924 const void* cookie = testHarness->create_cookie(); test_dcp_consumer_takeover() local
4077 const void* cookie = testHarness->create_cookie(); test_failover_scenario_one_with_dcp() local
4144 const void* cookie = testHarness->create_cookie(); test_failover_scenario_two_with_dcp() local
4243 const void* cookie = testHarness->create_cookie(); test_dcp_add_stream() local
4286 const void* cookie = testHarness->create_cookie(); test_consumer_backoff_stat() local
4364 const void* cookie = testHarness->create_cookie(); test_rollback_to_zero() local
4409 drainDcpControl(EngineIface* engine, const void* cookie, MockDcpMessageProducers& producers) drainDcpControl() argument
4460 const void* cookie = testHarness->create_cookie(); test_chk_manager_rollback() local
4557 const void* cookie = testHarness->create_cookie(); test_fullrollback_for_consumer() local
4684 const void* cookie = testHarness->create_cookie(); test_partialrollback_for_consumer() local
4790 const void* cookie = testHarness->create_cookie(); test_dcp_buffer_log_size() local
4865 const void* cookie = testHarness->create_cookie(); test_dcp_producer_flow_control() local
4896 const void* cookie = testHarness->create_cookie(); test_dcp_get_failover_log() local
4944 const void* cookie = testHarness->create_cookie(); test_dcp_add_stream_exists() local
5008 const void* cookie = testHarness->create_cookie(); test_dcp_add_stream_nmvb() local
5038 const void* cookie = testHarness->create_cookie(); test_dcp_add_stream_prod_exists() local
5064 const void* cookie = testHarness->create_cookie(); test_dcp_add_stream_prod_nmvb() local
5089 const void* cookie = testHarness->create_cookie(); test_dcp_close_stream_no_stream() local
5113 const void* cookie = testHarness->create_cookie(); test_dcp_close_stream() local
5149 const void* cookie = testHarness->create_cookie(); test_dcp_consumer_end_stream() local
5190 const void* cookie = testHarness->create_cookie(); test_dcp_consumer_mutate() local
5342 const void* cookie = testHarness->create_cookie(); test_dcp_consumer_delete() local
5437 const void* cookie = testHarness->create_cookie(); test_dcp_consumer_expire() local
5528 const void* cookie = testHarness->create_cookie(); test_dcp_replica_stream_backfill() local
5591 const void* cookie = testHarness->create_cookie(); test_dcp_replica_stream_backfill_MB_34173() local
5663 const void* cookie = testHarness->create_cookie(); test_dcp_replica_stream_in_memory() local
5715 const void* cookie = testHarness->create_cookie(); test_dcp_replica_stream_all() local
5817 const void* cookie = testHarness->create_cookie(); test_dcp_replica_stream_expiries() local
5941 const void* cookie = testHarness->create_cookie(); test_stream_deleteWithMeta_expiration() local
5987 const void* cookie = testHarness->create_cookie(); test_dcp_persistence_seqno() local
6067 const void* cookie = testHarness->create_cookie(); test_dcp_persistence_seqno_backfillItems() local
6180 const void* cookie = testHarness->create_cookie(); test_dcp_last_items_purged() local
6220 const void* cookie = testHarness->create_cookie(); test_dcp_rollback_after_purge() local
6312 const void* cookie = testHarness->create_cookie(); test_dcp_erroneous_mutations() local
6592 const void* cookie = testHarness->create_cookie(); test_dcp_invalid_mutation_deletion() local
6659 const void* cookie = testHarness->create_cookie(); test_dcp_invalid_snapshot_marker() local
6755 const void* cookie = testHarness->create_cookie(); test_dcp_early_termination() local
6931 const void* cookie = testHarness->create_cookie(); test_failover_log_dcp() local
6977 const void* cookie = testHarness->create_cookie(); test_mb17517_cas_minus_1_dcp() local
7113 const void* cookie = testHarness->create_cookie(); test_dcp_multiple_streams() local
7152 const void* cookie = testHarness->create_cookie(); test_dcp_on_vbucket_state_change() local
7200 const void* cookie = testHarness->create_cookie(); test_dcp_consumer_processer_behavior() local
7282 const void* cookie = testHarness->create_cookie(); test_get_all_vb_seqnos() local
7535 const void* cookie = testHarness->create_cookie(); test_mb19153() local
7589 mb19982_add_stat(const char* key, const uint16_t klen, const char* val, const uint32_t vlen, gsl::not_null<const void*> cookie) mb19982_add_stat() argument
7609 const void* cookie = testHarness->create_cookie(); test_mb19982() local
7724 const void* cookie = testHarness->create_cookie(); test_MB_34634() local
7864 const void* cookie = testHarness->create_cookie(); test_MB_34664() local
[all...] |
| /6.6.0/kv_engine/engines/default_engine/ |
| H A D | default_engine.cc | 153 gsl::not_null<const void*> cookie, in allocate()
161 auto pair = allocate_ex(cookie, in allocate()
177 gsl::not_null<const void*> cookie, in allocate_ex()
212 cookie, in allocate_ex()
234 gsl::not_null<const void*> cookie, in remove()
251 this, cookie, key.data(), key.size(), DocStateFilter::Alive); in remove()
270 cookie, in remove()
293 cookie, in remove()
316 gsl::not_null<const void*> cookie, in get()
327 item_get(this, cookie, ke in get()
152 allocate( gsl::not_null<const void*> cookie, const DocKey& key, size_t nbytes, int flags, rel_time_t exptime, uint8_t datatype, Vbid vbucket) allocate() argument
176 allocate_ex( gsl::not_null<const void*> cookie, const DocKey& key, size_t nbytes, size_t priv_nbytes, int flags, rel_time_t exptime, uint8_t datatype, Vbid vbucket) allocate_ex() argument
233 remove( gsl::not_null<const void*> cookie, const DocKey& key, uint64_t& cas, Vbid vbucket, const boost::optional<cb::durability::Requirements>& durability, mutation_descr_t& mut_info) remove() argument
315 get( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, DocStateFilter documentStateFilter) get() argument
335 get_if( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, std::function<bool(const item_info&)> filter) get_if() argument
368 get_and_touch( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint32_t expiry_time, const boost::optional<cb::durability::Requirements>& durability) get_and_touch() argument
394 get_locked( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint32_t lock_timeout) get_locked() argument
421 get_meta( gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket) get_meta() argument
447 unlock(gsl::not_null<const void*> cookie, const DocKey& key, Vbid vbucket, uint64_t cas) unlock() argument
455 get_stats(gsl::not_null<const void*> cookie, cb::const_char_buffer key, cb::const_char_buffer value, const AddStatFn& add_stat) get_stats() argument
523 store( gsl::not_null<const void*> cookie, gsl::not_null<item*> item, uint64_t& cas, ENGINE_STORE_OPERATION operation, const boost::optional<cb::durability::Requirements>& durability, DocumentState document_state) store() argument
543 store_if( gsl::not_null<const void*> cookie, gsl::not_null<item*> item, uint64_t cas, ENGINE_STORE_OPERATION operation, const cb::StoreIfPredicate& predicate, const boost::optional<cb::durability::Requirements>& durability, DocumentState document_state) store_if() argument
596 flush(gsl::not_null<const void*> cookie) flush() argument
602 reset_stats(gsl::not_null<const void*> cookie) reset_stats() argument
695 set_vbucket(struct default_engine* e, const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) set_vbucket() argument
717 get_vbucket(struct default_engine* e, const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) get_vbucket() argument
737 rm_vbucket(struct default_engine* e, const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) rm_vbucket() argument
754 scrub_cmd(struct default_engine* e, const void* cookie, const AddResponseFn& response) scrub_cmd() argument
778 set_param(struct default_engine* e, const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) set_param() argument
835 unknown_command( const void* cookie, const cb::mcbp::Request& request, const AddResponseFn& response) unknown_command() argument
[all...] |
| /6.6.0/kv_engine/engines/ep/benchmarks/ |
| H A D | tracing_bench.cc | 32 auto* cookie = create_mock_cookie(); in SessionTracingRecordMutationSpan() local
33 cookie_to_mock_object(cookie)->setTracingEnabled(true); in SessionTracingRecordMutationSpan()
37 { TRACE_SCOPE(cookie, cb::tracing::Code::Request); } in SessionTracingRecordMutationSpan()
38 { TRACE_SCOPE(cookie, cb::tracing::Code::Store); } in SessionTracingRecordMutationSpan()
40 cookie_to_mock_object(cookie)->getTracer().clear(); in SessionTracingRecordMutationSpan()
47 auto* cookie = create_mock_cookie(); in SessionTracingScopeTimer() local
48 cookie_to_mock_object(cookie)->setTracingEnabled(true); in SessionTracingScopeTimer()
54 TracerStopwatch(cookie, cb::tracing::Code::Request)); in SessionTracingScopeTimer()
58 TracerStopwatch(cookie, cb::tracing::Code::Store)); in SessionTracingScopeTimer()
61 cookie_to_mock_object(cookie) in SessionTracingScopeTimer()
68 auto* cookie = create_mock_cookie(); SessionTracingEncode() local
[all...] |