METHOD_0 ( ) { for ( int p = 0 ; p < 2 ; p ++ ) { com . IDENT_0 . IDENT_1 . core . utils . IDENT_2 . delete ( new java . io . File ( STRING_0 ) ) ; final int IDENT_3 = INT_0 ; final long IDENT_4 = INT_1 ; final java . util . List < com . IDENT_0 . IDENT_1 . core . IDENT_5 . IDENT_6 > IDENT_7 = java . util . Arrays . asList ( com . IDENT_0 . IDENT_1 . core . IDENT_5 . IDENT_6 . METHOD_1 ( ) . METHOD_2 ( STRING_1 ) . METHOD_3 ( "1" ) . build ( ) , com . IDENT_0 . IDENT_1 . core . IDENT_5 . IDENT_6 . METHOD_1 ( ) . METHOD_2 ( STRING_1 ) . METHOD_3 ( "2" ) . build ( ) ) ; IDENT_8 . METHOD_4 ( conf , engine , INT_2 , com . IDENT_0 . IDENT_1 . core . storage . IDENT_9 . IDENT_10 , STRING_2 , IDENT_11 , IDENT_12 , metadata , com . IDENT_0 . IDENT_1 . core . storage . IDENT_9 . IDENT_13 ) ; java . util . concurrent . IDENT_14 IDENT_15 = java . util . concurrent . IDENT_16 . METHOD_5 ( 2 , new com . IDENT_0 . IDENT_1 . core . utils . METHOD_6 ( STRING_3 ) ) ; java . util . concurrent . atomic . IDENT_17 IDENT_18 = new java . util . concurrent . atomic . METHOD_7 ( false ) ; for ( int i = 0 ; i < 2 ; i ++ ) { final int IDENT_19 = i ; IDENT_15 . METHOD_8 ( ( ) -> { while ( ! ( IDENT_18 . get ( ) ) ) { try { java . lang . Thread . sleep ( 1 ) ; } catch ( e ) { } } long t = IDENT_4 + ( IDENT_19 * 3 ) ; for ( int j = 0 ; j < IDENT_3 ; j ++ ) { try { long IDENT_20 = t + ( j * 1000 ) ; IDENT_8 . METHOD_9 ( build ( STRING_4 , IDENT_7 , IDENT_20 , j ) , false ) ; } catch ( e ) { com . IDENT_0 . IDENT_1 . core . storage . e . printStackTrace ( ) ; } } } ) ; } IDENT_15 . METHOD_10 ( ) ; IDENT_18 . set ( true ) ; IDENT_15 . METHOD_11 ( 10 , TimeUnit . IDENT_21 ) ; com . IDENT_0 . IDENT_1 . core . storage . IDENT_22 s = IDENT_8 . METHOD_12 ( IDENT_7 , false ) ; java . util . List < com . IDENT_0 . IDENT_1 . core . storage . IDENT_23 > IDENT_24 = s . METHOD_13 ( IDENT_8 , java . util . Arrays . asList ( STRING_4 ) , ( IDENT_4 - 100 ) , ( IDENT_4 + INT_3 ) , null ) . get ( STRING_4 ) ; "<AssertPlaceHolder>" ; IDENT_8 . close ( ) ; } } get ( ) { return com . IDENT_0 . IDENT_1 . core . IDENT_25 . IDENT_26 . IDENT_27 . table ; }
org . junit . Assert . assertEquals ( ( IDENT_3 * 2 ) , IDENT_24 . size ( ) , 10 )