Iterator it = fpn.hspp.iterator();
output.println("/* prefetch */");
output.println("; /* empty statement to avoid compiler error */");
+
/* TODO Add support for arrays, Currently handles only field pointers*/
/* The while loop below removes all prefetch tuples with arrays from the set of prefetches */
+ /*
while(it.hasNext()) {
PrefetchPair pp = (PrefetchPair) it.next();
for(i = 0; i < pp.desc.size(); i++) {
}
}
}
- it = fpn.hspp.iterator();
+ */
+ //it = fpn.hspp.iterator();
String oidlist = new String();
while(it.hasNext()) {
PrefetchPair pp = (PrefetchPair) it.next();
int sd;
struct sockaddr_in remoteAddr;
int bytesSent;
- int status, size, retry = 0;
-
+ int status, size;
+
int i = 0;
while(i < numoid) {
oid = *(oidarry + i);
char treplyctrl = 0, treplyretry = 0; /* keeps track of the common response that needs to be sent */
char localstat = 0;
+
/* Look through all the objects in the transaction record and make piles
* for each machine involved in the transaction*/
pile_ptr = pile = createPiles(record);
/* Open connection */
if (connect(sd, (struct sockaddr *) &serv_addr, sizeof(struct sockaddr)) < 0) {
- perror("Error in connect\n");
+ perror("getRemoteObj() Error in connect\n");
return NULL;
}
char readrequest[sizeof(char)+sizeof(unsigned int)];
transrecord_t *trans;
objheader_t *ptr;
/* Add transaction to check if thread finished for join operation */
+ goto transstart;
transstart:
trans = transStart();
ptr = transRead(trans, (unsigned int) VAR(___this___));