| /dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/acme/ |
| H A D | acme.c | 136 TSfree(my_state); in cleanup()
151 if (-1 == my_state->fd) { in add_file_to_resp()
166 close(my_state->fd); in add_file_to_resp()
167 my_state->fd = -1; in add_file_to_resp()
184 my_state->write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->resp_reader, INT64_MAX); in acme_process_read()
206 my_state->output_bytes += add_data_to_resp(buf, len, my_state); in acme_process_write()
207 my_state->output_bytes += add_file_to_resp(my_state); in acme_process_write()
209 TSVIONBytesSet(my_state->write_vio, my_state->output_bytes); in acme_process_write()
226 my_state->resp_reader = TSIOBufferReaderAlloc(my_state->resp_buffer); in acme_process_accept()
227 my_state->read_vio = TSVConnRead(my_state->net_vc, contp, my_state->req_buffer, INT64_MAX); in acme_process_accept()
[all …]
|
| /dports/www/trafficserver/trafficserver-9.1.1/plugins/stats_over_http/ |
| H A D | stats_over_http.c | 228 TSfree(my_state); in stats_cleanup()
238 my_state->read_vio = TSVConnRead(my_state->net_vc, contp, my_state->req_buffer, INT64_MAX); in stats_process_accept()
304 my_state->output_bytes = stats_add_resp_header(my_state); in stats_process_read()
306 my_state->write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->resp_reader, INT64_MAX); in stats_process_read()
493 …my_state->output_bytes += TSIOBufferWrite(my_state->resp_buffer, outputbuf, my_state->zstrm.total_… in gzip_out_stats()
530 TSVIONBytesSet(my_state->write_vio, my_state->output_bytes); in stats_process_write()
600 my_state = (stats_state *)TSmalloc(sizeof(*my_state)); in stats_origin()
601 memset(my_state, 0, sizeof(*my_state)); in stats_origin()
627 my_state->encoding = init_gzip(my_state, DEFLATE_MODE); in stats_origin()
630 my_state->encoding = init_gzip(my_state, GZIP_MODE); in stats_origin()
[all …]
|
| /dports/www/trafficserver/trafficserver-9.1.1/plugins/healthchecks/ |
| H A D | healthchecks.c | 395 TSfree(my_state); in cleanup()
414 … my_state->output_bytes = add_data_to_resp(my_state->info->ok, my_state->info->o_len, my_state); in hc_process_read()
417 … my_state->output_bytes = add_data_to_resp(my_state->info->miss, my_state->info->m_len, my_state); in hc_process_read()
420 my_state->write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->resp_reader, INT64_MAX); in hc_process_read()
442 my_state->output_bytes += add_data_to_resp(buf, len, my_state); in hc_process_write()
444 … my_state->output_bytes += add_data_to_resp(my_state->data->body, my_state->data->b_len, my_state); in hc_process_write()
446 my_state->output_bytes += add_data_to_resp("\r\n", 2, my_state); in hc_process_write()
448 TSVIONBytesSet(my_state->write_vio, my_state->output_bytes); in hc_process_write()
466 my_state->read_vio = TSVConnRead(my_state->net_vc, contp, my_state->req_buffer, INT64_MAX); in hc_process_accept()
525 my_state = (HCState *)TSmalloc(sizeof(*my_state)); in health_check_origin()
[all …]
|
| /dports/science/ghmm/ghmm-0.9-rc3/ghmm/ |
| H A D | pmodel.c | 66 if (!my_state) return; in ghmm_dpmodel_state_clean()
68 if (my_state->b) in ghmm_dpmodel_state_clean()
69 m_free(my_state->b); in ghmm_dpmodel_state_clean()
71 if (my_state->out_id) in ghmm_dpmodel_state_clean()
74 if (my_state->in_id) in ghmm_dpmodel_state_clean()
77 if (my_state->out_a) in ghmm_dpmodel_state_clean()
80 if (my_state->in_a) in ghmm_dpmodel_state_clean()
81 m_free(my_state->in_a); in ghmm_dpmodel_state_clean()
86 my_state->pi = 0; in ghmm_dpmodel_state_clean()
92 my_state->out_states = 0; in ghmm_dpmodel_state_clean()
[all …]
|
| /dports/devel/distcc/distcc-3.3.5/src/ |
| H A D | state.c | 187 if ((ret = dcc_writex(fd, my_state, sizeof *my_state))) in dcc_write_state()
215 my_state->struct_size = sizeof *my_state; in dcc_note_state()
216 my_state->magic = DCC_STATE_MAGIC; in dcc_note_state()
224 strlcpy(my_state->file, source_file, sizeof my_state->file); in dcc_note_state()
228 strlcpy(my_state->host, host, sizeof my_state->host); in dcc_note_state()
235 my_state->curr_phase = state; in dcc_note_state()
263 my_state->slot = slot; in dcc_note_state_slot()
277 my_state = &local_state; in direct_my_state()
281 my_state = &remote_state; in direct_my_state()
288 if (!my_state) in direct_my_state()
[all …]
|
| /dports/comms/gnuradio/gnuradio-3.8.4.0/gr-fec/lib/ |
| H A D | ccsds_encoder_impl.cc | 95 unsigned char my_state = d_start_state; in generic_work() local
102 my_state = (my_state << 1) | ((sym >> (5 - i)) & 1); in generic_work()
106 my_state = encode(out, in, d_frame_size / 8, my_state); in generic_work()
116 my_state = (my_state << 1) | ((d_start_state >> (7 - 2 - i)) & 1); in generic_work()
117 encode(&end_bits[0], &my_state, 1, my_state); in generic_work()
124 my_state = d_start_state; in generic_work()
127 d_start_state = my_state; in generic_work()
|
| H A D | cc_encoder_impl.cc | 183 unsigned my_state = d_start_state; in generic_work() local
187 my_state = (my_state << 1) | (in[d_frame_size - (d_k - 1) + i] & 1); in generic_work()
192 my_state = (my_state << 1) | (in[i] & 1); in generic_work()
195 (d_polys[j] < 0) ^ parity(my_state & abs(d_polys[j])) ? 1 : 0; in generic_work()
201 my_state = (my_state << 1) | ((d_start_state >> (d_k - 2 - i)) & 1); in generic_work()
204 (d_polys[j] < 0) ^ parity(my_state & abs(d_polys[j])) ? 1 : 0; in generic_work()
210 my_state = d_start_state; in generic_work()
213 d_start_state = my_state; in generic_work()
|
| /dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/tbb/ |
| H A D | queuing_rw_mutex.cpp | 213 my_state = STATE_ACTIVEREADER; in acquire()
276 if( n->my_state==STATE_UPGRADE_WAITING ) { in release()
280 n->my_state = STATE_UPGRADE_LOSER; in release()
365 my_state = STATE_READER; in downgrade_to_reader()
378 if( n->my_state & STATE_COMBINED_WAITINGREADER ) in downgrade_to_reader()
380 else if( n->my_state==STATE_UPGRADE_WAITING ) in downgrade_to_reader()
382 n->my_state = STATE_UPGRADE_LOSER; in downgrade_to_reader()
383 my_state = STATE_ACTIVEREADER; in downgrade_to_reader()
395 my_state = STATE_UPGRADE_REQUESTED; in upgrade_to_writer()
403 unsigned short n_state = n->my_state; in upgrade_to_writer()
[all …]
|
| H A D | co_context.h | 80 co_state my_state; variable
84 : my_state(arg ? co_suspended : co_executing) in co_context()
94 __TBB_ASSERT(1 << my_state & (1 << co_suspended | 1 << co_executing), NULL); in ~co_context()
95 if (my_state == co_suspended) in ~co_context()
97 my_state = co_destroyed; in ~co_context()
102 __TBB_ASSERT(my_state == co_executing, NULL); in resume()
103 __TBB_ASSERT(target.my_state == co_suspended, NULL); in resume()
105 my_state = co_suspended; in resume()
106 target.my_state = co_executing; in resume()
111 __TBB_ASSERT(my_state == co_executing, NULL); in resume()
|
| /dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/tbb-2018_U2/src/tbb/ |
| H A D | queuing_rw_mutex.cpp | 217 my_state = STATE_ACTIVEREADER; in acquire()
280 if( n->my_state==STATE_UPGRADE_WAITING ) { in release()
284 n->my_state = STATE_UPGRADE_LOSER; in release()
369 my_state = STATE_READER; in downgrade_to_reader()
382 if( n->my_state & STATE_COMBINED_WAITINGREADER ) in downgrade_to_reader()
384 else if( n->my_state==STATE_UPGRADE_WAITING ) in downgrade_to_reader()
386 n->my_state = STATE_UPGRADE_LOSER; in downgrade_to_reader()
387 my_state = STATE_ACTIVEREADER; in downgrade_to_reader()
399 my_state = STATE_UPGRADE_REQUESTED; in upgrade_to_writer()
407 unsigned short n_state = n->my_state; in upgrade_to_writer()
[all …]
|
| /dports/devel/concurrentqueue/concurrentqueue-1.0.3-15-g0753496/benchmarks/tbb/ |
| H A D | queuing_rw_mutex.cpp | 217 my_state = STATE_ACTIVEREADER; in acquire()
281 if( n->my_state==STATE_UPGRADE_WAITING ) { in release()
285 n->my_state = STATE_UPGRADE_LOSER; in release()
372 my_state = STATE_READER; in downgrade_to_reader()
385 if( n->my_state & STATE_COMBINED_WAITINGREADER ) in downgrade_to_reader()
387 else if( n->my_state==STATE_UPGRADE_WAITING ) in downgrade_to_reader()
389 n->my_state = STATE_UPGRADE_LOSER; in downgrade_to_reader()
390 my_state = STATE_ACTIVEREADER; in downgrade_to_reader()
402 my_state = STATE_UPGRADE_REQUESTED; in upgrade_to_writer()
410 unsigned short n_state = n->my_state; in upgrade_to_writer()
[all …]
|
| /dports/devel/tbb/oneTBB-2020.3/src/tbb/ |
| H A D | queuing_rw_mutex.cpp | 213 my_state = STATE_ACTIVEREADER; in acquire()
276 if( n->my_state==STATE_UPGRADE_WAITING ) { in release()
280 n->my_state = STATE_UPGRADE_LOSER; in release()
365 my_state = STATE_READER; in downgrade_to_reader()
378 if( n->my_state & STATE_COMBINED_WAITINGREADER ) in downgrade_to_reader()
380 else if( n->my_state==STATE_UPGRADE_WAITING ) in downgrade_to_reader()
382 n->my_state = STATE_UPGRADE_LOSER; in downgrade_to_reader()
383 my_state = STATE_ACTIVEREADER; in downgrade_to_reader()
395 my_state = STATE_UPGRADE_REQUESTED; in upgrade_to_writer()
403 unsigned short n_state = n->my_state; in upgrade_to_writer()
[all …]
|
| H A D | co_context.h | 80 co_state my_state; variable
84 : my_state(arg ? co_suspended : co_executing) in co_context()
94 __TBB_ASSERT(1 << my_state & (1 << co_suspended | 1 << co_executing), NULL); in ~co_context()
95 if (my_state == co_suspended) in ~co_context()
97 my_state = co_destroyed; in ~co_context()
102 __TBB_ASSERT(my_state == co_executing, NULL); in resume()
103 __TBB_ASSERT(target.my_state == co_suspended, NULL); in resume()
105 my_state = co_suspended; in resume()
106 target.my_state = co_executing; in resume()
111 __TBB_ASSERT(my_state == co_executing, NULL); in resume()
|
| /dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/tbb/ |
| H A D | queuing_rw_mutex.cpp | 213 my_state = STATE_ACTIVEREADER; in acquire()
276 if( n->my_state==STATE_UPGRADE_WAITING ) { in release()
280 n->my_state = STATE_UPGRADE_LOSER; in release()
365 my_state = STATE_READER; in downgrade_to_reader()
378 if( n->my_state & STATE_COMBINED_WAITINGREADER ) in downgrade_to_reader()
380 else if( n->my_state==STATE_UPGRADE_WAITING ) in downgrade_to_reader()
382 n->my_state = STATE_UPGRADE_LOSER; in downgrade_to_reader()
383 my_state = STATE_ACTIVEREADER; in downgrade_to_reader()
395 my_state = STATE_UPGRADE_REQUESTED; in upgrade_to_writer()
403 unsigned short n_state = n->my_state; in upgrade_to_writer()
[all …]
|
| H A D | co_context.h | 80 co_state my_state; variable
84 : my_state(arg ? co_suspended : co_executing) in co_context()
94 __TBB_ASSERT(1 << my_state & (1 << co_suspended | 1 << co_executing), NULL); in ~co_context()
95 if (my_state == co_suspended) in ~co_context()
97 my_state = co_destroyed; in ~co_context()
102 __TBB_ASSERT(my_state == co_executing, NULL); in resume()
103 __TBB_ASSERT(target.my_state == co_suspended, NULL); in resume()
105 my_state = co_suspended; in resume()
106 target.my_state = co_executing; in resume()
111 __TBB_ASSERT(my_state == co_executing, NULL); in resume()
|
| /dports/net/ntpsec/ntpsec-NTPsec_1_2_1/ntpd/ |
| H A D | keyword-gen.c | 474 unsigned short my_state; in create_scan_states() local
497 my_state = curr_char_s; in create_scan_states()
507 my_state = sst_highwater++; in create_scan_states()
519 sst[my_state].ch = text[0]; in create_scan_states()
526 return_state = my_state; in create_scan_states()
546 if (my_state != token) { in create_scan_states()
547 sst[token] = sst[my_state]; in create_scan_states()
548 ZERO(sst[my_state]); in create_scan_states()
552 my_state = token; in create_scan_states()
556 return_state = my_state; in create_scan_states()
[all …]
|
| /dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/python/rml/ |
| H A D | ipc_server.cpp | 240 atomic<state_t> my_state; member in tbb::internal::rml::ipc_worker
286 my_state = st_init; in ipc_worker()
502 s = my_state; in start_shutdown()
522 s = my_state; in start_stopping()
545 state_t state = my_state; in run()
554 state = my_state; in run()
564 state = my_state; in run()
572 if( ( my_state==st_init && my_state.compare_and_swap( st_starting, st_init )==st_init ) || in wake_or_launch()
643 while( my_state!=st_quit ) { in run()
675 if( my_state==st_init && my_state.compare_and_swap( st_starting, st_init )==st_init ) { in wake_or_launch()
[all …]
|
| /dports/devel/tbb/oneTBB-2020.3/python/rml/ |
| H A D | ipc_server.cpp | 240 atomic<state_t> my_state; member in tbb::internal::rml::ipc_worker
286 my_state = st_init; in ipc_worker()
502 s = my_state; in start_shutdown()
522 s = my_state; in start_stopping()
545 state_t state = my_state; in run()
554 state = my_state; in run()
564 state = my_state; in run()
572 if( ( my_state==st_init && my_state.compare_and_swap( st_starting, st_init )==st_init ) || in wake_or_launch()
643 while( my_state!=st_quit ) { in run()
675 if( my_state==st_init && my_state.compare_and_swap( st_starting, st_init )==st_init ) { in wake_or_launch()
[all …]
|
| /dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/python/rml/ |
| H A D | ipc_server.cpp | 240 atomic<state_t> my_state; member in tbb::internal::rml::ipc_worker
286 my_state = st_init; in ipc_worker()
502 s = my_state; in start_shutdown()
522 s = my_state; in start_stopping()
545 state_t state = my_state; in run()
554 state = my_state; in run()
564 state = my_state; in run()
572 if( ( my_state==st_init && my_state.compare_and_swap( st_starting, st_init )==st_init ) || in wake_or_launch()
643 while( my_state!=st_quit ) { in run()
675 if( my_state==st_init && my_state.compare_and_swap( st_starting, st_init )==st_init ) { in wake_or_launch()
[all …]
|
| /dports/devel/onetbb/oneTBB-2021.4.0/src/tbb/ |
| H A D | queuing_rw_mutex.cpp | 291 if( next->my_state.load()==STATE_UPGRADE_WAITING ) { in release()
387 s.my_state.store(STATE_READER, std::memory_order_relaxed); in downgrade_to_reader()
401 if( next->my_state & STATE_COMBINED_WAITINGREADER ) in downgrade_to_reader()
403 else if( next->my_state==STATE_UPGRADE_WAITING ) in downgrade_to_reader()
406 s.my_state.store(STATE_ACTIVEREADER, std::memory_order_relaxed); in downgrade_to_reader()
411 if (s.my_state.load(std::memory_order_relaxed) == STATE_WRITER) { in upgrade_to_writer()
431 unsigned short n_state = next->my_state; in upgrade_to_writer()
442 if( s.my_state & STATE_COMBINED_UPGRADING ) { in upgrade_to_writer()
515 bool result = ( s.my_state != STATE_UPGRADE_LOSER ); in upgrade_to_writer()
516 s.my_state.store(STATE_WRITER, std::memory_order_relaxed); in upgrade_to_writer()
[all …]
|
| /dports/net/ntp/ntp-4.2.8p15/ntpd/ |
| H A D | keyword-gen.c | 523 u_short my_state; in create_scan_states() local
546 my_state = curr_char_s; in create_scan_states()
556 my_state = sst_highwater++; in create_scan_states()
568 sst[my_state].ch = text[0]; in create_scan_states()
575 return_state = my_state; in create_scan_states()
594 if (my_state != token) { in create_scan_states()
595 sst[token] = sst[my_state]; in create_scan_states()
596 ZERO(sst[my_state]); in create_scan_states()
600 my_state = token; in create_scan_states()
604 return_state = my_state; in create_scan_states()
[all …]
|
| /dports/devel/hyperscan/boost_1_75_0/libs/multiprecision/example/ |
| H A D | cpp_int_mul_timing.cpp | 103 my_state(is_mcg ? state | itype(3U) : bump(state + increment())) { } in random_pcg32_fast()
108 my_state(other.my_state) { } in random_pcg32_fast()
119 my_state = other.my_state; in operator =()
129 my_state = (is_mcg ? state | itype(3U) : bump(state + increment())); in seed()
142 itype my_state; member in random_pcg32_fast
161 const itype old_state = my_state; in base_generate0()
163 my_state = bump(my_state); in base_generate0()
|
| /dports/devel/onetbb/oneTBB-2021.4.0/python/rml/ |
| H A D | ipc_server.cpp | 262 std::atomic<state_t> my_state; member in tbb::detail::rml::ipc_worker
308 my_state = st_init; in ipc_worker()
584 state = my_state.load(std::memory_order_acquire); in run()
593 …if( ( my_state.load(std::memory_order_acquire)==st_init && my_state.compare_exchange_strong( expec… in wake_or_launch()
594 …( my_state.load(std::memory_order_acquire)==st_stop && my_state.compare_exchange_strong( excepted_… in wake_or_launch()
623 my_state.compare_exchange_strong( s, st_normal ); in wake_or_launch()
699 …if( ( my_state.load(std::memory_order_acquire)==st_init && my_state.compare_exchange_strong( excep… in wake_or_launch()
711 my_state.compare_exchange_strong(s, st_init); in wake_or_launch()
727 my_state.compare_exchange_strong(s, st_normal); in wake_or_launch()
786 …if( ( my_state.load(std::memory_order_acquire)==st_init && my_state.compare_exchange_strong( excep… in wake_or_launch()
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/components/logging/ |
| H A D | log_sink_json.cc | 71 struct my_state { struct
214 if ((log_bi->dedicated_errstream(((my_state *)instance)->errstream) <
219 ((my_state *)instance)->id);
229 log_bi->write_errstream(((my_state *)instance)->errstream, out_buff,
260 my_state *mi;
268 if ((mi = (my_state *)log_bs->malloc(sizeof(my_state))) == nullptr) {
310 my_state *mi;
315 mi = (my_state *)*instance;
346 my_state *mi;
350 if ((mi = *((my_state **)instance)) == nullptr) return -2;
|
| /dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/ |
| H A D | test_parallel_while.cpp | 32 } my_state; member in MinimalArgumentType
35 ASSERT( my_state==LIVE||my_state==INITIALIZED, NULL ); in ~MinimalArgumentType()
36 my_state = DEAD; in ~MinimalArgumentType()
39 my_state = LIVE; in MinimalArgumentType()
42 ASSERT( my_state==LIVE||my_state==INITIALIZED, NULL ); in set_value()
44 my_state = INITIALIZED; in set_value()
47 ASSERT( my_state==INITIALIZED, NULL ); in get_value()
|