@@ -0,0 +1,835 @@
+package org.ccnx.ccn.impl.repo;%0A%0Aimport java.io.IOException;%0A%0Aimport org.ccnx.ccn.CCNHandle;%0Aimport org.ccnx.ccn.impl.CCNFlowControl;%0Aimport org.ccnx.ccn.protocol.ContentObject;%0A%0A/**%0A * Special flow controller to write CCN objects to repository internally%0A *%0A */%0A%0Apublic class RepositoryInternalFlowControl extends CCNFlowControl %7B%0A%09RepositoryStore _repo;%0A%0A%09public RepositoryInternalFlowControl(RepositoryStore repo, CCNHandle handle) throws IOException %7B%0A%09%09super(handle);%0A%09%09_repo = repo;%0A%09%7D%0A%09%0A%09/**%0A%09 * Put to the repository instead of ccnd%0A%09 */%0A%09public ContentObject put(ContentObject co) throws IOException %7B%0A%09%09try %7B%0A%09%09%09_repo.saveContent(co);%0A%09%09%7D catch (RepositoryException e) %7B%0A%09%09%09throw new IOException(e.getMessage());%0A%09%09%7D%0A%09%09return co;%0A%09%7D%0A%09%0A%09/**%0A%09 * Don't do waitForPutDrain%0A%09 */%0A%09public void afterClose() throws IOException %7B%7D;%0A%7D%0A

Add new flow controller to allow internal writes to repo