org.spearce.jgit/src/org/spearce/jgit/transport/DaemonClient.java

   1 /*
   2  * Copyright (C) 2008, Google Inc.
   3  *
   4  * All rights reserved.
   5  *
   6  * Redistribution and use in source and binary forms, with or
   7  * without modification, are permitted provided that the following
   8  * conditions are met:
   9  *
  10  * - Redistributions of source code must retain the above copyright
  11  *   notice, this list of conditions and the following disclaimer.
  12  *
  13  * - Redistributions in binary form must reproduce the above
  14  *   copyright notice, this list of conditions and the following
  15  *   disclaimer in the documentation and/or other materials provided
  16  *   with the distribution.
  17  *
  18  * - Neither the name of the Git Development Community nor the
  19  *   names of its contributors may be used to endorse or promote
  20  *   products derived from this software without specific prior
  21  *   written permission.
  22  *
  23  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
  24  * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
  25  * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  26  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  27  * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
  28  * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  29  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
  30  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  31  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  32  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
  33  * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  34  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  35  * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  36  */
  37
  38 package org.spearce.jgit.transport;
  39
  40 import java.io.IOException;
  41 import java.io.InputStream;
  42 import java.io.OutputStream;
  43 import java.net.InetAddress;
  44
  45 /** Active network client of {@link Daemon}. */
  46 public class DaemonClient {
  47         private final Daemon daemon;
  48
  49         private InetAddress peer;
  50
  51         private InputStream rawIn;
  52
  53         private OutputStream rawOut;
  54
  55         DaemonClient(final Daemon d) {
  56                 daemon = d;
  57         }
  58
  59         void setRemoteAddress(final InetAddress ia) {
  60                 peer = ia;
  61         }
  62
  63         /** @return the daemon which spawned this client. */
  64         public Daemon getDaemon() {
  65                 return daemon;
  66         }
  67
  68         /** @return Internet address of the remote client. */
  69         public InetAddress getRemoteAddress() {
  70                 return peer;
  71         }
  72
  73         /** @return input stream to read from the connected client. */
  74         public InputStream getInputStream() {
  75                 return rawIn;
  76         }
  77
  78         /** @return output stream to send data to the connected client. */
  79         public OutputStream getOutputStream() {
  80                 return rawOut;
  81         }
  82
  83         void execute(final InputStream in, final OutputStream out)
  84                         throws IOException {
  85                 rawIn = in;
  86                 rawOut = out;
  87
  88                 String cmd = new PacketLineIn(rawIn).readStringRaw();
  89                 final int nul = cmd.indexOf('\0');
  90                 if (nul >= 0) {
  91                         // Newer clients hide a "host" header behind this byte.
  92                         // Currently we don't use it for anything, so we ignore
  93                         // this portion of the command.
  94                         //
  95                         cmd = cmd.substring(0, nul);
  96                 }
  97
  98                 final DaemonService srv = getDaemon().matchService(cmd);
  99                 if (srv == null)
 100                         return;
 101                 srv.execute(this, cmd);
 102         }
 103 }