bytemark/flexnbd-c
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

bitset: Rename bitset_stream_on/off as bitset_enable/disable_stream

Browse Source
This commit is contained in:
nick
2013-09-23 17:10:14 +01:00
parent 5c1b119f83
commit 78fc65c515
3 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/bitset.h
View File

@@ -289,7 +289,7 @@ static inline uint64_t bitset_stream_queued_bytes(
return total; return total;
} }
static inline void bitset_stream_on( struct bitset * set ) static inline void bitset_enable_stream( struct bitset * set )
{ {
BITSET_LOCK; BITSET_LOCK;
set->stream_enabled = 1; set->stream_enabled = 1;
@@ -297,7 +297,7 @@ static inline void bitset_stream_on( struct bitset * set )
BITSET_UNLOCK; BITSET_UNLOCK;
} }
static inline void bitset_stream_off( struct bitset * set ) static inline void bitset_disable_stream( struct bitset * set )
{ {
BITSET_LOCK; BITSET_LOCK;
bitset_stream_enqueue( set, BITSET_STREAM_OFF, 0, set->size ); bitset_stream_enqueue( set, BITSET_STREAM_OFF, 0, set->size );

4
src/mirror.c
View File

@@ -762,7 +762,7 @@ void mirror_run( struct server *serve )
* should expand the event loop upwards so we can do the same there too */ * should expand the event loop upwards so we can do the same there too */
sock_set_nonblock( m->client, 1 ); sock_set_nonblock( m->client, 1 );
bitset_stream_on( serve->allocation_map ); bitset_enable_stream( serve->allocation_map );
info( "Entering event loop" ); info( "Entering event loop" );
ev_run( ctrl.ev_loop, 0 ); ev_run( ctrl.ev_loop, 0 );
@@ -789,7 +789,7 @@ void mirror_run( struct server *serve )
/* mirror_reset will be called before a retry, so keeping hold of events /* mirror_reset will be called before a retry, so keeping hold of events
* between now and our next mirroring attempt is not useful * between now and our next mirroring attempt is not useful
*/ */
bitset_stream_off( serve->allocation_map ); bitset_disable_stream( serve->allocation_map );
} }
return; return;

26
tests/unit/check_bitset.c
View File

@@ -324,13 +324,13 @@ START_TEST( test_bitset_clear_range_doesnt_push_to_stream )
} }
END_TEST END_TEST
START_TEST(test_bitset_stream_on) START_TEST(test_bitset_enable_stream)
{ {
struct bitset *map = bitset_alloc( 64, 1 ); struct bitset *map = bitset_alloc( 64, 1 );
struct bitset_stream_entry result; struct bitset_stream_entry result;
memset( &result, 0, sizeof( result ) ); memset( &result, 0, sizeof( result ) );
bitset_stream_on( map ); bitset_enable_stream( map );
ck_assert_int_eq( 1, map->stream_enabled ); ck_assert_int_eq( 1, map->stream_enabled );
@@ -344,14 +344,14 @@ START_TEST(test_bitset_stream_on)
} }
END_TEST END_TEST
START_TEST(test_bitset_stream_off) START_TEST(test_bitset_disable_stream)
{ {
struct bitset *map = bitset_alloc( 64, 1 ); struct bitset *map = bitset_alloc( 64, 1 );
struct bitset_stream_entry result; struct bitset_stream_entry result;
memset( &result, 0, sizeof( result ) ); memset( &result, 0, sizeof( result ) );
bitset_stream_on( map ); bitset_enable_stream( map );
bitset_stream_off( map ); bitset_disable_stream( map );
ck_assert_int_eq( 0, map->stream_enabled ); ck_assert_int_eq( 0, map->stream_enabled );
ck_assert_int_eq( 2, bitset_stream_size( map ) ); ck_assert_int_eq( 2, bitset_stream_size( map ) );
@@ -373,7 +373,7 @@ START_TEST(test_bitset_stream_with_set_range)
struct bitset_stream_entry result; struct bitset_stream_entry result;
memset( &result, 0, sizeof( result ) ); memset( &result, 0, sizeof( result ) );
bitset_stream_on( map ); bitset_enable_stream( map );
bitset_set_range( map, 0, 32 ); bitset_set_range( map, 0, 32 );
ck_assert_int_eq( 2, bitset_stream_size( map ) ); ck_assert_int_eq( 2, bitset_stream_size( map ) );
@@ -395,7 +395,7 @@ START_TEST(test_bitset_stream_with_clear_range)
struct bitset_stream_entry result; struct bitset_stream_entry result;
memset( &result, 0, sizeof( result ) ); memset( &result, 0, sizeof( result ) );
bitset_stream_on( map ); bitset_enable_stream( map );
bitset_clear_range( map, 0, 32 ); bitset_clear_range( map, 0, 32 );
ck_assert_int_eq( 2, bitset_stream_size( map ) ); ck_assert_int_eq( 2, bitset_stream_size( map ) );
@@ -413,7 +413,7 @@ END_TEST
START_TEST(test_bitset_stream_size) START_TEST(test_bitset_stream_size)
{ {
struct bitset *map = bitset_alloc( 64, 1 ); struct bitset *map = bitset_alloc( 64, 1 );
bitset_stream_on( map ); bitset_enable_stream( map );
bitset_set_range( map, 0, 32 ); bitset_set_range( map, 0, 32 );
bitset_set_range( map, 16, 32 ); bitset_set_range( map, 16, 32 );
bitset_set_range( map, 7, 16 ); bitset_set_range( map, 7, 16 );
@@ -421,7 +421,7 @@ START_TEST(test_bitset_stream_size)
bitset_clear_range( map, 0, 32 ); bitset_clear_range( map, 0, 32 );
bitset_clear_range( map, 16, 32 ); bitset_clear_range( map, 16, 32 );
bitset_clear_range( map, 48, 16 ); bitset_clear_range( map, 48, 16 );
bitset_stream_off( map ); bitset_disable_stream( map );
ck_assert_int_eq( 8, bitset_stream_size( map ) ); ck_assert_int_eq( 8, bitset_stream_size( map ) );
@@ -432,7 +432,7 @@ END_TEST
START_TEST(test_bitset_stream_queued_bytes) START_TEST(test_bitset_stream_queued_bytes)
{ {
struct bitset *map = bitset_alloc( 64, 1 ); struct bitset *map = bitset_alloc( 64, 1 );
bitset_stream_on( map ); bitset_enable_stream( map );
bitset_set_range( map, 0, 32 ); bitset_set_range( map, 0, 32 );
bitset_set_range( map, 16, 32 ); bitset_set_range( map, 16, 32 );
bitset_set_range( map, 7, 16 ); bitset_set_range( map, 7, 16 );
@@ -441,7 +441,7 @@ START_TEST(test_bitset_stream_queued_bytes)
bitset_clear_range( map, 16, 32 ); bitset_clear_range( map, 16, 32 );
bitset_clear_range( map, 48, 16 ); bitset_clear_range( map, 48, 16 );
bitset_clear_range( map, 0, 2 ); bitset_clear_range( map, 0, 2 );
bitset_stream_off( map ); bitset_disable_stream( map );
ck_assert_int_eq( 64, bitset_stream_queued_bytes( map, BITSET_STREAM_ON ) ); ck_assert_int_eq( 64, bitset_stream_queued_bytes( map, BITSET_STREAM_ON ) );
ck_assert_int_eq( 80, bitset_stream_queued_bytes( map, BITSET_STREAM_SET ) ); ck_assert_int_eq( 80, bitset_stream_queued_bytes( map, BITSET_STREAM_SET ) );
@@ -476,8 +476,8 @@ Suite* bitset_suite(void)
TCase *tc_bitset_stream = tcase_create("bitset_stream"); TCase *tc_bitset_stream = tcase_create("bitset_stream");
tcase_add_test(tc_bitset_stream, test_bitset_stream_on); tcase_add_test(tc_bitset_stream, test_bitset_enable_stream);
tcase_add_test(tc_bitset_stream, test_bitset_stream_off); tcase_add_test(tc_bitset_stream, test_bitset_disable_stream);
tcase_add_test(tc_bitset_stream, test_bitset_stream_with_set_range); tcase_add_test(tc_bitset_stream, test_bitset_stream_with_set_range);
tcase_add_test(tc_bitset_stream, test_bitset_stream_with_clear_range); tcase_add_test(tc_bitset_stream, test_bitset_stream_with_clear_range);
tcase_add_test(tc_bitset_stream, test_bitset_stream_size); tcase_add_test(tc_bitset_stream, test_bitset_stream_size);