Fix missing callbacks

com.ibm.wala.cast.python.ml.test/source/com/ibm/wala/cast/python/ml/test/TestTensorflowModel.java

@@ -223,6 +223,8 @@ public void testTf2()
     // https://github.com/wala/ML/issues/24 is fixed.
     testTf2("tf2_test_model_call3.py", "SequentialModel.call", 1, 4, 2);
     testTf2("tf2_test_model_call4.py", "SequentialModel.__call__", 1, 4, 2);
+    testTf2("tf2_test_callbacks.py", "get_dataset", 0, 0);
+    testTf2("tf2_test_callbacks2.py", "replica_fn", 0, 2);
   }
 
   private void testTf2(

com.ibm.wala.cast.python.ml/data/tensorflow.xml

@@ -36,6 +36,9 @@
         <new def="estimator" class="Lobject" />
         <putfield class="LRoot" field="estimator" fieldType="LRoot" ref="x" value="estimator" />
 
+        <new def="distribute" class="Lobject" />
+        <putfield class="LRoot" field="distribute" fieldType="LRoot" ref="x" value="distribute" />
+
         <new def="nn" class="Lobject" />
         <putfield class="LRoot" field="nn" fieldType="LRoot" ref="x" value="nn" />
         <new def="random" class="Lobject" />
@@ -58,6 +61,9 @@
         <new def="Estimator" class="Ltensorflow/estimator/Estimator" />
         <putfield class="LRoot" field="Estimator" fieldType="LRoot" ref="estimator" value="Estimator" />
 
+        <new def="MirroredStrategy" class="Ltensorflow/distribute/MirroredStrategy" />
+        <putfield class="LRoot" field="MirroredStrategy" fieldType="LRoot" ref="distribute" value="MirroredStrategy" />
+
         <new def="inputs" class="Lobject" />
         <putfield class="LRoot" field="inputs" fieldType="LRoot" ref="estimator" value="inputs" />
 
@@ -786,6 +792,41 @@
       </class>
     </package>
 
+    <package name="tensorflow/distribute">
+      <class name="MirroredStrategy" allocatable="true">
+        <method name="do" descriptor="()LRoot;" numArgs="2" paramNames="self model">
+          <new def="x" class="Ltensorflow/distribute/distribute_datasets_from_function/distribute_datasets_from_function" />
+          <putfield class="LRoot" field="distribute_datasets_from_function" fieldType="LRoot" ref="self" value="x" />
+          <return value="arg0" />
+          <new def="y" class="Ltensorflow/distribute/run/run" />
+          <putfield class="LRoot" field="run" fieldType="LRoot" ref="self" value="y" />
+          <return value="arg1" />
+        </method>
+      </class>
+    </package>
+
+    <package name="tensorflow/distribute/distribute_datasets_from_function">
+      <class name="distribute_datasets_from_function" allocatable="true">
+        <method name="do" descriptor="()LRoot;" numArgs="3">
+          <getfield class="LRoot" field="$callback" fieldType="LRoot" ref="arg0" def="xx" />
+          <getfield class="LRoot" field="data" fieldType="LRoot" ref="arg1" def="data" />
+          <call class="LRoot" name="do" descriptor="()LRoot;" type="virtual" arg0="xx" arg1="data" arg2="3" numArgs="3" def="v" />
+          <return value="v" />
+        </method>
+      </class>
+    </package>
+
+    <package name="tensorflow/distribute/run">
+      <class name="run" allocatable="true">
+        <method name="do" descriptor="()LRoot;" numArgs="3">
+          <getfield class="LRoot" field="$callback" fieldType="LRoot" ref="arg0" def="xx" />
+          <getfield class="LRoot" field="data" fieldType="LRoot" ref="arg1" def="data" />
+          <call class="LRoot" name="do" descriptor="()LRoot;" type="virtual" arg0="xx" arg1="data" arg2="3" numArgs="3" def="v" />
+          <return value="v" />
+        </method>
+      </class>
+    </package>
+
     <package name="tensorflow/app">
       <class name="run" allocatable="true">
         <method name="do" descriptor="()LRoot;" numArgs="3" paramNames="self main argv">

com.ibm.wala.cast.python.test/data/tf2_test_callbacks.py

@@ -0,0 +1,12 @@
+import tensorflow as tf
+
+def get_dataset(input_context):
+  batch_size = input_context.get_per_replica_batch_size(2)
+  return tf.data.Dataset.range(4).batch(batch_size)
+
+global_batch_size = 2
+
+strategy = tf.distribute.MirroredStrategy(devices=["GPU:0", "GPU:1"])
+
+input_context = tf.distribute.InputContext()
+dist_dataset = strategy.distribute_datasets_from_function(get_dataset)

com.ibm.wala.cast.python.test/data/tf2_test_callbacks2.py

@@ -0,0 +1,11 @@
+import tensorflow as tf
+
+# Code from https://www.tensorflow.org/api_docs/python/tf/distribute/Strategy#example_usage_2
+strategy = tf.distribute.MirroredStrategy(["GPU:0", "GPU:1"])
+tensor_input = tf.constant(3.0)
+
+@tf.function
+def replica_fn(input):
+  return input*2.0
+
+result = strategy.run(replica_fn, args=(tensor_input,))