Skip to content

Commit

Permalink
Revert unintentional changes
Browse files Browse the repository at this point in the history
  • Loading branch information
dixonjoel committed Feb 28, 2024
1 parent d860e46 commit 658aaf1
Show file tree
Hide file tree
Showing 3 changed files with 15 additions and 26 deletions.
Binary file removed examples/game_of_life/game_of_life.vi
Binary file not shown.
39 changes: 14 additions & 25 deletions examples/game_of_life/measurement.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
measurement_service = nims.MeasurementService(
service_config_path=service_directory / "game_of_life.serviceconfig",
version="1.0.0.0",
ui_file_paths=[service_directory / "game_of_life.vi"],
ui_file_paths=[service_directory / "game_of_life.measui"],
)

Grid = List[List[bool]]
Expand All @@ -29,24 +29,22 @@
@measurement_service.configuration("height", nims.DataType.UInt32, 100)
@measurement_service.configuration("update_interval_msec", nims.DataType.UInt32, 100)
@measurement_service.configuration("max_generations", nims.DataType.Int32, INFINITE_GENERATIONS)
@measurement_service.output("game_of_life", nims.DataType.DoubleXYDataArray1D)
@measurement_service.output("game_of_life", nims.DataType.DoubleXYData)
@measurement_service.output("generation", nims.DataType.UInt32)
def measure(
width: int, height: int, update_interval_msec: int, max_generations: int
) -> Generator[Tuple[List[xydata_pb2.DoubleXYData], int], None, None]:
) -> Generator[Tuple[xydata_pb2.DoubleXYData, int], None, None]:
"""Streaming measurement that returns Conway's Game of Life grid as DoubleXYData."""
cancellation_event = threading.Event()
measurement_service.context.add_cancel_callback(cancellation_event.set)
grid = _initialize_grid_with_seeded_data(width, height)
grid2 = _initialize_grid_with_seeded_data(width, height)
update_interval_sec = update_interval_msec / 1000
generation = 0
while max_generations == INFINITE_GENERATIONS or generation < max_generations:
iteration_start_time = time.monotonic()
generation += 1

xydata = _initialize_xydata_and_frame(width, height, 0, 0)
xydata2 = _initialize_xydata_and_frame(width, height, width, 0)
xydata = _initialize_xydata_and_frame(width, height)
row_index = 0
for row in grid:
col_index = 0
Expand All @@ -56,17 +54,8 @@ def measure(
xydata.y_data.append(col_index)
col_index += 1
row_index += 1
for row in grid2:
col_index = 0
for cell in row:
if cell:
xydata2.x_data.append(row_index)
xydata2.y_data.append(col_index)
col_index += 1
row_index += 1
grid = _update_grid(grid)
grid2 = _update_grid(grid2)
xydata_out = [xydata, xydata2]
xydata_out = xydata
generation += 1
delay = max(0.0, update_interval_sec - (time.monotonic() - iteration_start_time))
yield (xydata_out, generation)
Expand All @@ -77,18 +66,18 @@ def measure(
)


def _initialize_xydata_and_frame(width: int, height: int, xOffset: int, yOffset: int) -> xydata_pb2.DoubleXYData:
def _initialize_xydata_and_frame(width: int, height: int) -> xydata_pb2.DoubleXYData:
xydata = xydata_pb2.DoubleXYData()

# Frame To keep the graph stable
xydata.x_data.append(-1 + xOffset)
xydata.y_data.append(-1 + yOffset)
xydata.x_data.append(-1 + xOffset)
xydata.y_data.append(height + 1 + yOffset)
xydata.x_data.append(width + 1 + xOffset)
xydata.y_data.append(-1 + yOffset)
xydata.x_data.append(width + 1 + xOffset)
xydata.y_data.append(height + 1 + yOffset)
xydata.x_data.append(-1)
xydata.y_data.append(-1)
xydata.x_data.append(-1)
xydata.y_data.append(height + 1)
xydata.x_data.append(width + 1)
xydata.y_data.append(-1)
xydata.x_data.append(width + 1)
xydata.y_data.append(height + 1)
return xydata


Expand Down
2 changes: 1 addition & 1 deletion examples/game_of_life/pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ mypy = ">=1.0"
grpc-stubs = "^1.53"
types-protobuf = "^4.21"
# Uncomment to use prerelease dependencies.
ni-measurementlink-service = {path = "../..", develop = true}
# ni-measurementlink-service = {path = "../..", develop = true}

[tool.mypy]
disallow_untyped_defs = true
Expand Down

0 comments on commit 658aaf1

Please sign in to comment.