favour microseconds in "time eq. XX" event queries

diff --git a/org.glite.lb.server/src/query.c b/org.glite.lb.server/src/query.c
index 196c9be..2377719 100644 (file)
--- a/org.glite.lb.server/src/query.c
+++ b/org.glite.lb.server/src/query.c
@@ -613,6 +613,10 @@ static char *ec_to_head_where(edg_wll_Context ctx,const edg_wll_QueryRec **ec)
                                        trio_asprintf(&out, "%s OR (e.time_stamp >= %s AND e.time_stamp <= %s)", conds, aux, dbt);
                                        free(aux);
                                }
+                               else if (ec[m][n].op == EDG_WLL_QUERY_OP_EQUAL) {
+                                       trio_asprintf(&out, "%s OR (e.time_stamp = %s AND e.usec = %d)",
+                                                       conds, dbt, ec[m][n].value.t.tv_usec);
+                               }
                                else
                                        trio_asprintf(&out, "%s OR e.time_stamp %s %s", conds, opToString(ec[m][n].op), dbt);
                                free(conds);
@@ -625,6 +629,10 @@ static char *ec_to_head_where(edg_wll_Context ctx,const edg_wll_QueryRec **ec)
                                trio_asprintf(&conds, "(e.time_stamp >= %s AND e.time_stamp <= %s)", aux, dbt);
                                free(aux);
                        }
+                       else if (ec[m][n].op == EDG_WLL_QUERY_OP_EQUAL) {
+                               trio_asprintf(&out, "(e.time_stamp = %s AND e.usec = %d)",
+                                               dbt, ec[m][n].value.t.tv_usec);
+                       }
                        else
                                trio_asprintf(&conds, "e.time_stamp %s %s", opToString(ec[m][n].op), dbt);
                        break;