source: tbroadcast/HEAD/scripts/generateGantt@ 247

#!/usr/bin/env python

import os
import sys
import time
import string

if __name__ == '__main__':
    file = sys.argv[1]
    f = open (file)
    lines = f.readlines()
    f.close ()
    total = len(lines)
    min   = time.time()
    max   = 0.0
    for line in lines:
        package, start, end = string.split(line)
        #print float(end)-float(start)
        if float(start)< min:
            min = float(start) 
        if float(end)> max:
            max = float(end)

    packages = {}
    for line in lines:
        package, start, end = string.split(line)
        packages[package] = {'start': float(start)-min , 'end':float(end)-min}

    deb = 0.0
    index = 0
    step = 0.01
    i = float(max)-float(min)
    done  = list()
    start = list() 
    while i>0:
      for package in packages:        
            if not package in done:
                if packages[package]['end']>i:
                    index = index + 1
                    packages[package]['index']= index
                    done.append(package)
                    print i,index, package
            if not package in start:
                if packages[package]['start']> i:        
                    index = index - 1                    
                    start.append(package)
                    #print i, 'start', package, packages[package]['start'], packages[package]['end'], packages[package]['end']-packages[package]['start']
      i = i-step

    y = 0
    for package in packages:
        if packages[package]['index'] > y:
            y = packages[package]['index']

    f = open ("gantt.dat", "w+")     
    for index in xrange(total+1):
       for package in packages:
            if packages[package]['index'] == index:
                line = str(packages[package]['index'])+'\t'+str(packages[package]['start'])+'\t'+ str(packages[package]['end'])+'\n'
                f.write  (line)
    f.close  ()    
        
#    f = open ("gantt.dat", "w+")    
#    index = 1
#    for line in lines:
#        package, start, end = string.split(line)
#        f.write  (str(index)+ ' ' + str(float(start)-min)+ ' ' + str(float(end)-min) + '\n')        
#        index = index + 1        
#    f.close  ()
    
    content= '''    
        ops
        opt nsta
        Total = %s
        v/cre y([Total])  r
        v/cre x1([Total]) r
        v/cre x2([Total]) r
        v/read y,x1,x2  gantt.dat

        deb = 0.0
        max    = %s 
        totaly = %s
        set NDVY [Totaly].15
        NULL [deb] [max] 1 [Totaly] 
        SET BORD 1
        SET FAIS 1        
        SET PLCI 2
        SET FACI 3
        *HISTOGRAM/CREATE/2DHISTO 1 'Gannt chart' 0 10000 [max] 0 0 [Total]
        SET BORD 1
        SET FAIS 1        
        SET PLCI 2
        SET FACI 3
        
        DO i= 1,[Total]  
            y2 = y([i])+0.5
            GRAPHICS/PRIMITIVES/BOX x1([i]) x2([i]) y([i]) [y2] 
        ENDDO
        GRAPHICS/HPLOT/ATITLE 'Time(s)' 'Total number of parallel execution' ! 220
        cps
        '''%(str(total), str(float(max)-float(min)), str(y))
    f = open ("gantt.kumac", "w+")
    f.write  (content)
    f.close  ()

    f = open ("exec.kumac", "w+")
    f.write  ("\n\n kumac/"+string.lower(Site)+".kumac")
    f.close  ()

    status, output = commands.getstatusoutput ("paw<exec.kumac")
#    status, output = commands.getstatusoutput (cmd)
#
#            
#    
#    for package in packages:
#        #print packages[package]['start'], packages[package]['end']
#        concurent = list()
#        for pack in packages:            
#            if (packages[package]['start'] < packages[pack]['start'] and packages[pack]['start'] < packages[package]['end'])\
#            or (packages[package]['start'] < packages[pack]['end'] and packages[pack]['end'] < packages[package]['end']):            
#                concurent.append (pack)
#        packages[package]['concurent'] =  concurent
#
#    total = 0
#    for package in packages:
#        if len(packages[package]['concurent'])> total:
#            total = len(packages[package]['concurent'])        
#        if not packages[package].has_key('index'):
#            index = 1
#            for pack in packages[package]['concurent']:            
#                if packages[package]['end']<packages[pack]['end']:
#                    index = index + 1
#            packages[package]['index'] = index
#