Write trx info into trx.out file

Author: vadimtk

scripts/parse_trx.py

@@ -0,0 +1,24 @@
+import sys
+
+ins = open( sys.argv[1], "r" )
+array = {}
+if len(sys.argv)>=2:
+	pref=sys.argv[2]
+else:
+	pref=""
+for line in ins:
+	data=line.split()
+	if array.has_key(data[3]):
+		array[data[3]] = array[data[3]]+1
+	else:
+		array[data[3]] = 1
+
+minsec=int(min(array.keys()))
+maxsec=int(max(array.keys()))
+i=minsec
+while i<=maxsec:
+	if array.has_key(str(i)):
+		print pref,i-minsec,array[str(i)]
+	else:
+		print pref,i-minsec,0
+	i=i+1

src/main.c

@@ -35,6 +35,8 @@ char db_user[DB_STRING_MAX];
 char db_password[DB_STRING_MAX];
 char report_file[DB_STRING_MAX]="";
 FILE *freport_file=NULL;
+char trx_file[DB_STRING_MAX]="";
+FILE *ftrx_file=NULL;
 
 int num_ware;
 int num_conn;
@@ -139,7 +141,7 @@ int main( int argc, char *argv[] )
 
   /* Parse args */
 
-    while ( (c = getopt(argc, argv, "h:P:d:u:p:w:c:r:l:i:f:")) != -1) {
+    while ( (c = getopt(argc, argv, "h:P:d:u:p:w:c:r:l:i:f:t:")) != -1) {
         switch (c) {
         case 'h':
             printf ("option h with value '%s'\n", optarg);
@@ -161,6 +163,10 @@ int main( int argc, char *argv[] )
             printf ("option f with value '%s'\n", optarg);
             strncpy(report_file, optarg, DB_STRING_MAX);
             break;
+        case 't':
+            printf ("option t with value '%s'\n", optarg);
+            strncpy(trx_file, optarg, DB_STRING_MAX);
+            break;
         case 'w':
             printf ("option w with value '%s'\n", optarg);
             num_ware = atoi(optarg);
@@ -186,7 +192,7 @@ int main( int argc, char *argv[] )
             port = atoi(optarg);
             break;
         case '?':
-    	    printf("Usage: tpcc_start -h server_host -P port -d database_name -u mysql_user -p mysql_password -w warehouses -c connections -r warmup_time -l running_time -i report_interval -f report_file\n");
+    	    printf("Usage: tpcc_start -h server_host -P port -d database_name -u mysql_user -p mysql_password -w warehouses -c connections -r warmup_time -l running_time -i report_interval -f report_file -t trx_file\n");
             exit(0);
         default:
             printf ("?? getopt returned character code 0%o ??\n", c);
@@ -280,6 +286,10 @@ int main( int argc, char *argv[] )
     freport_file=fopen(report_file,"w+");
   }
 
+  if ( strlen(trx_file) > 0 ) {
+    ftrx_file=fopen(trx_file,"w+");
+  }
+
 
   printf("<Parameters>\n");
   if(is_local==0) {
@@ -455,6 +465,9 @@ int main( int argc, char *argv[] )
   if (freport_file != NULL)
 	  fclose(freport_file);
 
+  if (ftrx_file != NULL)
+	  fclose(ftrx_file);
+
   printf("\n<Raw Results>\n");
   for ( i=0; i<5; i++ ){
     printf("  [%d] sc:%d  lt:%d  rt:%d  fl:%d \n", i, success[i], late[i], retry[i], failure[i]);

src/neword.c

@@ -30,6 +30,8 @@ case 10: strncpy(ol_dist_info, s_dist_10, 25); break; \
 extern MYSQL **ctx;
 extern MYSQL_STMT ***stmt;
 
+extern FILE *ftrx_file;
+
 #define NNULL ((void *)0)
 
 /*
@@ -94,6 +96,9 @@ int neword( int t_num,
 	int            ol_num_seq[MAX_NUM_ITEMS];
 
 	int             proceed = 0;
+ 	struct timespec tbuf1;
+	clock_t clk1;	
+
 
 	MYSQL_STMT*   mysql_stmt;
         MYSQL_BIND    param[9];
@@ -497,6 +502,8 @@ int neword( int t_num,
 
 	/*EXEC_SQL COMMIT WORK;*/
 	if( mysql_commit(ctx[t_num]) ) goto sqlerr;
+	clk1 = clock_gettime(CLOCK_REALTIME, &tbuf1 );
+	fprintf(ftrx_file,"t_num: %d finish: %lu %lu start: %s\n",t_num, tbuf1.tv_sec, tbuf1.tv_nsec,datetime);
 
 	return (1);