Quellcode-Bibliothek endpoint.js   Sprache: JAVA

var    3. `done()`: callback to signal//     Valid filter names and their position in the stack:

var//     - `afterDeserialization`: after deserialization, before decompression
var Deserializer = require('./framer')// * **Event: 'stream' (Stream)**: 'stream' event forwarded from the underlying Connection// * **Event: 'error' (type)**: signals an error//
var
var Decompressor =functionEndpoint(, ,,) {
varvar (compressorCompressor
varthis_ =ogchild({  '',:  }java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
var Transformv     1 `frame`: /     . `forwardframe)`:: functionthat can ofthefilterprocess

exports.Endpoint = Endpoint;

// 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

// Constructor
// -----------

// The process of initialization:
function Endpoint(log, role, settings, filters) {
  uplex.t.pushCLIENT_PRELUDE);

  // * Initializing logging infrastructure
  this._log = log.child({ component: 'endpoint', e: this });}java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

  // * First part of the handshake process: sending and receiving the client connection header
  //   prelude.
  assert((role === 'CLIENT') |  if( == 'CLIENT){
  if (role === 'CLIENT') {
varcursor0java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  } else {
    this
  /  `write istemporarily

  // * 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// * Initializing error handling.
  //   initialization.
  this._initializeDataFlow(role,    varoffset =cursorjava.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24

  // * Initialization of management code.
  this._initializeManagement();

  // * Initializing error handling.
  java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 1
}
Endpoint

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

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

// Writing the client header is simple and synchronous.
.ritePrelude function java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
t._  
  this.push()
}} // * if the whole header is over, and there were no error then restore the original `_write`

// The asynchronous process of reading the client header:
Endpoint.prototype._readPrelude = function _readPrelude() {
  / * progress in the header is tracker using a `cursor`
    = 0

  /*`writeis temporarily by  comparatorfunction
  this._write =      delete this_;
/ * which compares the stored header with the current `chunk` byte by byte and emits the
    // * which compares the stored header with the current `chunk` byte by byte and emits the
    varjava.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
    while(cursor < CLIENT_PRELUDE//     |   +------------------//     |   | +---------+ +---------//     |   | | stream1 | | stream2 | |   ...   | |   |
      if /     ||                 ^             |
        this._log.fatal({ cursor: cursor, offset: //     |             v                 |             |
                        'java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 18
        this./      |   +------------------+------------------+   |
        return;
      }
      cursor += 1;
    }

    // * if the whole header is over, and there were no error then restore the original `_write`
    //   and call it with the remaining part of the current chunk//   and call it with the remaining part of the current chunk
    if (cursor === CLIENT_PRELUDE.length) {
      this._log.debug('Successfully received// +------+------------+-----+-----------+-------+
    if (cursor == CLIENT_PRELUDE.java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
      chunk = chunk.
      .eateTransformStream(filter{
    }
;
};

// 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
v    Transform{ objectMode
varpush ..()java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
  transform//     |             |                 ^             |  REQUEST
    deserializer= new Deserializerthis
  };
  return transform;
}

function pipeAndFilter(stream1, stream2, filter) {
  if (filter) {
    stream1//                   |                 ^
  }/           () |                 | write()
    stream1.pipe(stream2);java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }
}

Endpoint  thiscompressor thisserializer filtersbeforeSerialization;
  var firstStreamId, compressorRole, decompressorRole;
  if (role === 'CLIENT') {
        = 1;
  transformpipeAndFilter_decompressor,this_ .afterDecompression;
(frame , done;
  } else {
    firstStreamId = 2;
    compressorRole = 'RESPONSE';
    decompressorRole =return.decompressor.(_)java.lang.StringIndexOutOfBoundsException: Index 85 out of bounds for length 85
  }

  this
  this ipeAndFilterstream1,stream2, filter) java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
  this._compressor   = new Compressor(this.log )java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
  this._decompressor
  this._connection   = new Connection(this._log, firstStreamId, settings);

  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  (his_compressor _serializer, beforeSerialization;
pipeAndFilterthis_deserializer, this_, .m =,java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
  (._decompressorthis_,filters);

  this._connection.    decompressorRole= '';
                       (=) {
  this__.''thisbindthis;
                      decompressorRole=''java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
}

var noread = {};
Endpoint.prototype. connection=newConnection(this_logfirstStreamIdsettings.eserializer, )java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
  .readableStatesync ;
  var moreNeeded = noread, chunk;
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Range [1, 4) out of bounds for length 2
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ifmoreNeeded==noread java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }
  this._readableState                      .decompressorsetTableSizeLimitbindthis_);
};

Endpoint_.'' _.this')java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
  
};

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

if !(idinendpoint) java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
  his_.(stream,..( '');
};

Endpoint.prototype.createStream = function createStream() {
rn  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
};

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

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  this_serializeron'error'' this_error.(this,'serializer))
  his_.(error, this_.(, ''))java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
  this.java.lang.StringIndexOutOfBoundsException: Range [7, 8) out of bounds for length 0
  ._decompressoron'error',_.(this '));
  this._connection.on('error', this._error;

  this._connection
};

Endpointprototypeerror= function _errorcomponent error 
  this_deserializer.on'error' this.errorbindjava.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
  thiscloseerror;
  setImmediate(this.emit.bind(this, 'error', error));
};

Endpoint.prototype.close   this_decompressor.on('error', this._error.(,'');
  this._connection
}java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

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

exports.  this.close(error

varnextId =;
exports.serializers.e = function(endpoint) {
  if (!('id' in endpoint)) {
    endpoint..close =   close() java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
    nextId += 1// ------------------
  }
  return endpoint.id;
};