Gecko [ nbspublicschool.com ]

Name	Size	Permission
__init__.py	3.83 KB	-rw-r--r--
__init__.pyc	3.69 KB	-rw-r--r--
__init__.pyo	3.69 KB	-rw-r--r--
_version.py	80 B	-rw-r--r--
_version.pyc	270 B	-rw-r--r--
_version.pyo	270 B	-rw-r--r--
_winapi.py	10.91 KB	-rw-r--r--
_winapi.pyc	11.62 KB	-rw-r--r--
_winapi.pyo	11.48 KB	-rw-r--r--
agent.py	12.29 KB	-rw-r--r--
agent.pyc	15.79 KB	-rw-r--r--
agent.pyo	15.79 KB	-rw-r--r--
auth_handler.py	26.4 KB	-rw-r--r--
auth_handler.pyc	18.3 KB	-rw-r--r--
auth_handler.pyo	18.3 KB	-rw-r--r--
ber.py	4.16 KB	-rw-r--r--
ber.pyc	4.1 KB	-rw-r--r--
ber.pyo	4.1 KB	-rw-r--r--
buffered_pipe.py	7.33 KB	-rw-r--r--
buffered_pipe.pyc	6.98 KB	-rw-r--r--
buffered_pipe.pyo	6.98 KB	-rw-r--r--
channel.py	46.77 KB	-rw-r--r--
channel.pyc	47.31 KB	-rw-r--r--
channel.pyo	47.24 KB	-rw-r--r--
client.py	27.13 KB	-rw-r--r--
client.pyc	23.24 KB	-rw-r--r--
client.pyo	23.24 KB	-rw-r--r--
common.py	7.41 KB	-rw-r--r--
common.pyc	5.97 KB	-rw-r--r--
common.pyo	5.97 KB	-rw-r--r--
compress.py	1.22 KB	-rw-r--r--
compress.pyc	1.43 KB	-rw-r--r--
compress.pyo	1.43 KB	-rw-r--r--
config.py	10.78 KB	-rw-r--r--
config.pyc	7.55 KB	-rw-r--r--
config.pyo	7.55 KB	-rw-r--r--
dsskey.py	7.9 KB	-rw-r--r--
dsskey.pyc	7.84 KB	-rw-r--r--
dsskey.pyo	7.84 KB	-rw-r--r--
ecdsakey.py	9.37 KB	-rw-r--r--
ecdsakey.pyc	10.3 KB	-rw-r--r--
ecdsakey.pyo	10.3 KB	-rw-r--r--
file.py	18.76 KB	-rw-r--r--
file.pyc	16 KB	-rw-r--r--
file.pyo	16 KB	-rw-r--r--
hostkeys.py	12.08 KB	-rw-r--r--
hostkeys.pyc	13.54 KB	-rw-r--r--
hostkeys.pyo	13.49 KB	-rw-r--r--
kex_gex.py	9.67 KB	-rw-r--r--
kex_gex.pyc	7.73 KB	-rw-r--r--
kex_gex.pyo	7.73 KB	-rw-r--r--
kex_group1.py	5.42 KB	-rw-r--r--
kex_group1.pyc	4.55 KB	-rw-r--r--
kex_group1.pyo	4.55 KB	-rw-r--r--
kex_group14.py	1.67 KB	-rw-r--r--
kex_group14.pyc	1019 B	-rw-r--r--
kex_group14.pyo	1019 B	-rw-r--r--
kex_gss.py	24.28 KB	-rw-r--r--
kex_gss.pyc	19.46 KB	-rw-r--r--
kex_gss.pyo	19.46 KB	-rw-r--r--
message.py	9.29 KB	-rw-r--r--
message.pyc	11.68 KB	-rw-r--r--
message.pyo	11.68 KB	-rw-r--r--
packet.py	18.95 KB	-rw-r--r--
packet.pyc	15.93 KB	-rw-r--r--
packet.pyo	15.93 KB	-rw-r--r--
pipe.py	3.91 KB	-rw-r--r--
pipe.pyc	5.37 KB	-rw-r--r--
pipe.pyo	5.37 KB	-rw-r--r--
pkey.py	13.01 KB	-rw-r--r--
pkey.pyc	13.85 KB	-rw-r--r--
pkey.pyo	13.85 KB	-rw-r--r--
primes.py	4.83 KB	-rw-r--r--
primes.pyc	3.36 KB	-rw-r--r--
primes.pyo	3.36 KB	-rw-r--r--
proxy.py	4.38 KB	-rw-r--r--
proxy.pyc	3.98 KB	-rw-r--r--
proxy.pyo	3.98 KB	-rw-r--r--
py3compat.py	3.87 KB	-rw-r--r--
py3compat.pyc	5.59 KB	-rw-r--r--
py3compat.pyo	5.51 KB	-rw-r--r--
resource.py	2.49 KB	-rw-r--r--
resource.pyc	2.21 KB	-rw-r--r--
resource.pyo	2.21 KB	-rw-r--r--
rsakey.py	5.43 KB	-rw-r--r--
rsakey.pyc	6.37 KB	-rw-r--r--
rsakey.pyo	6.32 KB	-rw-r--r--
server.py	29.38 KB	-rw-r--r--
server.pyc	31.6 KB	-rw-r--r--
server.pyo	31.6 KB	-rw-r--r--
sftp.py	6.06 KB	-rw-r--r--
sftp.pyc	5.66 KB	-rw-r--r--
sftp.pyo	5.66 KB	-rw-r--r--
sftp_attr.py	7.7 KB	-rw-r--r--
sftp_attr.pyc	6.94 KB	-rw-r--r--
sftp_attr.pyo	6.94 KB	-rw-r--r--
sftp_client.py	31.47 KB	-rw-r--r--
sftp_client.pyc	31.51 KB	-rw-r--r--
sftp_client.pyo	31.51 KB	-rw-r--r--
sftp_file.py	19.59 KB	-rw-r--r--
sftp_file.pyc	19.21 KB	-rw-r--r--
sftp_file.pyo	19.21 KB	-rw-r--r--
sftp_handle.py	7.34 KB	-rw-r--r--
sftp_handle.pyc	7.43 KB	-rw-r--r--
sftp_handle.pyo	7.43 KB	-rw-r--r--
sftp_server.py	18 KB	-rw-r--r--
sftp_server.pyc	14.2 KB	-rw-r--r--
sftp_server.pyo	14.2 KB	-rw-r--r--
sftp_si.py	11.65 KB	-rw-r--r--
sftp_si.pyc	12.51 KB	-rw-r--r--
sftp_si.pyo	12.51 KB	-rw-r--r--
ssh_exception.py	6.03 KB	-rw-r--r--
ssh_exception.pyc	7.11 KB	-rw-r--r--
ssh_exception.pyo	7.11 KB	-rw-r--r--
ssh_gss.py	21.39 KB	-rw-r--r--
ssh_gss.pyc	18.78 KB	-rw-r--r--
ssh_gss.pyo	18.78 KB	-rw-r--r--
transport.py	103.08 KB	-rw-r--r--
transport.pyc	89.02 KB	-rw-r--r--
transport.pyo	89.02 KB	-rw-r--r--
util.py	8.24 KB	-rw-r--r--
util.pyc	9.95 KB	-rw-r--r--
util.pyo	9.95 KB	-rw-r--r--
win_pageant.py	4.11 KB	-rw-r--r--
win_pageant.pyc	4.2 KB	-rw-r--r--
win_pageant.pyo	4.2 KB	-rw-r--r--

Code Editor : message.py

# Copyright (C) 2003-2007  Robey Pointer <robeypointer@gmail.com>
#
# This file is part of paramiko.
#
# Paramiko is free software; you can redistribute it and/or modify it under the
# terms of the GNU Lesser General Public License as published by the Free
# Software Foundation; either version 2.1 of the License, or (at your option)
# any later version.
#
# Paramiko 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 Paramiko; if not, write to the Free Software Foundation, Inc.,
# 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA.

"""
Implementation of an SSH2 "message".
"""

import struct

from paramiko import util
from paramiko.common import zero_byte, max_byte, one_byte, asbytes
from paramiko.py3compat import long, BytesIO, u, integer_types

class Message (object):
    """
    An SSH2 message is a stream of bytes that encodes some combination of
    strings, integers, bools, and infinite-precision integers (known in Python
    as longs).  This class builds or breaks down such a byte stream.
    
    Normally you don't need to deal with anything this low-level, but it's
    exposed for people implementing custom extensions, or features that
    paramiko doesn't support yet.
    """

big_int = long(0xff000000)

def __init__(self, content=None):
        """
        Create a new SSH2 message.

:param str content:
            the byte stream to use as the message content (passed in only when
            decomposing a message).
        """
        if content is not None:
            self.packet = BytesIO(content)
        else:
            self.packet = BytesIO()

def __str__(self):
        """
        Return the byte stream content of this message, as a string/bytes obj.
        """
        return self.asbytes()

def __repr__(self):
        """
        Returns a string representation of this object, for debugging.
        """
        return 'paramiko.Message(' + repr(self.packet.getvalue()) + ')'

def asbytes(self):
        """
        Return the byte stream content of this Message, as bytes.
        """
        return self.packet.getvalue()

def rewind(self):
        """
        Rewind the message to the beginning as if no items had been parsed
        out of it yet.
        """
        self.packet.seek(0)

def get_remainder(self):
        """
        Return the bytes (as a `str`) of this message that haven't already been
        parsed and returned.
        """
        position = self.packet.tell()
        remainder = self.packet.read()
        self.packet.seek(position)
        return remainder

def get_so_far(self):
        """
        Returns the `str` bytes of this message that have been parsed and
        returned. The string passed into a message's constructor can be
        regenerated by concatenating ``get_so_far`` and `get_remainder`.
        """
        position = self.packet.tell()
        self.rewind()
        return self.packet.read(position)

def get_bytes(self, n):
        """
        Return the next ``n`` bytes of the message (as a `str`), without
        decomposing into an int, decoded string, etc.  Just the raw bytes are
        returned. Returns a string of ``n`` zero bytes if there weren't ``n``
        bytes remaining in the message.
        """
        b = self.packet.read(n)
        max_pad_size = 1 << 20  # Limit padding to 1 MB
        if len(b) < n < max_pad_size:
            return b + zero_byte * (n - len(b))
        return b

def get_byte(self):
        """
        Return the next byte of the message, without decomposing it.  This
        is equivalent to `get_bytes(1) <get_bytes>`.

:return:
            the next (`str`) byte of the message, or ``'\000'`` if there aren't
            any bytes remaining.
        """
        return self.get_bytes(1)

def get_boolean(self):
        """
        Fetch a boolean from the stream.
        """
        b = self.get_bytes(1)
        return b != zero_byte

def get_adaptive_int(self):
        """
        Fetch an int from the stream.

:return: a 32-bit unsigned `int`.
        """
        byte = self.get_bytes(1)
        if byte == max_byte:
            return util.inflate_long(self.get_binary())
        byte += self.get_bytes(3)
        return struct.unpack('>I', byte)[0]

def get_int(self):
        """
        Fetch an int from the stream.

@return: a 32-bit unsigned integer.
        @rtype: int
        """
        return struct.unpack('>I', self.get_bytes(4))[0]

def get_int64(self):
        """
        Fetch a 64-bit int from the stream.

:return: a 64-bit unsigned integer (`long`).
        """
        return struct.unpack('>Q', self.get_bytes(8))[0]

def get_mpint(self):
        """
        Fetch a long int (mpint) from the stream.

:return: an arbitrary-length integer (`long`).
        """
        return util.inflate_long(self.get_binary())

def get_string(self):
        """
        Fetch a `str` from the stream.  This could be a byte string and may
        contain unprintable characters.  (It's not unheard of for a string to
        contain another byte-stream message.)
        """
        return self.get_bytes(self.get_int())

def get_text(self):
        """
        Fetch a string from the stream.  This could be a byte string and may
        contain unprintable characters.  (It's not unheard of for a string to
        contain another byte-stream Message.)

@return: a string.
        @rtype: string
        """
        return u(self.get_bytes(self.get_int()))
        #return self.get_bytes(self.get_size())

def get_binary(self):
        """
        Fetch a string from the stream.  This could be a byte string and may
        contain unprintable characters.  (It's not unheard of for a string to
        contain another byte-stream Message.)

@return: a string.
        @rtype: string
        """
        return self.get_bytes(self.get_int())

def get_list(self):
        """
        Fetch a `list` of `strings <str>` from the stream.
        
        These are trivially encoded as comma-separated values in a string.
        """
        return self.get_text().split(',')

def add_bytes(self, b):
        """
        Write bytes to the stream, without any formatting.
        
        :param str b: bytes to add
        """
        self.packet.write(b)
        return self

def add_byte(self, b):
        """
        Write a single byte to the stream, without any formatting.
        
        :param str b: byte to add
        """
        self.packet.write(b)
        return self

def add_boolean(self, b):
        """
        Add a boolean value to the stream.
        
        :param bool b: boolean value to add
        """
        if b:
            self.packet.write(one_byte)
        else:
            self.packet.write(zero_byte)
        return self
            
    def add_int(self, n):
        """
        Add an integer to the stream.
        
        :param int n: integer to add
        """
        self.packet.write(struct.pack('>I', n))
        return self
            
    def add_adaptive_int(self, n):
        """
        Add an integer to the stream.
        
        :param int n: integer to add
        """
        if n >= Message.big_int:
            self.packet.write(max_byte)
            self.add_string(util.deflate_long(n))
        else:
            self.packet.write(struct.pack('>I', n))
        return self

def add_int64(self, n):
        """
        Add a 64-bit int to the stream.

:param long n: long int to add
        """
        self.packet.write(struct.pack('>Q', n))
        return self

def add_mpint(self, z):
        """
        Add a long int to the stream, encoded as an infinite-precision
        integer.  This method only works on positive numbers.
        
        :param long z: long int to add
        """
        self.add_string(util.deflate_long(z))
        return self

def add_string(self, s):
        """
        Add a string to the stream.
        
        :param str s: string to add
        """
        s = asbytes(s)
        self.add_int(len(s))
        self.packet.write(s)
        return self

def add_list(self, l):
        """
        Add a list of strings to the stream.  They are encoded identically to
        a single string of values separated by commas.  (Yes, really, that's
        how SSH2 does it.)
        
        :param list l: list of strings to add
        """
        self.add_string(','.join(l))
        return self
        
    def _add(self, i):
        if type(i) is bool:
            return self.add_boolean(i)
        elif isinstance(i, integer_types):
            return self.add_adaptive_int(i)
        elif type(i) is list:
            return self.add_list(i)
        else:
            return self.add_string(i)

def add(self, *seq):
        """
        Add a sequence of items to the stream.  The values are encoded based
        on their type: str, int, bool, list, or long.

.. warning::
            Longs are encoded non-deterministically.  Don't use this method.
        
        :param seq: the sequence of items
        """
        for item in seq:
            self._add(item)

${this.title}

Code Editor : message.py