Udate TODOs to use Github user names

Louis Ryan · Louis Ryan · commit 95c6f5082cee · 2015-02-23T12:46:28.000-08:00
diff --git a/auth/src/main/java/io/grpc/auth/OAuth2ChannelInterceptor.java b/auth/src/main/java/io/grpc/auth/OAuth2ChannelInterceptor.java
@@ -65,7 +65,7 @@ public OAuth2ChannelInterceptor(Credential credential, Executor executor) {
   @Override
   public <ReqT, RespT> Call<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
       Channel next) {
-    // TODO(ejona): If the call fails for Auth reasons, this does not properly propagate info that
+    // TODO(ejona86): If the call fails for Auth reasons, this does not properly propagate info that
     // would be in WWW-Authenticate, because it does not yet have access to the header.
     return new ForwardingCall<ReqT, RespT>(next.newCall(method)) {
       @Override
diff --git a/compiler/src/java_plugin/cpp/java_generator.cpp b/compiler/src/java_plugin/cpp/java_generator.cpp
@@ -337,7 +337,7 @@ static void PrintStub(const google::protobuf::ServiceDescriptor* service,
     p->Print("public ");
     switch (call_type) {
       case BLOCKING_CALL:
-        // TODO(zhangkun): decide the blocking server interface
+        // TODO(zhangkun83): decide the blocking server interface
         CHECK(type != BLOCKING_SERVER_INTERFACE)
             << "Blocking server interface is not available";
         CHECK(!client_streaming)
diff --git a/core/src/main/java/io/grpc/Call.java b/core/src/main/java/io/grpc/Call.java
@@ -90,7 +90,7 @@ public abstract static class Listener<T> {
    * @param headers which can contain extra information like authentication.
    * @throws IllegalStateException if call is already started
    */
-  // TODO(lryan): Might be better to put into Channel#newCall, might reduce decoration burden
+  // TODO(louiscryan): Might be better to put into Channel#newCall, might reduce decoration burden
   public abstract void start(Listener<ResponseT> responseListener, Metadata.Headers headers);
 
   /**
diff --git a/core/src/main/java/io/grpc/Channel.java b/core/src/main/java/io/grpc/Channel.java
@@ -44,6 +44,6 @@ public interface Channel {
   /**
    * Create a call to the given service method.
    */
-  // TODO(ejona): perform start() as part of new Call creation?
+  // TODO(ejona86): perform start() as part of new Call creation?
   public <ReqT, RespT> Call<ReqT, RespT> newCall(MethodDescriptor<ReqT, RespT> method);
 }
diff --git a/core/src/main/java/io/grpc/ChannelImpl.java b/core/src/main/java/io/grpc/ChannelImpl.java
@@ -92,7 +92,7 @@ public ChannelImpl(ClientTransportFactory transportFactory, ExecutorService exec
   }
 
   /** Hack to allow executors to auto-shutdown. Not for general use. */
-  // TODO(ejona): Replace with a real API.
+  // TODO(ejona86): Replace with a real API.
   void setTerminationRunnable(Runnable runnable) {
     this.terminationRunnable = runnable;
   }
@@ -126,7 +126,7 @@ public synchronized ChannelImpl shutdown() {
    *
    * <p>NOT YET IMPLEMENTED. This method currently behaves identically to shutdown().
    */
-  // TODO(ejona): cancel preexisting calls.
+  // TODO(ejona86): cancel preexisting calls.
   public synchronized ChannelImpl shutdownNow() {
     shutdown();
     return this;
@@ -256,7 +256,7 @@ public void start(Listener<RespT> observer, Metadata.Headers headers) {
         stream = transport.newStream(method, headers, listener);
       } catch (IllegalStateException ex) {
         // We can race with the transport and end up trying to use a terminated transport.
-        // TODO(ejona): Improve the API to remove the possibility of the race.
+        // TODO(ejona86): Improve the API to remove the possibility of the race.
         stream = new NoopClientStream();
         listener.closed(Status.fromThrowable(ex), new Metadata.Trailers());
         return;
diff --git a/core/src/main/java/io/grpc/Marshaller.java b/core/src/main/java/io/grpc/Marshaller.java
@@ -41,7 +41,7 @@ public interface Marshaller<T> {
   /**
    * Given a message produce an {@link InputStream} for it.
    */
-  // TODO(lryan): Switch to ByteSource equivalent when ready
+  // TODO(louiscryan): Switch to ByteSource equivalent when ready
   public InputStream stream(T value);
 
   /**
diff --git a/core/src/main/java/io/grpc/Metadata.java b/core/src/main/java/io/grpc/Metadata.java
@@ -104,7 +104,7 @@ public Integer parseAsciiString(String serialized) {
   /**
    * Constructor called by the transport layer when it receives binary metadata.
    */
-  // TODO(lryan): Convert to use ByteString so we can cache transformations
+  // TODO(louiscryan): Convert to use ByteString so we can cache transformations
   private Metadata(byte[]... binaryValues) {
     store = LinkedListMultimap.create();
     for (int i = 0; i < binaryValues.length; i++) {
@@ -430,7 +430,7 @@ public String name() {
       return name;
     }
 
-    // TODO (lryan): Migrate to ByteString
+    // TODO (louiscryan): Migrate to ByteString
     public byte[] asciiName() {
       return asciiName;
     }
diff --git a/core/src/main/java/io/grpc/SerializingExecutor.java b/core/src/main/java/io/grpc/SerializingExecutor.java
@@ -49,7 +49,7 @@
  * @author JJ Furman
  */
 
-// TODO(simonma): figure out a way to not expose it or move it to transport package.
+// TODO(madongfly): figure out a way to not expose it or move it to transport package.
 public final class SerializingExecutor implements Executor {
   private static final Logger log =
       Logger.getLogger(SerializingExecutor.class.getName());
diff --git a/core/src/main/java/io/grpc/ServerCall.java b/core/src/main/java/io/grpc/ServerCall.java
@@ -56,7 +56,7 @@ public abstract class ServerCall<ResponseT> {
    * <p>Implementations are free to block for extended periods of time. Implementations are not
    * required to be thread-safe.
    */
-  // TODO(ejona): We need to decide what to do in the case of server closing with non-cancellation
+  // TODO(ejona86): We need to decide what to do in the case of server closing with non-cancellation
   // before client half closes. It may be that we treat such a case as an error. If we permit such
   // a case then we either get to generate a half close or purposefully omit it.
   public abstract static class Listener<RequestT> {
diff --git a/core/src/main/java/io/grpc/ServerImpl.java b/core/src/main/java/io/grpc/ServerImpl.java
@@ -119,7 +119,7 @@ public ServerListener serverListener() {
   }
 
   /** Hack to allow executors to auto-shutdown. Not for general use. */
-  // TODO(ejona): Replace with a real API.
+  // TODO(ejona86): Replace with a real API.
   synchronized void setTerminationRunnable(Runnable runnable) {
     this.terminationRunnable = runnable;
   }
@@ -168,7 +168,7 @@ public synchronized ServerImpl shutdown() {
    *
    * <p>NOT YET IMPLEMENTED. This method currently behaves identically to shutdown().
    */
-  // TODO(ejona): cancel preexisting calls.
+  // TODO(ejona86): cancel preexisting calls.
   public synchronized ServerImpl shutdownNow() {
     shutdown();
     return this;
@@ -320,7 +320,7 @@ public void run() {
     /** Never returns {@code null}. */
     private <ReqT, RespT> ServerStreamListener startCall(ServerStream stream, String fullMethodName,
         ServerMethodDefinition<ReqT, RespT> methodDef, Metadata.Headers headers) {
-      // TODO(ejona): should we update fullMethodName to have the canonical path of the method?
+      // TODO(ejona86): should we update fullMethodName to have the canonical path of the method?
       final ServerCallImpl<ReqT, RespT> call = new ServerCallImpl<ReqT, RespT>(stream, methodDef);
       ServerCall.Listener<ReqT> listener
           = methodDef.getServerCallHandler().startCall(fullMethodName, call, headers);
@@ -382,7 +382,7 @@ private void setListener(ServerStreamListener listener) {
      * Like {@link ServerCall#close(Status, Metadata.Trailers)}, but thread-safe for internal use.
      */
     private void internalClose(Status status, Metadata.Trailers trailers) {
-      // TODO(ejona): this is not thread-safe :)
+      // TODO(ejona86): this is not thread-safe :)
       stream.close(status, trailers);
     }
 
diff --git a/core/src/main/java/io/grpc/transport/AbstractServerStream.java b/core/src/main/java/io/grpc/transport/AbstractServerStream.java
@@ -126,7 +126,7 @@ public void inboundDataReceived(Buffer frame, boolean endOfStream) {
       frame.close();
       return;
     }
-    // TODO(zhangkun): It sounds sub-optimal to deframe in the network thread. That means
+    // TODO(zhangkun83): It sounds sub-optimal to deframe in the network thread. That means
     // decompression is serialized.
     deframe(frame, endOfStream);
   }
@@ -208,12 +208,12 @@ protected final void remoteEndClosed() {
    *                     about stream closure and send the status
    */
   public final void abortStream(Status status, boolean notifyClient) {
-    // TODO(lryan): Investigate whether we can remove the notification to the client
+    // TODO(louiscryan): Investigate whether we can remove the notification to the client
     // and rely on a transport layer stream reset instead.
     Preconditions.checkArgument(!status.isOk(), "status must not be OK");
     closeListener(status);
     if (notifyClient) {
-      // TODO(lryan): Remove
+      // TODO(louiscryan): Remove
       if (stashedTrailers == null) {
         stashedTrailers = new Metadata.Trailers();
       }
diff --git a/core/src/main/java/io/grpc/transport/AbstractStream.java b/core/src/main/java/io/grpc/transport/AbstractStream.java
@@ -125,7 +125,7 @@ public void writeMessage(InputStream message, int length, @Nullable Runnable acc
       framer.writePayload(message, length);
     }
 
-    // TODO(nathanmittler): add flow control.
+    // TODO(nmittler): add flow control.
     if (accepted != null) {
       accepted.run();
     }
diff --git a/core/src/main/java/io/grpc/transport/ClientTransport.java b/core/src/main/java/io/grpc/transport/ClientTransport.java
@@ -43,7 +43,7 @@ public interface ClientTransport {
   /**
    * Creates a new stream for sending messages to the remote end-point. If the service is already
    * stopped, throws an {@link IllegalStateException}.
-   * TODO(nathanmittler): Consider also throwing for stopping.
+   * TODO(nmittler): Consider also throwing for stopping.
    * <p>
    * This method returns immediately and does not wait for any validation of the request. If
    * creation fails for any reason, {@link ClientStreamListener#closed} will be called to provide
diff --git a/core/src/main/java/io/grpc/transport/MessageFramer.java b/core/src/main/java/io/grpc/transport/MessageFramer.java
@@ -195,7 +195,7 @@ public void close() {
    * closed or disposed, additional calls to this method will have no affect.
    */
   public void dispose() {
-    // TODO(lryan): Returning buffer to a pool would go here
+    // TODO(louiscryan): Returning buffer to a pool would go here
     bytebuf = null;
   }
 
diff --git a/core/src/main/java/io/grpc/transport/TransportFrameUtil.java b/core/src/main/java/io/grpc/transport/TransportFrameUtil.java
@@ -56,7 +56,7 @@ public final class TransportFrameUtil {
   private static final byte[] binaryHeaderSuffixBytes =
       Metadata.BINARY_HEADER_SUFFIX.getBytes(US_ASCII);
 
-  // TODO(lryan): This needs proper namespacing support, this is currently just a hack
+  // TODO(louiscryan): This needs proper namespacing support, this is currently just a hack
   /**
    * Converts the path from the HTTP request to the full qualified method name.
    *
@@ -89,7 +89,7 @@ public static byte[][] toHttp2Headers(Metadata headers) {
       } else {
         // Non-binary header.
         // Filter out headers that contain non-spec-compliant ASCII characters.
-        // TODO(zhangkun): only do such check in development mode since it's expensive
+        // TODO(zhangkun83): only do such check in development mode since it's expensive
         if (isSpecCompliantAscii(value)) {
           result.add(key);
           result.add(value);
diff --git a/examples/src/main/java/io/grpc/examples/MathClient.java b/examples/src/main/java/io/grpc/examples/MathClient.java
@@ -218,7 +218,7 @@ public void onCompleted() {
    * <p> The asynchronous usage is similar to {@link #divMany}.
    */
   public void blockingFib() {
-    // TODO(simonma): Support "send until cancel". Currently, client application can not
+    // TODO(madongfly): Support "send until cancel". Currently, client application can not
     // cancel a server streaming call.
     int limit = rand.nextInt(20) + 10;
     logger.info("*** Blocking Fib, print the first " + limit + " fibonacci numbers.");
diff --git a/examples/src/main/java/io/grpc/examples/MathServer.java b/examples/src/main/java/io/grpc/examples/MathServer.java
@@ -62,7 +62,7 @@ public void start() {
         .addService(CalcGrpc.bindService(new CalcService()))
         .build().start();
     logger.info("Server started, listening on " + port);
-    // TODO(simonma): gRPC server should register JVM shutdown hook to shutdown itself, remove this
+    // TODO(madongfly): gRPC server should register JVM shutdown hook to shutdown itself, remove this
     // after we support that.
     Runtime.getRuntime().addShutdownHook(new Thread() {
       @Override
@@ -130,7 +130,7 @@ public void onCompleted() {
     public void fib(FibArgs request, StreamObserver<Num> responseObserver) {
       int limit = (int) request.getLimit();
       if (limit <= 0) {
-        // TODO(simonma): Support "send until cancel". Currently, client application can not
+        // TODO(madongfly): Support "send until cancel". Currently, client application can not
         // cancel a server streaming call.
         return;
       }
diff --git a/netty/src/main/java/io/grpc/transport/netty/NettyClientHandler.java b/netty/src/main/java/io/grpc/transport/netty/NettyClientHandler.java
@@ -179,7 +179,7 @@ private void onDataRead(int streamId, ByteBuf data, boolean endOfStream) throws
    */
   private void onRstStreamRead(int streamId)
       throws Http2Exception {
-    // TODO(nathanmittler): do something with errorCode?
+    // TODO(nmittler): do something with errorCode?
     Http2Stream http2Stream = connection().requireStream(streamId);
     NettyClientStream stream = clientStream(http2Stream);
     stream.transportReportStatus(Status.UNKNOWN, false, new Metadata.Trailers());
@@ -324,7 +324,7 @@ private void createPendingStreams() {
       if (streamId <= 0) {
         // The HTTP/2 connection has exhausted its stream IDs. Permanently fail all stream creation
         // attempts for this transport.
-        // TODO(nathanmittler): send GO_AWAY?
+        // TODO(nmittler): send GO_AWAY?
         failPendingStreams(goAwayStatus);
         return;
       }
diff --git a/netty/src/main/java/io/grpc/transport/netty/NettyClientTransport.java b/netty/src/main/java/io/grpc/transport/netty/NettyClientTransport.java
@@ -143,7 +143,7 @@ class NettyClientTransport implements ClientTransport {
             throw new RuntimeException(ex);
           }
         }
-        // TODO(ejona): specify allocator. The method currently ignores it though.
+        // TODO(ejona86): specify allocator. The method currently ignores it though.
         SSLEngine sslEngine
             = sslContext.newEngine(null, inetAddress.getHostString(), inetAddress.getPort());
         SSLParameters sslParams = new SSLParameters();
diff --git a/netty/src/main/java/io/grpc/transport/netty/NettyServer.java b/netty/src/main/java/io/grpc/transport/netty/NettyServer.java
@@ -80,7 +80,7 @@ public NettyServer(final ServerListener serverListener, SocketAddress address,
       public void initChannel(Channel ch) throws Exception {
         NettyServerTransport transport = new NettyServerTransport(ch, serverListener, sslContext);
         transport.startAsync();
-        // TODO(nathanmittler): Should we wait for transport shutdown before shutting down server?
+        // TODO(nmittler): Should we wait for transport shutdown before shutting down server?
       }
     };
     this.bossGroup = bossGroup;
diff --git a/netty/src/test/java/io/grpc/transport/netty/NettyClientHandlerTest.java b/netty/src/test/java/io/grpc/transport/netty/NettyClientHandlerTest.java
@@ -88,7 +88,7 @@ public class NettyClientHandlerTest extends NettyHandlerTestBase {
 
   private NettyClientHandler handler;
 
-  // TODO(zhangkun): mocking concrete classes is not safe. Consider making NettyClientStream an
+  // TODO(zhangkun83): mocking concrete classes is not safe. Consider making NettyClientStream an
   // interface.
   @Mock
   private NettyClientStream stream;
diff --git a/okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpClientStream.java b/okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpClientStream.java
@@ -118,7 +118,7 @@ protected void sendFrame(ByteBuffer frame, boolean endOfStream) {
     Preconditions.checkState(id() != 0, "streamId should be set");
     okio.Buffer buffer = new okio.Buffer();
     // Read the data into a buffer.
-    // TODO(simonma): swap to NIO buffers or zero-copy if/when okhttp/okio supports it
+    // TODO(madongfly): swap to NIO buffers or zero-copy if/when okhttp/okio supports it
     buffer.write(frame.array(), frame.arrayOffset(), frame.remaining());
     // Write the data to the remote endpoint.
     // Per http2 SPEC, the max data length should be larger than 64K, while our frame size is
diff --git a/okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpClientTransport.java b/okhttp/src/main/java/io/grpc/transport/okhttp/OkHttpClientTransport.java
@@ -458,13 +458,13 @@ public void windowUpdate(int streamId, long delta) {
     @Override
     public void priority(int streamId, int streamDependency, int weight, boolean exclusive) {
       // Ignore priority change.
-      // TODO(simonma): log
+      // TODO(madongfly): log
     }
 
     @Override
     public void alternateService(int streamId, String origin, ByteString protocol, String host,
         int port, long maxAge) {
-      // TODO(simonma): Deal with alternateService propagation
+      // TODO(madongfly): Deal with alternateService propagation
     }
   }
 
diff --git a/stub/src/main/java/io/grpc/stub/AbstractStub.java b/stub/src/main/java/io/grpc/stub/AbstractStub.java
@@ -49,8 +49,8 @@
  * @param <S> the concrete type of this stub.
  * @param <C> the service descriptor type
  */
-// TODO(lryan): Move into 3rd party when tidy
-// TODO(lryan/kevinb): Excessive parameterization can be a pain, try to eliminate once the generated
+// TODO(louiscryan): Move into 3rd party when tidy
+// TODO(louiscryan): Excessive parameterization can be a pain, try to eliminate once the generated
 // code is more tangible.
 public abstract class AbstractStub<S extends AbstractStub<?, ?>,
     C extends AbstractServiceDescriptor<C>> {
diff --git a/stub/src/main/java/io/grpc/stub/Calls.java b/stub/src/main/java/io/grpc/stub/Calls.java
@@ -67,7 +67,7 @@ public class Calls {
    */
   public static <RequestT, ResponseT> MethodDescriptor<RequestT, ResponseT> createMethodDescriptor(
       String fullServiceName, Method<RequestT, ResponseT> method) {
-    // TODO(zhangkun): if timeout is not defined in proto file, use a default timeout here.
+    // TODO(zhangkun83): if timeout is not defined in proto file, use a default timeout here.
     // If timeout is defined in proto file, Method should carry the timeout.
     return MethodDescriptor.create(method.getType(), fullServiceName + "/" + method.getName(),
         1, TimeUnit.SECONDS, method.getRequestMarshaller(), method.getResponseMarshaller());
@@ -146,7 +146,7 @@ public static <ReqT, RespT> void asyncUnaryCall(
    * response stream.
    * @return an iterator over the response stream.
    */
-  // TODO(lryan): Not clear if we want to use this idiom for 'simple' stubs.
+  // TODO(louiscryan): Not clear if we want to use this idiom for 'simple' stubs.
   public static <ReqT, RespT> Iterator<RespT> blockingServerStreamingCall(
       Call<ReqT, RespT> call, ReqT param) {
     BlockingResponseStream<RespT> result = new BlockingResponseStream<RespT>(call);
@@ -242,7 +242,7 @@ public void onValue(T value) {
 
     @Override
     public void onError(Throwable t) {
-      // TODO(ejona): log?
+      // TODO(ejona86): log?
       call.cancel();
     }
 
@@ -330,7 +330,7 @@ public void onClose(Status status, Metadata.Trailers trailers) {
    * <p>The class is not thread-safe, but it does permit Call.Listener calls in a separate thread
    * from Iterator calls.
    */
-  // TODO(ejona): determine how to allow Call.cancel() in case of application error.
+  // TODO(ejona86): determine how to allow Call.cancel() in case of application error.
   private static class BlockingResponseStream<T> implements Iterator<T> {
     // Due to flow control, only needs to hold up to 2 items: 1 for value, 1 for close.
     private final BlockingQueue<Object> buffer = new ArrayBlockingQueue<Object>(2);
diff --git a/stub/src/main/java/io/grpc/stub/StreamObserver.java b/stub/src/main/java/io/grpc/stub/StreamObserver.java
@@ -37,7 +37,7 @@
  * <p>Implementations are expected to be thread-compatible. Separate StreamObservers do not need to
  * be sychronized together; incoming and outgoing directions are independent.
  */
-// TODO(lryan): Consider whether we need to interact with flow-control at this layer. E.g.
+// TODO(louiscryan): Consider whether we need to interact with flow-control at this layer. E.g.
 // public ListenableFuture<Void> onValue(V value). Do we layer it in here or as an additional
 // interface? Interaction with flow control can be done by blocking here.
 public interface StreamObserver<V>  {

Original file line number	Diff line number	Diff line change
`@@ -44,6 +44,6 @@ public interface Channel {`
`44`	`44`	`/**`
`45`	`45`	`* Create a call to the given service method.`
`46`	`46`	`*/`
`47`		`- // TODO(ejona): perform start() as part of new Call creation?`
	`47`	`+ // TODO(ejona86): perform start() as part of new Call creation?`
`48`	`48`	`public <ReqT, RespT> Call<ReqT, RespT> newCall(MethodDescriptor<ReqT, RespT> method);`
`49`	`49`	`}`