Skip to content

targets/spiperf add Server FSM #196

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
dmortondev wants to merge 3 commits into
base: master
Choose a base branch
from
Open

targets/spiperf add Server FSM #196

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
e582517
targets/spiperf: move FSM constant to a different file
dmortondev Mar 4, 2020
9c4ee5c
targets/spiperf: minor change to client FSM
dmortondev Mar 11, 2020
52ad047
targets/spiperf: add Server FSM
dmortondev Mar 11, 2020
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
10 changes: 4 additions & 6 deletions targets/spiperf/fsm/client.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,6 @@ import (
"github.com/go-openapi/strfmt/conv"
)

const TimeFormatString = time.RFC3339Nano

// Client FSM that handles client mode.
type Client struct {
// PeerCmdOut sends commands to the peer's Server FSM.
Expand Down Expand Up @@ -293,7 +291,7 @@ Done:

case msg.PeerDisconnectLocalType, msg.PeerDisconnectRemoteType:
// Return an error here. Peer should not have disconnected.
err := processUnexpectedPeerDisconnect(notif)
err := c.processUnexpectedPeerDisconnect(notif)
return (*Client).cleanup, err

default:
Expand Down Expand Up @@ -408,7 +406,7 @@ Done:

case msg.PeerDisconnectLocalType, msg.PeerDisconnectRemoteType:
// Return an error here. Peer should not have disconnected.
err := processUnexpectedPeerDisconnect(notif)
err := c.processUnexpectedPeerDisconnect(notif)
return (*Client).cleanup, err

default:
Expand Down Expand Up @@ -616,7 +614,7 @@ func (c *Client) waitForPeerResponse(expectedType string) (*msg.Message, error)

switch notif.Type {
case msg.PeerDisconnectLocalType, msg.PeerDisconnectRemoteType:
return nil, processUnexpectedPeerDisconnect(notif)
return nil, c.processUnexpectedPeerDisconnect(notif)

case msg.StatsNotificationType:
// Sometimes upstream-only tests can have an in-flight stats notification from
Expand Down Expand Up @@ -666,7 +664,7 @@ func (c *Client) handleStatsNotification(notif *msg.Message) error {
return nil
}

func processUnexpectedPeerDisconnect(notif *msg.Message) error {
func (c *Client) processUnexpectedPeerDisconnect(notif *msg.Message) error {

switch notif.Type {
case msg.PeerDisconnectLocalType:
Expand Down
5 changes: 5 additions & 0 deletions targets/spiperf/fsm/const.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,4 +8,9 @@ const (
DefaultStartDelay = 3 * time.Second
DefaultStatsPollInterval = 1 * time.Second
DefaultGeneratorPollInterval = 1 * time.Second
TimeFormatString = time.RFC3339Nano

// MaximumStartTimeDelta maximum time in the future to start traffic.
// This value is somewhat arbitrary.
MaximumStartTimeDelta = 3 * time.Minute
)
Loading