old_contents: 
  from traffic import rootwrap
  from traffic import utils
  from traffic import db
  from traffic.db import base
  import os
  
  class API(base.Base):
      
      def set_execute(self, execute):        
          self._execute = execute
          
      def create(self, context, ip, class_id, prio=1):
          ips = ip + '/32'
          cmd = ['tc filter add dev eth0 parent 10: protocol ip prio ', prio ,' u32 match ip src ', ips, ' flowid ', class_id]
          cmd = map(str, cmd)
          #self._execute(cmd)
          
          handle = self.db.tfilter_get_last_handle(context)
          if not handle:
              handle = 799
          else:
              handle = handle[0]
          self.db.tfilter_create(context, 
                                 {'ip': ip, 
                                  'classid': class_id,
                                  'flowid': class_id, 
                                  'handle': handle+1, 
                                  'prio': prio})
          os.system(''.join(cmd))
          
      def delete(self, context, handle, prio ):       
          handle_r = '800::' + handle
          cmd = ['tc filter del dev eth0 parent 10: prio', prio, 'handle', handle_r]
          self._execute(cmd)
          self.db.tfilter_delete_by_handle(context, handle)
      
      def get(self, context, class_id):
          result = self.db.tfilter_get_by_classid(context, class_id)
          return result
new_contents: 
  from traffic import rootwrap
  from traffic import utils
  from traffic import db
  from traffic.db import base
  import os
  
  class API(base.Base):
      
      def set_execute(self, execute):        
          self._execute = execute
          
      def create(self, context, ip, class_id, prio=1):
          ips = ip + '/32'
          cmd = ['tc filter add dev br100 parent 10: protocol ip prio ', prio ,' u32 match ip src ', ips, ' flowid ', class_id]
          cmd = map(str, cmd)
          #self._execute(cmd)
          
          handle = self.db.tfilter_get_last_handle(context)
          if not handle:
              handle = 799
          else:
              handle = handle[0]
          self.db.tfilter_create(context, 
                                 {'ip': ip, 
                                  'classid': class_id,
                                  'flowid': class_id, 
                                  'handle': handle+1, 
                                  'prio': prio})
          os.system(''.join(cmd))
          
      def delete(self, context, handle, prio ):       
          handle_r = '800::' + handle
          cmd = ['tc filter del dev eth0 parent 10: prio', prio, 'handle', handle_r]
          self._execute(cmd)
          self.db.tfilter_delete_by_handle(context, handle)
      
      def get(self, context, class_id):
          result = self.db.tfilter_get_by_classid(context, class_id)
          return result
subject: change br10