Inheritance diagram for com.mapd.logrunner.LogRunner.myThread:

Collaboration diagram for com.mapd.logrunner.LogRunner.myThread:

Public Member Functions
void	run ()

Package Functions
	myThread (String str1, Heavy.Client client1, String session1)

Private Attributes
String	str

Heavy.Client	client

String	session

Detailed Description

Definition at line 238 of file LogRunner.java.

Constructor & Destructor Documentation

com.mapd.logrunner.LogRunner.myThread.myThread	(	String	str1,
		Heavy.Client	client1,
		String	session1
	)

inlinepackage

Definition at line 243 of file LogRunner.java.

References com.mapd.logrunner.LogRunner.myThread.client, com.mapd.logrunner.LogRunner.myThread.session, and com.mapd.logrunner.LogRunner.myThread.str.

                                                                  {
       str = str1;
       client = client1;
       session = session1;
     }

Member Function Documentation

void com.mapd.logrunner.LogRunner.myThread.run ( )

inline

Definition at line 250 of file LogRunner.java.

References com.mapd.logrunner.LogRunner.cpuMode, com.mapd.logrunner.LogRunner.gpuMode, report.header, Integer, setup.name, and com.mapd.logrunner.LogRunner.myThread.session.

                       {
       int logStart = str.indexOf(']');
       if (logStart != -1) {
         String det = str.substring(logStart + 1).trim();
         String header = str.substring(0, logStart).trim();
 
         String[] headDet = header.split(" .");
         // logger.info("header "+ header + " count " + headDet.length + " detail " + det
         // );
         if (headDet.length != 4 || headDet[0].equals("Log")) {
           return;
         }
         Integer pid = Integer.valueOf(headDet[2]);
 
         if (det.contains("sql_execute :")) {
           logger.info("det " + det);
           String sl[] = det.split(":query_str:");
           logger.info("run query " + sl[1]);
           try {
             client.sql_execute(session, sl[1], true, null, -1, -1);
           } catch (TDBException ex1) {
             logger.error(
                     "Failed to execute " + sl[1] + " exception " + ex1.getError_msg());
           } catch (TException ex) {
             logger.error("Failed to execute " + sl[1] + " exception " + ex.toString());
           }
           return;
         }
 
         // get_result_row_for_pixel
         // :5pFFQUCKs17GLHOqI7ykK09U8mX7GnLF:widget_id:3:pixel.x:396:pixel.y:53:column_format:1
         // :PixelRadius:2:table_col_names::points,dest,conv_4326_900913_x(dest_lon) as
         // x,conv_4326_900913_y(dest_lat) as y,arrdelay as size
         if (det.contains("get_result_row_for_pixel :")) {
           logger.info("det " + det);
           String ss[] = det.split(":");
           String sl[] = det.split(":table_col_names:");
           logger.info("run get_result_for_pixel " + sl[1]);
           Map<String, List<String>> tcn = new HashMap<String, List<String>>();
 
           String tn[] = sl[1].split(":");
           for (int i = 0; i < tn.length; i++) {
             String name[] = tn[i].split(",");
             List<String> col = new ArrayList<String>();
             for (int j = 1; j < name.length; j++) {
               col.add(name[j]);
             }
             tcn.put(name[0], col);
           }
           try {
             client.get_result_row_for_pixel(session,
                     Integer.parseInt(ss[3]),
                     new TPixel(Integer.parseInt(ss[5]), Integer.parseInt(ss[7])),
                     tcn,
                     Boolean.TRUE,
                     Integer.parseInt(ss[11]),
                     null);
           } catch (TDBException ex1) {
             logger.error("Failed to execute get_result_row_for_pixel exception "
                     + ex1.getError_msg());
           } catch (TException ex) {
             logger.error("Failed to execute get_result_row_for_pixel exception "
                     + ex.toString());
           }
           return;
         }
 
         if (det.contains("render_vega :")) {
           logger.info("det " + det);
           String ss[] = det.split(":");
           String sl[] = det.split(":vega_json:");
           json.put(pid, det.substring(det.indexOf("render_vega :") + 13, det.length()));
           logger.info("JSON = " + sl[1]);
           logger.info("widget = " + Integer.parseInt(ss[3]));
           logger.info("compressionLevel = " + Integer.parseInt(ss[5]));
           logger.info("run render_vega");
           if (cpuMode) {
             logger.info("In render: setting gpu mode as we were in CPU mode");
             gpuMode = true;
             cpuMode = false;
             try {
               client.set_execution_mode(session, TExecuteMode.GPU);
             } catch (TException ex) {
               logger.error("Failed to set_execution_mode exception " + ex.toString());
             }
           }
           try {
             TRenderResult fred = client.render_vega(session,
                     Integer.parseInt(ss[3]),
                     sl[1],
                     Integer.parseInt(ss[5]),
                     null);
             if (false) {
               try {
                 FileOutputStream fos;
 
                 fos = new FileOutputStream("/tmp/png.png");
 
                 fred.image.position(0);
                 byte[] tgxImageDataByte = new byte[fred.image.limit()];
                 fred.image.get(tgxImageDataByte);
                 fos.write(tgxImageDataByte);
                 fos.close();
               } catch (FileNotFoundException ex) {
                 logger.error("Failed to create file exception " + ex.toString());
               } catch (IOException ex) {
                 logger.error("Failed to create file exception " + ex.toString());
               }
             }
 
           } catch (TException ex) {
             logger.error("Failed to execute render_vega exception " + ex.toString());
           }
           return;
         }
 
         if (det.contains("User mapd sets CPU mode")) {
           logger.info("Set cpu mode");
           cpuMode = true;
           gpuMode = false;
           try {
             client.set_execution_mode(session, TExecuteMode.CPU);
           } catch (TException ex) {
             logger.error("Failed to set_execution_mode exception " + ex.toString());
           }
           return;
         }
 
         if (det.contains("User mapd sets GPU mode")) {
           logger.info("Set gpu mode");
           gpuMode = true;
           cpuMode = false;
           try {
             client.set_execution_mode(session, TExecuteMode.GPU);
           } catch (TException ex) {
             logger.error(
                     "Failed to execute set_execution_mode exception " + ex.toString());
           }
           return;
         }
       }
     }

Member Data Documentation

Heavy.Client com.mapd.logrunner.LogRunner.myThread.client

private

Definition at line 240 of file LogRunner.java.

Referenced by com.mapd.logrunner.LogRunner.myThread.myThread().

String com.mapd.logrunner.LogRunner.myThread.session

private

Definition at line 241 of file LogRunner.java.

String com.mapd.logrunner.LogRunner.myThread.str

private

Definition at line 239 of file LogRunner.java.

Referenced by com.mapd.logrunner.LogRunner.myThread.myThread().

The documentation for this class was generated from the following file:

/home/jenkins-slave/workspace/core-os-doxygen/java/utility/src/main/java/com/mapd/logrunner/LogRunner.java

Public Member Functions

Package Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation