/dports/databases/galera/galera-release_25.3.35/gcs/src/ |
H A D | gcs_defrag.cpp | 51 df->frag_no++; in gcs_defrag_handle_frag() 55 (df->frag_no != frg->frag_no))) { in gcs_defrag_handle_frag() 57 (df->sent_id == frg->act_id) && (0 == frg->frag_no)) { in gcs_defrag_handle_frag() 63 df->frag_no = 0; in gcs_defrag_handle_frag() 84 else if (frg->act_id == df->sent_id && frg->frag_no < df->frag_no) { in gcs_defrag_handle_frag() 88 frg->act_id, frg->frag_no, df->sent_id, df->frag_no); in gcs_defrag_handle_frag() 89 df->frag_no--; // revert counter in hope that we get good frag in gcs_defrag_handle_frag() 96 df->sent_id, df->frag_no, frg->act_id, frg->frag_no); in gcs_defrag_handle_frag() 106 if (gu_likely(0 == frg->frag_no)) { in gcs_defrag_handle_frag() 126 frg->act_id, frg->frag_no, frg->act_size); in gcs_defrag_handle_frag() [all …]
|
H A D | gcs_act_proto.hpp | 30 unsigned long frag_no; member 53 uint32_t frag_no = gtohl(((uint32_t*)buf)[3]) + 1; in gcs_act_proto_inc() local 55 if (!frag_no) return -EOVERFLOW; in gcs_act_proto_inc() 57 ((uint32_t*)buf)[3] = htogl(frag_no); in gcs_act_proto_inc() 58 return frag_no; in gcs_act_proto_inc()
|
H A D | gcs_act_proto.cpp | 52 (frag->frag_no > PROTO_FRAG_NO_MAX) || in gcs_act_proto_write() 57 frag->frag_no, PROTO_FRAG_NO_MAX, in gcs_act_proto_write() 69 ((uint32_t*)buf)[3] = htogl (frag->frag_no); in gcs_act_proto_write() 104 frag->frag_no = gtohl (((uint32_t*)buf)[3]); in gcs_act_proto_read()
|
H A D | gcs_defrag.hpp | 30 ulong frag_no; // number of fragment received member
|
H A D | gcs_group.hpp | 173 !(local && 0 == frg->frag_no && in gcs_group_handle_act_msg()
|
/dports/databases/galera26/galera-release_26.4.10/gcs/src/ |
H A D | gcs_defrag.cpp | 51 df->frag_no++; in gcs_defrag_handle_frag() 55 (df->frag_no != frg->frag_no))) { in gcs_defrag_handle_frag() 57 (df->sent_id == frg->act_id) && (0 == frg->frag_no)) { in gcs_defrag_handle_frag() 63 df->frag_no = 0; in gcs_defrag_handle_frag() 84 else if (frg->act_id == df->sent_id && frg->frag_no < df->frag_no) { in gcs_defrag_handle_frag() 88 frg->act_id, frg->frag_no, df->sent_id, df->frag_no); in gcs_defrag_handle_frag() 89 df->frag_no--; // revert counter in hope that we get good frag in gcs_defrag_handle_frag() 96 df->sent_id, df->frag_no, frg->act_id, frg->frag_no); in gcs_defrag_handle_frag() 106 if (gu_likely(0 == frg->frag_no)) { in gcs_defrag_handle_frag() 126 frg->act_id, frg->frag_no, frg->act_size); in gcs_defrag_handle_frag() [all …]
|
H A D | gcs_act_proto.hpp | 35 unsigned long frag_no; member 58 uint32_t frag_no = gtohl(((uint32_t*)buf)[3]) + 1; in gcs_act_proto_inc() local 60 if (!frag_no) return -EOVERFLOW; in gcs_act_proto_inc() 62 ((uint32_t*)buf)[3] = htogl(frag_no); in gcs_act_proto_inc() 63 return frag_no; in gcs_act_proto_inc()
|
H A D | gcs_act_proto.cpp | 50 (frag->frag_no > PROTO_FRAG_NO_MAX) || in gcs_act_proto_write() 55 frag->frag_no, PROTO_FRAG_NO_MAX, in gcs_act_proto_write() 67 ((uint32_t*)buf)[3] = htogl (frag->frag_no); in gcs_act_proto_write() 102 frag->frag_no = gtohl (((uint32_t*)buf)[3]); in gcs_act_proto_read()
|
H A D | gcs_defrag.hpp | 30 ulong frag_no; // number of fragment received member
|
H A D | gcs_group.hpp | 191 !(local && 0 == frg->frag_no && in gcs_group_handle_act_msg()
|
/dports/databases/galera/galera-release_25.3.35/gcs/src/unit_tests/ |
H A D | gcs_proto_test.cpp | 44 frg_send.frag_no = 0; in START_TEST() 68 ck_assert_msg(frg_send.frag_no == frg_recv.frag_no, in START_TEST() 70 frg_send.frag_no, frg_recv.frag_no); in START_TEST() 90 ck_assert_msg(frg_send.frag_no + 1 == frg_recv.frag_no, in START_TEST() 92 frg_send.frag_no, frg_recv.frag_no); in START_TEST()
|
H A D | gcs_defrag_test.cpp | 26 ck_assert(defrag->frag_no == 0); in defrag_check_init() 67 frg1.frag_no = 0; in START_TEST() 76 frg2.frag_no = frg1.frag_no + 1; in START_TEST() 79 frg3.frag_no = frg2.frag_no + 1; in START_TEST() 111 if (defrag.frag_no < frag.frag_no) ck_assert(ret == -EPROTO); \ in START_TEST()
|
H A D | gcs_group_test.cpp | 116 frg1.frag_no = 0; in START_TEST() 122 frg2.frag_no = frg1.frag_no + 1; in START_TEST() 123 frg3.frag_no = frg2.frag_no + 1; in START_TEST()
|
/dports/databases/galera26/galera-release_26.4.10/gcs/src/unit_tests/ |
H A D | gcs_proto_test.cpp | 40 frg_send.frag_no = 0; in START_TEST() 64 ck_assert_msg(frg_send.frag_no == frg_recv.frag_no, in START_TEST() 66 frg_send.frag_no, frg_recv.frag_no); in START_TEST() 86 ck_assert_msg(frg_send.frag_no + 1 == frg_recv.frag_no, in START_TEST() 88 frg_send.frag_no, frg_recv.frag_no); in START_TEST()
|
H A D | gcs_defrag_test.cpp | 22 ck_assert(defrag->frag_no == 0); in defrag_check_init() 63 frg1.frag_no = 0; in START_TEST() 72 frg2.frag_no = frg1.frag_no + 1; in START_TEST() 75 frg3.frag_no = frg2.frag_no + 1; in START_TEST() 107 if (defrag.frag_no < frag.frag_no) ck_assert(ret == -EPROTO); \ in START_TEST()
|
H A D | gcs_group_test.cpp | 108 frg1.frag_no = 0; in START_TEST() 114 frg2.frag_no = frg1.frag_no + 1; in START_TEST() 115 frg3.frag_no = frg2.frag_no + 1; in START_TEST()
|
/dports/biology/cd-hit/cdhit-4.8.1/ |
H A D | cdhit-common.c++ | 2959 int F = frag_no < MAX_TABLE_SEQ ? frag_no : MAX_TABLE_SEQ; in MinimalMemory() 3039 int frag_no = seq_no; in DoClustering() local 3048 frag_no = 0; in DoClustering() 3049 for (i=0; i<seq_no; i++) frag_no += (sequences[i]->size - NAA) / frag_size + 1; in DoClustering() 3060 buffers[i].Set( frag_no, max_len, options ); in DoClustering() 3070 size_t mem_need = MinimalMemory( frag_no, buffers[0].total_bytes, T, options ); in DoClustering() 3669 int frag_no = seq_no; in DoClustering() local 3686 frag_no = 0; in DoClustering() 3687 for (i=0; i<seq_no; i++) frag_no += (sequences[i]->size - NAA) / frag_size + 1; in DoClustering() 3695 WorkingBuffer buffer( frag_no, max_len, options ); in DoClustering() [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/wireless/atmel/ |
H A D | atmel.c | 464 u16 frag_seq, frag_len, frag_no; member 966 u8 frag_no, int more_frags) in frag_rx_path() argument 982 if (frag_no == 0) { /* first fragment */ in frag_rx_path() 991 priv->frag_no = 1; in frag_rx_path() 1009 } else if (priv->frag_no == frag_no && in frag_rx_path() 1029 priv->frag_no++; in frag_rx_path()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/wireless/atmel/ |
H A D | atmel.c | 464 u16 frag_seq, frag_len, frag_no; member 966 u8 frag_no, int more_frags) in frag_rx_path() argument 982 if (frag_no == 0) { /* first fragment */ in frag_rx_path() 991 priv->frag_no = 1; in frag_rx_path() 1009 } else if (priv->frag_no == frag_no && in frag_rx_path() 1029 priv->frag_no++; in frag_rx_path()
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/wireless/atmel/ |
H A D | atmel.c | 464 u16 frag_seq, frag_len, frag_no; member 966 u8 frag_no, int more_frags) in frag_rx_path() argument 982 if (frag_no == 0) { /* first fragment */ in frag_rx_path() 991 priv->frag_no = 1; in frag_rx_path() 1009 } else if (priv->frag_no == frag_no && in frag_rx_path() 1029 priv->frag_no++; in frag_rx_path()
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/wireless/ath/ath11k/ |
H A D | dp_rx.c | 3449 u16 seqno, frag_no; in ath11k_dp_rx_frag_h_mpdu() local 3458 frag_no = ath11k_dp_rx_h_mpdu_start_frag_no(ar->ab, msdu); in ath11k_dp_rx_frag_h_mpdu() 3471 if (WARN_ON_ONCE(!frag_no && !more_frags)) in ath11k_dp_rx_frag_h_mpdu() 3491 if (rx_tid->rx_frag_bitmap & BIT(frag_no)) { in ath11k_dp_rx_frag_h_mpdu() 3497 if (frag_no > __fls(rx_tid->rx_frag_bitmap)) in ath11k_dp_rx_frag_h_mpdu() 3502 rx_tid->rx_frag_bitmap |= BIT(frag_no); in ath11k_dp_rx_frag_h_mpdu() 3504 rx_tid->last_frag_no = frag_no; in ath11k_dp_rx_frag_h_mpdu() 3506 if (frag_no == 0) { in ath11k_dp_rx_frag_h_mpdu()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/wireless/ath/ath11k/ |
H A D | dp_rx.c | 3449 u16 seqno, frag_no; in ath11k_dp_rx_frag_h_mpdu() local 3458 frag_no = ath11k_dp_rx_h_mpdu_start_frag_no(ar->ab, msdu); in ath11k_dp_rx_frag_h_mpdu() 3471 if (WARN_ON_ONCE(!frag_no && !more_frags)) in ath11k_dp_rx_frag_h_mpdu() 3491 if (rx_tid->rx_frag_bitmap & BIT(frag_no)) { in ath11k_dp_rx_frag_h_mpdu() 3497 if (frag_no > __fls(rx_tid->rx_frag_bitmap)) in ath11k_dp_rx_frag_h_mpdu() 3502 rx_tid->rx_frag_bitmap |= BIT(frag_no); in ath11k_dp_rx_frag_h_mpdu() 3504 rx_tid->last_frag_no = frag_no; in ath11k_dp_rx_frag_h_mpdu() 3506 if (frag_no == 0) { in ath11k_dp_rx_frag_h_mpdu()
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/wireless/ath/ath11k/ |
H A D | dp_rx.c | 3449 u16 seqno, frag_no; in ath11k_dp_rx_frag_h_mpdu() local 3458 frag_no = ath11k_dp_rx_h_mpdu_start_frag_no(ar->ab, msdu); in ath11k_dp_rx_frag_h_mpdu() 3471 if (WARN_ON_ONCE(!frag_no && !more_frags)) in ath11k_dp_rx_frag_h_mpdu() 3491 if (rx_tid->rx_frag_bitmap & BIT(frag_no)) { in ath11k_dp_rx_frag_h_mpdu() 3497 if (frag_no > __fls(rx_tid->rx_frag_bitmap)) in ath11k_dp_rx_frag_h_mpdu() 3502 rx_tid->rx_frag_bitmap |= BIT(frag_no); in ath11k_dp_rx_frag_h_mpdu() 3504 rx_tid->last_frag_no = frag_no; in ath11k_dp_rx_frag_h_mpdu() 3506 if (frag_no == 0) { in ath11k_dp_rx_frag_h_mpdu()
|
/dports/net/wireshark/wireshark-3.6.1/epan/dissectors/ |
H A D | packet-tipc.c | 862 guint32 frag_no, frag_msg_no; in dissect_tipc_v2_internal_msg() local 1443 frag_no = (dword >> 16) & 0x0000ffff; in dissect_tipc_v2_internal_msg() 1501 (frag_no-1), /* number of the fragment */ in dissect_tipc_v2_internal_msg() 1514 " (Message fragment %u)", frag_no); in dissect_tipc_v2_internal_msg()
|
/dports/net/wireshark-lite/wireshark-3.6.1/epan/dissectors/ |
H A D | packet-tipc.c | 862 guint32 frag_no, frag_msg_no; in dissect_tipc_v2_internal_msg() local 1443 frag_no = (dword >> 16) & 0x0000ffff; in dissect_tipc_v2_internal_msg() 1501 (frag_no-1), /* number of the fragment */ in dissect_tipc_v2_internal_msg() 1514 " (Message fragment %u)", frag_no); in dissect_tipc_v2_internal_msg()
|