test_class.declarator: refreshBackoffMs = 100
test_class.modifier: private
test_class.original_string: private long refreshBackoffMs = 100;
test_class.type: long
test_class.var_name: refreshBackoffMs
test_class.declarator: metadataExpireMs = 1000
test_class.modifier: private
test_class.original_string: private long metadataExpireMs = 1000;
test_class.type: long
test_class.var_name: metadataExpireMs
test_class.declarator: metadata = new Metadata(refreshBackoffMs, metadataExpireMs)
test_class.modifier: private
test_class.original_string: private Metadata metadata = new Metadata(refreshBackoffMs, metadataExpireMs);
test_class.type: Metadata
test_class.var_name: metadata
test_class.declarator: backgroundError = new AtomicReference<String>()
test_class.modifier: private
test_class.original_string: private AtomicReference<String> backgroundError = new AtomicReference<String>();
test_class.type: AtomicReference<String>
test_class.var_name: backgroundError
test_class.file: clients/src/test/java/org/apache/kafka/clients/MetadataTest.java
test_class.identifier: MetadataTest
test_case.body: @Test
      public void testFailedUpdate() {
          long time = 100;
          metadata.update(Cluster.empty(), time);
  
          assertEquals(100, metadata.timeToNextUpdate(1000));
          metadata.failedUpdate(1100);
  
          assertEquals(100, metadata.timeToNextUpdate(1100));
          assertEquals(100, metadata.lastSuccessfulUpdate());
  
          metadata.needMetadataForAllTopics(true);
          metadata.update(null, time);
          assertEquals(100, metadata.timeToNextUpdate(1000));
      }
test_case.class_method_signature: MetadataTest.testFailedUpdate()
test_case.full_signature: @Test public void testFailedUpdate()
test_case.identifier: testFailedUpdate
test_case.invocations: update empty assertEquals timeToNextUpdate failedUpdate assertEquals timeToNextUpdate assertEquals lastSuccessfulUpdate needMetadataForAllTopics update assertEquals timeToNextUpdate
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testFailedUpdate()
focal_class.declarator: log = LoggerFactory.getLogger(Metadata.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger log = LoggerFactory.getLogger(Metadata.class);
focal_class.type: Logger
focal_class.var_name: log
focal_class.declarator: refreshBackoffMs
focal_class.modifier: private final
focal_class.original_string: private final long refreshBackoffMs;
focal_class.type: long
focal_class.var_name: refreshBackoffMs
focal_class.declarator: metadataExpireMs
focal_class.modifier: private final
focal_class.original_string: private final long metadataExpireMs;
focal_class.type: long
focal_class.var_name: metadataExpireMs
focal_class.declarator: version
focal_class.modifier: private
focal_class.original_string: private int version;
focal_class.type: int
focal_class.var_name: version
focal_class.declarator: lastRefreshMs
focal_class.modifier: private
focal_class.original_string: private long lastRefreshMs;
focal_class.type: long
focal_class.var_name: lastRefreshMs
focal_class.declarator: lastSuccessfulRefreshMs
focal_class.modifier: private
focal_class.original_string: private long lastSuccessfulRefreshMs;
focal_class.type: long
focal_class.var_name: lastSuccessfulRefreshMs
focal_class.declarator: cluster
focal_class.modifier: private
focal_class.original_string: private Cluster cluster;
focal_class.type: Cluster
focal_class.var_name: cluster
focal_class.declarator: needUpdate
focal_class.modifier: private
focal_class.original_string: private boolean needUpdate;
focal_class.type: boolean
focal_class.var_name: needUpdate
focal_class.declarator: topics
focal_class.modifier: private final
focal_class.original_string: private final Set<String> topics;
focal_class.type: Set<String>
focal_class.var_name: topics
focal_class.declarator: listeners
focal_class.modifier: private final
focal_class.original_string: private final List<Listener> listeners;
focal_class.type: List<Listener>
focal_class.var_name: listeners
focal_class.declarator: needMetadataForAllTopics
focal_class.modifier: private
focal_class.original_string: private boolean needMetadataForAllTopics;
focal_class.type: boolean
focal_class.var_name: needMetadataForAllTopics
focal_class.file: clients/src/main/java/org/apache/kafka/clients/Metadata.java
focal_class.identifier: Metadata
focal_class.class_method_signature: Metadata.Metadata()
focal_class.full_signature: public  Metadata()
focal_class.identifier: Metadata
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.signature:  Metadata()
focal_class.class_method_signature: Metadata.Metadata(long refreshBackoffMs, long metadataExpireMs)
focal_class.full_signature: public  Metadata(long refreshBackoffMs, long metadataExpireMs)
focal_class.identifier: Metadata
focal_class.modifiers: public
focal_class.parameters: (long refreshBackoffMs, long metadataExpireMs)
focal_class.signature:  Metadata(long refreshBackoffMs, long metadataExpireMs)
focal_class.class_method_signature: Metadata.fetch()
focal_class.full_signature: public synchronized Cluster fetch()
focal_class.identifier: fetch
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: Cluster
focal_class.signature: Cluster fetch()
focal_class.class_method_signature: Metadata.add(String topic)
focal_class.full_signature: public synchronized void add(String topic)
focal_class.identifier: add
focal_class.modifiers: public synchronized
focal_class.parameters: (String topic)
focal_class.return: void
focal_class.signature: void add(String topic)
focal_class.class_method_signature: Metadata.timeToNextUpdate(long nowMs)
focal_class.full_signature: public synchronized long timeToNextUpdate(long nowMs)
focal_class.identifier: timeToNextUpdate
focal_class.modifiers: public synchronized
focal_class.parameters: (long nowMs)
focal_class.return: long
focal_class.signature: long timeToNextUpdate(long nowMs)
focal_class.class_method_signature: Metadata.requestUpdate()
focal_class.full_signature: public synchronized int requestUpdate()
focal_class.identifier: requestUpdate
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int requestUpdate()
focal_class.class_method_signature: Metadata.updateRequested()
focal_class.full_signature: public synchronized boolean updateRequested()
focal_class.identifier: updateRequested
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean updateRequested()
focal_class.class_method_signature: Metadata.awaitUpdate(final int lastVersion, final long maxWaitMs)
focal_class.full_signature: public synchronized void awaitUpdate(final int lastVersion, final long maxWaitMs)
focal_class.identifier: awaitUpdate
focal_class.modifiers: public synchronized
focal_class.parameters: (final int lastVersion, final long maxWaitMs)
focal_class.return: void
focal_class.signature: void awaitUpdate(final int lastVersion, final long maxWaitMs)
focal_class.class_method_signature: Metadata.setTopics(Collection<String> topics)
focal_class.full_signature: public synchronized void setTopics(Collection<String> topics)
focal_class.identifier: setTopics
focal_class.modifiers: public synchronized
focal_class.parameters: (Collection<String> topics)
focal_class.return: void
focal_class.signature: void setTopics(Collection<String> topics)
focal_class.class_method_signature: Metadata.topics()
focal_class.full_signature: public synchronized Set<String> topics()
focal_class.identifier: topics
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: Set<String>
focal_class.signature: Set<String> topics()
focal_class.class_method_signature: Metadata.containsTopic(String topic)
focal_class.full_signature: public synchronized boolean containsTopic(String topic)
focal_class.identifier: containsTopic
focal_class.modifiers: public synchronized
focal_class.parameters: (String topic)
focal_class.return: boolean
focal_class.signature: boolean containsTopic(String topic)
focal_class.class_method_signature: Metadata.update(Cluster cluster, long now)
focal_class.full_signature: public synchronized void update(Cluster cluster, long now)
focal_class.identifier: update
focal_class.modifiers: public synchronized
focal_class.parameters: (Cluster cluster, long now)
focal_class.return: void
focal_class.signature: void update(Cluster cluster, long now)
focal_class.class_method_signature: Metadata.failedUpdate(long now)
focal_class.full_signature: public synchronized void failedUpdate(long now)
focal_class.identifier: failedUpdate
focal_class.modifiers: public synchronized
focal_class.parameters: (long now)
focal_class.return: void
focal_class.signature: void failedUpdate(long now)
focal_class.class_method_signature: Metadata.version()
focal_class.full_signature: public synchronized int version()
focal_class.identifier: version
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int version()
focal_class.class_method_signature: Metadata.lastSuccessfulUpdate()
focal_class.full_signature: public synchronized long lastSuccessfulUpdate()
focal_class.identifier: lastSuccessfulUpdate
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long lastSuccessfulUpdate()
focal_class.class_method_signature: Metadata.refreshBackoff()
focal_class.full_signature: public long refreshBackoff()
focal_class.identifier: refreshBackoff
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long refreshBackoff()
focal_class.class_method_signature: Metadata.needMetadataForAllTopics(boolean needMetadataForAllTopics)
focal_class.full_signature: public synchronized void needMetadataForAllTopics(boolean needMetadataForAllTopics)
focal_class.identifier: needMetadataForAllTopics
focal_class.modifiers: public synchronized
focal_class.parameters: (boolean needMetadataForAllTopics)
focal_class.return: void
focal_class.signature: void needMetadataForAllTopics(boolean needMetadataForAllTopics)
focal_class.class_method_signature: Metadata.needMetadataForAllTopics()
focal_class.full_signature: public synchronized boolean needMetadataForAllTopics()
focal_class.identifier: needMetadataForAllTopics
focal_class.modifiers: public synchronized
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean needMetadataForAllTopics()
focal_class.class_method_signature: Metadata.addListener(Listener listener)
focal_class.full_signature: public synchronized void addListener(Listener listener)
focal_class.identifier: addListener
focal_class.modifiers: public synchronized
focal_class.parameters: (Listener listener)
focal_class.return: void
focal_class.signature: void addListener(Listener listener)
focal_class.class_method_signature: Metadata.removeListener(Listener listener)
focal_class.full_signature: public synchronized void removeListener(Listener listener)
focal_class.identifier: removeListener
focal_class.modifiers: public synchronized
focal_class.parameters: (Listener listener)
focal_class.return: void
focal_class.signature: void removeListener(Listener listener)
focal_class.class_method_signature: Metadata.getClusterForCurrentTopics(Cluster cluster)
focal_class.full_signature: private Cluster getClusterForCurrentTopics(Cluster cluster)
focal_class.identifier: getClusterForCurrentTopics
focal_class.modifiers: private
focal_class.parameters: (Cluster cluster)
focal_class.return: Cluster
focal_class.signature: Cluster getClusterForCurrentTopics(Cluster cluster)
focal_method.body: public synchronized void failedUpdate(long now) {
          this.lastRefreshMs = now;
      }
focal_method.class_method_signature: Metadata.failedUpdate(long now)
focal_method.full_signature: public synchronized void failedUpdate(long now)
focal_method.identifier: failedUpdate
focal_method.modifiers: public synchronized
focal_method.parameters: (long now)
focal_method.return: void
focal_method.signature: void failedUpdate(long now)