dali/bacnet_stack
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added better packet size limiting. Added file and stdout flushing.

Browse Source
This commit is contained in:
skarg
2009-02-15 15:07:41 +00:00
parent 0573afd406
commit c9d5807431
1 changed files with 7 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bacnet-stack/demo/mstpcap/main.c
+7 -12
View File
@@ -151,13 +151,8 @@ void Sleep(unsigned long milliseconds)
void *milliseconds_task( void *milliseconds_task(
void *pArg) void *pArg)
{ {
struct timespec timeOut, remains;
timeOut.tv_sec = 0;
timeOut.tv_nsec = 10000000; /* 1 milliseconds */
for (;;) { for (;;) {
nanosleep(&timeOut, &remains); Sleep(1);
dlmstp_millisecond_timer(); dlmstp_millisecond_timer();
} }
@@ -289,10 +284,7 @@ static void milliseconds_task_win32(
{ {
(void) SetThreadPriority(GetCurrentThread(), (void) SetThreadPriority(GetCurrentThread(),
THREAD_PRIORITY_TIME_CRITICAL); THREAD_PRIORITY_TIME_CRITICAL);
for (;;) { milliseconds_task(pArg);
Sleep(1);
dlmstp_millisecond_timer();
}
} }
#endif #endif
@@ -325,7 +317,7 @@ uint16_t MSTP_Get_Reply(
return 0; return 0;
} }
static char Capture_Filename[32] = "mstp-20090123-091200.cap"; static char Capture_Filename[32] = "mstp-20090123091200.cap";
static FILE *pFile = NULL; /* stream pointer */ static FILE *pFile = NULL; /* stream pointer */
static void filename_create(char *filename) static void filename_create(char *filename)
@@ -394,7 +386,8 @@ static void write_received_packet(
fwrite(&ts_sec, sizeof(ts_sec), 1, pFile); fwrite(&ts_sec, sizeof(ts_sec), 1, pFile);
fwrite(&ts_usec, sizeof(ts_usec), 1, pFile); fwrite(&ts_usec, sizeof(ts_usec), 1, pFile);
if (packet_info->DataLength) { if (packet_info->DataLength) {
max_data = packet_info->DataLength; max_data = min(sizeof(packet_info->InputBuffer),
packet_info->DataLength);
incl_len = orig_len = 8 + max_data + 2; incl_len = orig_len = 8 + max_data + 2;
} else { } else {
incl_len = orig_len = 8; incl_len = orig_len = 8;
@@ -415,6 +408,7 @@ static void write_received_packet(
fwrite((char *) &packet_info->DataCRCActualMSB, 1, 1, pFile); fwrite((char *) &packet_info->DataCRCActualMSB, 1, 1, pFile);
fwrite((char *) &packet_info->DataCRCActualLSB, 1, 1, pFile); fwrite((char *) &packet_info->DataCRCActualLSB, 1, 1, pFile);
} }
fflush(pFile); /* stream pointer */
} else { } else {
fprintf(stderr, "mstpcap: failed to open %s: %s\n", Capture_Filename, fprintf(stderr, "mstpcap: failed to open %s: %s\n", Capture_Filename,
strerror(errno)); strerror(errno));
@@ -523,6 +517,7 @@ int main(
packet_count++; packet_count++;
if (!(packet_count % 100)) { if (!(packet_count % 100)) {
fprintf(stdout, "\r%hu packets", packet_count); fprintf(stdout, "\r%hu packets", packet_count);
fflush(stdout);
} }
if (packet_count >= 65535) { if (packet_count >= 65535) {
filename_create_new(); filename_create_new();