| /dports/lang/sbcl/sbcl-1.3.13/contrib/sb-concurrency/ |
| H A D | sb-concurrency.texinfo | 1 @node sb-concurrency
2 @section sb-concurrency
4 @cindex Sb-concurrency
11 @anchor{Section sb-concurrency:queue}
25 @include struct-sb-concurrency-queue.texinfo
27 @include fun-sb-concurrency-dequeue.texinfo
28 @include fun-sb-concurrency-enqueue.texinfo
34 @include fun-sb-concurrency-queuep.texinfo
61 @anchor{Section sb-concurrency:gate}
73 @include fun-sb-concurrency-gatep.texinfo
[all …]
|
| /dports/devel/cpprestsdk/cpprestsdk-2.10.16/Release/tests/functional/streams/ |
| H A D | prefix.h | 40 template class concurrency::streams::file_buffer<char>;
41 template class concurrency::streams::file_buffer<wchar_t>;
42 template class concurrency::streams::streambuf<char>;
43 template class concurrency::streams::streambuf<wchar_t>;
45 template class concurrency::streams::rawptr_buffer<char>;
46 template class concurrency::streams::rawptr_buffer<wchar_t>;
47 template class concurrency::streams::rawptr_buffer<uint8_t>;
48 template class concurrency::streams::rawptr_buffer<utf16char>;
51 template class concurrency::streams::container_buffer<std::vector<char>>;
54 template class concurrency::streams::producer_consumer_buffer<char>;
[all …]
|
| /dports/net-im/chatterino2/chatterino2-2.3.4/src/providers/twitch/ |
| H A D | ChatterinoWebSocketppLogger.hpp | 40 template <typename concurrency, typename names>
44 typedef chatterinowebsocketpplogger<concurrency, names> base;
46 chatterinowebsocketpplogger<concurrency, names>(
59 chatterinowebsocketpplogger<concurrency, names>(
72 ~chatterinowebsocketpplogger<concurrency, names>()
76 chatterinowebsocketpplogger<concurrency, names>(
84 chatterinowebsocketpplogger<concurrency, names> &operator=(
90 chatterinowebsocketpplogger<concurrency, names>(
91 chatterinowebsocketpplogger<concurrency, names> &&other)
98 chatterinowebsocketpplogger<concurrency, names> &operator=(
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/devel/etcd33/etcd-3.3.23/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/devel/etcd32/etcd-3.2.32/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/devel/etcd34/etcd-3.4.18/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/integration/ |
| H A D | v3_stm_test.go | 47 applyf := func(stm concurrency.STM) error {
67 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
101 applyf := func(stm concurrency.STM) error {
106 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
127 applyf := func(stm concurrency.STM) error {
134 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
135 sctx := concurrency.WithAbortContext(ctx)
196 iso := concurrency.WithIsolation(concurrency.Serializable)
229 applyf := func(stm concurrency.STM) error {
241 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/games/pokerth/pokerth-1.1.2-rc/src/third_party/websocketpp/websocketpp/logger/ |
| H A D | basic.hpp | 58 template <typename concurrency, typename names>
61 basic<concurrency,names>(channel_type_hint::value h =
67 basic<concurrency,names>(std::ostream * out)
72 basic<concurrency,names>(level c, channel_type_hint::value h =
78 basic<concurrency,names>(level c, std::ostream * out)
84 ~basic<concurrency,names>() {}
87 basic<concurrency,names>(basic<concurrency,names> const & other)
95 basic<concurrency,names> & operator=(basic<concurrency,names> const &) = delete;
100 basic<concurrency,names>(basic<concurrency,names> && other)
108 basic<concurrency,names> & operator=(basic<concurrency,names> &&) = delete;
[all …]
|
| /dports/devel/websocketpp/websocketpp-0.8.2/websocketpp/logger/ |
| H A D | basic.hpp | 58 template <typename concurrency, typename names>
61 basic<concurrency,names>(channel_type_hint::value h =
67 basic<concurrency,names>(std::ostream * out)
72 basic<concurrency,names>(level c, channel_type_hint::value h =
78 basic<concurrency,names>(level c, std::ostream * out)
84 ~basic<concurrency,names>() {}
87 basic<concurrency,names>(basic<concurrency,names> const & other)
95 basic<concurrency,names> & operator=(basic<concurrency,names> const &) = delete;
100 basic<concurrency,names>(basic<concurrency,names> && other)
108 basic<concurrency,names> & operator=(basic<concurrency,names> &&) = delete;
[all …]
|
| /dports/multimedia/musikcube/musikcube-0.96.7/src/3rdparty/include/websocketpp/logger/ |
| H A D | basic.hpp | 58 template <typename concurrency, typename names>
61 basic<concurrency,names>(channel_type_hint::value h =
67 basic<concurrency,names>(std::ostream * out)
72 basic<concurrency,names>(level c, channel_type_hint::value h =
78 basic<concurrency,names>(level c, std::ostream * out)
84 ~basic<concurrency,names>() {}
87 basic<concurrency,names>(basic<concurrency,names> const & other)
95 basic<concurrency,names> & operator=(basic<concurrency,names> const &) = delete;
100 basic<concurrency,names>(basic<concurrency,names> && other)
108 basic<concurrency,names> & operator=(basic<concurrency,names> &&) = delete;
[all …]
|
| /dports/www/minio-client/etcd-3.5.0/tests/integration/ |
| H A D | v3_stm_test.go | 49 applyf := func(stm concurrency.STM) error {
69 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
105 applyf := func(stm concurrency.STM) error {
110 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
133 applyf := func(stm concurrency.STM) error {
140 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
141 sctx := concurrency.WithAbortContext(ctx)
204 iso := concurrency.WithIsolation(concurrency.Serializable)
239 applyf := func(stm concurrency.STM) error {
251 iso := concurrency.WithIsolation(concurrency.RepeatableReads)
[all …]
|
| /dports/devel/cpprestsdk/cpprestsdk-2.10.16/Release/include/cpprest/details/ |
| H A D | fileio.h | 141 … _ASYNCRTIMP bool __cdecl _close_fsb_nolock(_In_ concurrency::streams::details::_file_info** info,
143 _ASYNCRTIMP bool __cdecl _close_fsb(_In_ concurrency::streams::details::_file_info** info,
144 … _In_ concurrency::streams::details::_filestream_callback* callback);
154 _ASYNCRTIMP size_t __cdecl _putn_fsb(_In_ concurrency::streams::details::_file_info* info,
168 _ASYNCRTIMP size_t __cdecl _getn_fsb(_In_ concurrency::streams::details::_file_info* info,
180 _ASYNCRTIMP bool __cdecl _sync_fsb(_In_ concurrency::streams::details::_file_info* info,
181 … _In_ concurrency::streams::details::_filestream_callback* callback);
188 …_ASYNCRTIMP utility::size64_t __cdecl _get_size(_In_ concurrency::streams::details::_file_info* in…
197 _ASYNCRTIMP size_t __cdecl _seekrdpos_fsb(_In_ concurrency::streams::details::_file_info* info,
207 … _ASYNCRTIMP size_t __cdecl _seekrdtoend_fsb(_In_ concurrency::streams::details::_file_info* info,
[all …]
|
| /dports/devel/cpprestsdk/cpprestsdk-2.10.16/Release/include/cpprest/ |
| H A D | ws_msg.h | 69 this->set_message_ping(concurrency::streams::container_buffer<std::string>(data));
97 this->set_message(concurrency::streams::container_buffer<std::string>(data)); in set_utf8_message()
105 void set_utf8_message(const concurrency::streams::istream& istream) in set_utf8_message()
115 void set_utf8_message(const concurrency::streams::istream& istream, size_t len) in set_utf8_message()
125 void set_binary_message(const concurrency::streams::istream& istream, size_t len) in set_binary_message()
135 void set_binary_message(const concurrency::streams::istream& istream) in set_binary_message()
145 concurrency::streams::streambuf<uint8_t> m_body;
170 void set_message(const concurrency::streams::container_buffer<std::string>& buffer) in set_message()
206 concurrency::streams::istream body() const in body()
209 … [](const concurrency::streams::streambuf<uint8_t>& buf) -> concurrency::streams::istream { in body()
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/pkg/kube/inject/ |
| H A D | concurrency.go | 49 concurrency := ""
52 concurrency = s
57 if concurrency == "" {
62 concurrency = sidecar.Args[i+1]
64 c, err := strconv.Atoi(concurrency)
66 log.Errorf("Failed to convert concurrency to int %v, err %v", concurrency, err)
79 concurrency := extractConcurrency(&c)
81 if concurrency > 0 {
97 concurrency := int(math.Ceil(cpu))
98 if concurrency > 0 {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/cpp/src/thrift/server/ |
| H A D | TThreadedServer.h | 46 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
47 new apache::thrift::concurrency::ThreadFactory(false)));
55 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
56 new apache::thrift::concurrency::ThreadFactory(false)));
66 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
67 new apache::thrift::concurrency::ThreadFactory(false)));
77 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
78 new apache::thrift::concurrency::ThreadFactory(false)));
105 std::shared_ptr<apache::thrift::concurrency::ThreadFactory> threadFactory_;
114 class TConnectedClientRunner : public apache::thrift::concurrency::Runnable
[all …]
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/cpp/src/thrift/server/ |
| H A D | TThreadedServer.h | 46 = stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
47 new apache::thrift::concurrency::PlatformThreadFactory(false)));
55 = stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
56 new apache::thrift::concurrency::PlatformThreadFactory(false)));
66 = stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
67 new apache::thrift::concurrency::PlatformThreadFactory(false)));
77 = stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
78 new apache::thrift::concurrency::PlatformThreadFactory(false)));
105 stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory> threadFactory_;
114 class TConnectedClientRunner : public apache::thrift::concurrency::Runnable
[all …]
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/cpp/src/thrift/server/ |
| H A D | TThreadedServer.h | 46 = stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
47 new apache::thrift::concurrency::PlatformThreadFactory(false)));
55 = stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
56 new apache::thrift::concurrency::PlatformThreadFactory(false)));
66 = stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
67 new apache::thrift::concurrency::PlatformThreadFactory(false)));
77 = stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
78 new apache::thrift::concurrency::PlatformThreadFactory(false)));
105 stdcxx::shared_ptr<apache::thrift::concurrency::ThreadFactory> threadFactory_;
114 class TConnectedClientRunner : public apache::thrift::concurrency::Runnable
[all …]
|
| /dports/devel/thrift-c_glib/thrift-0.14.0/lib/cpp/src/thrift/server/ |
| H A D | TThreadedServer.h | 46 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
47 new apache::thrift::concurrency::ThreadFactory(false)));
55 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
56 new apache::thrift::concurrency::ThreadFactory(false)));
66 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
67 new apache::thrift::concurrency::ThreadFactory(false)));
77 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
78 new apache::thrift::concurrency::ThreadFactory(false)));
105 std::shared_ptr<apache::thrift::concurrency::ThreadFactory> threadFactory_;
114 class TConnectedClientRunner : public apache::thrift::concurrency::Runnable
[all …]
|
| /dports/devel/thrift-cpp/thrift-0.14.0/lib/cpp/src/thrift/server/ |
| H A D | TThreadedServer.h | 46 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
47 new apache::thrift::concurrency::ThreadFactory(false)));
55 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
56 new apache::thrift::concurrency::ThreadFactory(false)));
66 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
67 new apache::thrift::concurrency::ThreadFactory(false)));
77 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
78 new apache::thrift::concurrency::ThreadFactory(false)));
105 std::shared_ptr<apache::thrift::concurrency::ThreadFactory> threadFactory_;
114 class TConnectedClientRunner : public apache::thrift::concurrency::Runnable
[all …]
|
| /dports/devel/thrift/thrift-0.14.0/lib/cpp/src/thrift/server/ |
| H A D | TThreadedServer.h | 46 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
47 new apache::thrift::concurrency::ThreadFactory(false)));
55 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
56 new apache::thrift::concurrency::ThreadFactory(false)));
66 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
67 new apache::thrift::concurrency::ThreadFactory(false)));
77 = std::shared_ptr<apache::thrift::concurrency::ThreadFactory>(
78 new apache::thrift::concurrency::ThreadFactory(false)));
105 std::shared_ptr<apache::thrift::concurrency::ThreadFactory> threadFactory_;
114 class TConnectedClientRunner : public apache::thrift::concurrency::Runnable
[all …]
|