| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/md/ |
| H A D | dm-region-hash.c | 184 rh = kzalloc(sizeof(*rh), GFP_KERNEL); in dm_region_hash_create()
268 return (unsigned) ((region * rh->prime) >> rh->shift) & rh->mask; in rh_hash()
298 nreg->rh = rh; in __rh_alloc()
366 struct dm_region_hash *rh = reg->rh; in complete_resync_work() local
499 rh->log->type->flush(rh->log); in dm_rh_update_states()
533 rh_inc(rh, dm_rh_bio_to_region(rh, bio)); in dm_rh_inc_pending()
580 rh->wakeup_workers(rh->context); in dm_rh_dec()
663 struct dm_region_hash *rh = reg->rh; in dm_rh_recovery_end() local
673 rh->wakeup_workers(rh->context); in dm_rh_recovery_end()
686 return rh->log->type->flush(rh->log); in dm_rh_flush()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/md/ |
| H A D | dm-region-hash.c | 184 rh = kzalloc(sizeof(*rh), GFP_KERNEL); in dm_region_hash_create()
268 return (unsigned) ((region * rh->prime) >> rh->shift) & rh->mask; in rh_hash()
298 nreg->rh = rh; in __rh_alloc()
366 struct dm_region_hash *rh = reg->rh; in complete_resync_work() local
499 rh->log->type->flush(rh->log); in dm_rh_update_states()
533 rh_inc(rh, dm_rh_bio_to_region(rh, bio)); in dm_rh_inc_pending()
580 rh->wakeup_workers(rh->context); in dm_rh_dec()
663 struct dm_region_hash *rh = reg->rh; in dm_rh_recovery_end() local
673 rh->wakeup_workers(rh->context); in dm_rh_recovery_end()
686 return rh->log->type->flush(rh->log); in dm_rh_flush()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/md/ |
| H A D | dm-region-hash.c | 184 rh = kzalloc(sizeof(*rh), GFP_KERNEL); in dm_region_hash_create()
268 return (unsigned) ((region * rh->prime) >> rh->shift) & rh->mask; in rh_hash()
298 nreg->rh = rh; in __rh_alloc()
366 struct dm_region_hash *rh = reg->rh; in complete_resync_work() local
499 rh->log->type->flush(rh->log); in dm_rh_update_states()
533 rh_inc(rh, dm_rh_bio_to_region(rh, bio)); in dm_rh_inc_pending()
580 rh->wakeup_workers(rh->context); in dm_rh_dec()
663 struct dm_region_hash *rh = reg->rh; in dm_rh_recovery_end() local
673 rh->wakeup_workers(rh->context); in dm_rh_recovery_end()
686 return rh->log->type->flush(rh->log); in dm_rh_flush()
[all …]
|
| /dports/misc/amanda-client/amanda-3.3.9/common-src/ |
| H A D | bsdtcp-security.c | 129 rh->rs = NULL; in bsdtcp_connect()
131 rh->rc = NULL; in bsdtcp_connect()
151 rh->rs = tcpma_stream_client(rh, newhandle++); in bsdtcp_connect()
159 rh->hostname = stralloc(rh->rs->rc->hostname); in bsdtcp_connect()
185 result = runbsdtcp(rh, rh->port); in bsdtcp_connect()
203 rh->arg = rh; in bsdtcp_connect()
245 result = runbsdtcp(rh, rh->port); in bsdtcp_fn_connect()
259 if (rh->res) in bsdtcp_fn_connect()
261 rh->res = NULL; in bsdtcp_fn_connect()
264 rh->port = 0; in bsdtcp_fn_connect()
[all …]
|
| H A D | security-util.c | 154 (*rh->fn.connect)(rh->arg, &rh->sech, S_OK); in sec_connect_callback()
171 (*rh->fn.connect)(rh->arg, &rh->sech, S_TIMEOUT); in sec_connect_timeout()
655 if (rh && rh->rc && rh->rc->read >= 0 && rh->rc->toclose == 0) { in tcpm_close_connection()
894 rh->rc->write = rh->rc->read; in tcp1_stream_client()
1176 rh->next->prev = rh->prev; in udp_close()
1179 rh->udp->bh_last = rh->prev; in udp_close()
1182 rh->prev->next = rh->next; in udp_close()
1185 rh->udp->bh_first = rh->next; in udp_close()
1297 rh->udp->recv_security_ok(rh, &rh->udp->pkt) < 0) { in udp_recvpkt_callback()
1351 rh->prev->next = rh; in udp_inithandle()
[all …]
|
| /dports/misc/amanda-server/amanda-3.3.9/common-src/ |
| H A D | bsdtcp-security.c | 129 rh->rs = NULL; in bsdtcp_connect()
131 rh->rc = NULL; in bsdtcp_connect()
151 rh->rs = tcpma_stream_client(rh, newhandle++); in bsdtcp_connect()
159 rh->hostname = stralloc(rh->rs->rc->hostname); in bsdtcp_connect()
185 result = runbsdtcp(rh, rh->port); in bsdtcp_connect()
203 rh->arg = rh; in bsdtcp_connect()
245 result = runbsdtcp(rh, rh->port); in bsdtcp_fn_connect()
259 if (rh->res) in bsdtcp_fn_connect()
261 rh->res = NULL; in bsdtcp_fn_connect()
264 rh->port = 0; in bsdtcp_fn_connect()
[all …]
|
| H A D | security-util.c | 154 (*rh->fn.connect)(rh->arg, &rh->sech, S_OK); in sec_connect_callback()
171 (*rh->fn.connect)(rh->arg, &rh->sech, S_TIMEOUT); in sec_connect_timeout()
655 if (rh && rh->rc && rh->rc->read >= 0 && rh->rc->toclose == 0) { in tcpm_close_connection()
894 rh->rc->write = rh->rc->read; in tcp1_stream_client()
1176 rh->next->prev = rh->prev; in udp_close()
1179 rh->udp->bh_last = rh->prev; in udp_close()
1182 rh->prev->next = rh->next; in udp_close()
1185 rh->udp->bh_first = rh->next; in udp_close()
1297 rh->udp->recv_security_ok(rh, &rh->udp->pkt) < 0) { in udp_recvpkt_callback()
1351 rh->prev->next = rh; in udp_inithandle()
[all …]
|
| /dports/net-mgmt/blackbox_exporter/blackbox_exporter-0.17.0/ |
| H A D | history.go | 41 rh.mu.Lock()
42 defer rh.mu.Unlock()
51 rh.nextId++
53 rh.results = append(rh.results, r)
54 if uint(len(rh.results)) > rh.maxResults {
58 rh.preservedFailedResults = append(rh.preservedFailedResults, rh.results[0])
59 if uint(len(rh.preservedFailedResults)) > rh.maxResults {
73 rh.mu.Lock()
74 defer rh.mu.Unlock()
77 return append(rh.preservedFailedResults[:], rh.results...)
[all …]
|
| /dports/x11/xscreensaver/xscreensaver-5.44/jwxyz/ |
| H A D | jwxyz-android.c | 251 wnd->window.rh = rh; in doinit()
263 rh->xsft->setup_cb(rh->xsft, rh->xsft->setup_arg); in doinit()
358 rh->egl_p = rh->jwxyz_gl_p || rh->xsft->visual == GL_VISUAL; in doinit()
393 rh->egl_ctx = eglCreateContext (rh->egl_display, rh->egl_config, in doinit()
505 rh->copy_gc = XCreateGC (rh->dpy, &rh->frontbuffer, 0, NULL); in doinit()
585 rh->closure = init_cb (rh->dpy, wnd, rh->xsft->setup_arg); in drawXScreenSaver()
619 delay = rh->xsft->draw_cb(rh->dpy, wnd, rh->closure); in drawXScreenSaver()
628 rh->xsft->fps_cb (rh->dpy, wnd, rh->fpst, rh->closure); in drawXScreenSaver()
844 rh->xsft->reshape_cb (rh->dpy, rh->window, rh->closure, in Java_org_jwz_xscreensaver_jwxyz_nativeResize()
881 rh->xsft->free_cb (rh->dpy, rh->window, rh->closure); in Java_org_jwz_xscreensaver_jwxyz_nativeDone()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/i3c/master/mipi-i3c-hci/ |
| H A D | dma.c | 184 rh->xfer_struct_sz * rh->xfer_entries, in hci_dma_cleanup()
185 rh->xfer, rh->xfer_dma); in hci_dma_cleanup()
188 rh->resp_struct_sz * rh->xfer_entries, in hci_dma_cleanup()
189 rh->resp, rh->resp_dma); in hci_dma_cleanup()
193 rh->ibi_status_sz * rh->ibi_status_entries, in hci_dma_cleanup()
194 rh->ibi_status, rh->ibi_status_dma); in hci_dma_cleanup()
197 rh->ibi_chunk_sz * rh->ibi_chunks_total, in hci_dma_cleanup()
250 rh->xfer_struct_sz, rh->resp_struct_sz); in hci_dma_init()
262 if (!rh->xfer || !rh->resp || !rh->src_xfers) in hci_dma_init()
304 if (!rh->ibi_status || !rh->ibi_data) in hci_dma_init()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/i3c/master/mipi-i3c-hci/ |
| H A D | dma.c | 184 rh->xfer_struct_sz * rh->xfer_entries, in hci_dma_cleanup()
185 rh->xfer, rh->xfer_dma); in hci_dma_cleanup()
188 rh->resp_struct_sz * rh->xfer_entries, in hci_dma_cleanup()
189 rh->resp, rh->resp_dma); in hci_dma_cleanup()
193 rh->ibi_status_sz * rh->ibi_status_entries, in hci_dma_cleanup()
194 rh->ibi_status, rh->ibi_status_dma); in hci_dma_cleanup()
197 rh->ibi_chunk_sz * rh->ibi_chunks_total, in hci_dma_cleanup()
250 rh->xfer_struct_sz, rh->resp_struct_sz); in hci_dma_init()
262 if (!rh->xfer || !rh->resp || !rh->src_xfers) in hci_dma_init()
304 if (!rh->ibi_status || !rh->ibi_data) in hci_dma_init()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/i3c/master/mipi-i3c-hci/ |
| H A D | dma.c | 184 rh->xfer_struct_sz * rh->xfer_entries, in hci_dma_cleanup()
185 rh->xfer, rh->xfer_dma); in hci_dma_cleanup()
188 rh->resp_struct_sz * rh->xfer_entries, in hci_dma_cleanup()
189 rh->resp, rh->resp_dma); in hci_dma_cleanup()
193 rh->ibi_status_sz * rh->ibi_status_entries, in hci_dma_cleanup()
194 rh->ibi_status, rh->ibi_status_dma); in hci_dma_cleanup()
197 rh->ibi_chunk_sz * rh->ibi_chunks_total, in hci_dma_cleanup()
250 rh->xfer_struct_sz, rh->resp_struct_sz); in hci_dma_init()
262 if (!rh->xfer || !rh->resp || !rh->src_xfers) in hci_dma_init()
304 if (!rh->ibi_status || !rh->ibi_data) in hci_dma_init()
[all …]
|
| /dports/net/freeradius-client/freeradius-client-1.1.7/src/ |
| H A D | radembedded.c | 33 rh = rc_new(); in main()
34 if (rh == NULL) in main()
42 rh = rc_config_init(rh); in main()
43 if (rh == NULL) in main()
58 rc_destroy(rh); in main()
65 rc_destroy(rh); in main()
72 rc_destroy(rh); in main()
79 rc_destroy(rh); in main()
86 rc_destroy(rh); in main()
93 rc_destroy(rh); in main()
[all …]
|
| /dports/devel/fifechan/fifechan-0.1.5/src/ |
| H A D | rectangle.cpp | 164 int nx = x < rh.x ? x : rh.x; in operator +()
165 int ny = y < rh.y ? y : rh.y; in operator +()
166 int nx2 = x + width > rh.x + rh.width ? x + width : rh.x + rh.width; in operator +()
167 int ny2 = y + height > rh.y + rh.height ? y + height : rh.y + rh.height; in operator +()
179 x = x < rh.x ? x : rh.x; in operator +=()
180 y = y < rh.y ? y : rh.y; in operator +=()
181 int x2 = x + width > rh.x + rh.width ? x + width : rh.x + rh.width; in operator +=()
182 int y2 = y + height > rh.y + rh.height ? y + height : rh.y + rh.height; in operator +=()
190 int nx = x > rh.x ? x : rh.x; in intersection()
196 int nx2 = x + width < rh.x + rh.width ? x + width : rh.x + rh.width; in intersection()
[all …]
|
| /dports/mail/bogofilter-lmdb/bogofilter-1.2.5/src/ |
| H A D | robx.c | 45 rh->sum += prob; in robx_accum()
46 rh->count += 1; in robx_accum()
53 (unsigned long)rh->count, rh->sum, rh->sum / rh->count, in robx_accum()
96 if (rh.spam_cnt == 0 || rh.good_cnt == 0) in compute_robinson_x()
99 rh.scalefactor = (double)rh.spam_cnt/(double)rh.good_cnt; in compute_robinson_x()
101 rh.dsh = dsh; in compute_robinson_x()
102 rh.sum = 0.0; in compute_robinson_x()
103 rh.count = 0; in compute_robinson_x()
116 rx = rh.sum/rh.count; in compute_robinson_x()
119 MSG_COUNT, rh.spam_cnt, rh.good_cnt, in compute_robinson_x()
[all …]
|
| /dports/mail/bogofilter-sqlite/bogofilter-1.2.5/src/ |
| H A D | robx.c | 45 rh->sum += prob; in robx_accum()
46 rh->count += 1; in robx_accum()
53 (unsigned long)rh->count, rh->sum, rh->sum / rh->count, in robx_accum()
96 if (rh.spam_cnt == 0 || rh.good_cnt == 0) in compute_robinson_x()
99 rh.scalefactor = (double)rh.spam_cnt/(double)rh.good_cnt; in compute_robinson_x()
101 rh.dsh = dsh; in compute_robinson_x()
102 rh.sum = 0.0; in compute_robinson_x()
103 rh.count = 0; in compute_robinson_x()
116 rx = rh.sum/rh.count; in compute_robinson_x()
119 MSG_COUNT, rh.spam_cnt, rh.good_cnt, in compute_robinson_x()
[all …]
|
| /dports/mail/bogofilter/bogofilter-1.2.5/src/ |
| H A D | robx.c | 45 rh->sum += prob; in robx_accum()
46 rh->count += 1; in robx_accum()
53 (unsigned long)rh->count, rh->sum, rh->sum / rh->count, in robx_accum()
96 if (rh.spam_cnt == 0 || rh.good_cnt == 0) in compute_robinson_x()
99 rh.scalefactor = (double)rh.spam_cnt/(double)rh.good_cnt; in compute_robinson_x()
101 rh.dsh = dsh; in compute_robinson_x()
102 rh.sum = 0.0; in compute_robinson_x()
103 rh.count = 0; in compute_robinson_x()
116 rx = rh.sum/rh.count; in compute_robinson_x()
119 MSG_COUNT, rh.spam_cnt, rh.good_cnt, in compute_robinson_x()
[all …]
|
| /dports/mail/bogofilter-kc/bogofilter-1.2.5/src/ |
| H A D | robx.c | 45 rh->sum += prob; in robx_accum()
46 rh->count += 1; in robx_accum()
53 (unsigned long)rh->count, rh->sum, rh->sum / rh->count, in robx_accum()
96 if (rh.spam_cnt == 0 || rh.good_cnt == 0) in compute_robinson_x()
99 rh.scalefactor = (double)rh.spam_cnt/(double)rh.good_cnt; in compute_robinson_x()
101 rh.dsh = dsh; in compute_robinson_x()
102 rh.sum = 0.0; in compute_robinson_x()
103 rh.count = 0; in compute_robinson_x()
116 rx = rh.sum/rh.count; in compute_robinson_x()
119 MSG_COUNT, rh.spam_cnt, rh.good_cnt, in compute_robinson_x()
[all …]
|
| /dports/math/pynac/pynac-pynac-0.7.27/ginac/ |
| H A D | operators.cpp | 91 return lh.add(rh); in operator +()
96 return lh.sub(rh); in operator -()
101 return lh.mul(rh); in operator *()
162 rh = numeric(ex_to<numeric>(rh) + *_num1_p); in operator ++()
165 return rh = exadd(rh, _ex1); in operator ++()
172 rh = numeric(ex_to<numeric>(rh) + *_num_1_p); in operator --()
175 return rh = exadd(rh, _ex_1); in operator --()
199 rh = rh.add(*_num1_p); in operator ++()
200 return rh; in operator ++()
206 rh = rh.add(*_num_1_p); in operator --()
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | rds_handler.go | 66 rh.mu.Lock()
67 defer rh.mu.Unlock()
84 rh.cancels[routeName]()
92 if len(rh.updates) == len(rh.cancels) && len(routeNamesToWatch) != 0 {
93 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
105 rh.mu.Lock()
106 defer rh.mu.Unlock()
111 if len(rh.updates) == len(rh.cancels) {
112 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
128 rh.mu.Lock()
[all …]
|
| /dports/net/cloudquery/cloudquery-0.16.0/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | rds_handler.go | 66 rh.mu.Lock()
67 defer rh.mu.Unlock()
84 rh.cancels[routeName]()
92 if len(rh.updates) == len(rh.cancels) && len(routeNamesToWatch) != 0 {
93 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
105 rh.mu.Lock()
106 defer rh.mu.Unlock()
111 if len(rh.updates) == len(rh.cancels) {
112 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
128 rh.mu.Lock()
[all …]
|
| /dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | rds_handler.go | 66 rh.mu.Lock()
67 defer rh.mu.Unlock()
84 rh.cancels[routeName]()
92 if len(rh.updates) == len(rh.cancels) && len(routeNamesToWatch) != 0 {
93 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
105 rh.mu.Lock()
106 defer rh.mu.Unlock()
111 if len(rh.updates) == len(rh.cancels) {
112 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
128 rh.mu.Lock()
[all …]
|
| /dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | rds_handler.go | 66 rh.mu.Lock()
67 defer rh.mu.Unlock()
84 rh.cancels[routeName]()
92 if len(rh.updates) == len(rh.cancels) && len(routeNamesToWatch) != 0 {
93 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
105 rh.mu.Lock()
106 defer rh.mu.Unlock()
111 if len(rh.updates) == len(rh.cancels) {
112 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
128 rh.mu.Lock()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | rds_handler.go | 66 rh.mu.Lock()
67 defer rh.mu.Unlock()
84 rh.cancels[routeName]()
92 if len(rh.updates) == len(rh.cancels) && len(routeNamesToWatch) != 0 {
93 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
105 rh.mu.Lock()
106 defer rh.mu.Unlock()
111 if len(rh.updates) == len(rh.cancels) {
112 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
128 rh.mu.Lock()
[all …]
|
| /dports/ftp/sftpgo/sftpgo-2.2.0/vendor/google.golang.org/grpc/xds/internal/server/ |
| H A D | rds_handler.go | 66 rh.mu.Lock()
67 defer rh.mu.Unlock()
84 rh.cancels[routeName]()
92 if len(rh.updates) == len(rh.cancels) && len(routeNamesToWatch) != 0 {
93 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
105 rh.mu.Lock()
106 defer rh.mu.Unlock()
111 if len(rh.updates) == len(rh.cancels) {
112 drainAndPush(rh.updateChannel, rdsHandlerUpdate{updates: rh.updates})
128 rh.mu.Lock()
[all …]
|