Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * (C) Copyright 2013 Kurento (http://kurento.org/)
   *
   * All rights reserved. This program and the accompanying materials
   * are made available under the terms of the GNU Lesser General Public License
   * (LGPL) version 2.1 which accompanies this distribution, and is available at
   * http://www.gnu.org/licenses/lgpl-2.1.html
   *
   * This library 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.
  *
  */
 
 package com.kurento.kmf.repository.internal;
 
 import java.util.Date;
 
 
 
 public class RepositoryHttpEndpointImpl implements RepositoryHttpEndpoint {
 
 	private final RepositoryItem repositoryItem;
 
 	private final String sessionId;
 	private final String url;
 
 	private OutputStream os;
 
 	private final ListenerManager listeners = new ListenerManager();
 
 	private long disconnectionTimeoutInMillis = 5000;
 
 	@SuppressWarnings("rawtypes")
 
 	private boolean startedEventFired;
 
 	private long writtenBytes;
 	private boolean outputStreamClosed;
 
 	public RepositoryHttpEndpointImpl(RepositoryItem repositoryItem,
 			String sessionIdString urlRepositoryHttpManager httpManager) {
 		this. = repositoryItem;
 		this. = sessionId;
 		this. = url;
 		this. = httpManager;
 	}
 
 	public String getURL() {
 		return ;
 	}
 
 	public String getDispatchURL() {
 	}
 
 	public void setAutoTerminationTimeout(long timeoutInMillis) {
 		this. = timeoutInMillis;
 	}
 
 	public long getAutoTerminationTimeout() {
 	}
 
 	public void addSessionStartedListener(
 	}
 
 	}
 
 	}
	}
	}
	public synchronized void fireStartedEventIfFirstTime() {
		}
	}
	public void fireSessionTerminatedEvent() {
	}
	}
	}
			throw new IllegalStateException("The outputStream is closed");
		}
		if ( == null) {
				protected void afterWrite(int nthrows IOException {
				}
				public void close() throws IOException {
					super.close();
				}
			};
		}
		return ;
	}
	private void addWrittenBytes(int numBytes) {
		 += numBytes;
	}
	public long getWrittenBytes() {
		return ;
	}
	// TODO Review for potentially race conditions if the timer is cancelled at
	// the same time it is executing
	public void stopInTimeout() {
				new Runnable() {
					public void run() {
					}
				},
				new Date(System.currentTimeMillis()
	}
	public void stopCurrentTimer() {
		if ( != null) {
		}
	}
	public String getSessionId() {
		return ;
	}
	public void fireSessionErrorEvent(Exception e) {
	}
	public void forceStopHttpManager(String message) {
	}
	// TODO Review for potentially race conditions if the timer is cancelled at
	// the same time it is executing
	// TODO Investigate how to "lock" the item when is been served to a client.
	// If we don't do, we can obtain a closed stream exception
	public void stop() {
	}
	private void stopTimerAndCloseOS() {
		if ( != null) {
		}
		if ( != null) {
			try {
catch (IOException e) {
				throw new KurentoException(e);
			}
		}
	}
New to GrepCode? Check out our FAQ X