mirrors/fort
1
0
Fork 0
mirror of https://github.com/tnodir/fort synced 2024-11-15 10:35:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Driver: Optimize flows storage size.

Browse Source
This commit is contained in:
Nodir Temirkhodjaev 2017-12-08 15:40:34 +05:00
parent 45bdd1b72b
commit 9f2d356376
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/driver/fortstat.c
View File

@ -4,7 +4,6 @@
#define FORT_PROC_BAD_INDEX ((UINT16) -1) #define FORT_PROC_BAD_INDEX ((UINT16) -1)
#define FORT_FLOW_BAD_INDEX ((UINT32) -1) #define FORT_FLOW_BAD_INDEX ((UINT32) -1)
#define FORT_FLOW_BUSY_INDEX ((UINT32) -2)
typedef struct fort_stat_traf { typedef struct fort_stat_traf {
UINT32 in_bytes; UINT32 in_bytes;
@ -24,10 +23,12 @@ typedef struct fort_stat_proc {
} FORT_STAT_PROC, *PFORT_STAT_PROC; } FORT_STAT_PROC, *PFORT_STAT_PROC;
typedef struct fort_stat_flow { typedef struct fort_stat_flow {
UINT32 next_index;
union { union {
LARGE_INTEGER l; struct {
UINT32 next_index;
UINT32 is_free;
};
UINT64 flow_id; UINT64 flow_id;
}; };
} FORT_STAT_FLOW, *PFORT_STAT_FLOW; } FORT_STAT_FLOW, *PFORT_STAT_FLOW;
@ -218,6 +219,8 @@ fort_stat_flow_free (PFORT_STAT stat, UINT32 flow_index)
PFORT_STAT_FLOW flow = &stat->flows[flow_index]; PFORT_STAT_FLOW flow = &stat->flows[flow_index];
/* Add to free chain */ /* Add to free chain */
flow->is_free = FORT_FLOW_BAD_INDEX;
flow->next_index = stat->flow_free_index; flow->next_index = stat->flow_free_index;
stat->flow_free_index = flow_index; stat->flow_free_index = flow_index;
} }
@ -269,7 +272,6 @@ fort_stat_flow_add (PFORT_STAT stat, UINT64 flow_id)
flow = &stat->flows[flow_index]; flow = &stat->flows[flow_index];
} }
flow->next_index = FORT_FLOW_BUSY_INDEX;
flow->flow_id = flow_id; flow->flow_id = flow_id;
stat->flow_count++; stat->flow_count++;
@ -299,7 +301,7 @@ fort_stat_flow_remove_contexts (PFORT_STAT stat, UINT32 callout_id)
UINT32 count = stat->flow_count; UINT32 count = stat->flow_count;
for (; count != 0; ++flow) { for (; count != 0; ++flow) {
if (flow->next_index == FORT_FLOW_BUSY_INDEX) if (flow->is_free == FORT_FLOW_BAD_INDEX)
continue; continue;
fort_stat_flow_remove_context(flow->flow_id, callout_id); fort_stat_flow_remove_context(flow->flow_id, callout_id);
@ -315,6 +317,9 @@ fort_stat_init_indexes (PFORT_STAT stat)
stat->proc_free_index = FORT_PROC_BAD_INDEX; stat->proc_free_index = FORT_PROC_BAD_INDEX;
stat->flow_free_index = FORT_FLOW_BAD_INDEX; stat->flow_free_index = FORT_FLOW_BAD_INDEX;
while (!++stat->version)
continue; /* version must not be zero to avoid zero flow-context */
} }
static void static void
@ -335,8 +340,6 @@ fort_stat_close (PFORT_STAT stat, UINT32 callout_id)
stat->closing = TRUE; stat->closing = TRUE;
stat->is_dirty = FALSE; stat->is_dirty = FALSE;
stat->version++;
if (stat->procs != NULL) { if (stat->procs != NULL) {
fort_stat_array_del(stat->procs); fort_stat_array_del(stat->procs);
stat->procs = NULL; stat->procs = NULL;