forked from chromium/chromium
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathclient_socket_pool_base.h
938 lines (747 loc) · 35 KB
/
client_socket_pool_base.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
// Copyright (c) 2012 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
//
// A ClientSocketPoolBase is used to restrict the number of sockets open at
// a time. It also maintains a list of idle persistent sockets for reuse.
// Subclasses of ClientSocketPool should compose ClientSocketPoolBase to handle
// the core logic of (1) restricting the number of active (connected or
// connecting) sockets per "group" (generally speaking, the hostname), (2)
// maintaining a per-group list of idle, persistent sockets for reuse, and (3)
// limiting the total number of active sockets in the system.
//
// ClientSocketPoolBase abstracts socket connection details behind ConnectJob,
// ConnectJobFactory, and SocketParams. When a socket "slot" becomes available,
// the ClientSocketPoolBase will ask the ConnectJobFactory to create a
// ConnectJob with a SocketParams. Subclasses of ClientSocketPool should
// implement their socket specific connection by subclassing ConnectJob and
// implementing ConnectJob::ConnectInternal(). They can control the parameters
// passed to each new ConnectJob instance via their ConnectJobFactory subclass
// and templated SocketParams parameter.
//
#ifndef NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_
#define NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_
#include <stddef.h>
#include <stdint.h>
#include <cstddef>
#include <list>
#include <map>
#include <memory>
#include <set>
#include <string>
#include <utility>
#include <vector>
#include "base/macros.h"
#include "base/memory/ref_counted.h"
#include "base/memory/weak_ptr.h"
#include "base/time/time.h"
#include "base/timer/timer.h"
#include "net/base/address_list.h"
#include "net/base/completion_callback.h"
#include "net/base/load_states.h"
#include "net/base/load_timing_info.h"
#include "net/base/net_errors.h"
#include "net/base/net_export.h"
#include "net/base/network_change_notifier.h"
#include "net/base/priority_queue.h"
#include "net/base/request_priority.h"
#include "net/log/net_log_with_source.h"
#include "net/socket/client_socket_handle.h"
#include "net/socket/client_socket_pool.h"
#include "net/socket/stream_socket.h"
namespace base {
class DictionaryValue;
namespace trace_event {
class ProcessMemoryDump;
}
}
namespace net {
class ClientSocketHandle;
struct NetLogSource;
// ConnectJob provides an abstract interface for "connecting" a socket.
// The connection may involve host resolution, tcp connection, ssl connection,
// etc.
class NET_EXPORT_PRIVATE ConnectJob {
public:
class NET_EXPORT_PRIVATE Delegate {
public:
Delegate() {}
virtual ~Delegate() {}
// Alerts the delegate that the connection completed. |job| must
// be destroyed by the delegate. A std::unique_ptr<> isn't used because
// the caller of this function doesn't own |job|.
virtual void OnConnectJobComplete(int result,
ConnectJob* job) = 0;
private:
DISALLOW_COPY_AND_ASSIGN(Delegate);
};
// A |timeout_duration| of 0 corresponds to no timeout.
ConnectJob(const std::string& group_name,
base::TimeDelta timeout_duration,
RequestPriority priority,
ClientSocketPool::RespectLimits respect_limits,
Delegate* delegate,
const NetLogWithSource& net_log);
virtual ~ConnectJob();
// Accessors
const std::string& group_name() const { return group_name_; }
const NetLogWithSource& net_log() { return net_log_; }
// Releases ownership of the underlying socket to the caller.
// Returns the released socket, or NULL if there was a connection
// error.
std::unique_ptr<StreamSocket> PassSocket();
void set_motivation(HttpRequestInfo::RequestMotivation motivation) {
motivation_ = motivation;
}
// Begins connecting the socket. Returns OK on success, ERR_IO_PENDING if it
// cannot complete synchronously without blocking, or another net error code
// on error. In asynchronous completion, the ConnectJob will notify
// |delegate_| via OnConnectJobComplete. In both asynchronous and synchronous
// completion, ReleaseSocket() can be called to acquire the connected socket
// if it succeeded.
int Connect();
virtual LoadState GetLoadState() const = 0;
// If Connect returns an error (or OnConnectJobComplete reports an error
// result) this method will be called, allowing the pool to add
// additional error state to the ClientSocketHandle (post late-binding).
virtual void GetAdditionalErrorState(ClientSocketHandle* handle) {}
const LoadTimingInfo::ConnectTiming& connect_timing() const {
return connect_timing_;
}
const NetLogWithSource& net_log() const { return net_log_; }
// TODO(mmenke): Remove when https://crbug.com/756993 is figured out.
// Checks that |group_name_| and |group_name_copy_| are the same. If not,
// crashes.
void CheckGroupName() const;
// Copies |group_name_| and |group_name_copy_| to the stack and crashes.
void LogGroupNameAndCrash() const;
protected:
RequestPriority priority() const { return priority_; }
ClientSocketPool::RespectLimits respect_limits() const {
return respect_limits_;
}
void SetSocket(std::unique_ptr<StreamSocket> socket);
StreamSocket* socket() { return socket_.get(); }
void NotifyDelegateOfCompletion(int rv);
void ResetTimer(base::TimeDelta remainingTime);
// Connection establishment timing information.
LoadTimingInfo::ConnectTiming connect_timing_;
private:
virtual int ConnectInternal() = 0;
void LogConnectStart();
void LogConnectCompletion(int net_error);
// Alerts the delegate that the ConnectJob has timed out.
void OnTimeout();
const std::string group_name_;
// TODO(mmenke): Remove when https://crbug.com/756993 is figured out.
const std::string group_name_copy_;
const base::TimeDelta timeout_duration_;
// TODO(akalin): Support reprioritization.
const RequestPriority priority_;
const ClientSocketPool::RespectLimits respect_limits_;
// Timer to abort jobs that take too long.
base::OneShotTimer timer_;
Delegate* delegate_;
std::unique_ptr<StreamSocket> socket_;
NetLogWithSource net_log_;
HttpRequestInfo::RequestMotivation motivation_;
// A ConnectJob is idle until Connect() has been called.
bool idle_;
DISALLOW_COPY_AND_ASSIGN(ConnectJob);
};
namespace internal {
// ClientSocketPoolBaseHelper is an internal class that implements almost all
// the functionality from ClientSocketPoolBase without using templates.
// ClientSocketPoolBase adds templated definitions built on top of
// ClientSocketPoolBaseHelper. This class is not for external use, please use
// ClientSocketPoolBase instead.
class NET_EXPORT_PRIVATE ClientSocketPoolBaseHelper
: public ConnectJob::Delegate,
public NetworkChangeNotifier::IPAddressObserver {
public:
typedef uint32_t Flags;
// Used to specify specific behavior for the ClientSocketPool.
enum Flag {
NORMAL = 0, // Normal behavior.
NO_IDLE_SOCKETS = 0x1, // Do not return an idle socket. Create a new one.
};
class NET_EXPORT_PRIVATE Request {
public:
Request(ClientSocketHandle* handle,
const CompletionCallback& callback,
RequestPriority priority,
ClientSocketPool::RespectLimits respect_limits,
Flags flags,
const NetLogWithSource& net_log);
virtual ~Request();
ClientSocketHandle* handle() const { return handle_; }
const CompletionCallback& callback() const { return callback_; }
RequestPriority priority() const { return priority_; }
void set_priority(RequestPriority priority) { priority_ = priority; }
ClientSocketPool::RespectLimits respect_limits() const {
return respect_limits_;
}
Flags flags() const { return flags_; }
const NetLogWithSource& net_log() const { return net_log_; }
// TODO(eroman): Temporary until crbug.com/467797 is solved.
void CrashIfInvalid() const;
private:
// TODO(eroman): Temporary until crbug.com/467797 is solved.
enum Liveness {
ALIVE = 0xCA11AB13,
DEAD = 0xDEADBEEF,
};
ClientSocketHandle* const handle_;
const CompletionCallback callback_;
RequestPriority priority_;
const ClientSocketPool::RespectLimits respect_limits_;
const Flags flags_;
const NetLogWithSource net_log_;
// TODO(eroman): Temporary until crbug.com/467797 is solved.
Liveness liveness_ = ALIVE;
DISALLOW_COPY_AND_ASSIGN(Request);
};
class ConnectJobFactory {
public:
ConnectJobFactory() {}
virtual ~ConnectJobFactory() {}
virtual std::unique_ptr<ConnectJob> NewConnectJob(
const std::string& group_name,
const Request& request,
ConnectJob::Delegate* delegate) const = 0;
virtual base::TimeDelta ConnectionTimeout() const = 0;
private:
DISALLOW_COPY_AND_ASSIGN(ConnectJobFactory);
};
ClientSocketPoolBaseHelper(
HigherLayeredPool* pool,
int max_sockets,
int max_sockets_per_group,
base::TimeDelta unused_idle_socket_timeout,
base::TimeDelta used_idle_socket_timeout,
ConnectJobFactory* connect_job_factory);
~ClientSocketPoolBaseHelper() override;
// Adds a lower layered pool to |this|, and adds |this| as a higher layered
// pool on top of |lower_pool|.
void AddLowerLayeredPool(LowerLayeredPool* lower_pool);
// See LowerLayeredPool::IsStalled for documentation on this function.
bool IsStalled() const;
// See LowerLayeredPool for documentation on these functions. It is expected
// in the destructor that no higher layer pools remain.
void AddHigherLayeredPool(HigherLayeredPool* higher_pool);
void RemoveHigherLayeredPool(HigherLayeredPool* higher_pool);
// See ClientSocketPool::RequestSocket for documentation on this function.
int RequestSocket(const std::string& group_name,
std::unique_ptr<Request> request);
// See ClientSocketPool::RequestSockets for documentation on this function.
void RequestSockets(const std::string& group_name,
const Request& request,
int num_sockets,
HttpRequestInfo::RequestMotivation motivation);
// See ClientSocketPool::SetPriority for documentation on this function.
void SetPriority(const std::string& group_name,
ClientSocketHandle* handle,
RequestPriority priority);
// See ClientSocketPool::CancelRequest for documentation on this function.
void CancelRequest(const std::string& group_name,
ClientSocketHandle* handle);
// See ClientSocketPool::ReleaseSocket for documentation on this function.
void ReleaseSocket(const std::string& group_name,
std::unique_ptr<StreamSocket> socket,
int id);
// See ClientSocketPool::FlushWithError for documentation on this function.
void FlushWithError(int error);
// See ClientSocketPool::CloseIdleSockets for documentation on this function.
void CloseIdleSockets();
// See ClientSocketPool::CloseIdleSocketsInGroup for documentation.
void CloseIdleSocketsInGroup(const std::string& group_name);
// See ClientSocketPool::IdleSocketCount() for documentation on this function.
int idle_socket_count() const {
return idle_socket_count_;
}
// See ClientSocketPool::IdleSocketCountInGroup() for documentation on this
// function.
int IdleSocketCountInGroup(const std::string& group_name) const;
// See ClientSocketPool::GetLoadState() for documentation on this function.
LoadState GetLoadState(const std::string& group_name,
const ClientSocketHandle* handle) const;
base::TimeDelta ConnectRetryInterval() const {
// TODO(mbelshe): Make this tuned dynamically based on measured RTT.
// For now, just use the max retry interval.
return base::TimeDelta::FromMilliseconds(
ClientSocketPool::kMaxConnectRetryIntervalMs);
}
int NumUnassignedConnectJobsInGroup(const std::string& group_name) const {
return group_map_.find(group_name)->second->unassigned_job_count();
}
int NumConnectJobsInGroup(const std::string& group_name) const {
return group_map_.find(group_name)->second->jobs().size();
}
int NumActiveSocketsInGroup(const std::string& group_name) const {
return group_map_.find(group_name)->second->active_socket_count();
}
bool HasGroup(const std::string& group_name) const;
// Closes all idle sockets if |force| is true. Else, only closes idle
// sockets that timed out or can't be reused. Made public for testing.
void CleanupIdleSockets(bool force);
// Closes one idle socket. Picks the first one encountered.
// TODO(willchan): Consider a better algorithm for doing this. Perhaps we
// should keep an ordered list of idle sockets, and close them in order.
// Requires maintaining more state. It's not clear if it's worth it since
// I'm not sure if we hit this situation often.
bool CloseOneIdleSocket();
// Checks higher layered pools to see if they can close an idle connection.
bool CloseOneIdleConnectionInHigherLayeredPool();
// See ClientSocketPool::GetInfoAsValue for documentation on this function.
std::unique_ptr<base::DictionaryValue> GetInfoAsValue(
const std::string& name,
const std::string& type) const;
// Dumps memory allocation stats. |parent_dump_absolute_name| is the name
// used by the parent MemoryAllocatorDump in the memory dump hierarchy.
void DumpMemoryStats(base::trace_event::ProcessMemoryDump* pmd,
const std::string& parent_dump_absolute_name) const;
base::TimeDelta ConnectionTimeout() const {
return connect_job_factory_->ConnectionTimeout();
}
static bool connect_backup_jobs_enabled();
static bool set_connect_backup_jobs_enabled(bool enabled);
void EnableConnectBackupJobs();
// ConnectJob::Delegate methods:
void OnConnectJobComplete(int result, ConnectJob* job) override;
// NetworkChangeNotifier::IPAddressObserver methods:
void OnIPAddressChanged() override;
private:
// Entry for a persistent socket which became idle at time |start_time|.
struct IdleSocket {
IdleSocket() : socket(NULL) {}
// An idle socket can't be used if it is disconnected or has been used
// before and has received data unexpectedly (hence no longer idle). The
// unread data would be mistaken for the beginning of the next response if
// we were to use the socket for a new request.
//
// Note that a socket that has never been used before (like a preconnected
// socket) may be used even with unread data. This may be, e.g., a SPDY
// SETTINGS frame.
bool IsUsable() const;
StreamSocket* socket;
base::TimeTicks start_time;
};
typedef PriorityQueue<Request*> RequestQueue;
typedef std::map<const ClientSocketHandle*, Request*> RequestMap;
// A Group is allocated per group_name when there are idle sockets or pending
// requests. Otherwise, the Group object is removed from the map.
// |active_socket_count| tracks the number of sockets held by clients.
class Group {
public:
using JobList = std::list<std::unique_ptr<ConnectJob>>;
Group();
~Group();
bool IsEmpty() const {
return active_socket_count_ == 0 && idle_sockets_.empty() &&
jobs_.empty() && pending_requests_.empty();
}
bool HasAvailableSocketSlot(int max_sockets_per_group) const {
return NumActiveSocketSlots() < max_sockets_per_group;
}
int NumActiveSocketSlots() const {
return active_socket_count_ + static_cast<int>(jobs_.size()) +
static_cast<int>(idle_sockets_.size());
}
// Returns true if the group could make use of an additional socket slot, if
// it were given one.
bool CanUseAdditionalSocketSlot(int max_sockets_per_group) const {
return HasAvailableSocketSlot(max_sockets_per_group) &&
pending_requests_.size() > jobs_.size();
}
// Returns the priority of the top of the pending request queue
// (which may be less than the maximum priority over the entire
// queue, due to how we prioritize requests with |respect_limits|
// DISABLED over others).
RequestPriority TopPendingPriority() const {
// NOTE: FirstMax().value()->priority() is not the same as
// FirstMax().priority()!
return pending_requests_.FirstMax().value()->priority();
}
// Set a timer to create a backup job if it takes too long to
// create one and if a timer isn't already running.
void StartBackupJobTimer(const std::string& group_name,
ClientSocketPoolBaseHelper* pool);
bool BackupJobTimerIsRunning() const;
// If there's a ConnectJob that's never been assigned to Request,
// decrements |unassigned_job_count_| and returns true.
// Otherwise, returns false.
bool TryToUseUnassignedConnectJob();
void AddJob(std::unique_ptr<ConnectJob> job, bool is_preconnect);
// Remove |job| from this group, which must already own |job|.
void RemoveJob(ConnectJob* job);
void RemoveAllJobs();
bool has_pending_requests() const {
return !pending_requests_.empty();
}
size_t pending_request_count() const {
return pending_requests_.size();
}
// Gets (but does not remove) the next pending request. Returns
// NULL if there are no pending requests.
const Request* GetNextPendingRequest() const;
// Returns true if there is a connect job for |handle|.
bool HasConnectJobForHandle(const ClientSocketHandle* handle) const;
// Inserts the request into the queue based on priority
// order. Older requests are prioritized over requests of equal
// priority.
void InsertPendingRequest(std::unique_ptr<Request> request);
// Gets and removes the next pending request. Returns NULL if
// there are no pending requests.
std::unique_ptr<Request> PopNextPendingRequest();
// Finds the pending request for |handle| and removes it. Returns
// the removed pending request, or NULL if there was none.
std::unique_ptr<Request> FindAndRemovePendingRequest(
ClientSocketHandle* handle);
// Change the priority of the request named by |*handle|. |*handle|
// must refer to a request currently present in the group. If |priority|
// is the same as the current priority of the request, this is a no-op.
void SetPriority(ClientSocketHandle* handle, RequestPriority priority);
void IncrementActiveSocketCount() { active_socket_count_++; }
void DecrementActiveSocketCount() { active_socket_count_--; }
int unassigned_job_count() const { return unassigned_job_count_; }
const JobList& jobs() const { return jobs_; }
const std::list<IdleSocket>& idle_sockets() const { return idle_sockets_; }
int active_socket_count() const { return active_socket_count_; }
std::list<IdleSocket>* mutable_idle_sockets() { return &idle_sockets_; }
private:
// Returns the iterator's pending request after removing it from
// the queue.
std::unique_ptr<Request> RemovePendingRequest(
const RequestQueue::Pointer& pointer);
// Called when the backup socket timer fires.
void OnBackupJobTimerFired(
std::string group_name,
ClientSocketPoolBaseHelper* pool);
// Checks that |unassigned_job_count_| does not execeed the number of
// ConnectJobs.
void SanityCheck();
// Total number of ConnectJobs that have never been assigned to a Request.
// Since jobs use late binding to requests, which ConnectJobs have or have
// not been assigned to a request are not tracked. This is incremented on
// preconnect and decremented when a preconnect is assigned, or when there
// are fewer than |unassigned_job_count_| ConnectJobs. Not incremented
// when a request is cancelled.
size_t unassigned_job_count_;
std::list<IdleSocket> idle_sockets_;
JobList jobs_;
RequestQueue pending_requests_;
int active_socket_count_; // number of active sockets used by clients
// A timer for when to start the backup job.
base::OneShotTimer backup_job_timer_;
};
typedef std::map<std::string, Group*> GroupMap;
typedef std::set<ConnectJob*> ConnectJobSet;
struct CallbackResultPair {
CallbackResultPair();
CallbackResultPair(const CompletionCallback& callback_in, int result_in);
CallbackResultPair(const CallbackResultPair& other);
~CallbackResultPair();
CompletionCallback callback;
int result;
};
typedef std::map<const ClientSocketHandle*, CallbackResultPair>
PendingCallbackMap;
// Closes all idle sockets in |group| if |force| is true. Else, only closes
// idle sockets in |group| that timed out with respect to |now| or can't be
// reused.
void CleanupIdleSocketsInGroup(bool force,
Group* group,
const base::TimeTicks& now);
Group* GetOrCreateGroup(const std::string& group_name);
void RemoveGroup(const std::string& group_name);
void RemoveGroup(GroupMap::iterator it);
// Called when the number of idle sockets changes.
void IncrementIdleCount();
void DecrementIdleCount();
// Scans the group map for groups which have an available socket slot and
// at least one pending request. Returns true if any groups are stalled, and
// if so (and if both |group| and |group_name| are not NULL), fills |group|
// and |group_name| with data of the stalled group having highest priority.
bool FindTopStalledGroup(Group** group, std::string* group_name) const;
// Removes |job| from |group|, which must already own |job|.
void RemoveConnectJob(ConnectJob* job, Group* group);
// Tries to see if we can handle any more requests for |group|.
void OnAvailableSocketSlot(const std::string& group_name, Group* group);
// Process a pending socket request for a group.
void ProcessPendingRequest(const std::string& group_name, Group* group);
// Assigns |socket| to |handle| and updates |group|'s counters appropriately.
void HandOutSocket(std::unique_ptr<StreamSocket> socket,
ClientSocketHandle::SocketReuseType reuse_type,
const LoadTimingInfo::ConnectTiming& connect_timing,
ClientSocketHandle* handle,
base::TimeDelta time_idle,
Group* group,
const NetLogWithSource& net_log);
// Adds |socket| to the list of idle sockets for |group|.
void AddIdleSocket(std::unique_ptr<StreamSocket> socket, Group* group);
// Iterates through |group_map_|, canceling all ConnectJobs and deleting
// groups if they are no longer needed.
void CancelAllConnectJobs();
// Iterates through |group_map_|, posting |error| callbacks for all
// requests, and then deleting groups if they are no longer needed.
void CancelAllRequestsWithError(int error);
// Returns true if we can't create any more sockets due to the total limit.
bool ReachedMaxSocketsLimit() const;
// This is the internal implementation of RequestSocket(). It differs in that
// it does not handle logging into NetLog of the queueing status of
// |request|.
int RequestSocketInternal(const std::string& group_name,
const Request& request,
HttpRequestInfo::RequestMotivation motivation);
// Assigns an idle socket for the group to the request.
// Returns |true| if an idle socket is available, false otherwise.
bool AssignIdleSocketToRequest(const Request& request, Group* group);
static void LogBoundConnectJobToRequest(
const NetLogSource& connect_job_source,
const Request& request);
// Same as CloseOneIdleSocket() except it won't close an idle socket in
// |group|. If |group| is NULL, it is ignored. Returns true if it closed a
// socket.
bool CloseOneIdleSocketExceptInGroup(const Group* group);
// Checks if there are stalled socket groups that should be notified
// for possible wakeup.
void CheckForStalledSocketGroups();
// Posts a task to call InvokeUserCallback() on the next iteration through the
// current message loop. Inserts |callback| into |pending_callback_map_|,
// keyed by |handle|.
void InvokeUserCallbackLater(
ClientSocketHandle* handle, const CompletionCallback& callback, int rv);
// Invokes the user callback for |handle|. By the time this task has run,
// it's possible that the request has been cancelled, so |handle| may not
// exist in |pending_callback_map_|. We look up the callback and result code
// in |pending_callback_map_|.
void InvokeUserCallback(ClientSocketHandle* handle);
// Tries to close idle sockets in a higher level socket pool as long as this
// this pool is stalled.
void TryToCloseSocketsInLayeredPools();
GroupMap group_map_;
// Map of the ClientSocketHandles for which we have a pending Task to invoke a
// callback. This is necessary since, before we invoke said callback, it's
// possible that the request is cancelled.
PendingCallbackMap pending_callback_map_;
// The total number of idle sockets in the system.
int idle_socket_count_;
// Number of connecting sockets across all groups.
int connecting_socket_count_;
// Number of connected sockets we handed out across all groups.
int handed_out_socket_count_;
// The maximum total number of sockets. See ReachedMaxSocketsLimit.
const int max_sockets_;
// The maximum number of sockets kept per group.
const int max_sockets_per_group_;
// The time to wait until closing idle sockets.
const base::TimeDelta unused_idle_socket_timeout_;
const base::TimeDelta used_idle_socket_timeout_;
const std::unique_ptr<ConnectJobFactory> connect_job_factory_;
// TODO(vandebo) Remove when backup jobs move to TransportClientSocketPool
bool connect_backup_jobs_enabled_;
// A unique id for the pool. It gets incremented every time we
// FlushWithError() the pool. This is so that when sockets get released back
// to the pool, we can make sure that they are discarded rather than reused.
int pool_generation_number_;
// Used to add |this| as a higher layer pool on top of lower layer pools. May
// be NULL if no lower layer pools will be added.
HigherLayeredPool* pool_;
// Pools that create connections through |this|. |this| will try to close
// their idle sockets when it stalls. Must be empty on destruction.
std::set<HigherLayeredPool*> higher_pools_;
// Pools that this goes through. Typically there's only one, but not always.
// |this| will check if they're stalled when it has a new idle socket. |this|
// will remove itself from all lower layered pools on destruction.
std::set<LowerLayeredPool*> lower_pools_;
base::WeakPtrFactory<ClientSocketPoolBaseHelper> weak_factory_;
DISALLOW_COPY_AND_ASSIGN(ClientSocketPoolBaseHelper);
};
} // namespace internal
template <typename SocketParams>
class ClientSocketPoolBase {
public:
class Request : public internal::ClientSocketPoolBaseHelper::Request {
public:
Request(ClientSocketHandle* handle,
const CompletionCallback& callback,
RequestPriority priority,
ClientSocketPool::RespectLimits respect_limits,
internal::ClientSocketPoolBaseHelper::Flags flags,
const scoped_refptr<SocketParams>& params,
const NetLogWithSource& net_log)
: internal::ClientSocketPoolBaseHelper::Request(handle,
callback,
priority,
respect_limits,
flags,
net_log),
params_(params) {}
const scoped_refptr<SocketParams>& params() const { return params_; }
private:
const scoped_refptr<SocketParams> params_;
};
class ConnectJobFactory {
public:
ConnectJobFactory() {}
virtual ~ConnectJobFactory() {}
virtual std::unique_ptr<ConnectJob> NewConnectJob(
const std::string& group_name,
const Request& request,
ConnectJob::Delegate* delegate) const = 0;
virtual base::TimeDelta ConnectionTimeout() const = 0;
private:
DISALLOW_COPY_AND_ASSIGN(ConnectJobFactory);
};
// |max_sockets| is the maximum number of sockets to be maintained by this
// ClientSocketPool. |max_sockets_per_group| specifies the maximum number of
// sockets a "group" can have. |unused_idle_socket_timeout| specifies how
// long to leave an unused idle socket open before closing it.
// |used_idle_socket_timeout| specifies how long to leave a previously used
// idle socket open before closing it.
ClientSocketPoolBase(HigherLayeredPool* self,
int max_sockets,
int max_sockets_per_group,
base::TimeDelta unused_idle_socket_timeout,
base::TimeDelta used_idle_socket_timeout,
ConnectJobFactory* connect_job_factory)
: helper_(self,
max_sockets,
max_sockets_per_group,
unused_idle_socket_timeout,
used_idle_socket_timeout,
new ConnectJobFactoryAdaptor(connect_job_factory)) {}
virtual ~ClientSocketPoolBase() {}
// These member functions simply forward to ClientSocketPoolBaseHelper.
void AddLowerLayeredPool(LowerLayeredPool* lower_pool) {
helper_.AddLowerLayeredPool(lower_pool);
}
void AddHigherLayeredPool(HigherLayeredPool* higher_pool) {
helper_.AddHigherLayeredPool(higher_pool);
}
void RemoveHigherLayeredPool(HigherLayeredPool* higher_pool) {
helper_.RemoveHigherLayeredPool(higher_pool);
}
// RequestSocket bundles up the parameters into a Request and then forwards to
// ClientSocketPoolBaseHelper::RequestSocket().
int RequestSocket(const std::string& group_name,
const scoped_refptr<SocketParams>& params,
RequestPriority priority,
ClientSocketPool::RespectLimits respect_limits,
ClientSocketHandle* handle,
const CompletionCallback& callback,
const NetLogWithSource& net_log) {
std::unique_ptr<Request> request(new Request(
handle, callback, priority, respect_limits,
internal::ClientSocketPoolBaseHelper::NORMAL, params, net_log));
return helper_.RequestSocket(group_name, std::move(request));
}
// RequestSockets bundles up the parameters into a Request and then forwards
// to ClientSocketPoolBaseHelper::RequestSockets(). Note that it assigns the
// priority to IDLE and specifies the NO_IDLE_SOCKETS flag.
void RequestSockets(const std::string& group_name,
const scoped_refptr<SocketParams>& params,
int num_sockets,
const NetLogWithSource& net_log,
HttpRequestInfo::RequestMotivation motivation) {
const Request request(nullptr /* no handle */, CompletionCallback(), IDLE,
ClientSocketPool::RespectLimits::ENABLED,
internal::ClientSocketPoolBaseHelper::NO_IDLE_SOCKETS,
params, net_log);
helper_.RequestSockets(group_name, request, num_sockets, motivation);
}
void SetPriority(const std::string& group_name,
ClientSocketHandle* handle,
RequestPriority priority) {
return helper_.SetPriority(group_name, handle, priority);
}
void CancelRequest(const std::string& group_name,
ClientSocketHandle* handle) {
return helper_.CancelRequest(group_name, handle);
}
void ReleaseSocket(const std::string& group_name,
std::unique_ptr<StreamSocket> socket,
int id) {
return helper_.ReleaseSocket(group_name, std::move(socket), id);
}
void FlushWithError(int error) { helper_.FlushWithError(error); }
bool IsStalled() const { return helper_.IsStalled(); }
void CloseIdleSockets() { return helper_.CloseIdleSockets(); }
void CloseIdleSocketsInGroup(const std::string& group_name) {
return helper_.CloseIdleSocketsInGroup(group_name);
}
int idle_socket_count() const { return helper_.idle_socket_count(); }
int IdleSocketCountInGroup(const std::string& group_name) const {
return helper_.IdleSocketCountInGroup(group_name);
}
LoadState GetLoadState(const std::string& group_name,
const ClientSocketHandle* handle) const {
return helper_.GetLoadState(group_name, handle);
}
void DumpMemoryStats(base::trace_event::ProcessMemoryDump* pmd,
const std::string& parent_dump_absolute_name) const {
return helper_.DumpMemoryStats(pmd, parent_dump_absolute_name);
}
virtual void OnConnectJobComplete(int result, ConnectJob* job) {
return helper_.OnConnectJobComplete(result, job);
}
int NumUnassignedConnectJobsInGroup(const std::string& group_name) const {
return helper_.NumUnassignedConnectJobsInGroup(group_name);
}
int NumConnectJobsInGroup(const std::string& group_name) const {
return helper_.NumConnectJobsInGroup(group_name);
}
int NumActiveSocketsInGroup(const std::string& group_name) const {
return helper_.NumActiveSocketsInGroup(group_name);
}
bool HasGroup(const std::string& group_name) const {
return helper_.HasGroup(group_name);
}
void CleanupIdleSockets(bool force) {
return helper_.CleanupIdleSockets(force);
}
std::unique_ptr<base::DictionaryValue> GetInfoAsValue(
const std::string& name,
const std::string& type) const {
return helper_.GetInfoAsValue(name, type);
}
base::TimeDelta ConnectionTimeout() const {
return helper_.ConnectionTimeout();
}
void EnableConnectBackupJobs() { helper_.EnableConnectBackupJobs(); }
bool CloseOneIdleSocket() { return helper_.CloseOneIdleSocket(); }
bool CloseOneIdleConnectionInHigherLayeredPool() {
return helper_.CloseOneIdleConnectionInHigherLayeredPool();
}
private:
// This adaptor class exists to bridge the
// internal::ClientSocketPoolBaseHelper::ConnectJobFactory and
// ClientSocketPoolBase::ConnectJobFactory types, allowing clients to use the
// typesafe ClientSocketPoolBase::ConnectJobFactory, rather than having to
// static_cast themselves.
class ConnectJobFactoryAdaptor
: public internal::ClientSocketPoolBaseHelper::ConnectJobFactory {
public:
typedef typename ClientSocketPoolBase<SocketParams>::ConnectJobFactory
ConnectJobFactory;
explicit ConnectJobFactoryAdaptor(ConnectJobFactory* connect_job_factory)
: connect_job_factory_(connect_job_factory) {}
~ConnectJobFactoryAdaptor() override {}
std::unique_ptr<ConnectJob> NewConnectJob(
const std::string& group_name,
const internal::ClientSocketPoolBaseHelper::Request& request,
ConnectJob::Delegate* delegate) const override {
const Request& casted_request = static_cast<const Request&>(request);
return connect_job_factory_->NewConnectJob(
group_name, casted_request, delegate);
}
base::TimeDelta ConnectionTimeout() const override {
return connect_job_factory_->ConnectionTimeout();
}
const std::unique_ptr<ConnectJobFactory> connect_job_factory_;
};
internal::ClientSocketPoolBaseHelper helper_;
DISALLOW_COPY_AND_ASSIGN(ClientSocketPoolBase);
};
} // namespace net
#endif // NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_