Commit e3d9aa6

authored

Supress RA thread stdout (#252)

Get rid of annoying messages that get in the way when debugging continuous workflow

1 parent c7ab0cd commit e3d9aa6Copy full SHA for e3d9aa6

File tree

+16

-4

lines changed

+16

-4

lines changed

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -121,6 +121,8 @@ import edu.berkeley.cs.rise.opaque.logical.EncryptLocalRelation`
`121`	`121`	`import org.apache.spark.sql.catalyst.expressions.PromotePrecision`
`122`	`122`	`import org.apache.spark.sql.catalyst.expressions.CheckOverflow`
`123`	`123`
	`124`	`+import edu.berkeley.cs.rise.opaque.rpc.RA`
	`125`	`+`
`124`	`126`	`object Utils extends Logging {`
`125`	`127`
`126`	`128`	`def time[A](desc: String)(f: => A): A = {`

Lines changed: 14 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -15,18 +15,26 @@`
`15`	`15`	`* limitations under the License.`
`16`	`16`	`*/`
`17`	`17`
`18`		`-package edu.berkeley.cs.rise.opaque`
	`18`	`+package edu.berkeley.cs.rise.opaque.rpc`
`19`	`19`
`20`	`20`	`import opaque.protos.client._`
`21`	`21`
	`22`	`+import edu.berkeley.cs.rise.opaque.Utils`
	`23`	`+import edu.berkeley.cs.rise.opaque.OpaqueException`
	`24`	`+`
	`25`	`+import org.apache.log4j.Logger`
	`26`	`+import org.apache.log4j.Level`
	`27`	`+import org.apache.spark.rdd.RDD`
`22`	`28`	`import org.apache.spark.SparkContext`
`23`	`29`	`import org.apache.spark.internal.Logging`
`24`		`-import org.apache.spark.rdd.RDD`
`25`	`30`
`26`	`31`	`import com.google.protobuf.ByteString`
`27`	`32`	`import io.grpc.netty.NettyServerBuilder`
`28`	`33`
	`34`	`+import java.io.ByteArrayOutputStream`
	`35`	`+`
`29`	`36`	`import scala.concurrent.{ExecutionContext, Future}`
	`37`	`+import scala.Console`
`30`	`38`
`31`	`39`	`// Performs remote attestation for all executors`
`32`	`40`	`// that have not been attested yet.`
`@@ -129,8 +137,10 @@ object RA extends Logging {`
`129`	`137`	`def startThread(sc: SparkContext, rdd: RDD[Unit]): Unit = {`
`130`	`138`	`val thread = new Thread {`
`131`	`139`	`override def run: Unit = {`
`132`		`- while (false) { // loop`
`133`		`- attestEnclaves(sc, rdd)`
	`140`	`+ Logger.getLogger("org").setLevel(Level.OFF)`
	`141`	`+ Logger.getLogger("akka").setLevel(Level.OFF)`
	`142`	`+ while (loop) {`
	`143`	`+ RA.attestEnclaves(sc, rdd)`
`134`	`144`	`}`
`135`	`145`	`}`
`136`	`146`	`}`

Comments

(0)