(t *testing.T, conn *Conn)
| 778 | } |
| 779 | |
| 780 | func testConnJoinGroupInvalidSessionTimeout(t *testing.T, conn *Conn) { |
| 781 | groupID := makeGroupID() |
| 782 | waitForCoordinator(t, conn, groupID) |
| 783 | |
| 784 | _, err := conn.joinGroup(joinGroupRequest{ |
| 785 | GroupID: groupID, |
| 786 | }) |
| 787 | if !errors.Is(err, InvalidSessionTimeout) && !errors.Is(err, NotCoordinatorForGroup) { |
| 788 | t.Fatalf("expected %v or %v; got %v", InvalidSessionTimeout, NotCoordinatorForGroup, err) |
| 789 | } |
| 790 | } |
| 791 | |
| 792 | func testConnJoinGroupInvalidRefreshTimeout(t *testing.T, conn *Conn) { |
| 793 | groupID := makeGroupID() |
nothing calls this directly
no test coverage detected