Home
last modified time | relevance | path

Searched refs:frag_no (Results 1 – 25 of 36) sorted by relevance

12

/dports/databases/galera/galera-release_25.3.35/gcs/src/
H A Dgcs_defrag.cpp51 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 Dgcs_act_proto.hpp30 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 Dgcs_act_proto.cpp52 (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 Dgcs_defrag.hpp30 ulong frag_no; // number of fragment received member
H A Dgcs_group.hpp173 !(local && 0 == frg->frag_no && in gcs_group_handle_act_msg()
/dports/databases/galera26/galera-release_26.4.10/gcs/src/
H A Dgcs_defrag.cpp51 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 Dgcs_act_proto.hpp35 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 Dgcs_act_proto.cpp50 (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 Dgcs_defrag.hpp30 ulong frag_no; // number of fragment received member
H A Dgcs_group.hpp191 !(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 Dgcs_proto_test.cpp44 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 Dgcs_defrag_test.cpp26 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 Dgcs_group_test.cpp116 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 Dgcs_proto_test.cpp40 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 Dgcs_defrag_test.cpp22 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 Dgcs_group_test.cpp108 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 Dcdhit-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 Datmel.c464 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 Datmel.c464 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 Datmel.c464 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 Ddp_rx.c3449 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 Ddp_rx.c3449 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 Ddp_rx.c3449 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 Dpacket-tipc.c862 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 Dpacket-tipc.c862 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()

12