ptp_clock.c 8.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346
  1. /*
  2. * PTP 1588 clock support
  3. *
  4. * Copyright (C) 2010 OMICRON electronics GmbH
  5. *
  6. * This program is free software; you can redistribute it and/or modify
  7. * it under the terms of the GNU General Public License as published by
  8. * the Free Software Foundation; either version 2 of the License, or
  9. * (at your option) any later version.
  10. *
  11. * This program is distributed in the hope that it will be useful,
  12. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. * GNU General Public License for more details.
  15. *
  16. * You should have received a copy of the GNU General Public License
  17. * along with this program; if not, write to the Free Software
  18. * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  19. */
  20. #include <linux/bitops.h>
  21. #include <linux/device.h>
  22. #include <linux/err.h>
  23. #include <linux/init.h>
  24. #include <linux/kernel.h>
  25. #include <linux/module.h>
  26. #include <linux/posix-clock.h>
  27. #include <linux/pps_kernel.h>
  28. #include <linux/slab.h>
  29. #include <linux/syscalls.h>
  30. #include <linux/uaccess.h>
  31. #include "ptp_private.h"
  32. #define PTP_MAX_ALARMS 4
  33. #define PTP_MAX_CLOCKS 8
  34. #define PTP_PPS_DEFAULTS (PPS_CAPTUREASSERT | PPS_OFFSETASSERT)
  35. #define PTP_PPS_EVENT PPS_CAPTUREASSERT
  36. #define PTP_PPS_MODE (PTP_PPS_DEFAULTS | PPS_CANWAIT | PPS_TSFMT_TSPEC)
  37. /* private globals */
  38. static dev_t ptp_devt;
  39. static struct class *ptp_class;
  40. static DECLARE_BITMAP(ptp_clocks_map, PTP_MAX_CLOCKS);
  41. static DEFINE_MUTEX(ptp_clocks_mutex); /* protects 'ptp_clocks_map' */
  42. /* time stamp event queue operations */
  43. static inline int queue_free(struct timestamp_event_queue *q)
  44. {
  45. return PTP_MAX_TIMESTAMPS - queue_cnt(q) - 1;
  46. }
  47. static void enqueue_external_timestamp(struct timestamp_event_queue *queue,
  48. struct ptp_clock_event *src)
  49. {
  50. struct ptp_extts_event *dst;
  51. unsigned long flags;
  52. s64 seconds;
  53. u32 remainder;
  54. seconds = div_u64_rem(src->timestamp, 1000000000, &remainder);
  55. spin_lock_irqsave(&queue->lock, flags);
  56. dst = &queue->buf[queue->tail];
  57. dst->index = src->index;
  58. dst->t.sec = seconds;
  59. dst->t.nsec = remainder;
  60. if (!queue_free(queue))
  61. queue->head = (queue->head + 1) % PTP_MAX_TIMESTAMPS;
  62. queue->tail = (queue->tail + 1) % PTP_MAX_TIMESTAMPS;
  63. spin_unlock_irqrestore(&queue->lock, flags);
  64. }
  65. static s32 scaled_ppm_to_ppb(long ppm)
  66. {
  67. /*
  68. * The 'freq' field in the 'struct timex' is in parts per
  69. * million, but with a 16 bit binary fractional field.
  70. *
  71. * We want to calculate
  72. *
  73. * ppb = scaled_ppm * 1000 / 2^16
  74. *
  75. * which simplifies to
  76. *
  77. * ppb = scaled_ppm * 125 / 2^13
  78. */
  79. s64 ppb = 1 + ppm;
  80. ppb *= 125;
  81. ppb >>= 13;
  82. return (s32) ppb;
  83. }
  84. /* posix clock implementation */
  85. static int ptp_clock_getres(struct posix_clock *pc, struct timespec *tp)
  86. {
  87. tp->tv_sec = 0;
  88. tp->tv_nsec = 1;
  89. return 0;
  90. }
  91. static int ptp_clock_settime(struct posix_clock *pc, const struct timespec *tp)
  92. {
  93. struct ptp_clock *ptp = container_of(pc, struct ptp_clock, clock);
  94. return ptp->info->settime(ptp->info, tp);
  95. }
  96. static int ptp_clock_gettime(struct posix_clock *pc, struct timespec *tp)
  97. {
  98. struct ptp_clock *ptp = container_of(pc, struct ptp_clock, clock);
  99. return ptp->info->gettime(ptp->info, tp);
  100. }
  101. static int ptp_clock_adjtime(struct posix_clock *pc, struct timex *tx)
  102. {
  103. struct ptp_clock *ptp = container_of(pc, struct ptp_clock, clock);
  104. struct ptp_clock_info *ops;
  105. int err = -EOPNOTSUPP;
  106. ops = ptp->info;
  107. if (tx->modes & ADJ_SETOFFSET) {
  108. struct timespec ts;
  109. ktime_t kt;
  110. s64 delta;
  111. ts.tv_sec = tx->time.tv_sec;
  112. ts.tv_nsec = tx->time.tv_usec;
  113. if (!(tx->modes & ADJ_NANO))
  114. ts.tv_nsec *= 1000;
  115. if ((unsigned long) ts.tv_nsec >= NSEC_PER_SEC)
  116. return -EINVAL;
  117. kt = timespec_to_ktime(ts);
  118. delta = ktime_to_ns(kt);
  119. err = ops->adjtime(ops, delta);
  120. } else if (tx->modes & ADJ_FREQUENCY) {
  121. err = ops->adjfreq(ops, scaled_ppm_to_ppb(tx->freq));
  122. }
  123. return err;
  124. }
  125. static struct posix_clock_operations ptp_clock_ops = {
  126. .owner = THIS_MODULE,
  127. .clock_adjtime = ptp_clock_adjtime,
  128. .clock_gettime = ptp_clock_gettime,
  129. .clock_getres = ptp_clock_getres,
  130. .clock_settime = ptp_clock_settime,
  131. .ioctl = ptp_ioctl,
  132. .open = ptp_open,
  133. .poll = ptp_poll,
  134. .read = ptp_read,
  135. };
  136. static void delete_ptp_clock(struct posix_clock *pc)
  137. {
  138. struct ptp_clock *ptp = container_of(pc, struct ptp_clock, clock);
  139. mutex_destroy(&ptp->tsevq_mux);
  140. /* Remove the clock from the bit map. */
  141. mutex_lock(&ptp_clocks_mutex);
  142. clear_bit(ptp->index, ptp_clocks_map);
  143. mutex_unlock(&ptp_clocks_mutex);
  144. kfree(ptp);
  145. }
  146. /* public interface */
  147. struct ptp_clock *ptp_clock_register(struct ptp_clock_info *info)
  148. {
  149. struct ptp_clock *ptp;
  150. int err = 0, index, major = MAJOR(ptp_devt);
  151. if (info->n_alarm > PTP_MAX_ALARMS)
  152. return ERR_PTR(-EINVAL);
  153. /* Find a free clock slot and reserve it. */
  154. err = -EBUSY;
  155. mutex_lock(&ptp_clocks_mutex);
  156. index = find_first_zero_bit(ptp_clocks_map, PTP_MAX_CLOCKS);
  157. if (index < PTP_MAX_CLOCKS)
  158. set_bit(index, ptp_clocks_map);
  159. else
  160. goto no_slot;
  161. /* Initialize a clock structure. */
  162. err = -ENOMEM;
  163. ptp = kzalloc(sizeof(struct ptp_clock), GFP_KERNEL);
  164. if (ptp == NULL)
  165. goto no_memory;
  166. ptp->clock.ops = ptp_clock_ops;
  167. ptp->clock.release = delete_ptp_clock;
  168. ptp->info = info;
  169. ptp->devid = MKDEV(major, index);
  170. ptp->index = index;
  171. spin_lock_init(&ptp->tsevq.lock);
  172. mutex_init(&ptp->tsevq_mux);
  173. init_waitqueue_head(&ptp->tsev_wq);
  174. /* Create a new device in our class. */
  175. ptp->dev = device_create(ptp_class, NULL, ptp->devid, ptp,
  176. "ptp%d", ptp->index);
  177. if (IS_ERR(ptp->dev))
  178. goto no_device;
  179. dev_set_drvdata(ptp->dev, ptp);
  180. err = ptp_populate_sysfs(ptp);
  181. if (err)
  182. goto no_sysfs;
  183. /* Register a new PPS source. */
  184. if (info->pps) {
  185. struct pps_source_info pps;
  186. memset(&pps, 0, sizeof(pps));
  187. snprintf(pps.name, PPS_MAX_NAME_LEN, "ptp%d", index);
  188. pps.mode = PTP_PPS_MODE;
  189. pps.owner = info->owner;
  190. ptp->pps_source = pps_register_source(&pps, PTP_PPS_DEFAULTS);
  191. if (!ptp->pps_source) {
  192. pr_err("failed to register pps source\n");
  193. goto no_pps;
  194. }
  195. }
  196. /* Create a posix clock. */
  197. err = posix_clock_register(&ptp->clock, ptp->devid);
  198. if (err) {
  199. pr_err("failed to create posix clock\n");
  200. goto no_clock;
  201. }
  202. mutex_unlock(&ptp_clocks_mutex);
  203. return ptp;
  204. no_clock:
  205. if (ptp->pps_source)
  206. pps_unregister_source(ptp->pps_source);
  207. no_pps:
  208. ptp_cleanup_sysfs(ptp);
  209. no_sysfs:
  210. device_destroy(ptp_class, ptp->devid);
  211. no_device:
  212. mutex_destroy(&ptp->tsevq_mux);
  213. kfree(ptp);
  214. no_memory:
  215. clear_bit(index, ptp_clocks_map);
  216. no_slot:
  217. mutex_unlock(&ptp_clocks_mutex);
  218. return ERR_PTR(err);
  219. }
  220. EXPORT_SYMBOL(ptp_clock_register);
  221. int ptp_clock_unregister(struct ptp_clock *ptp)
  222. {
  223. ptp->defunct = 1;
  224. wake_up_interruptible(&ptp->tsev_wq);
  225. /* Release the clock's resources. */
  226. if (ptp->pps_source)
  227. pps_unregister_source(ptp->pps_source);
  228. ptp_cleanup_sysfs(ptp);
  229. device_destroy(ptp_class, ptp->devid);
  230. posix_clock_unregister(&ptp->clock);
  231. return 0;
  232. }
  233. EXPORT_SYMBOL(ptp_clock_unregister);
  234. void ptp_clock_event(struct ptp_clock *ptp, struct ptp_clock_event *event)
  235. {
  236. struct pps_event_time evt;
  237. switch (event->type) {
  238. case PTP_CLOCK_ALARM:
  239. break;
  240. case PTP_CLOCK_EXTTS:
  241. enqueue_external_timestamp(&ptp->tsevq, event);
  242. wake_up_interruptible(&ptp->tsev_wq);
  243. break;
  244. case PTP_CLOCK_PPS:
  245. pps_get_ts(&evt);
  246. pps_event(ptp->pps_source, &evt, PTP_PPS_EVENT, NULL);
  247. break;
  248. }
  249. }
  250. EXPORT_SYMBOL(ptp_clock_event);
  251. /* module operations */
  252. static void __exit ptp_exit(void)
  253. {
  254. class_destroy(ptp_class);
  255. unregister_chrdev_region(ptp_devt, PTP_MAX_CLOCKS);
  256. }
  257. static int __init ptp_init(void)
  258. {
  259. int err;
  260. ptp_class = class_create(THIS_MODULE, "ptp");
  261. if (IS_ERR(ptp_class)) {
  262. pr_err("ptp: failed to allocate class\n");
  263. return PTR_ERR(ptp_class);
  264. }
  265. err = alloc_chrdev_region(&ptp_devt, 0, PTP_MAX_CLOCKS, "ptp");
  266. if (err < 0) {
  267. pr_err("ptp: failed to allocate device region\n");
  268. goto no_region;
  269. }
  270. ptp_class->dev_attrs = ptp_dev_attrs;
  271. pr_info("PTP clock support registered\n");
  272. return 0;
  273. no_region:
  274. class_destroy(ptp_class);
  275. return err;
  276. }
  277. subsys_initcall(ptp_init);
  278. module_exit(ptp_exit);
  279. MODULE_AUTHOR("Richard Cochran <richardcochran@gmail.com>");
  280. MODULE_DESCRIPTION("PTP clocks support");
  281. MODULE_LICENSE("GPL");