Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
L
linux
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
nexedi
linux
Commits
94093659
Commit
94093659
authored
Nov 08, 2003
by
Herbert Xu
Committed by
David S. Miller
Nov 08, 2003
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
[NET]: Use cpumask_t for cpumap in flow cache.
parent
7c411484
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
8 additions
and
7 deletions
+8
-7
net/core/flow.c
net/core/flow.c
+8
-7
No files found.
net/core/flow.c
View file @
94093659
...
@@ -19,6 +19,7 @@
...
@@ -19,6 +19,7 @@
#include <linux/bitops.h>
#include <linux/bitops.h>
#include <linux/notifier.h>
#include <linux/notifier.h>
#include <linux/cpu.h>
#include <linux/cpu.h>
#include <linux/cpumask.h>
#include <net/flow.h>
#include <net/flow.h>
#include <asm/atomic.h>
#include <asm/atomic.h>
#include <asm/semaphore.h>
#include <asm/semaphore.h>
...
@@ -65,7 +66,7 @@ static struct timer_list flow_hash_rnd_timer;
...
@@ -65,7 +66,7 @@ static struct timer_list flow_hash_rnd_timer;
struct
flow_flush_info
{
struct
flow_flush_info
{
atomic_t
cpuleft
;
atomic_t
cpuleft
;
unsigned
long
cpumap
;
cpumask_t
cpumap
;
struct
completion
completion
;
struct
completion
completion
;
};
};
static
DEFINE_PER_CPU
(
struct
tasklet_struct
,
flow_flush_tasklets
)
=
{
NULL
};
static
DEFINE_PER_CPU
(
struct
tasklet_struct
,
flow_flush_tasklets
)
=
{
NULL
};
...
@@ -73,7 +74,7 @@ static DEFINE_PER_CPU(struct tasklet_struct, flow_flush_tasklets) = { NULL };
...
@@ -73,7 +74,7 @@ static DEFINE_PER_CPU(struct tasklet_struct, flow_flush_tasklets) = { NULL };
#define flow_flush_tasklet(cpu) (&per_cpu(flow_flush_tasklets, cpu))
#define flow_flush_tasklet(cpu) (&per_cpu(flow_flush_tasklets, cpu))
static
DECLARE_MUTEX
(
flow_cache_cpu_sem
);
static
DECLARE_MUTEX
(
flow_cache_cpu_sem
);
static
unsigned
long
flow_cache_cpu_map
;
static
cpumask_t
flow_cache_cpu_map
;
static
unsigned
int
flow_cache_cpu_count
;
static
unsigned
int
flow_cache_cpu_count
;
static
void
flow_cache_new_hashrnd
(
unsigned
long
arg
)
static
void
flow_cache_new_hashrnd
(
unsigned
long
arg
)
...
@@ -81,7 +82,7 @@ static void flow_cache_new_hashrnd(unsigned long arg)
...
@@ -81,7 +82,7 @@ static void flow_cache_new_hashrnd(unsigned long arg)
int
i
;
int
i
;
for
(
i
=
0
;
i
<
NR_CPUS
;
i
++
)
for
(
i
=
0
;
i
<
NR_CPUS
;
i
++
)
if
(
test_bit
(
i
,
&
flow_cache_cpu_map
))
if
(
cpu_isset
(
i
,
flow_cache_cpu_map
))
flow_hash_rnd_recalc
(
i
)
=
1
;
flow_hash_rnd_recalc
(
i
)
=
1
;
flow_hash_rnd_timer
.
expires
=
jiffies
+
FLOW_HASH_RND_PERIOD
;
flow_hash_rnd_timer
.
expires
=
jiffies
+
FLOW_HASH_RND_PERIOD
;
...
@@ -178,7 +179,7 @@ void *flow_cache_lookup(struct flowi *key, u16 family, u8 dir,
...
@@ -178,7 +179,7 @@ void *flow_cache_lookup(struct flowi *key, u16 family, u8 dir,
cpu
=
smp_processor_id
();
cpu
=
smp_processor_id
();
fle
=
NULL
;
fle
=
NULL
;
if
(
!
test_bit
(
cpu
,
&
flow_cache_cpu_map
))
if
(
!
cpu_isset
(
cpu
,
flow_cache_cpu_map
))
goto
nocache
;
goto
nocache
;
if
(
flow_hash_rnd_recalc
(
cpu
))
if
(
flow_hash_rnd_recalc
(
cpu
))
...
@@ -277,7 +278,7 @@ static void flow_cache_flush_per_cpu(void *data)
...
@@ -277,7 +278,7 @@ static void flow_cache_flush_per_cpu(void *data)
struct
tasklet_struct
*
tasklet
;
struct
tasklet_struct
*
tasklet
;
cpu
=
smp_processor_id
();
cpu
=
smp_processor_id
();
if
(
!
test_bit
(
cpu
,
&
info
->
cpumap
))
if
(
!
cpu_isset
(
cpu
,
info
->
cpumap
))
return
;
return
;
tasklet
=
flow_flush_tasklet
(
cpu
);
tasklet
=
flow_flush_tasklet
(
cpu
);
...
@@ -301,7 +302,7 @@ void flow_cache_flush(void)
...
@@ -301,7 +302,7 @@ void flow_cache_flush(void)
local_bh_disable
();
local_bh_disable
();
smp_call_function
(
flow_cache_flush_per_cpu
,
&
info
,
1
,
0
);
smp_call_function
(
flow_cache_flush_per_cpu
,
&
info
,
1
,
0
);
if
(
test_bit
(
smp_processor_id
(),
&
info
.
cpumap
))
if
(
cpu_isset
(
smp_processor_id
(),
info
.
cpumap
))
flow_cache_flush_tasklet
((
unsigned
long
)
&
info
);
flow_cache_flush_tasklet
((
unsigned
long
)
&
info
);
local_bh_enable
();
local_bh_enable
();
...
@@ -341,7 +342,7 @@ static int __devinit flow_cache_cpu_prepare(int cpu)
...
@@ -341,7 +342,7 @@ static int __devinit flow_cache_cpu_prepare(int cpu)
static
int
__devinit
flow_cache_cpu_online
(
int
cpu
)
static
int
__devinit
flow_cache_cpu_online
(
int
cpu
)
{
{
down
(
&
flow_cache_cpu_sem
);
down
(
&
flow_cache_cpu_sem
);
set_bit
(
cpu
,
&
flow_cache_cpu_map
);
cpu_set
(
cpu
,
flow_cache_cpu_map
);
flow_cache_cpu_count
++
;
flow_cache_cpu_count
++
;
up
(
&
flow_cache_cpu_sem
);
up
(
&
flow_cache_cpu_sem
);
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment