← Back to branch summary

~graphite-dev/carbon/0.9

« back to all changes in this revision

Viewing changes to lib/carbon/service.py

  • Committer: Scott Sanders
  • Date: 2015-05-13 16:11:48 UTC
  • mfrom: (325.1.6)
  • Revision ID: git-v1:3f9b95c17bff209b0e33b686fdc8249da40f8d7a
Merge pull request #405 from jssjr/tunable_tcp_backlog

Tunable tcp backlog

Show diffs side-by-side

added added

removed removed

Lines of Context:
lib/carbon/service.py
62
62
        amqp_spec = settings.get("AMQP_SPEC", None)
63
63
        amqp_exchange_name = settings.get("AMQP_EXCHANGE", "graphite")
64
64
 
65
 
    for interface, port, protocol in ((settings.LINE_RECEIVER_INTERFACE,
66
 
                                       settings.LINE_RECEIVER_PORT,
67
 
                                       MetricLineReceiver),
68
 
                                      (settings.PICKLE_RECEIVER_INTERFACE,
69
 
                                       settings.PICKLE_RECEIVER_PORT,
70
 
                                       MetricPickleReceiver)):
 
65
    for interface, port, backlog, protocol in ((settings.LINE_RECEIVER_INTERFACE,
 
66
                                                settings.LINE_RECEIVER_PORT,
 
67
                                                settings.LINE_RECEIVER_BACKLOG,
 
68
                                                MetricLineReceiver),
 
69
                                               (settings.PICKLE_RECEIVER_INTERFACE,
 
70
                                                settings.PICKLE_RECEIVER_PORT,
 
71
                                                settings.PICKLE_RECEIVER_BACKLOG,
 
72
                                                MetricPickleReceiver)):
71
73
        if port:
72
74
            factory = ServerFactory()
73
75
            factory.protocol = protocol
74
 
            service = TCPServer(int(port), factory, interface=interface)
 
76
            service = TCPServer(int(port), factory, interface=interface, backlog=backlog)
75
77
            service.setServiceParent(root_service)
76
78
 
77
79
    if settings.ENABLE_UDP_LISTENER:
124
126
    factory = ServerFactory()
125
127
    factory.protocol = CacheManagementHandler
126
128
    service = TCPServer(int(settings.CACHE_QUERY_PORT), factory,
127
 
                        interface=settings.CACHE_QUERY_INTERFACE)
 
129
                        interface=settings.CACHE_QUERY_INTERFACE,
 
130
                        backlog=settings.CACHE_QUERY_BACKLOG)
128
131
    service.setServiceParent(root_service)
129
132
 
130
133
    # have to import this *after* settings are defined