diff --git a/apps/connected-components/src/main.rs b/apps/connected-components/src/main.rs index de1f08d..154f195 100644 --- a/apps/connected-components/src/main.rs +++ b/apps/connected-components/src/main.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + extern crate topology_generator; extern crate strymon_runtime; extern crate timely; diff --git a/apps/topology-generator/src/bin/main.rs b/apps/topology-generator/src/bin/main.rs index 6d47426..821d4cd 100644 --- a/apps/topology-generator/src/bin/main.rs +++ b/apps/topology-generator/src/bin/main.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + extern crate topology_generator; extern crate rand; diff --git a/apps/topology-generator/src/lib.rs b/apps/topology-generator/src/lib.rs index 2510a54..bd38e4e 100644 --- a/apps/topology-generator/src/lib.rs +++ b/apps/topology-generator/src/lib.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + extern crate rand; extern crate abomonation; #[macro_use] diff --git a/src/strymon_communication/src/fetch.rs b/src/strymon_communication/src/fetch.rs index 6d2a640..3058191 100644 --- a/src/strymon_communication/src/fetch.rs +++ b/src/strymon_communication/src/fetch.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::net::{TcpListener, TcpStream}; use std::io::{copy, Result, Error, ErrorKind}; use std::fs::{self, File}; diff --git a/src/strymon_communication/src/lib.rs b/src/strymon_communication/src/lib.rs index 672c943..3731fc7 100644 --- a/src/strymon_communication/src/lib.rs +++ b/src/strymon_communication/src/lib.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + extern crate bytes; extern crate byteorder; diff --git a/src/strymon_communication/src/message.rs b/src/strymon_communication/src/message.rs index c97c800..726f435 100644 --- a/src/strymon_communication/src/message.rs +++ b/src/strymon_communication/src/message.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::{self, Cursor, Read, Write, ErrorKind}; use serde::ser::Serialize; diff --git a/src/strymon_communication/src/rpc.rs b/src/strymon_communication/src/rpc.rs index 515a076..94b7762 100644 --- a/src/strymon_communication/src/rpc.rs +++ b/src/strymon_communication/src/rpc.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::collections::HashMap; use std::io::{self, ErrorKind}; use std::net::{TcpListener, TcpStream, Shutdown, ToSocketAddrs}; diff --git a/src/strymon_communication/src/transport.rs b/src/strymon_communication/src/transport.rs index c048d54..2c886ff 100644 --- a/src/strymon_communication/src/transport.rs +++ b/src/strymon_communication/src/transport.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io; use std::net::{TcpListener, TcpStream, Shutdown, ToSocketAddrs}; use std::sync::{mpsc, Arc}; diff --git a/src/strymon_runtime/src/bin/errors.rs b/src/strymon_runtime/src/bin/errors.rs index e33dd9c..e810b63 100644 --- a/src/strymon_runtime/src/bin/errors.rs +++ b/src/strymon_runtime/src/bin/errors.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + error_chain!{ foreign_links { Io(::std::io::Error); diff --git a/src/strymon_runtime/src/bin/main.rs b/src/strymon_runtime/src/bin/main.rs index d217ec6..fc11f1c 100644 --- a/src/strymon_runtime/src/bin/main.rs +++ b/src/strymon_runtime/src/bin/main.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + extern crate clap; #[macro_use] extern crate error_chain; diff --git a/src/strymon_runtime/src/bin/manage/coordinator.rs b/src/strymon_runtime/src/bin/manage/coordinator.rs index 129769d..ddea187 100644 --- a/src/strymon_runtime/src/bin/manage/coordinator.rs +++ b/src/strymon_runtime/src/bin/manage/coordinator.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use clap::{App, Arg, ArgMatches, SubCommand}; use strymon_runtime::coordinator; diff --git a/src/strymon_runtime/src/bin/manage/executor.rs b/src/strymon_runtime/src/bin/manage/executor.rs index afc6eae..5d80ffb 100644 --- a/src/strymon_runtime/src/bin/manage/executor.rs +++ b/src/strymon_runtime/src/bin/manage/executor.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use clap::{App, Arg, ArgMatches, SubCommand}; use strymon_runtime::executor; diff --git a/src/strymon_runtime/src/bin/manage/mod.rs b/src/strymon_runtime/src/bin/manage/mod.rs index 8dff2b8..8a75aef 100644 --- a/src/strymon_runtime/src/bin/manage/mod.rs +++ b/src/strymon_runtime/src/bin/manage/mod.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use clap::{App, AppSettings, ArgMatches, SubCommand}; mod coordinator; diff --git a/src/strymon_runtime/src/bin/status.rs b/src/strymon_runtime/src/bin/status.rs index 472d8fd..0d4665a 100644 --- a/src/strymon_runtime/src/bin/status.rs +++ b/src/strymon_runtime/src/bin/status.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::collections::BTreeMap; use clap::{App, Arg, ArgMatches, SubCommand}; diff --git a/src/strymon_runtime/src/bin/submit.rs b/src/strymon_runtime/src/bin/submit.rs index 751e1ce..d21c0cb 100644 --- a/src/strymon_runtime/src/bin/submit.rs +++ b/src/strymon_runtime/src/bin/submit.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io; use std::env; use std::path::{Path}; diff --git a/src/strymon_runtime/src/coordinator/catalog.rs b/src/strymon_runtime/src/coordinator/catalog.rs index 3233a3d..73b6ea9 100644 --- a/src/strymon_runtime/src/coordinator/catalog.rs +++ b/src/strymon_runtime/src/coordinator/catalog.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io; use std::collections::hash_map::{HashMap, Entry as HashEntry}; use std::collections::btree_map::{BTreeMap, Values}; diff --git a/src/strymon_runtime/src/coordinator/dispatch.rs b/src/strymon_runtime/src/coordinator/dispatch.rs index 544d5de..6ee9324 100644 --- a/src/strymon_runtime/src/coordinator/dispatch.rs +++ b/src/strymon_runtime/src/coordinator/dispatch.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::{Error, ErrorKind}; use futures::future::Future; diff --git a/src/strymon_runtime/src/coordinator/handler.rs b/src/strymon_runtime/src/coordinator/handler.rs index 591cabe..4f217a9 100644 --- a/src/strymon_runtime/src/coordinator/handler.rs +++ b/src/strymon_runtime/src/coordinator/handler.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::collections::{BTreeMap, HashMap, VecDeque}; use std::collections::btree_map::Entry; use std::rc::{Rc, Weak}; diff --git a/src/strymon_runtime/src/coordinator/mod.rs b/src/strymon_runtime/src/coordinator/mod.rs index 3282cca..a9f611f 100644 --- a/src/strymon_runtime/src/coordinator/mod.rs +++ b/src/strymon_runtime/src/coordinator/mod.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::Result; use std::env; diff --git a/src/strymon_runtime/src/coordinator/requests.rs b/src/strymon_runtime/src/coordinator/requests.rs index 2002997..de7cabf 100644 --- a/src/strymon_runtime/src/coordinator/requests.rs +++ b/src/strymon_runtime/src/coordinator/requests.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use model::*; use strymon_communication::rpc::Request; diff --git a/src/strymon_runtime/src/coordinator/util.rs b/src/strymon_runtime/src/coordinator/util.rs index d495319..cebfca1 100644 --- a/src/strymon_runtime/src/coordinator/util.rs +++ b/src/strymon_runtime/src/coordinator/util.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::ops::RangeFrom; use std::marker::PhantomData; diff --git a/src/strymon_runtime/src/executor/executable.rs b/src/strymon_runtime/src/executor/executable.rs index 25deeb2..d472403 100644 --- a/src/strymon_runtime/src/executor/executable.rs +++ b/src/strymon_runtime/src/executor/executable.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::env; use std::num; use std::process::{Command, Stdio}; diff --git a/src/strymon_runtime/src/executor/mod.rs b/src/strymon_runtime/src/executor/mod.rs index 5fb7766..58a0907 100644 --- a/src/strymon_runtime/src/executor/mod.rs +++ b/src/strymon_runtime/src/executor/mod.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::{Error, ErrorKind}; use std::env; use std::path::PathBuf; diff --git a/src/strymon_runtime/src/executor/requests.rs b/src/strymon_runtime/src/executor/requests.rs index db4fd34..f811246 100644 --- a/src/strymon_runtime/src/executor/requests.rs +++ b/src/strymon_runtime/src/executor/requests.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use model::*; use strymon_communication::rpc::Request; diff --git a/src/strymon_runtime/src/lib.rs b/src/strymon_runtime/src/lib.rs index 12710cd..c42ed9d 100644 --- a/src/strymon_runtime/src/lib.rs +++ b/src/strymon_runtime/src/lib.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + #![feature(core_intrinsics)] #[macro_use] diff --git a/src/strymon_runtime/src/model/mod.rs b/src/strymon_runtime/src/model/mod.rs index fa5a1cc..7abcd32 100644 --- a/src/strymon_runtime/src/model/mod.rs +++ b/src/strymon_runtime/src/model/mod.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::fmt; use std::intrinsics::type_name; diff --git a/src/strymon_runtime/src/pubsub/mod.rs b/src/strymon_runtime/src/pubsub/mod.rs index 61e9a78..a75c626 100644 --- a/src/strymon_runtime/src/pubsub/mod.rs +++ b/src/strymon_runtime/src/pubsub/mod.rs @@ -1,2 +1,10 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + pub mod publisher; pub mod subscriber; diff --git a/src/strymon_runtime/src/pubsub/publisher/collection.rs b/src/strymon_runtime/src/pubsub/publisher/collection.rs index 684619e..fc0a1e5 100644 --- a/src/strymon_runtime/src/pubsub/publisher/collection.rs +++ b/src/strymon_runtime/src/pubsub/publisher/collection.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::{Result, Error}; use std::collections::BTreeMap; use std::sync::Arc; diff --git a/src/strymon_runtime/src/pubsub/publisher/item.rs b/src/strymon_runtime/src/pubsub/publisher/item.rs index ea040c6..e471666 100644 --- a/src/strymon_runtime/src/pubsub/publisher/item.rs +++ b/src/strymon_runtime/src/pubsub/publisher/item.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::Result; use std::marker::PhantomData; use std::collections::BTreeMap; diff --git a/src/strymon_runtime/src/pubsub/publisher/mod.rs b/src/strymon_runtime/src/pubsub/publisher/mod.rs index 45d4737..a4b0612 100644 --- a/src/strymon_runtime/src/pubsub/publisher/mod.rs +++ b/src/strymon_runtime/src/pubsub/publisher/mod.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::{Result, Error, ErrorKind}; use std::mem; use std::sync::Arc; diff --git a/src/strymon_runtime/src/pubsub/publisher/timely.rs b/src/strymon_runtime/src/pubsub/publisher/timely.rs index bc6a15a..d25673c 100644 --- a/src/strymon_runtime/src/pubsub/publisher/timely.rs +++ b/src/strymon_runtime/src/pubsub/publisher/timely.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::Result; use std::marker::PhantomData; use std::collections::BTreeMap; diff --git a/src/strymon_runtime/src/pubsub/subscriber.rs b/src/strymon_runtime/src/pubsub/subscriber.rs index d364d93..d9c8788 100644 --- a/src/strymon_runtime/src/pubsub/subscriber.rs +++ b/src/strymon_runtime/src/pubsub/subscriber.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::{Result, Error}; use std::marker::PhantomData; diff --git a/src/strymon_runtime/src/query/keepers.rs b/src/strymon_runtime/src/query/keepers.rs index 7ef7f0d..525a7ea 100644 --- a/src/strymon_runtime/src/query/keepers.rs +++ b/src/strymon_runtime/src/query/keepers.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::Error as IoError; use std::net::ToSocketAddrs; diff --git a/src/strymon_runtime/src/query/mod.rs b/src/strymon_runtime/src/query/mod.rs index c8cd3bb..a71cf42 100644 --- a/src/strymon_runtime/src/query/mod.rs +++ b/src/strymon_runtime/src/query/mod.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::{Error as IoError, ErrorKind}; use std::sync::Mutex; diff --git a/src/strymon_runtime/src/query/publish.rs b/src/strymon_runtime/src/query/publish.rs index d97bbf2..299e688 100644 --- a/src/strymon_runtime/src/query/publish.rs +++ b/src/strymon_runtime/src/query/publish.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::Error as IoError; use timely::ExchangeData; diff --git a/src/strymon_runtime/src/query/subscribe.rs b/src/strymon_runtime/src/query/subscribe.rs index 3166f2d..bb345ec 100644 --- a/src/strymon_runtime/src/query/subscribe.rs +++ b/src/strymon_runtime/src/query/subscribe.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io; use timely::Data; diff --git a/src/strymon_runtime/src/submit/mod.rs b/src/strymon_runtime/src/submit/mod.rs index ecca39b..83e107a 100644 --- a/src/strymon_runtime/src/submit/mod.rs +++ b/src/strymon_runtime/src/submit/mod.rs @@ -1,3 +1,11 @@ +// Copyright 2017 ETH Zurich. All rights reserved. +// +// Licensed under the Apache License, Version 2.0 or the MIT license +// , at your +// option. This file may not be copied, modified, or distributed +// except according to those terms. + use std::io::{Error, Result, ErrorKind}; use std::net::ToSocketAddrs; use std::iter::repeat;