import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
@SuppressWarnings("cast")
@Override
public boolean connect(IScope newScope, Object[] params) {
    log.debug("Connect scope: {}", newScope);
    boolean success = super.connect(newScope, params);
    if (success) {
        final Channel two = getChannel(2);
        // tell the flash player how fast we want data and how fast we shall send it
        two.write(new ServerBW(defaultServerBandwidth));
        // second param is the limit type (0=hard,1=soft,2=dynamic)
        two.write(new ClientBW(defaultClientBandwidth, (byte) limitType));
        // if the client is null for some reason, skip the jmx registration
        if (client != null) {
            // perform bandwidth detection
            if (bandwidthDetection && !client.isBandwidthChecked()) {
                client.checkBandwidth();
            }
        } else {
            log.warn("Client was null");
        }
        registerJMX();
    } else {
        log.debug("Connect failed");
    }
    return success;
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
@SuppressWarnings("cast")
@Override
public boolean connect(IScope newScope, Object[] params) {
	log.debug("Connect scope: {}", newScope);
	boolean success = super.connect(newScope, params);
	if (success) {
		// tell the flash player how fast we want data and how fast we shall send it
		getChannel(2).write(new ServerBW(defaultServerBandwidth));
		// second param is the limit type (0=hard,1=soft,2=dynamic)
		getChannel(2).write(new ClientBW(defaultClientBandwidth, (byte) limitType));
		//if the client is null for some reason, skip the jmx registration
		if (client != null) {
			// perform bandwidth detection
			if (bandwidthDetection && !client.isBandwidthChecked()) {
				client.checkBandwidth();
			}
		} else {
			log.warn("Client was null");
		}
		registerJMX();
	}
	return success;
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/** {@inheritDoc} */
public void setBandwidth(int mbits) {
    // tell the flash player how fast we want data and how fast we shall send it
    getChannel(2).write(new ServerBW(mbits));
    // second param is the limit type (0=hard,1=soft,2=dynamic)
    getChannel(2).write(new ClientBW(mbits, (byte) limitType));
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
protected void onServerBandwidth(RTMPConnection conn, Channel channel, ServerBW message) {
    log.trace("onServerBandwidth");
    // if the size is not equal to our read size send a client bw control message
    int bandwidth = message.getBandwidth();
    if (bandwidth != bytesReadWindow) {
        ClientBW clientBw = new ClientBW(bandwidth, (byte) 2);
        channel.write(clientBw);
    }
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
protected void onClientBandwidth(RTMPConnection conn, Channel channel, ClientBW message) {
    log.trace("onClientBandwidth");
    // if the size is not equal to our write size send a server bw control message
    int bandwidth = message.getBandwidth();
    if (bandwidth != bytesWrittenWindow) {
        ServerBW serverBw = new ServerBW(bandwidth);
        channel.write(serverBw);
    }
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/** {@inheritDoc} */
public void setBandwidth(int mbits) {
	// tell the flash player how fast we want data and how fast we shall send it
	getChannel(2).write(new ServerBW(mbits));
	// second param is the limit type (0=hard,1=soft,2=dynamic)
	getChannel(2).write(new ClientBW(mbits, (byte) limitType));
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/**
 * Encode client-side bandwidth event.
 *
 * @param clientBW    Client-side bandwidth event
 * @return            Encoded event data
 */
private IoBuffer encodeClientBW(ClientBW clientBW) {
	final IoBuffer out = IoBuffer.allocate(5);
	out.putInt(clientBW.getBandwidth());
	out.put(clientBW.getLimitType());
	return out;
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/**
 * Encode client-side bandwidth event.
 *
 * @param clientBW
 *            Client-side bandwidth event
 * @return Encoded event data
 */
private IoBuffer encodeClientBW(ClientBW clientBW) {
    final IoBuffer out = IoBuffer.allocate(5);
    out.putInt(clientBW.getBandwidth());
    out.put(clientBW.getLimitType());
    return out;
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/**
 * Decodes client bandwidth.
 * 
 * @param in
 *            Byte buffer
 * @return RTMP event
 */
private IRTMPEvent decodeClientBW(IoBuffer in) {
    return new ClientBW(in.getInt(), in.get());
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/**
 * Decodes client bandwidth.
 * 
 * @param in
 *            Byte buffer
 * @return RTMP event
 */
private IRTMPEvent decodeClientBW(IoBuffer in) {
	return new ClientBW(in.getInt(), in.get());
}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/**
 * Client bandwidth / Peer bandwidth set event handler.
 * 
 * @param conn
 *            Connection
 * @param channel
 *            Channel
 * @param message
 *            ClientBW
 */
protected void onClientBandwidth(RTMPConnection conn, Channel channel, ClientBW message) {

}
 

import org.red5.server.net.rtmp.event.ClientBW; //导入依赖的package包/类
/**
 * Client bandwidth / Peer bandwidth set event handler.
 *  
 * @param conn Connection
 * @param channel Channel
 * @param message ClientBW
 */
protected void onClientBandwidth(RTMPConnection conn, Channel channel, ClientBW message) {
	
}