void function ( ) { CurrentInprogress loc0 = new CurrentInprogress ( zkc , CURRENT_NODE_PATH ) ; loc0 . init ( ) ; loc0 . update ( "srini_string" ) ; assertEquals ( "srini_string" , "srini_string" , loc0 . read ( ) ) ; loc0 . update ( "srini_string" ) ; loc0 . update ( "srini_string" ) ; }
tests that update should throw ioe , if version number modifies between read and update concode_field_sep int CONNECTION_TIMEOUT concode_elem_sep int ZooKeeperDefaultPort concode_elem_sep File zkTmpDir concode_elem_sep ZooKeeperServer zks concode_elem_sep ZooKeeper zkc concode_elem_sep Log LOG concode_elem_sep NIOServerCnxnFactory serverFactory concode_elem_sep String CURRENT_NODE_PATH concode_elem_sep String HOSTPORT concode_field_sep ZooKeeper connectZooKeeper concode_elem_sep void testReadShouldReturnNullAfterClear concode_elem_sep void shutDownServer concode_elem_sep void setupZooKeeper concode_elem_sep void setup concode_elem_sep void teardown concode_elem_sep void testReadShouldReturnTheZnodePathAfterUpdate