/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/tddb/td/db/binlog/ |
H A D | BinlogEvent.cpp | 17 Status BinlogEvent::init(BufferSlice &&raw_event, bool check_crc) { in init() argument 18 TlParser parser(raw_event.as_slice()); in init() 20 LOG_CHECK(size_ == raw_event.size()) << size_ << " " << raw_event.size() << debug_info_; in init() 36 raw_event_ = std::move(raw_event); in init() 53 auto raw_event = BufferSlice{storer.size() + MIN_SIZE}; in create_raw() 55 TlStorerUnsafe tl_storer(raw_event.as_slice().ubegin()); in create_raw() 56 tl_storer.store_int(narrow_cast<int32>(raw_event.size())); in create_raw() 62 CHECK(tl_storer.get_buf() == raw_event.as_slice().ubegin() + HEADER_SIZE); in create_raw() 65 CHECK(tl_storer.get_buf() == raw_event.as_slice().uend() - TAIL_SIZE); in create_raw() 66 tl_storer.store_int(crc32(raw_event.as_slice().truncate(raw_event.size() - TAIL_SIZE))); in create_raw() [all …]
|
H A D | ConcurrentBinlog.cpp | 38 BufferSlice raw_event; member 42 …void add_raw_event(uint64 seq_no, BufferSlice &&raw_event, Promise<> &&promise, BinlogDebugInfo in… in add_raw_event() argument 43 …processor_.add(seq_no, Event{std::move(raw_event), std::move(promise), info}, [&](uint64 id, Event… in add_raw_event() 44 if (!event.raw_event.empty()) { in add_raw_event() 45 do_add_raw_event(std::move(event.raw_event), event.debug_info); in add_raw_event() 99 void do_add_raw_event(BufferSlice &&raw_event, BinlogDebugInfo info) { in do_add_raw_event() argument 100 binlog_->add_raw_event(std::move(raw_event), info); in do_add_raw_event() 195 void ConcurrentBinlog::add_raw_event_impl(uint64 id, BufferSlice &&raw_event, Promise<> promise, Bi… in add_raw_event_impl() argument 196 …send_closure(binlog_actor_, &detail::BinlogActor::add_raw_event, id, std::move(raw_event), std::mo… in add_raw_event_impl()
|
H A D | BinlogInterface.h | 35 …void add_raw_event(BinlogDebugInfo info, uint64 id, BufferSlice &&raw_event, Promise<> promise = P… 36 add_raw_event_impl(id, std::move(raw_event), std::move(promise), info); 38 void add_raw_event(uint64 id, BufferSlice &&raw_event, Promise<> promise = Promise<>()) { 39 add_raw_event_impl(id, std::move(raw_event), std::move(promise), {}); 77 …virtual void add_raw_event_impl(uint64 id, BufferSlice &&raw_event, Promise<> promise, BinlogDebug…
|
H A D | BinlogEvent.h | 94 BinlogEvent(BufferSlice &&raw_event, BinlogDebugInfo info) { in BinlogEvent() 96 init(std::move(raw_event), false).ensure(); in BinlogEvent() 99 Status init(BufferSlice &&raw_event, bool check_crc = true) TD_WARN_UNUSED_RESULT;
|
/dports/x11-wm/leftwm/leftwm-0.2.11/leftwm-core/src/display_servers/xlib_display_server/ |
H A D | event_translate.rs | 22 let raw_event = x_event.1; in from() localVariable 24 match raw_event.get_type() { in from() 26 xlib::MapRequest => from_map_request(raw_event, xw), in from() 67 let event = xlib::XKeyEvent::from(raw_event); in from() 82 let event = xlib::XMapRequestEvent::from(raw_event); in from_map_request() 155 let mut event = xlib::XMappingEvent::from(raw_event); in from_mapping_notify() 168 fn from_unmap_event(raw_event: xlib::XEvent) -> DisplayEvent { in from_unmap_event() 169 let event = xlib::XUnmapEvent::from(raw_event); in from_unmap_event() 180 let event = xlib::XEnterWindowEvent::from(raw_event); in from_enter_notify() 181 let crossing = xlib::XCrossingEvent::from(raw_event); in from_enter_notify() [all …]
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/ucs/sys/ |
H A D | event_set.c | 131 struct epoll_event raw_event; in ucs_event_set_add() local 134 memset(&raw_event, 0, sizeof(raw_event)); in ucs_event_set_add() 135 raw_event.events = ucs_event_set_map_to_raw_events(events); in ucs_event_set_add() 136 raw_event.data.ptr = callback_data; in ucs_event_set_add() 138 ret = epoll_ctl(event_set->event_fd, EPOLL_CTL_ADD, fd, &raw_event); in ucs_event_set_add() 151 struct epoll_event raw_event; in ucs_event_set_mod() local 154 memset(&raw_event, 0, sizeof(raw_event)); in ucs_event_set_mod() 155 raw_event.events = ucs_event_set_map_to_raw_events(events); in ucs_event_set_mod() 156 raw_event.data.ptr = callback_data; in ucs_event_set_mod() 158 ret = epoll_ctl(event_set->event_fd, EPOLL_CTL_MOD, fd, &raw_event); in ucs_event_set_mod()
|
/dports/net-im/tdlib/td-a53cb30e99f937cfd64e0266fa558785a184a553/tddb/td/db/ |
H A D | TQueue.cpp | 104 raw_event.expires_at <= 0) { in do_push() 107 auto event_id = raw_event.event_id; in do_push() 127 raw_event.log_event_id = callback_->push(queue_id, raw_event); in do_push() 174 RawEvent raw_event; in push() local 175 raw_event.event_id = event_id; in push() 176 raw_event.data = std::move(data); in push() 178 raw_event.extra = extra; in push() 465 RawEvent raw_event; in replay() local 467 raw_event.event_id = event_id; in replay() 469 raw_event.data = event.data.str(); in replay() [all …]
|
/dports/lang/rust/rustc-1.58.1-src/vendor/measureme/src/ |
H A D | profiler.rs | 3 use crate::raw_event::RawEvent; 101 let raw_event = in record_instant_event() localVariable 104 self.record_raw_event(&raw_event); in record_instant_event() 116 let raw_event = RawEvent::new_integer(event_kind, event_id, thread_id, value); in record_integer_event() localVariable 117 self.record_raw_event(&raw_event); in record_integer_event() 174 fn record_raw_event(&self, raw_event: &RawEvent) { in record_raw_event() 177 raw_event.serialize(bytes); in record_raw_event() 207 let raw_event = RawEvent::new_interval( in drop() localVariable 215 self.profiler.record_raw_event(&raw_event); in drop()
|
/dports/games/jinput/jinput-bf22dd975bbba31f01895332255b63df376894e6/plugins/windows/src/main/java/net/java/games/input/ |
H A D | RawKeyboard.java | 47 private final RawKeyboardEvent raw_event = new RawKeyboardEvent(); field in RawKeyboard 76 if (!device.getNextKeyboardEvent(raw_event)) in getNextDeviceEvent() 78 int vkey = raw_event.getVKey(); in getNextDeviceEvent() 83 int message = raw_event.getMessage(); in getNextDeviceEvent() 85 event.set(key, 1, raw_event.getNanos()); in getNextDeviceEvent() 88 event.set(key, 0, raw_event.getNanos()); in getNextDeviceEvent()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/arch/mips/kernel/ |
H A D | perf_event_mipsxx.c | 1789 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1800 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1802 raw_event.range = V; in mipsxx_pmu_map_raw_event() 1804 raw_event.range = T; in mipsxx_pmu_map_raw_event() 1815 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1825 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1839 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1856 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1917 return &raw_event; in mipsxx_pmu_map_raw_event() 1953 return &raw_event; in octeon_pmu_map_raw_event() [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/arch/mips/kernel/ |
H A D | perf_event_mipsxx.c | 1789 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1800 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1802 raw_event.range = V; in mipsxx_pmu_map_raw_event() 1804 raw_event.range = T; in mipsxx_pmu_map_raw_event() 1815 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1825 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1839 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1856 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1917 return &raw_event; in mipsxx_pmu_map_raw_event() 1953 return &raw_event; in octeon_pmu_map_raw_event() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/arch/mips/kernel/ |
H A D | perf_event_mipsxx.c | 1789 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1800 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1802 raw_event.range = V; in mipsxx_pmu_map_raw_event() 1804 raw_event.range = T; in mipsxx_pmu_map_raw_event() 1815 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1825 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1839 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1856 raw_event.range = P; in mipsxx_pmu_map_raw_event() 1917 return &raw_event; in mipsxx_pmu_map_raw_event() 1953 return &raw_event; in octeon_pmu_map_raw_event() [all …]
|
/dports/devel/racer/racer-2.1.48/cargo-crates/measureme-9.1.0/src/ |
H A D | profiler.rs | 3 use crate::raw_event::RawEvent; 101 let raw_event = in record_instant_event() localVariable 104 self.record_raw_event(&raw_event); in record_instant_event() 125 fn record_raw_event(&self, raw_event: &RawEvent) { in record_raw_event() 128 raw_event.serialize(bytes); in record_raw_event() 147 let raw_event = RawEvent::new_interval( in drop() localVariable 155 self.profiler.record_raw_event(&raw_event); in drop()
|
H A D | raw_event.rs | 143 let mut raw_event = RawEvent::default(); in deserialize() localVariable 145 let raw_event = std::slice::from_raw_parts_mut( in deserialize() localVariable 146 &mut raw_event as *mut RawEvent as *mut u8, in deserialize() 149 raw_event.copy_from_slice(bytes); in deserialize() 151 raw_event in deserialize()
|
H A D | lib.rs | 46 mod raw_event; module 54 pub use crate::raw_event::{RawEvent, MAX_INSTANT_TIMESTAMP, MAX_INTERVAL_TIMESTAMP};
|
/dports/devel/py-pyinotify/pyinotify-0.9.6/python2/ |
H A D | pyinotify.py | 691 def process_IN_CREATE(self, raw_event): argument 698 if raw_event.mask & IN_ISDIR: 737 return self.process_default(raw_event) 747 return self.process_default(raw_event, {'cookie': raw_event.cookie}) 749 def process_IN_MOVED_TO(self, raw_event): argument 779 def process_IN_MOVE_SELF(self, raw_event): argument 819 return self.process_default(raw_event) 828 def process_IN_IGNORED(self, raw_event): argument 852 dict_ = {'wd': raw_event.wd, 853 'mask': raw_event.mask, [all …]
|
/dports/devel/py-pyinotify/pyinotify-0.9.6/python3/ |
H A D | pyinotify.py | 677 def process_IN_CREATE(self, raw_event): argument 684 if raw_event.mask & IN_ISDIR: 723 return self.process_default(raw_event) 733 return self.process_default(raw_event, {'cookie': raw_event.cookie}) 735 def process_IN_MOVED_TO(self, raw_event): argument 765 def process_IN_MOVE_SELF(self, raw_event): argument 805 return self.process_default(raw_event) 814 def process_IN_IGNORED(self, raw_event): argument 838 dict_ = {'wd': raw_event.wd, 839 'mask': raw_event.mask, [all …]
|
/dports/lang/rust/rustc-1.58.1-src/vendor/measureme-9.1.2/src/ |
H A D | profiler.rs | 3 use crate::raw_event::RawEvent; 101 let raw_event = in record_instant_event() localVariable 104 self.record_raw_event(&raw_event); in record_instant_event() 164 fn record_raw_event(&self, raw_event: &RawEvent) { in record_raw_event() 167 raw_event.serialize(bytes); in record_raw_event() 197 let raw_event = RawEvent::new_interval( in drop() localVariable 205 self.profiler.record_raw_event(&raw_event); in drop()
|
H A D | raw_event.rs | 143 let mut raw_event = RawEvent::default(); in deserialize() localVariable 145 let raw_event = std::slice::from_raw_parts_mut( in deserialize() localVariable 146 &mut raw_event as *mut RawEvent as *mut u8, in deserialize() 149 raw_event.copy_from_slice(bytes); in deserialize() 151 raw_event in deserialize()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/extensions/browser/api/audio/ |
H A D | audio_api.cc | 105 audio::LevelChangedEvent raw_event; in OnLevelChanged() local 106 raw_event.device_id = id; in OnLevelChanged() 107 raw_event.level = level; in OnLevelChanged() 110 audio::OnLevelChanged::Create(raw_event); in OnLevelChanged() 123 audio::MuteChangedEvent raw_event; in OnMuteChanged() local 124 raw_event.stream_type = in OnMuteChanged() 126 raw_event.is_muted = is_muted; in OnMuteChanged() 128 audio::OnMuteChanged::Create(raw_event); in OnMuteChanged()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/browser/api/audio/ |
H A D | audio_api.cc | 105 audio::LevelChangedEvent raw_event; in OnLevelChanged() local 106 raw_event.device_id = id; in OnLevelChanged() 107 raw_event.level = level; in OnLevelChanged() 110 audio::OnLevelChanged::Create(raw_event); in OnLevelChanged() 123 audio::MuteChangedEvent raw_event; in OnMuteChanged() local 124 raw_event.stream_type = in OnMuteChanged() 126 raw_event.is_muted = is_muted; in OnMuteChanged() 128 audio::OnMuteChanged::Create(raw_event); in OnMuteChanged()
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/models/container_registry/ |
H A D | event_spec.rb | 14 subject { described_class.new(raw_event).supported? } 31 subject { described_class.new(raw_event).handle! } 41 subject { described_class.new(raw_event).track! }
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/requests/api/error_tracking/ |
H A D | collector_spec.rb | 38 let(:params) { raw_event } 110 let(:params) { ActiveSupport::Gzip.compress(raw_event) } 120 let(:params) { raw_event } 163 let(:params) { ActiveSupport::Gzip.compress(raw_event) }
|
/dports/sysutils/py-salt/salt-3004.1/salt/engines/ |
H A D | script.py | 108 for raw_event in _read_stdout(proc): 109 log.debug(raw_event) 111 event = serializer.deserialize(raw_event)
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/platform/widget/input/ |
H A D | main_thread_event_queue.cc | 69 std::unique_ptr<WebCoalescedInputEvent> raw_event, in CreateForRawEvent() argument 72 DCHECK_EQ(raw_event->Event().GetType(), in CreateForRawEvent() 76 : raw_event->Event().TimeStamp(); in CreateForRawEvent() 78 raw_event->Event().GetTypeAsUiEventType(), base::nullopt, in CreateForRawEvent() 79 original_time_stamp, raw_event->Event().GetScrollInputType()); in CreateForRawEvent() 81 std::move(raw_event), false, HandledEventCallback(), false, attribution, in CreateForRawEvent() 357 auto raw_event = std::make_unique<WebCoalescedInputEvent>( in HandleEvent() local 363 std::move(raw_event), attribution, metrics.get())); in HandleEvent() 370 auto raw_event = std::make_unique<WebCoalescedInputEvent>( in HandleEvent() local 373 raw_event->EventPointer()->SetType( in HandleEvent() [all …]
|