anchor.diff:  	 case file:read(DataFile,3) of
       	{ok,<<3,3,3>>} -> lager:info("Last message found at ~p in ~p, truncating file...",[Offset,FileName]),
       					  file:truncate(DataFile);
  -    	Data           -> fix_file(DataFile,NewOffset,FileName)
  +    	_Data          -> fix_file(DataFile,NewOffset,FileName)
       end.
   
   
  
positive.code: writer_init(From,Stream,SliceName) ->
  	% First ensure stream directory exists...
  	{ok,DataDir} = application:get_env(cake,data_dir),
  	Path = DataDir ++ binary_to_list(Stream) ++ "/",
  	filelib:ensure_dir(Path),
  	DataFile  = Path ++ SliceName ++ ".data",
  	IndexFile = Path ++ SliceName ++ ".index",
  	lager:debug("Data File:   ~p",[DataFile]),
  	lager:debug("Index File:  ~p",[IndexFile]),
  	{ok,File}   = file:open(DataFile,[append,raw,{delayed_write, 50*1024*1024, 10000}]),  % Wait for 50MB of 10 seconds before flushing
  	{ok,FileInfo} = file:read_file_info(DataFile),
  	{ok,Index}  = file:open(IndexFile,[append,raw]),
  
  
negative.code: 	loop(Writer,[],true,0,0,Stream).
  
  loop(Writer,DataList,ClearToSend,LastTS,Count,StreamName) ->
          case length(DataList) > 0 of
  		true ->
                          case ClearToSend of
  				true ->
  					lager:debug("Now clear to send - sending what we have..."),
  					Writer ! {Count,LastTS,lists:reverse(DataList)},
  					loop(Writer,[],false,LastTS,0,StreamName);
  				false ->
  					lager:debug("Have data, waiting for clear to send")
  			end;
  		false ->
                          lager:debug("Have no data, listening")
  	end,	
  	receive
  		Message ->
  			case Message of 
  