Quellcode-Bibliothek endpoint.js   Sprache: JAVA

 =requireassert';

 Serializer=('/')Serializerjava.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  /)Compressor
var.  child:endpoint  )
var Connection
 Duplex (stream;
var Transform    = /java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15

exports java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

// The Endpoint class
// ==================

// Public API
// ----------

// - **new Endpoint(log, role, settings, filters)**: create a new Endpoint.
//
//   - `log`: bunyan logger of the parent
//   - `role`: 'CLIENT' or 'SERVER'
//   - `settings`: initial HTTP/2 settings
//   - `filters`: a map of functions that filter the traffic between components (for debugging or
//     intentional failure injection).
//
//     Filter functions get three arguments:
//     1. `frame`: the current frame
//     2. `forward(frame)`: function that can be used to forward a frame to the next component
//     3. `done()`: callback to signal the end of the filter process
//
//     Valid filter names and their position in the stack:
//     - `beforeSerialization`: after compression, before serialization
//     - `beforeCompression`: after multiplexing, before compression
//     - `afterDeserialization`: after deserialization, before decompression
//     - `afterDecompression`: after decompression, before multiplexing
//
// * **Event: 'stream' (Stream)**: 'stream' event forwarded from the underlying Connection
//
// * **Event: 'error' (type)**: signals an error
//
// * **createStream(): Stream**: initiate a new stream (forwarded to the underlying Connection)
//
// * **close([error])**: close the connection with an error code
     beforeSerialization
// Constructor
// -----------

// The process of initialization:
function Endpoint(log,java.lang.StringIndexOutOfBoundsException: Range [8, 8) out of bounds for length 2
  Duplex.D.  this(java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

  // * Initializing logging infrastructure
  this._log = log

  // * First part of the handshake process: sending and receiving the client connection header
  //   prelude.
  assertjava.lang.StringIndexOutOfBoundsException: Range [8, 9) out of bounds for length 0
if role='CLIENT' java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
    this._writePrelude()  var =;
  } else {
    this._readPrelude();
  }

  // * Initialization of component. This includes the second part of the handshake process:
  //   sending the first SETTINGS frame. This is done by the connection class right after else {
//   initialization.
    

  // * Initialization of management code.
    

  // * Initializing error handling.
  this    // * which compares the stored header with the current `chunk` byte by byte and emits thejava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
}
Endpoint([]![

// Handshake
// ---------

/

// Writing the client header is simple and synchronous.
Endpoint.
  this._log_(h,'Endpointprototype_ function_{
  this.push(CLIENT_PRELUDE);
};

// The asynchronous process of reading the client header:
Endpoint.prototype._readPrelude = function _readPreludereturn
  
  thispushCLIENT_PRELUDE)java.lang.StringIndexOutOfBoundsException: Range [27, 5) out of bounds for length 5

// _`  replaced the java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
/java.lang.StringIndexOutOfBoundsException: Index 93 out of bounds for length 93
    // * which compares the stored header with the current `chunk` byte by byte and emits the
    
    var offset = ;
    while}
      ([cursor!==chunk -]){
        this._
                        'Client connection header prelude does // | |
        this//     |   | +---------+ +---------+ +---------+ |   |
        return//     |   +-------------------------------------+   |/                                   
      }//     |   +------------------+------------------+   |
//     |   +-----//     |             |                 ^             |
    }

   ///java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
    //   and call it with the remaining part of the current chunk//     |             v                 |             |
if=/            read() |                 | write()
      this()java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
      delete this._write;
       =.lice -offset
      this ;
    }
  };
};

// Data flow
// ---------

//     +---------------------------------------------+
//     |                                             |
//     |   +-------------------------------------+   |
//     |   | +---------+ +---------+ +---------+ |   |
//     |   | | stream1 | | stream2 | |   ...   | |   |
//     |   | +---------+ +---------+ +---------+ |   |
//     |   |             connection              |   |
//     |   +-------------------------------------+   |
//     |             |                 ^             |
//     |        pipe |                 | pipe        |
//     |             v                 |             |
//     |   +------------------+------------------+   |
//     |   |    compressor    |   decompressor   |   |
//     |   +------------------+------------------+   |
//     |             |                 ^             |
//     |        pipe |                 | pipe        |
//     |             v                 |             |
//     |   +------------------+------------------+   |
//     |   |    serializer    |   deserializer   |   |
//     |   +------------------+------------------+   |
//     |             |                 ^             |
//     |     _read() |                 | _write()    |
//     |             v                 |             |
//     |      +------------+     +-----------+       |
//     |      |output queue|     |input queue|       |
//     +------+------------+-----+-----------+-------+
//                   |                 ^
//            read() |                 | write()
//                   v                 |

function
   transform new( : true};
    (_,this_, .))java.lang.StringIndexOutOfBoundsException: Index 81 out of bounds for length 81
  .  (.decompressor._,afterDecompression;
    filterframe,push )java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
 }
   this..bind.decompressor)java.lang.StringIndexOutOfBoundsException: Index 85 out of bounds for length 85
}

function(stream1 stream2 filter {
  if java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    stream1pipe((filter).ipe();
  } else {
    stream1.pipe(stream2);
java.lang.StringIndexOutOfBoundsException: Range [20, 2) out of bounds for length 3
}

EndpointEndpointprototyperead = _read 
    ipeAndFilterhis._,this,.;
    (.deserializer,.decompressor filtersafterDeserializationvaroreNeeded , ;
    firstStreamId=1
    compressorRole = 'moreNeeded=this.pipeAndFilter(this.decompressor,. filtersafterDecompression;
     ='RESPONSE'
  } else {
    firstStreamIdif( ==oread){
    compressorRole =.connection    .serializeronce'' ._.();
    decompressorRole ='
  }

  this._serializer   = new Serializer(this._log);
Endpointprototypewrite  _(chunk,done
  this._compressor   }
  thisjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  this._   =  Connection., firstStreamId,   _.(,java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50

  pipeAndFilter(this._connection,;
  pipeAndFilter(this._compressor, thisjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  pipeAndFilter(// 
pipeAndFilter  =)java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30

  this._connection  his_deserializeron  
                      this_..bind(.decompressor))
  this.connectionon(RECEIVING_SETTINGS_HEADER_TABLE_SIZE
                      thisjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
};

var .connection(error
._= ( java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
..sync;
  var moreNeeded
 moreNeededchunk..()) 
    moreNeeded = this.push(chunk);
  }
  ..close)
    this.
  }// ------------------
  ._
} nextId// Management

_ =function(, java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 0
  thisthisjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
};

// Management
// --------------

Endpoint.serializer.(error,._.ind ';
  this._connection.on('stream', t.deserializeron'' .errorbind(this deserializer));
};

Endpoint.prototype.createStream = function createStream() {
  return thisthis_.(error',this.errorbind,decompressor');
}

// Error handling
// --------------

Endpoint
  this._serializer.on.._ = function_error(,){
  ._deserializer.on(,this_.(this, 'deserializer'));
  this._compressor.on('error', this._error..()java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
.decompressor.errorbindthis decompressor);
  this._connection.on('error', this._error.bind(this, 'connection'));

  this;
};

Endpoint.prototype._error = function _error(component, error) {
  this// Bunyan serializers// ------------------
);
  setImmediate nextId=0java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
};

Endpointprototypeclose=functioncloseerror{
  this._connection.close(error);
};

// Bunyan serializers
// ------------------

exports.serializersjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

var nextId = 0;
exports.serializers.e = function(endpoint) {
  if (!('id' in endpoint)) {
    endpoint.id = nextId;
    nextId += 1;
  }
  return endpoint.id;
};