| 2764 | } |
| 2765 | |
| 2766 | void* thread4(void* pParam) |
| 2767 | { |
| 2768 | ErasureCodeShec* shec = (ErasureCodeShec*) pParam; |
| 2769 | |
| 2770 | bufferlist in; |
| 2771 | in.append("ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789"//length = 62 |
| 2772 | "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789"//124 |
| 2773 | "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789"//186 |
| 2774 | "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789"//248 |
| 2775 | ); |
| 2776 | set<int> want_to_encode; |
| 2777 | for (unsigned int i = 0; i < shec->get_chunk_count(); ++i) { |
| 2778 | want_to_encode.insert(i); |
| 2779 | } |
| 2780 | |
| 2781 | map<int, bufferlist> encoded; |
| 2782 | |
| 2783 | printf("*** thread loop start ***\n"); |
| 2784 | g_flag = 1; |
| 2785 | while (g_flag == 1) { |
| 2786 | shec->encode(want_to_encode, in, &encoded); |
| 2787 | encoded.clear(); |
| 2788 | } |
| 2789 | printf("*** thread loop end ***\n"); |
| 2790 | |
| 2791 | return NULL; |
| 2792 | } |
| 2793 | |
| 2794 | void* thread5(void* pParam) |
| 2795 | { |
nothing calls this directly
no test coverage detected