published by the Free Software Foundation, either version 2.1 of the License,

or (at your option) any later version.

git_http_backend.py Project is distributed in the hope that it will be useful,

but WITHOUT ANY WARRANTY; without even the implied warranty of

MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

GNU Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public License

along with git_http_backend.py Project.

If not, see <http://www.gnu.org/licenses/>.

'''

import os

import subprocess

import threading

from collections import deque

class StreamFeeder(threading.Thread):

    """

    Normal writing into pipe-like is blocking once the buffer is filled.

    This thread allows a thread to seep data from a file-like into a pipe

    without blocking the main thread.

    We close inpipe once the end of the source stream is reached.

    def __init__(self, source):

        super(StreamFeeder, self).__init__()

        self.daemon = True

        filelike = False

        self.bytes = b''

        if type(source) in (type(''), bytes, bytearray): # string-like

            self.bytes = bytes(source)

        else: # can be either file pointer or file-like

            if type(source) in (int, long): # file pointer it is

                ## converting file descriptor (int) stdin into file-like

                try:

                    source = os.fdopen(source, 'rb', 16384)

                    pass

            # let's see if source is file-like by now

            try:

                filelike = source.read

                pass

        if not filelike and not self.bytes:

        self.source = source

        self.readiface, self.writeiface = os.pipe()

    def run(self):

        t = self.writeiface

        if self.bytes:

            os.write(t, self.bytes)

        else:

            s = self.source

            b = s.read(4096)

            while b:

                os.write(t, b)

    #        print str(e)

    #        raise e

    #

    #    return answer

    '''

    def __init__(self, cmd, inputstream=None, buffer_size=65536,

                 chunk_size=4096, starting_values=[], **kwargs):

        '''

        Initializes SubprocessIOChunker

        '''

        if inputstream:

            input_streamer = StreamFeeder(inputstream)

            input_streamer.start()

            inputstream = input_streamer.output

        _p = subprocess.Popen(cmd,

            bufsize=-1,

            shell=True,

            stdin=inputstream,

            stdout=subprocess.PIPE,