Home
last modified time | relevance | path

Searched refs:impl (Results 1 – 25 of 3150) sorted by relevance

12345678910>>...126

/third_party/boost/boost/beast/websocket/impl/
Dread.hpp94 auto& impl = *sp; local
97 impl.update_timer(this->get_executor());
101 if(! impl.rd_block.try_lock(this))
110 impl.op_r_rd.emplace(std::move(*this));
112 impl.rd_block.lock(this);
121 BOOST_ASSERT(impl.rd_block.is_locked(this));
124 if(impl.check_stop_now(ec))
133 BOOST_ASSERT(impl.wr_close);
134 BOOST_ASSERT(impl.status_ != status::open);
141 if( impl.status_ == status::closed ||
[all …]
Dclose.hpp82 auto& impl = *sp; local
86 if(! impl.wr_block.try_lock(this))
94 impl.op_close.emplace(std::move(*this));
96 impl.wr_block.lock(this);
105 BOOST_ASSERT(impl.wr_block.is_locked(this));
107 if(impl.check_stop_now(ec))
112 BOOST_ASSERT(! impl.wr_close);
115 impl.wr_close = true;
116 impl.change_status(status::closing);
117 impl.update_timer(this->get_executor());
[all …]
Dwrite.hpp84 auto& impl = *sp; in write_some_op() local
87 if(! impl.wr_cont) in write_some_op()
89 impl.begin_msg(); in write_some_op()
90 fh_.rsv1 = impl.wr_compress; in write_some_op()
98 fh_.op = impl.wr_cont ? in write_some_op()
99 detail::opcode::cont : impl.wr_opcode; in write_some_op()
101 impl.role == role_type::client; in write_some_op()
104 if(impl.wr_compress) in write_some_op()
110 if(! impl.wr_frag) in write_some_op()
116 BOOST_ASSERT(impl.wr_buf_size != 0); in write_some_op()
[all …]
/third_party/boost/libs/beast/include/boost/beast/websocket/impl/
Dread.hpp94 auto& impl = *sp; local
97 impl.update_timer(this->get_executor());
101 if(! impl.rd_block.try_lock(this))
110 impl.op_r_rd.emplace(std::move(*this));
112 impl.rd_block.lock(this);
121 BOOST_ASSERT(impl.rd_block.is_locked(this));
124 if(impl.check_stop_now(ec))
133 BOOST_ASSERT(impl.wr_close);
134 BOOST_ASSERT(impl.status_ != status::open);
141 if( impl.status_ == status::closed ||
[all …]
Dclose.hpp82 auto& impl = *sp; local
86 if(! impl.wr_block.try_lock(this))
94 impl.op_close.emplace(std::move(*this));
96 impl.wr_block.lock(this);
105 BOOST_ASSERT(impl.wr_block.is_locked(this));
107 if(impl.check_stop_now(ec))
112 BOOST_ASSERT(! impl.wr_close);
115 impl.wr_close = true;
116 impl.change_status(status::closing);
117 impl.update_timer(this->get_executor());
[all …]
Dwrite.hpp84 auto& impl = *sp; in write_some_op() local
87 if(! impl.wr_cont) in write_some_op()
89 impl.begin_msg(); in write_some_op()
90 fh_.rsv1 = impl.wr_compress; in write_some_op()
98 fh_.op = impl.wr_cont ? in write_some_op()
99 detail::opcode::cont : impl.wr_opcode; in write_some_op()
101 impl.role == role_type::client; in write_some_op()
104 if(impl.wr_compress) in write_some_op()
110 if(! impl.wr_frag) in write_some_op()
116 BOOST_ASSERT(impl.wr_buf_size != 0); in write_some_op()
[all …]
/third_party/iowow/src/fs/
Diwfsmfile.c68 if (!(f_) || !(f_)->impl) return IW_ERROR_INVALID_STATE;
106 static iwrc _fsm_ensure_size_lw(FSM *impl, off_t size);
119 IW_INLINE iwrc _fsm_ctrl_wlock(FSM *impl) { in _fsm_ctrl_wlock() argument
120 int rci = impl->ctlrwlk ? pthread_rwlock_wrlock(impl->ctlrwlk) : 0; in _fsm_ctrl_wlock()
124 IW_INLINE iwrc _fsm_ctrl_rlock(FSM *impl) { in _fsm_ctrl_rlock() argument
125 int rci = impl->ctlrwlk ? pthread_rwlock_rdlock(impl->ctlrwlk) : 0; in _fsm_ctrl_rlock()
129 IW_INLINE iwrc _fsm_ctrl_unlock(FSM *impl) { in _fsm_ctrl_unlock() argument
130 int rci = impl->ctlrwlk ? pthread_rwlock_unlock(impl->ctlrwlk) : 0; in _fsm_ctrl_unlock()
134 IW_INLINE iwrc _fsm_bmptr(FSM *impl, uint64_t **bmptr) { in _fsm_bmptr() argument
139 iwrc rc = impl->pool.probe_mmap(&impl->pool, impl->mmap_all ? 0 : impl->bmoff, &mm, &sp); in _fsm_bmptr()
[all …]
Diwexfile.c68 struct IWFS_EXT_IMPL *impl = f->impl; in _exfile_wlock() local
69 if (impl) { in _exfile_wlock()
70 if (!impl->use_locks) return 0; in _exfile_wlock()
71 if (impl->rwlock) { in _exfile_wlock()
72 int rv = pthread_rwlock_wrlock(impl->rwlock); in _exfile_wlock()
80 struct IWFS_EXT_IMPL *impl = f->impl; in _exfile_rlock() local
81 if (impl) { in _exfile_rlock()
82 if (!impl->use_locks) return 0; in _exfile_rlock()
83 if (impl->rwlock) { in _exfile_rlock()
84 int rv = pthread_rwlock_rdlock(impl->rwlock); in _exfile_rlock()
[all …]
/third_party/grpc/src/core/tsi/alts/frame_protector/
Dalts_frame_protector.cc60 static tsi_result seal(alts_frame_protector* impl) { in seal() argument
64 impl->seal_crypter, impl->in_place_protect_buffer, in seal()
65 impl->max_protected_frame_size, impl->in_place_protect_bytes_buffered, in seal()
67 impl->in_place_protect_bytes_buffered = output_size; in seal()
76 static size_t max_encrypted_payload_bytes(alts_frame_protector* impl) { in max_encrypted_payload_bytes() argument
77 return impl->max_protected_frame_size - kFrameHeaderSize; in max_encrypted_payload_bytes()
90 alts_frame_protector* impl = reinterpret_cast<alts_frame_protector*>(self); in alts_protect_flush() local
95 if (impl->in_place_protect_bytes_buffered == 0) { in alts_protect_flush()
105 if (alts_is_frame_writer_done(impl->writer)) { in alts_protect_flush()
106 tsi_result result = seal(impl); in alts_protect_flush()
[all …]
/third_party/boost/boost/phoenix/operator/detail/cpp03/preprocessed/
Dmem_fun_ptr_eval_result_of_50.hpp19 …typedef typename evaluator::impl< A0 , Context , proto::empty_env >::result_type child0; typedef t…
38 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
57 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
76 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
95 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
114 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
133 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
152 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
171 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
190 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
[all …]
Dmem_fun_ptr_eval_result_of_40.hpp19 …typedef typename evaluator::impl< A0 , Context , proto::empty_env >::result_type child0; typedef t…
38 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
57 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
76 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
95 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
114 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
133 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
152 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
171 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
190 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
[all …]
Dmem_fun_ptr_eval_result_of_30.hpp19 …typedef typename evaluator::impl< A0 , Context , proto::empty_env >::result_type child0; typedef t…
38 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
57 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
76 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
95 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
114 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
133 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
152 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
171 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
190 …impl< A0 , Context , proto::empty_env >::result_type child0; typedef typename evaluator::impl< A1 …
[all …]
/third_party/glib/gio/
Dgapplicationimpl-dbus.c141 GApplicationImpl *impl = user_data; in g_application_impl_get_property() local
144 return g_variant_new_boolean (impl->busy); in g_application_impl_get_property()
152 send_property_change (GApplicationImpl *impl) in send_property_change() argument
159 "Busy", g_variant_new_boolean (impl->busy)); in send_property_change()
161 g_dbus_connection_emit_signal (impl->session_bus, in send_property_change()
163 impl->object_path, in send_property_change()
183 GApplicationImpl *impl = user_data; in g_application_impl_method_call() local
186 class = G_APPLICATION_GET_CLASS (impl->app); in g_application_impl_method_call()
196 class->before_emit (impl->app, platform_data); in g_application_impl_method_call()
197 g_signal_emit_by_name (impl->app, "activate"); in g_application_impl_method_call()
[all …]
/third_party/boost/boost/asio/detail/
Dwin_iocp_socket_service.hpp147 void move_construct(implementation_type& impl, in move_construct() argument
150 this->base_move_construct(impl, other_impl); in move_construct()
152 impl.protocol_ = other_impl.protocol_; in move_construct()
155 impl.have_remote_endpoint_ = other_impl.have_remote_endpoint_; in move_construct()
158 impl.remote_endpoint_ = other_impl.remote_endpoint_; in move_construct()
163 void move_assign(implementation_type& impl, in move_assign() argument
167 this->base_move_assign(impl, other_service, other_impl); in move_assign()
169 impl.protocol_ = other_impl.protocol_; in move_assign()
172 impl.have_remote_endpoint_ = other_impl.have_remote_endpoint_; in move_assign()
175 impl.remote_endpoint_ = other_impl.remote_endpoint_; in move_assign()
[all …]
Dwin_iocp_socket_service_base.hpp95 BOOST_ASIO_DECL void construct(base_implementation_type& impl);
98 BOOST_ASIO_DECL void base_move_construct(base_implementation_type& impl,
102 BOOST_ASIO_DECL void base_move_assign(base_implementation_type& impl,
107 BOOST_ASIO_DECL void destroy(base_implementation_type& impl);
110 bool is_open(const base_implementation_type& impl) const in is_open()
112 return impl.socket_ != invalid_socket; in is_open()
117 base_implementation_type& impl, boost::system::error_code& ec);
121 base_implementation_type& impl, boost::system::error_code& ec);
125 base_implementation_type& impl, boost::system::error_code& ec);
128 bool at_mark(const base_implementation_type& impl, in at_mark() argument
[all …]
/third_party/boost/libs/asio/include/boost/asio/detail/
Dwin_iocp_socket_service.hpp147 void move_construct(implementation_type& impl, in move_construct() argument
150 this->base_move_construct(impl, other_impl); in move_construct()
152 impl.protocol_ = other_impl.protocol_; in move_construct()
155 impl.have_remote_endpoint_ = other_impl.have_remote_endpoint_; in move_construct()
158 impl.remote_endpoint_ = other_impl.remote_endpoint_; in move_construct()
163 void move_assign(implementation_type& impl, in move_assign() argument
167 this->base_move_assign(impl, other_service, other_impl); in move_assign()
169 impl.protocol_ = other_impl.protocol_; in move_assign()
172 impl.have_remote_endpoint_ = other_impl.have_remote_endpoint_; in move_assign()
175 impl.remote_endpoint_ = other_impl.remote_endpoint_; in move_assign()
[all …]
Dwin_iocp_socket_service_base.hpp95 BOOST_ASIO_DECL void construct(base_implementation_type& impl);
98 BOOST_ASIO_DECL void base_move_construct(base_implementation_type& impl,
102 BOOST_ASIO_DECL void base_move_assign(base_implementation_type& impl,
107 BOOST_ASIO_DECL void destroy(base_implementation_type& impl);
110 bool is_open(const base_implementation_type& impl) const in is_open()
112 return impl.socket_ != invalid_socket; in is_open()
117 base_implementation_type& impl, boost::system::error_code& ec);
121 base_implementation_type& impl, boost::system::error_code& ec);
125 base_implementation_type& impl, boost::system::error_code& ec);
128 bool at_mark(const base_implementation_type& impl, in at_mark() argument
[all …]
/third_party/boost/libs/asio/include/boost/asio/detail/impl/
Dwin_object_handle_service.ipp2 // detail/impl/win_object_handle_service.ipp
50 for (implementation_type* impl = impl_list_; impl; impl = impl->next_)
51 ops.push(impl->op_queue_);
59 win_object_handle_service::implementation_type& impl)
61 impl.handle_ = INVALID_HANDLE_VALUE;
62 impl.wait_handle_ = INVALID_HANDLE_VALUE;
63 impl.owner_ = this;
69 impl.next_ = impl_list_;
70 impl.prev_ = 0;
72 impl_list_->prev_ = &impl;
[all …]
Dreactive_descriptor_service.ipp2 // detail/impl/reactive_descriptor_service.ipp
46 reactive_descriptor_service::implementation_type& impl)
48 impl.descriptor_ = -1;
49 impl.state_ = 0;
53 reactive_descriptor_service::implementation_type& impl,
57 impl.descriptor_ = other_impl.descriptor_;
60 impl.state_ = other_impl.state_;
63 reactor_.move_descriptor(impl.descriptor_,
64 impl.reactor_data_, other_impl.reactor_data_);
68 reactive_descriptor_service::implementation_type& impl,
[all …]
Dreactive_socket_service_base.ipp43 reactive_socket_service_base::base_implementation_type& impl)
45 impl.socket_ = invalid_socket;
46 impl.state_ = 0;
50 reactive_socket_service_base::base_implementation_type& impl,
54 impl.socket_ = other_impl.socket_;
57 impl.state_ = other_impl.state_;
60 reactor_.move_descriptor(impl.socket_,
61 impl.reactor_data_, other_impl.reactor_data_);
65 reactive_socket_service_base::base_implementation_type& impl,
69 destroy(impl);
[all …]
/third_party/boost/boost/asio/detail/impl/
Dwin_object_handle_service.ipp2 // detail/impl/win_object_handle_service.ipp
50 for (implementation_type* impl = impl_list_; impl; impl = impl->next_)
51 ops.push(impl->op_queue_);
59 win_object_handle_service::implementation_type& impl)
61 impl.handle_ = INVALID_HANDLE_VALUE;
62 impl.wait_handle_ = INVALID_HANDLE_VALUE;
63 impl.owner_ = this;
69 impl.next_ = impl_list_;
70 impl.prev_ = 0;
72 impl_list_->prev_ = &impl;
[all …]
Dreactive_descriptor_service.ipp2 // detail/impl/reactive_descriptor_service.ipp
46 reactive_descriptor_service::implementation_type& impl)
48 impl.descriptor_ = -1;
49 impl.state_ = 0;
53 reactive_descriptor_service::implementation_type& impl,
57 impl.descriptor_ = other_impl.descriptor_;
60 impl.state_ = other_impl.state_;
63 reactor_.move_descriptor(impl.descriptor_,
64 impl.reactor_data_, other_impl.reactor_data_);
68 reactive_descriptor_service::implementation_type& impl,
[all …]
Dreactive_socket_service_base.ipp43 reactive_socket_service_base::base_implementation_type& impl)
45 impl.socket_ = invalid_socket;
46 impl.state_ = 0;
50 reactive_socket_service_base::base_implementation_type& impl,
54 impl.socket_ = other_impl.socket_;
57 impl.state_ = other_impl.state_;
60 reactor_.move_descriptor(impl.socket_,
61 impl.reactor_data_, other_impl.reactor_data_);
65 reactive_socket_service_base::base_implementation_type& impl,
69 destroy(impl);
[all …]
/third_party/node/deps/npm/node_modules/safer-buffer/
Dtests.js23 [index, safer, dangerous].forEach(function (impl) { argument
24 t.equal(typeof impl, 'object')
25 t.equal(typeof impl.Buffer, 'object')
27 [buffer].forEach(function (impl) { argument
28 t.equal(typeof impl, 'object')
29 t.equal(typeof impl.Buffer, 'function')
35 [index, safer, dangerous].forEach(function (impl) { argument
36 t.throws(function () { impl.Buffer() })
37 t.throws(function () { impl.Buffer(0) })
38 t.throws(function () { impl.Buffer('a') })
[all …]
/third_party/mindspore/mindspore/lite/src/c_api/
Dcontext_c.cc22 auto impl = new (std::nothrow) mindspore::ContextC; in OH_AI_ContextCreate() local
23 if (impl == nullptr) { in OH_AI_ContextCreate()
27 return static_cast<OH_AI_ContextHandle>(impl); in OH_AI_ContextCreate()
32 auto impl = static_cast<mindspore::ContextC *>(*context); in OH_AI_ContextDestroy() local
33 delete impl; in OH_AI_ContextDestroy()
43 auto impl = static_cast<mindspore::ContextC *>(context); in OH_AI_ContextSetThreadNum() local
44 impl->thread_num = thread_num; in OH_AI_ContextSetThreadNum()
52 auto impl = static_cast<mindspore::ContextC *>(context); in OH_AI_ContextGetThreadNum() local
53 return impl->thread_num; in OH_AI_ContextGetThreadNum()
61 auto impl = static_cast<mindspore::ContextC *>(context); in OH_AI_ContextSetThreadAffinityMode() local
[all …]

12345678910>>...126