1 /* 2 * This file is part of gtkD. 3 * 4 * gtkD is free software; you can redistribute it and/or modify 5 * it under the terms of the GNU Lesser General Public License 6 * as published by the Free Software Foundation; either version 3 7 * of the License, or (at your option) any later version, with 8 * some exceptions, please read the COPYING file. 9 * 10 * gtkD is distributed in the hope that it will be useful, 11 * but WITHOUT ANY WARRANTY; without even the implied warranty of 12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 13 * GNU Lesser General Public License for more details. 14 * 15 * You should have received a copy of the GNU Lesser General Public License 16 * along with gtkD; if not, write to the Free Software 17 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110, USA 18 */ 19 20 // generated automatically - do not change 21 // find conversion definition on APILookup.txt 22 // implement new conversion functionalities on the wrap.utils pakage 23 24 25 module gio.ThreadedSocketService; 26 27 private import gio.SocketConnection; 28 private import gio.SocketService; 29 private import glib.ConstructionException; 30 private import gobject.ObjectG; 31 private import gobject.Signals; 32 public import gtkc.gdktypes; 33 private import gtkc.gio; 34 public import gtkc.giotypes; 35 36 37 /** 38 * A #GThreadedSocketService is a simple subclass of #GSocketService 39 * that handles incoming connections by creating a worker thread and 40 * dispatching the connection to it by emitting the 41 * #GThreadedSocketService::run signal in the new thread. 42 * 43 * The signal handler may perform blocking IO and need not return 44 * until the connection is closed. 45 * 46 * The service is implemented using a thread pool, so there is a 47 * limited amount of threads available to serve incoming requests. 48 * The service automatically stops the #GSocketService from accepting 49 * new connections when all threads are busy. 50 * 51 * As with #GSocketService, you may connect to #GThreadedSocketService::run, 52 * or subclass and override the default handler. 53 * 54 * Since: 2.22 55 */ 56 public class ThreadedSocketService : SocketService 57 { 58 /** the main Gtk struct */ 59 protected GThreadedSocketService* gThreadedSocketService; 60 61 /** Get the main Gtk struct */ 62 public GThreadedSocketService* getThreadedSocketServiceStruct() 63 { 64 return gThreadedSocketService; 65 } 66 67 /** the main Gtk struct as a void* */ 68 protected override void* getStruct() 69 { 70 return cast(void*)gThreadedSocketService; 71 } 72 73 protected override void setStruct(GObject* obj) 74 { 75 gThreadedSocketService = cast(GThreadedSocketService*)obj; 76 super.setStruct(obj); 77 } 78 79 /** 80 * Sets our main struct and passes it to the parent class. 81 */ 82 public this (GThreadedSocketService* gThreadedSocketService, bool ownedRef = false) 83 { 84 this.gThreadedSocketService = gThreadedSocketService; 85 super(cast(GSocketService*)gThreadedSocketService, ownedRef); 86 } 87 88 /** 89 */ 90 91 public static GType getType() 92 { 93 return g_threaded_socket_service_get_type(); 94 } 95 96 /** 97 * Creates a new #GThreadedSocketService with no listeners. Listeners 98 * must be added with one of the #GSocketListener "add" methods. 99 * 100 * Params: 101 * maxThreads = the maximal number of threads to execute concurrently 102 * handling incoming clients, -1 means no limit 103 * 104 * Return: a new #GSocketService. 105 * 106 * Since: 2.22 107 * 108 * Throws: ConstructionException GTK+ fails to create the object. 109 */ 110 public this(int maxThreads) 111 { 112 auto p = g_threaded_socket_service_new(maxThreads); 113 114 if(p is null) 115 { 116 throw new ConstructionException("null returned by new"); 117 } 118 119 this(cast(GThreadedSocketService*) p, true); 120 } 121 122 int[string] connectedSignals; 123 124 bool delegate(SocketConnection, ObjectG, ThreadedSocketService)[] onRunListeners; 125 /** 126 * The ::run signal is emitted in a worker thread in response to an 127 * incoming connection. This thread is dedicated to handling 128 * @connection and may perform blocking IO. The signal handler need 129 * not return until the connection is closed. 130 * 131 * Params: 132 * connection = a new #GSocketConnection object. 133 * sourceObject = the source_object passed to g_socket_listener_add_address(). 134 * 135 * Return: %TRUE to stop further signal handlers from being called 136 */ 137 void addOnRun(bool delegate(SocketConnection, ObjectG, ThreadedSocketService) dlg, ConnectFlags connectFlags=cast(ConnectFlags)0) 138 { 139 if ( "run" !in connectedSignals ) 140 { 141 Signals.connectData( 142 this, 143 "run", 144 cast(GCallback)&callBackRun, 145 cast(void*)this, 146 null, 147 connectFlags); 148 connectedSignals["run"] = 1; 149 } 150 onRunListeners ~= dlg; 151 } 152 extern(C) static int callBackRun(GThreadedSocketService* threadedsocketserviceStruct, GSocketConnection* connection, GObject* sourceObject, ThreadedSocketService _threadedsocketservice) 153 { 154 foreach ( bool delegate(SocketConnection, ObjectG, ThreadedSocketService) dlg; _threadedsocketservice.onRunListeners ) 155 { 156 if ( dlg(ObjectG.getDObject!(SocketConnection)(connection), ObjectG.getDObject!(ObjectG)(sourceObject), _threadedsocketservice) ) 157 { 158 return 1; 159 } 160 } 161 162 return 0; 163 } 164 }