ClientCacheManager.cs

using System;
using System.Collections;
using System.Collections.Specialized;
using Common;

namespace Client {
        /*************************************************************************/
        public class ClientCacheManager : CacheManager, IResponseHandler {
                readonly long CLIENT_CACHE_SIZE;
                ClientControl clientControl;

                public ClientCacheManager(ClientControl clientControl) : base(clientControl.settings.CacheSize) {
                        this.clientControl = clientControl;
                        CLIENT_CACHE_SIZE = clientControl.settings.CacheSize;
                }

                public void ServiceReq(HTTPRequest req, Connection client) {
                        // we assume that req.uri is in the cache... by the time we're here.
                        if (!uriMapper.IsFresh(req.URI)) { // if URL <-> CHK mapping is not fresh
                                // send 'freshen up' request
//                              Console.WriteLine("- URI Mapping for {0} is not fresh. Spawning HTTP Request", req.URI);
                                HTTPResponseHandler responseHandler = new HTTPResponseHandler(req, client, clientControl);
//                              clientControl.serverStub.Freshen(((URIMappingEntry)uriMapper[req.URI]).CHK, req, responseHandler);
                        }
                        else { // mapping is fresh, so return it from the cache directly.
                                //Console.WriteLine("- Servicing {0} from client cache.", req.URI);
                                client.SendResponse(Get(req));
                        }
                }

                public CacheIndexMessage GetCacheIndexMessage() {
                        return new CacheIndexMessage(cache.GetCacheIndex());
                }

                public void Handle(Message msg) {
                        if (msg.Type == MessageType.CacheUpdateHTTPResponse) {
                                CacheUpdateHTTPResponseMsg typedMsg = (CacheUpdateHTTPResponseMsg)msg;
                                HTTPResponse response; 
                                try {
                                        response = typedMsg.encodedResponse.Decode(this);
                                        Console.WriteLine("> Got (Pushed) Cache Update Message (HTTP Response) for {0}", typedMsg.RequestUri);
                                        UpdateCache(response, typedMsg.RequestUri);
                                } catch (CacheNotFoundException ex) { 
                                        // TODO *** Extend this catch block to include the 'no change' message. Perhaps
                                        // didn't go so well, so thell the server what we do have
                                        Console.WriteLine("***" + ex.Message + "***");
                                        Console.WriteLine("Re-issuing index message");
                                        clientControl.serverStub.SendCacheIndexMessage(this.GetCacheIndexMessage());
                                }
                        } else if (msg.Type == MessageType.CacheUpdateNoChange) {
                                CacheUpdateNoChangeMsg typedMsg = (CacheUpdateNoChangeMsg)msg;
                                Console.WriteLine("> Got (Pushed) Cache Update Message (No Change) for {0}", typedMsg.RequestUri);
                                if (typedMsg.chk == null) {
                                        Console.WriteLine("### NEW CODE: Server has requested cache index. Sending... ###");
                                        clientControl.serverStub.SendCacheIndexMessage(this.GetCacheIndexMessage());
                                } else {
                                        UpdateURIMapping(typedMsg.RequestUri, typedMsg.chk, typedMsg.responseHeaders.rawString);
                                }
                        } else if (msg.Type == MessageType.CacheIndexRequest) {
                                Console.WriteLine("### NEW CODE: Server has requested cache index. Sending... ###");
                                clientControl.serverStub.SendCacheIndexMessage(this.GetCacheIndexMessage());
                        } else {
                                throw new ApplicationException("Client Cache Manager asked to handle inappropriate message");
                        }
                }

                public void Stop() {
                        Console.WriteLine("+++ Stopping Client Cache Manager +++");
                        Console.WriteLine("### TODO: Code Client Cache Manager Start and Stop ###");
                        Console.WriteLine("+++ Client Cache Manager Stopped +++");
                }
        }



}

---