parameters: (self, channel_id)
docstring: Called by the writer thread when a write operation has done.
  
          Args:
              channel_id: objective channel id.
docstring_summary: Called by the writer thread when a write operation has done.
docstring_tokens: Called by the writer thread when a write operation has done .
function: def notify_write_data_done(self, channel_id):
          """Called by the writer thread when a write operation has done.
  
          Args:
              channel_id: objective channel id.
          """
  
          try:
              self._logical_channels_condition.acquire()
              if channel_id in self._logical_channels:
                  channel_data = self._logical_channels[channel_id]
                  channel_data.request.connection.on_write_data_done()
              else:
                  self._logger.debug('Seems that logical channel for %d has gone'
                                     % channel_id)
          finally:
              self._logical_channels_condition.release()
function_tokens: def notify_write_data_done ( self , channel_id ) : try : self . _logical_channels_condition . acquire ( ) if channel_id in self . _logical_channels : channel_data = self . _logical_channels [ channel_id ] channel_data . request . connection . on_write_data_done ( ) else : self . _logger . debug ( 'Seems that logical channel for %d has gone' % channel_id ) finally : self . _logical_channels_condition . release ( )