/shark/trunk/tracer/newtrace/FTrace.c |
---|
455,6 → 455,7 |
} |
FT_temp->flags |= FTRACE_CHUNK_FLAG_BUSY; |
FTrace_OSD_update_chunk_flags(FT_temp); |
FTrace_unlock(); |
498,6 → 499,7 |
/* Set the new chunk flags and update the main table */ |
New_chunk->flags = new_flags; |
New_chunk->flags |= FTRACE_CHUNK_FLAG_COMPR; |
FTrace_OSD_update_chunk_flags(New_chunk); |
ChunkTable[number] = New_chunk; |
FTrace_unlock(); |
531,6 → 533,7 |
} |
FT_temp->flags |= FTRACE_CHUNK_FLAG_BUSY; |
FTrace_OSD_update_chunk_flags(FT_temp); |
FTrace_unlock(); |
546,6 → 549,7 |
/* Set the new chunk flags */ |
FT_temp->flags = new_flags; |
FTrace_OSD_update_chunk_flags(FT_temp); |
FTrace_unlock(); |
/shark/trunk/tracer/newtrace/FTrace_OSD.c |
---|
112,8 → 112,12 |
int FTrace_OSD_send_chunk(FTrace_Chunk_Ptr c, int osd_flag) |
{ |
extern volatile int sending_flag; |
FTrace_OSD_create_udp_task(c); |
while(sending_flag); |
return 0; |
} |
/shark/trunk/tracer/newtrace/FTrace_udp.c |
---|
63,6 → 63,8 |
PID udp_task; |
int sending_flag = 0; |
struct FTrace_udp_header { |
char id[12]; |
unsigned int pkt_number; |
192,6 → 194,8 |
// Flush the buffer out |
send_udp_event(NULL, 0); |
sending_flag = 0; |
#ifdef TRACER_UDP_DEBUG |
cprintf("Total Chunk Event Sent: %d\n",(int)count); |
#endif |
205,6 → 209,8 |
NRT_TASK_MODEL st; |
sending_flag = 1; |
nrt_task_default_model(st); |
nrt_task_def_arg(st,(void *)c); |