Skip to content

added l2port #131

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
axamon wants to merge 1 commit into
base: master
Choose a base branch
from
Open

added l2port #131

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion memproxy.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,7 @@ var (
batchOpts batched.Opts

l2enabled bool
l2port int
l2sock string

locked bool
Expand Down Expand Up @@ -104,6 +105,7 @@ func init() {
flag.Float64Var(&tempBatchOverloadedRatio, "batch-expand-overloaded-ratio", 0, "The ratio of connections whose average size is greater than the max batch size - 1 above which the pool will expand (float). Positive values only between 0 and 1. 0 assumes default.")

flag.BoolVar(&l2enabled, "l2-enabled", false, "Specifies if l2 is enabled")
flag.IntVar(&l2port, "l2-direct-port", 0, "The direct port for L2 cache")
flag.StringVar(&l2sock, "l2-sock", "invalid.sock", "Specifies the unix socket to connect to L2. Only used if --l2-enabled is true.")

flag.BoolVar(&locked, "locked", false, "Add locking to overall operations (above L1/L2 layers)")
Expand Down Expand Up @@ -215,7 +217,9 @@ func main() {

if l2enabled {
// If L2 is enabled, start the batch L1 / L2 orchestrator
l = server.TCPListener(batchPort)
//l = server.TCPListener(batchPort)
l = server.TCPListener(l2port)

o := orcas.L1L2Batch

if locked {
Expand Down