| /dports/databases/p5-MongoDB/MongoDB-v2.2.2/lib/MongoDB/Op/ |
| H A D | _BulkWrite.pm | 316 my $queue_idx = 0;
320 push @batches, [ $type => [$doc], [$queue_idx] ];
326 push @{ $batches[-1][2] }, $queue_idx;
329 $queue_idx++;
342 my $queue_idx = 0;
347 push @{ $queue_map{$type} }, [ $queue_idx ];
351 push @{ $queue_map{$type}[-1] }, $queue_idx;
353 $queue_idx++;
|
| /dports/net/haproxy21/haproxy-2.1.12/src/ |
| H A D | queue.c | 138 p->strm->logs.srv_queue_pos += p->srv->queue_idx - p->queue_idx; in __pendconn_unlink()
141 p->strm->logs.prx_queue_pos += p->px->queue_idx - p->queue_idx; in __pendconn_unlink()
292 srv->queue_idx++; in pendconn_process_next_strm()
294 px->queue_idx++; in pendconn_process_next_strm()
376 p->queue_idx = srv->queue_idx - 1; // for increment in pendconn_add()
383 p->queue_idx = px->queue_idx - 1; // for increment in pendconn_add()
|
| /dports/net/haproxy19/haproxy-1.9.16/src/ |
| H A D | queue.c | 138 p->strm->logs.srv_queue_pos += p->srv->queue_idx - p->queue_idx; in __pendconn_unlink()
141 p->strm->logs.prx_queue_pos += p->px->queue_idx - p->queue_idx; in __pendconn_unlink()
292 srv->queue_idx++; in pendconn_process_next_strm()
294 px->queue_idx++; in pendconn_process_next_strm()
375 p->queue_idx = srv->queue_idx - 1; // for increment in pendconn_add()
382 p->queue_idx = px->queue_idx - 1; // for increment in pendconn_add()
|
| /dports/net/nuster/nuster-5.0.4.21/src/ |
| H A D | queue.c | 138 p->strm->logs.srv_queue_pos += p->srv->queue_idx - p->queue_idx; in __pendconn_unlink()
141 p->strm->logs.prx_queue_pos += p->px->queue_idx - p->queue_idx; in __pendconn_unlink()
292 srv->queue_idx++; in pendconn_process_next_strm()
294 px->queue_idx++; in pendconn_process_next_strm()
376 p->queue_idx = srv->queue_idx - 1; // for increment in pendconn_add()
383 p->queue_idx = px->queue_idx - 1; // for increment in pendconn_add()
|
| /dports/net/haproxy20/haproxy-2.0.26/src/ |
| H A D | queue.c | 138 p->strm->logs.srv_queue_pos += p->srv->queue_idx - p->queue_idx; in __pendconn_unlink()
141 p->strm->logs.prx_queue_pos += p->px->queue_idx - p->queue_idx; in __pendconn_unlink()
292 srv->queue_idx++; in pendconn_process_next_strm()
294 px->queue_idx++; in pendconn_process_next_strm()
379 p->queue_idx = srv->queue_idx - 1; // for increment in pendconn_add()
386 p->queue_idx = px->queue_idx - 1; // for increment in pendconn_add()
|
| /dports/net/haproxy22/haproxy-2.2.19/src/ |
| H A D | queue.c | 136 p->strm->logs.srv_queue_pos += p->srv->queue_idx - p->queue_idx; in __pendconn_unlink()
139 p->strm->logs.prx_queue_pos += p->px->queue_idx - p->queue_idx; in __pendconn_unlink()
290 srv->queue_idx++; in pendconn_process_next_strm()
292 px->queue_idx++; in pendconn_process_next_strm()
377 p->queue_idx = srv->queue_idx - 1; // for increment in pendconn_add()
384 p->queue_idx = px->queue_idx - 1; // for increment in pendconn_add()
|
| /dports/net/haproxy/haproxy-2.4.10/src/ |
| H A D | queue.c | 136 p->strm->logs.srv_queue_pos += p->srv->queue_idx - p->queue_idx; in __pendconn_unlink_srv()
149 p->strm->logs.prx_queue_pos += p->px->queue_idx - p->queue_idx; in __pendconn_unlink_prx()
315 px->queue_idx++; in pendconn_process_next_strm()
322 srv->queue_idx++; in pendconn_process_next_strm()
416 p->queue_idx = srv->queue_idx - 1; // for increment in pendconn_add()
432 p->queue_idx = px->queue_idx - 1; // for increment in pendconn_add()
|
| /dports/net/haproxy23/haproxy-2.3.16/src/ |
| H A D | queue.c | 135 p->strm->logs.srv_queue_pos += p->srv->queue_idx - p->queue_idx; in __pendconn_unlink_srv()
148 p->strm->logs.prx_queue_pos += p->px->queue_idx - p->queue_idx; in __pendconn_unlink_prx()
314 px->queue_idx++; in pendconn_process_next_strm()
321 srv->queue_idx++; in pendconn_process_next_strm()
415 p->queue_idx = srv->queue_idx - 1; // for increment in pendconn_add()
431 p->queue_idx = px->queue_idx - 1; // for increment in pendconn_add()
|
| /dports/emulators/vice/vice-3.5/src/lib/libffmpeg/libavfilter/ |
| H A D | f_interleave.c | 55 int i, queue_idx = -1; in push_frame() local
68 queue_idx = i; in push_frame()
74 if (queue_idx < 0) in push_frame()
77 frame = ff_bufqueue_get(&s->queues[queue_idx]); in push_frame()
79 queue_idx, frame->pts * av_q2d(AV_TIME_BASE_Q)); in push_frame()
|
| /dports/emulators/libretro-vice/vice-libretro-5725415/vice/src/lib/libffmpeg/libavfilter/ |
| H A D | f_interleave.c | 55 int i, queue_idx = -1; in push_frame() local
68 queue_idx = i; in push_frame()
74 if (queue_idx < 0) in push_frame()
77 frame = ff_bufqueue_get(&s->queues[queue_idx]); in push_frame()
79 queue_idx, frame->pts * av_q2d(AV_TIME_BASE_Q)); in push_frame()
|
| /dports/multimedia/gstreamer1-libav/gst-libav-1.16.2/gst-libs/ext/libav/libavfilter/ |
| H A D | f_interleave.c | 59 int i, queue_idx = -1; in push_frame() local
72 queue_idx = i; in push_frame()
78 if (queue_idx < 0) in push_frame()
81 frame = ff_bufqueue_get(&s->queues[queue_idx]); in push_frame()
83 queue_idx, frame->pts * av_q2d(AV_TIME_BASE_Q)); in push_frame()
|
| /dports/games/freeorion/freeorion-0.4.10.2/UI/ |
| H A D | BuildDesignatorWnd.h | 42 void CenterOnBuild(int queue_idx, bool open = false);
123 void BuildQuantityChanged(int queue_idx, int quantity);
124 void SetBuild(int queue_idx);
|
| H A D | ProductionWnd.h | 81 void CenterOnBuild(int queue_idx, bool open = false);
119 void ChangeBuildQuantitySlot(int queue_idx, int quantity);
120 void ChangeBuildQuantityBlockSlot(int queue_idx, int quantity, int blocksize);
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/atheros/alx/ |
| H A D | alx.h | 68 u16 queue_idx; member
83 u16 queue_idx; member
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/atheros/alx/ |
| H A D | alx.h | 68 u16 queue_idx; member
83 u16 queue_idx; member
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/atheros/alx/ |
| H A D | alx.h | 68 u16 queue_idx; member
83 u16 queue_idx; member
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/staging/rtl8723bs/hal/ |
| H A D | hal_sdio.c | 80 u32 rtw_hal_get_sdio_tx_max_length(struct adapter *padapter, u8 queue_idx) in rtw_hal_get_sdio_tx_max_length() argument
87 deviceId = ffaddr2deviceId(pdvobjpriv, queue_idx); in rtw_hal_get_sdio_tx_max_length()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/staging/rtl8723bs/hal/ |
| H A D | hal_sdio.c | 80 u32 rtw_hal_get_sdio_tx_max_length(struct adapter *padapter, u8 queue_idx) in rtw_hal_get_sdio_tx_max_length() argument
87 deviceId = ffaddr2deviceId(pdvobjpriv, queue_idx); in rtw_hal_get_sdio_tx_max_length()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/staging/rtl8723bs/hal/ |
| H A D | hal_sdio.c | 80 u32 rtw_hal_get_sdio_tx_max_length(struct adapter *padapter, u8 queue_idx) in rtw_hal_get_sdio_tx_max_length() argument
87 deviceId = ffaddr2deviceId(pdvobjpriv, queue_idx); in rtw_hal_get_sdio_tx_max_length()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/google/gve/ |
| H A D | gve.h | 441 static inline u32 gve_tx_idx_to_ntfy(struct gve_priv *priv, u32 queue_idx) in gve_tx_idx_to_ntfy() argument
443 return queue_idx; in gve_tx_idx_to_ntfy()
448 static inline u32 gve_rx_idx_to_ntfy(struct gve_priv *priv, u32 queue_idx) in gve_rx_idx_to_ntfy() argument
450 return (priv->num_ntfy_blks / 2) + queue_idx; in gve_rx_idx_to_ntfy()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/google/gve/ |
| H A D | gve.h | 441 static inline u32 gve_tx_idx_to_ntfy(struct gve_priv *priv, u32 queue_idx) in gve_tx_idx_to_ntfy() argument
443 return queue_idx; in gve_tx_idx_to_ntfy()
448 static inline u32 gve_rx_idx_to_ntfy(struct gve_priv *priv, u32 queue_idx) in gve_rx_idx_to_ntfy() argument
450 return (priv->num_ntfy_blks / 2) + queue_idx; in gve_rx_idx_to_ntfy()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/google/gve/ |
| H A D | gve.h | 441 static inline u32 gve_tx_idx_to_ntfy(struct gve_priv *priv, u32 queue_idx) in gve_tx_idx_to_ntfy() argument
443 return queue_idx; in gve_tx_idx_to_ntfy()
448 static inline u32 gve_rx_idx_to_ntfy(struct gve_priv *priv, u32 queue_idx) in gve_rx_idx_to_ntfy() argument
450 return (priv->num_ntfy_blks / 2) + queue_idx; in gve_rx_idx_to_ntfy()
|
| /dports/emulators/qemu-powernv/qemu-powernv-3.0.50/hw/virtio/ |
| H A D | vhost-user.c | 643 int queue_idx) in vhost_user_host_notifier_restore() argument
646 VhostUserHostNotifier *n = &u->user->notifier[queue_idx]; in vhost_user_host_notifier_restore()
650 virtio_queue_set_host_notifier_mr(vdev, queue_idx, &n->mr, true); in vhost_user_host_notifier_restore()
656 int queue_idx) in vhost_user_host_notifier_remove() argument
659 VhostUserHostNotifier *n = &u->user->notifier[queue_idx]; in vhost_user_host_notifier_remove()
663 virtio_queue_set_host_notifier_mr(vdev, queue_idx, &n->mr, false); in vhost_user_host_notifier_remove()
885 int queue_idx = area->u64 & VHOST_USER_VRING_IDX_MASK; in vhost_user_slave_handle_vring_host_notifier() local
896 vdev == NULL || queue_idx >= virtio_get_num_queues(vdev)) { in vhost_user_slave_handle_vring_host_notifier()
900 n = &user->notifier[queue_idx]; in vhost_user_slave_handle_vring_host_notifier()
903 virtio_queue_set_host_notifier_mr(vdev, queue_idx, &n->mr, false); in vhost_user_slave_handle_vring_host_notifier()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/mellanox/mlx5/core/en/ |
| H A D | health.c | 308 int queue_idx, char *lbl) in mlx5e_health_queue_dump() argument
314 key.index1 = queue_idx; in mlx5e_health_queue_dump()
326 err = devlink_fmsg_u32_pair_put(fmsg, "index", queue_idx); in mlx5e_health_queue_dump()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/mellanox/mlx5/core/en/ |
| H A D | health.c | 308 int queue_idx, char *lbl) in mlx5e_health_queue_dump() argument
314 key.index1 = queue_idx; in mlx5e_health_queue_dump()
326 err = devlink_fmsg_u32_pair_put(fmsg, "index", queue_idx); in mlx5e_health_queue_dump()
|